Add listening and forwarding

Author: zix99

.eslintrc

@@ -18,5 +18,6 @@
         "consistent-return" : "warn",
         "curly" : ["error", "multi-or-nest"],
         "no-plusplus" : "off",
+        "no-console" : "off"
     }
 }

README.md

@@ -17,7 +17,7 @@ events from the public internet to a local network.
 
 To use the `ubsub` CLI on your command line, make sure you have a recent version of [NodeJS](https://nodejs.org/en/) installed, and then run:
 
-```
+```bash
 npm install -g ubsub
 ```
 
@@ -27,17 +27,29 @@ Once installed, you can run `ubsub help` from command line to see help output.
 
 Installing into your project:
 
-```
+```bash
 npm install --save ubsub-client
 ```
 
+See [examples/](examples/) for some sample uses.
+
 ### Listening to a Topic
 
-TODO
+```js
+const ubsub = require('../')(<user id>, <user secret>);
+
+ubsub.listen(<topic id>, (event) => {
+	console.log('received event ' + JSON.stringify(event));
+});
+```
 
 ### Forwarding a Topic to an HTTP endpoint
 
-TODO
+```js
+const ubsub = require('../')(<user id>, <user secret>);
+
+ubsub.listen(<topic id>, 'http://localhost:5000', {..optional axios opts..});
+```
 
 # License
 

cli.js

@@ -0,0 +1,9 @@
+#!/usr/bin/env node
+const ubsub = require('../')('ry2VZ8e3Z', 'a12e59acf83bbda211e02f9f7bbe6069eeac623412953da8b8179ef4db4ee061');
+
+/* eslint no-console: off */
+ubsub.listen('SylW8bIe3Z', (event) => {
+  console.log(`received event ${JSON.stringify(event)}`);
+});
+
+ubsub.forward('SylW8bIe3Z', 'http://localhost:8000');

examples/listening.js

@@ -3,31 +3,28 @@ const io = require('socket.io-client');
 const axios = require('axios');
 const _ = require('lodash');
 
-function UbSubClient(userId, userKey, opts) {
+module.exports = (userId, userKey, opts) => {
   const o = opts || {};
+  const host = o.host || 'https://socket.ubsub.io';
 
-  this._host = o.host || 'https://socket.ubsub.io';
-  this._userId = userId;
-  this._userSecret = userKey;
+  return {
+    listen(topicId, onEvent) {
+      const sock = io(`${host}/socket?userId=${userId}&topicId=${topicId}&userKey=${userKey}`);
+      sock.on('event', onEvent);
+      return sock;
+    },
 
-  this._sockets = {};
-}
+    forward(topicId, forwardUrl, httpOpts) {
+      return this.listen(topicId, data => {
+        axios(_.assign({
+          url: forwardUrl,
+          data,
+          method: 'post', // default, can be overriden in opts
+        }, httpOpts)).catch(err => {
+          console.error(`Error forwarding event from '${topicId} to URL ${forwardUrl}: ${err.message}`);
+        });
+      });
+    },
 
-UbSubClient.prototype.listen = function listen(topicId, onEvent) {
-  const sock = io(`${this._host}/socket?userId=${this._userId}&topicId=${topicId}&userKey=${this._userKey}`);
-  sock.on('event', onEvent);
+  };
 };
-
-UbSubClient.prototype.forward = function forward(topicId, forwardUrl, opts) {
-  this.listen(topicId, data => {
-    axios(_.assign({
-      url: forwardUrl,
-      data,
-      method: 'post', // default, can be overriden in opts
-    }, opts));
-  });
-};
-
-
-module.exports = new UbSubClient();
-module.exports.Client = UbSubClient;