using karma to run test

Author: sandro-k

karma.conf.js

@@ -0,0 +1,84 @@
+// Karma configuration
+// Generated on Mon Jun 13 2016 13:04:33 GMT+0200 (CEST)
+
+module.exports = function (config) {
+    config.set({
+
+        // base path that will be used to resolve all patterns (eg. files, exclude)
+        basePath: '',
+
+
+        // frameworks to use
+        // available frameworks: https://npmjs.org/browse/keyword/karma-adapter
+        //frameworks: ['browserify', 'mocha'],
+        frameworks: ['mocha'],
+        //'requirejs'
+
+        // list of files / patterns to load in the browser
+        files: [
+            'node_modules/mocha/mocha.js',
+            'node_modules/chai/chai.js',
+            'node_modules/should/should.js',
+            'dist/MqttWorker.js',
+            {pattern: 'mqttWorker.js', included: false},
+            'dist/MqttBundle.js',
+            {pattern: 'test/*.spec.js', included: true}
+        ],
+
+
+        // list of files to exclude
+        exclude: [],
+
+
+        // preprocess matching files before serving them to the browser
+        // available preprocessors: https://npmjs.org/browse/keyword/karma-preprocessor
+        //    'lib/*.js': ['coverage'],
+        preprocessors: {
+            // source files for coverage
+            'mqttWorker.js': ['coverage']
+        },
+
+        // optionally, configure the reporter
+        coverageReporter: {
+            type : 'lcov',
+            dir : 'coverage/'
+        },
+
+
+        // test results reporter to use
+        // possible values: 'dots', 'progress'
+        // available reporters: https://npmjs.org/browse/keyword/karma-reporter
+        reporters: ['progress', 'coverage'],
+
+
+        // web server port
+        port: 9876,
+
+
+        // enable / disable colors in the output (reporters and logs)
+        colors: true,
+
+
+        // level of logging
+        // possible values: config.LOG_DISABLE || config.LOG_ERROR || config.LOG_WARN || config.LOG_INFO || config.LOG_DEBUG
+        logLevel: config.LOG_INFO,
+
+
+        // enable / disable watching file and executing tests whenever any file changes
+        autoWatch: true,
+
+
+        // start these browsers
+        // available browser launchers: https://npmjs.org/browse/keyword/karma-launcher
+        browsers: ['Chrome'],
+
+
+        // Continuous Integration mode
+        // if true, Karma captures browsers, runs the tests and exits
+        singleRun: false,
+
+        // Concurrency level
+        // how many browser should be started simultaneous
+        concurrency: Infinity
+    })
+};

mqttWorker.js

@@ -1,7 +1,6 @@
 'use strict';
 
 importScripts('dist/MqttBundle.js');
-//importScripts('dist/MqttBundle.min.js');
 
 // detect if we are a Worker or SharedWorker
 var worker = typeof self.postMessage === 'function' || false;
@@ -25,14 +24,39 @@ var util = {
 // the proper URL is supplied via client.connect as the last argument
 var document = {};
 
-var serviceWorker = {
+var mqttWorker = {
     // map for the clients eg. portN => clientN
     clients: {},
     // a scope wrapping function to generate different postMessages to the worker client
     generateMessageCallback: function (port, type) {
         return function () {
             // type is something like 'publish', 'subscribe', 'message' or 'callback'
-            port.postMessage({type: type, args: arguments});
+            // posting arguments can fail to du cloning the object. We might have to reduce the arguments we send back
+            // to the browser
+
+            switch (arguments.length) {
+                case 0:
+                    port.postMessage({type: type});
+                    break;
+                case 1:
+                    port.postMessage({type: type, args: {0: arguments[0]}});
+                    break;
+                case 2:
+                    port.postMessage({type: type, args: {0: arguments[0],1: arguments[1]}});
+                    break;
+                case 3:
+                    //port.postMessage({type: type, args: {0: arguments[0],1: arguments[1]}});
+                    port.postMessage({type: type, args: {0: arguments[0],1: arguments[1],2: arguments[2]}});
+                    break;
+                default:
+                    port.postMessage({type: type, args: {0: arguments[0]}});
+                    //port.postMessage({type: type, args: arguments});
+            }
+
+            //if(type === 'close') {
+            //    port.postMessage({type: type});
+            //} else {
+            //}
         }
     },
 
@@ -45,7 +69,6 @@ var serviceWorker = {
     createClient: function (args, port) {
         var generateMessageCallback = this.generateMessageCallback;
 
-
         function addCallbacks(mqtt) {
 
             ['close', 'connect', 'error', 'message', 'offline', 'reconnect']
@@ -61,7 +84,7 @@ var serviceWorker = {
 
     /**
      * A callback method for the 'connect' event. Connect events are only fired when used with a
-     * SharedServiceWorker.
+     * SharedWebWorker.
      * @param {Object} event that triggered the connect
      */
     connect: function (event) {
@@ -100,6 +123,7 @@ var serviceWorker = {
         } else {
             port = event.srcElement;
         }
+
         var callback;
         var client = this.clients[port];
 
@@ -110,8 +134,9 @@ var serviceWorker = {
                 try {
                     this.clients[port] = this.createClient.apply(this, [arr, port]);
                 } catch (err) {
-                    console.error(err);
+                    //console.error(err);
                 }
+                // sending back the options set on the client
                 port.postMessage({type: 'options', args: this.clients[port].options});
                 break;
 
@@ -155,5 +180,5 @@ if(worker) {
     event = 'message';
 }
 // binding to the 'message'/'connect' event at the serverWorker
-self.addEventListener(event, serviceWorker[event].bind(serviceWorker));
+self.addEventListener(event, mqttWorker[event].bind(mqttWorker));
 

package.json

@@ -4,7 +4,7 @@
   "description": "",
   "main": "mqttWorker.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "karma start"
   },
   "author": "",
   "license": "MIT",
@@ -19,8 +19,13 @@
     "grunt-browserify": "^5.0.0",
     "grunt-contrib-uglify": "^1.0.1",
     "grunt-contrib-watch": "^1.0.0",
+    "karma": "^0.13.22",
+    "karma-browserify": "^5.0.5",
+    "karma-chrome-launcher": "^1.0.1",
+    "karma-coverage": "^1.0.0",
+    "karma-mocha": "^1.0.1",
     "load-grunt-tasks": "^3.4.1",
-    "mocha": "^2.4.5",
+    "mocha": "^2.5.3",
     "should": "^8.2.2"
   }
 }