nydus

WebSocket server using the nydus protocol, a simple RPC/PubSub protocol.

Usage

import nydus from 'nydus'

const nydusServer = nydus(httpServer[, options])

Create a nydus server and attach it to a particular httpServer. An optional options object can be passed as the second argument. For the list of acceptable options, check the constructor method of engine.io.

API

nydusServer.registerRoute(pathPattern, ...handlers)

Register one or more handlers to respond to INVOKE messages on a path matching the specified pattern. Handlers are ES7 async functions (and thus return promises when called) of the form: async function(data, next)

Handlers will be composed in order, and are expected to call next(data, next) to make execution continue further down the chain. Data is an immutable map that can be changed before passing it to the next function, but should present the same API (or ideally, be an ImmutableJS map) for compatibility with other handlers.

The final resolved value will be sent to the client (as a RESULT if the promise was successfully resolved, or an ERROR if it was rejected).

nydusServer.subscribeClient(client, path[, initialData])

Add a subscription to a publish path for a client. Whenever messages are published to that path, this client will receive a message (until unsubscribed). If initialData is specified and the client was previously not subscribed, this data will be published to the client immediately (but not to the other subscribed clients).

nydusServer.publish(path, data)

Publish the given data to all of the clients subscribed on the specified path.

nydusServer.unsubscribeClient(client, path)

Remove a client's subscription to a particular path (if it was subscribed).

nydusServer.close()

Close any open connections and then stop the nydus server.

License

MIT