first version

Author: nicola

.gitignore

@@ -0,0 +1,5 @@
+node_modules/
+*~
+*.swp
+.tern-port
+npm-debug.log

README.md

@@ -0,0 +1,52 @@
+# solid-ws
+
+WebSockets for Solid
+
+## Usage
+
+### Simple way
+
+```javascript
+
+var ldnode = require('ldnode')
+
+var server = ldnode.createServer({live: true})
+
+server.listen(port, function () {
+  console.log('Solid server started')
+})
+```
+
+### Short way 
+
+```javascript
+var SolidWs = require('solid-ws')
+var ldnode = require('ldnode')
+
+var server = ldnode.createServer()
+solidWs(server)
+
+server.listen(port, function () {
+  console.log('Solid server started')
+})
+```
+
+### Long way
+
+```javascript
+var SolidWs = require('solid-ws')
+var ldnode = require('ldnode')
+var express = require('express')
+var https = require('https')
+
+var app = express()
+app.use('/databox', ldnode())
+var server = https.createServer({/* your settings*/}, app)
+
+server.listen(port, function () {
+  console.log('Solid server started')
+})
+
+// Attach WS to solid
+solidWs(server)
+```

index.js

@@ -0,0 +1,7 @@
+var SolidWs = require('./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

@@ -0,0 +1,31 @@
+module.exports = InMemory
+
+var uuid = require('node-uuid')
+
+function InMemory (opts) {
+  opts = opts || {}
+  this.uris = opts.uris || {}
+  this.subscribers = opts.subscribers || {}
+}
+
+InMemory.prototype.subscribe = function (uri, client, callback) {
+  var self = this
+  this.uris[uri] = true
+
+  if (!this.subscribers[uri]) {
+    this.subscribers[uri] = {}
+  }
+
+  client.uuid = uuid.v1()
+  this.subscribers[uri][client.uuid] = client
+
+  client.on('close', function () {
+    delete self.subscribers[uri][client.uuid]
+  })
+
+  return callback(null, client.uuid)
+}
+
+InMemory.prototype.get = function (uri, callback) {
+  return callback(null, this.subscribers)
+}

lib/server.js

@@ -0,0 +1,73 @@
+var WebSocketServer = require('ws').Server
+var debug = require('debug')('solid:subscription')
+var InMemory = require('./in-memory')
+var parallel = require('run-parallel')
+
+module.exports = WsServer
+
+function WsServer (server, opts) {
+  var self = this
+
+  opts = opts || {}
+  this.suffix = opts.suffix || '.changes'
+  this.store = opts.store || new InMemory(opts)
+
+  // Starting WSS server
+  var wss = new WebSocketServer({
+    server: server,
+    clientTracking: false,
+    path: opts.path
+  })
+
+  // Handling a single connection
+  wss.on('connection', function (client) {
+    debug('New connection')
+    // var location = url.parse(client.upgradeReq.url, true)
+
+    // Handling messages
+    client.on('message', function (message) {
+      debug('New message: ' + message)
+
+      if (!message || typeof message !== 'string') {
+        return
+      }
+
+      var tuple = message.split(' ')
+
+      // Only accept 'sub http://example.tld/hello'
+      if (tuple.length < 2 || tuple[0] !== 'sub') {
+        return
+      }
+
+      self.store.subscribe(tuple[1], client, function (err, uuid) {
+        if (err) {
+          // TODO Should return an error
+          return
+        }
+
+        client.send('ack ' + uuid)
+      })
+    })
+
+    // Respond to ping
+    client.on('ping', function () {
+      client.pong()
+    })
+  })
+}
+
+WsServer.prototype.publish = function (uri, callback) {
+  this.store.get(uri, function (err, subscribers) {
+    if (err) return callback(err)
+
+    var tasks = Object.keys(subscribers)
+      .map(function (uuid) {
+        return function (cb) {
+          var client = subscribers[uri][uuid]
+          client.send('pub ' + uri)
+        }
+      })
+
+    parallel(tasks, callback)
+  })
+}

package.json

@@ -0,0 +1,19 @@
+{
+  "name": "solid-ws",
+  "version": "0.1.0",
+  "description": "Web sockets for Solid",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [
+    "solid",
+    "websockets",
+    "live",
+    "updates",
+    "decentralized",
+    "web"
+  ],
+  "author": "Nicola Greco <me@nicola.io> (http://nicola.io/)",
+  "license": "MIT"
+}