making it work

Author: nicola

README.md

@@ -48,5 +48,5 @@ server.listen(port, function () {
 })
 
 // Attach WS to solid
-solidWs(server)
+solidWs(server, app)
 ```

index.js

@@ -1,7 +1,6 @@
-var SolidWs = require('./server')
+var SolidWs = require('./lib/server')
 
 module.exports = function attachToServer (server, app, opts) {
   var solidWs = new SolidWs(server, opts)
-  if (app) server.on('request', app)
   return solidWs
 }

lib/in-memory.js

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

lib/server.js

@@ -58,12 +58,16 @@ function WsServer (server, opts) {
 
 WsServer.prototype.publish = function (uri, callback) {
   this.store.get(uri, function (err, subscribers) {
-    if (err) return callback(err)
+    
+    if (err) {
+      if (callback) return callback(err)
+      else return
+    }
 
     var tasks = Object.keys(subscribers)
       .map(function (uuid) {
         return function (cb) {
-          var client = subscribers[uri][uuid]
+          var client = subscribers[uuid]
           client.send('pub ' + uri)
         }
       })

package.json

@@ -15,5 +15,10 @@
     "web"
   ],
   "author": "Nicola Greco <me@nicola.io> (http://nicola.io/)",
-  "license": "MIT"
+  "license": "MIT",
+  "dependencies": {
+    "debug": "^2.2.0",
+    "node-uuid": "^1.4.3",
+    "run-parallel": "^1.1.4"
+  }
 }