Fixed rpc call

lib/handlers.js

@@ -85,7 +85,7 @@ handlers[WAMP.CALL] = function (session, args) {
     var callId = args.shift();
     var options = args.shift();
     var procUri = args.shift();
-    args = args || [];
+    args = args.shift() || [];
     var resultCallback = function(err, args) {
         if (err) {
             var msg = [
@@ -109,7 +109,7 @@ handlers[WAMP.CALL] = function (session, args) {
             session.send(msg);
         }
     };
-    if (!this.callrpc(procUri, args, resultCallback)) {
+    if (!this.callrpc(procUri, args, resultCallback, session)) {
         var msg = [
             WAMP.ERROR,
             WAMP.CALL,

lib/router.js

@@ -77,11 +77,17 @@ function Router(options) {
         this.emit('RPCUnregistered', [uri])
     };
 
-    this.callrpc = function(uri, args, callback) {
+    this.callrpc = function(uri, args, callback, session) {
         if (typeof this.getrpc(uri) !== 'undefined') {
             var invId = tools.randomId();
             _pending[invId] = callback;
-            this.getrpc(uri).apply(this ,[invId, args]);
+            args.unshift(invId);
+
+            if (session) {
+                args.push(session);
+            }
+
+            this.getrpc(uri).apply(this ,args);
             return true;
         } else {
             return false;

lib/session.js

@@ -17,6 +17,9 @@ function Session (router, wsclient) {
             "] " + msg;
         log.trace(trace);
     }.bind(this);
+
+    this.client = wsclient;
+
     this.register = function (uri) {
         var registrationId = util.randomId();
         _registeredUris[registrationId] = uri;