adding first tests

Author: nicola

lib/in-memory.js

@@ -27,6 +27,5 @@ InMemory.prototype.subscribe = function (uri, client, callback) {
 }
 
 InMemory.prototype.get = function (uri, callback) {
-  console.log(this.subscribers, uri)
   return callback(null, this.subscribers[uri])
 }

lib/server.js

@@ -45,7 +45,7 @@ function WsServer (server, opts) {
           return
         }
 
-        client.send('ack ' + uuid)
+        client.send('ack ' + tuple[1])
       })
     })
 

package.json

@@ -4,7 +4,7 @@
   "description": "Web sockets for Solid",
   "main": "index.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "./node_modules/mocha/bin/mocha ./test/*.js"
   },
   "keywords": [
     "solid",
@@ -20,5 +20,9 @@
     "debug": "^2.2.0",
     "node-uuid": "^1.4.3",
     "run-parallel": "^1.1.4"
+  },
+  "devDependencies": {
+    "chai": "^3.3.0",
+    "mocha": "^2.3.3"
   }
 }

test/websockets.js

@@ -0,0 +1,131 @@
+var WebSocket = require('ws')
+var assert = require('chai').assert
+var http = require('http')
+var parallel = require('run-parallel')
+var SolidWs = require('../')
+
+describe('Solid-ws', function() {
+  var server = http.createServer()
+  var port = 8000
+  var pubsub = SolidWs(server)
+  var client
+
+  function check(msgs, uris, done) {
+    parallel(msgs.map(function (msg, i) {
+      return function(cb) {
+        assert.equal(msg.split(' ')[0], 'ack')
+        var index = uris.indexOf(msg.split(' ')[1])
+        assert.notEqual(index, -1, "URL not found")
+        uris.splice(index, 1)
+        cb()
+      }
+    }),
+    function() {
+      assert.equal(uris.length, 0)
+      done()
+    })
+  }
+
+  before(function(done) {
+    server.listen(port, function (err) {
+      if (err) done(err)
+      client = new WebSocket('http://localhost:' + port)
+      client.on('open', done)
+    })
+  })
+
+  describe('sub', function() {
+    it('should receive ack for any resource given', function(done) {
+
+      var uris = [
+        'http://example.com/hello',
+        'http://example.com/hello/hello.ttl',
+        'http://example.com/hello/hello/.acl']
+
+      uris.map(function(uri) {
+        client.send('sub ' + uri)
+      })
+
+      var msgs = []
+      client.on('message', function (msg) {
+        msgs.push(msg)
+        if (msgs.length == uris.length) {
+          check(msgs, uris, done)
+        }
+      })
+    })
+
+    it('should receive ack even if has already subscribed', function(done) {
+
+      var uris = [
+        'http://example.com/hello',
+        'http://example.com/hello',
+        'http://example.com/hello/hello.ttl',
+        'http://example.com/hello/hello.ttl',
+        'http://example.com/hello/hello/.acl',
+        'http://example.com/hello/hello/.acl']
+
+      uris.map(function(uri) {
+        client.send('sub ' + uri)
+      })
+
+      var msgs = []
+      client.on('message', function (msg) {
+        msgs.push(msg)
+        if (msgs.length == uris.length) {
+          check(msgs, uris, done)
+        }
+      })
+    })
+  })
+  // describe('pub', function() {
+  //   describe('delete resource', function() {
+      
+  //     it('should', function(done) {
+  //       server.emit('pub '+ url)
+
+  //       client.onmessage = function(msg) {
+  //         assert.ok(msg)
+  //         assert.equal('pub ' + url)
+  //         done()
+  //       }
+  //     })
+  //   })
+  //   describe('patch resource', function() {
+      
+  //     it('should', function(done) {
+  //       server.emit('pub '+ url)
+
+  //       client.onmessage = function(msg) {
+  //         assert.ok(msg)
+  //         assert.equal('pub ' + url)
+  //         done()
+  //       }
+  //     })
+  //   })
+  //   describe('put resource', function() {
+      
+  //     it('should', function(done) {
+  //       server.emit('pub '+ url)
+
+  //       client.onmessage = function(msg) {
+  //         assert.ok(msg)
+  //         assert.equal('pub ' + url)
+  //         done()
+  //       }
+  //     })
+  //   })
+  //   describe('add resource in folder', function() {
+      
+  //     it('should', function(done) {
+  //       server.emit('pub '+ url)
+
+  //       client.onmessage = function(msg) {
+  //         assert.ok(msg)
+  //         assert.equal('pub ' + url)
+  //         done()
+  //       }
+  //     })
+  //   })
+  // })
+})