testutil.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 fs = require("fs");

/*
// fully qualified config
var config = {
   transports: [
      {
         type: 'websocket',
         url: 'ws://127.0.0.1:8080/ws',
         protocols: ['wamp.2.json']
      }
   ],
   realm: 'crossbardemo'
}
*/

var create_timeout_handler = function(testcase) {
    var TIMEOUT = 3000;
    var timer;
    return {
        set: function () {
            timer = setTimeout(function() {
                testcase.ok(false, 'Timeout!');
                testcase.done();
            }, TIMEOUT);
        },
        clear: function () {
            clearTimeout(timer);
        }
    }
}

// shortcut config
var default_config = {
   url: 'ws://127.0.0.1:8080/ws',
   realm: 'realm1'
}

function connect_n(n, config) {
   var dl = [];
   for (var i = 0; i < n; ++i) {
      (function (idx) {
         var d = autobahn.when.defer();
         var connection = new autobahn.Connection(config || default_config);

         connection.onopen = function (session) {
            d.resolve(session);
         };

         connection.onclose = function (reason, details) {
            console.log('CLOSE', reason, details);
         }

         connection.open();

         dl.push(d.promise);
      })(i);
   }
   return dl;
}


var Testlog = function (filename) {

   var self = this;

   self._filename = filename;
   self._log = [];
//   self._log = [["AutobahnJS " + autobahn.version]];
};


Testlog.prototype.log = function () {

   var self = this;

   console.log.apply(this, arguments);
   self._log.push(arguments);
};


Testlog.prototype.stringify = function () {

   var self = this;

   var s = '';
   for (var i = 0; i < self._log.length; ++i) {
      s += i;
      args = self._log[i];
      for (arg in args) {

         // stringify with dict attributes ordered
         s += ' ' + self.stringifyWithOrderedKeys(args[arg]);
         //s += ' ' + JSON.stringify(args[arg]);
      }
      s += "\n";
   }
   return s;
};

Testlog.prototype.stringifyWithOrderedKeys = function (arg) {
   var self = this;
   if(arg != null && typeof(arg) == "object") {
      var clazz = Object.prototype.toString.call(arg).toLowerCase();
      if(clazz.indexOf("array") != -1) {
        var retval = "[";
        for (var i = 0; i < arg.length; i++) {
          if(i > 0) retval += ',';
          retval += self.stringifyWithOrderedKeys(arg[i]);
        }
        retval += "]";
        return retval;
      } else {
        var retval = "{";
        var keys = Object.keys(arg).sort();
        for (var i = 0; i < keys.length; i++) {
          if(i > 0) retval += ',';
          retval += '"'+keys[i]+'":' + self.stringifyWithOrderedKeys(arg[keys[i]]);
        }
        retval += "}";
        return retval;
      }
   } else {
      return JSON.stringify(arg);
   }
};


Testlog.prototype.check = function () {

   var self = this;
   var slog = self.stringify();

   if (fs.existsSync(self._filename)) {
      var slog_baseline = fs.readFileSync(self._filename);
      //TH 26.07.2016 on Windows platform replace crlf in baseline file with Unix style lf
     //if the file is already in unix format nothing will be replaced, so it works also in this case
      if (process.platform==="win32") slog_baseline=slog_baseline.toString().replace(/\r\n/g,"\n");
      if (slog != slog_baseline) {
         return "\nExpected:\n\n" + slog_baseline + "\n\n\nGot:\n\n" + slog + "\n\n";
      } else {
         return null;
      }
   } else {
      fs.writeFileSync(self._filename, slog);
      console.log("Know-good log file created", self._filename, slog.length);
      return null;
   }
};


exports.Testlog = Testlog;
exports.config = default_config;
exports.connect_n = connect_n;
exports.create_timeout_handler = create_timeout_handler;