test_rpc_routing.js

///////////////////////////////////////////////////////////////////////////////
//
//  AutobahnJS - http://autobahn.ws, http://wamp.ws
//
//  A JavaScript library for WAMP ("The Web Application Messaging Protocol").
//
//  Copyright (c) Crossbar.io Technologies GmbH and contributors
//
//  Licensed under the MIT License.
//  http://www.opensource.org/licenses/mit-license.php
//
///////////////////////////////////////////////////////////////////////////////

var autobahn = require('./../index.js');
var testutil = require('./testutil.js');


exports.testRpcRouting = function (testcase) {

   testcase.expect(2);

   var test = new testutil.Testlog("test/test_rpc_routing.txt");

   var dl = testutil.connect_n(2);

   autobahn.when.all(dl).then(
      function (res) {
         test.log("all sessions connected");

         var session1 = res[0];
         var session2 = res[1];

         function square(args, kwargs, details) {
            var x = args[0];
            test.log("square() called from session 2", x);

            // FIXME: caller disclosure now is pure router config based
            // testcase.ok(details.caller == session2.id);
            return x * x;
         }

         session1.register('com.math.square', square).then(
            function (res) {

               test.log("square() registered on session 1");

               session2.call('com.math.square', [23], {}, {}).then(
                  function (res) {
                     test.log("result:", res);

                     session1.leave();
                     session2.leave();

                     testcase.ok(res == (23*23));

                     var chk = test.check()
                     testcase.ok(!chk, chk);

                     testcase.done();
                  })
            }
         );
      },
      function (err) {
         test.log(err);
      }
   );
}