RFE: remove pusher.com dependency

.env.local.example

@@ -0,0 +1 @@
+TEST_DATABASE_URL=postgres://teletype:password@localhost:5433/teletype-server-test

.gitignore

@@ -1,3 +1,4 @@
 node_modules
 .env
 .DS_Store
+test-database

README.md

@@ -29,6 +29,13 @@ To run teletype-client tests locally, you'll first need to have:
     npm test
     ```
 
+3. Create postgresql docker instance:
+
+    ```
+    docker-compose up -d
+    cp .env.local.example .env
+    ```
+
 ## TODO
 
 * [ ] Document APIs

docker-compose.yml

@@ -0,0 +1,19 @@
+version: '3'
+
+services:
+  test-database:
+    image: postgres
+    ports:
+     - 5433:5432
+    volumes:
+     - ./test-database:/var/lib/postgresql/data
+    restart: always
+    environment:
+      POSTGRES_USER: teletype
+      POSTGRES_PASSWORD: password
+      POSTGRES_DB: teletype-server-test
+    networks:
+      teletype:
+
+networks:
+  teletype:

lib/socketcluster-pub-sub-gateway.js

@@ -0,0 +1,30 @@
+const socketCluster = require('socketcluster-client');
+const {Disposable} = require('event-kit')
+const Errors = require('./errors')
+
+module.exports =
+class SocketClusterPubSubGateway {
+  constructor ({}) {
+    this.socketClusterClient = createDisconnectedSocketClusterClient()
+  }
+
+  async subscribe (channelName, eventName, callback) {
+    channelName = channelName.replace(/\//g, '.')
+    let eventChannel = this.socketClusterClient.subscribe(`${channelName}.${eventName}`);
+
+    eventChannel.watch(callback);
+
+    return new Disposable(() => {
+      this.socketClusterClient.unsubscribe(`${channelName}.${eventName}`)
+    })
+  }
+}
+
+function createDisconnectedSocketClusterClient () {
+  const options = {
+    port: 8000
+  };
+
+  const socket = socketCluster.create(options);
+  return socket
+}

lib/teletype-client.js

@@ -5,6 +5,7 @@ const PeerPool = require('./peer-pool')
 const Portal = require('./portal')
 const Errors = require('./errors')
 const PusherPubSubGateway = require('./pusher-pub-sub-gateway')
+const SocketClusterPubSubGateway = require('./socketcluster-pub-sub-gateway')
 const RestGateway = require('./rest-gateway')
 const {Emitter} = require('event-kit')
 const NOOP = () => {}
@@ -13,9 +14,21 @@ const LOCAL_PROTOCOL_VERSION = 9
 
 module.exports =
 class TeletypeClient {
-  constructor ({restGateway, pubSubGateway, connectionTimeout, tetherDisconnectWindow, testEpoch, pusherKey, pusherOptions, baseURL, didCreateOrJoinPortal}) {
+  constructor ({restGateway, pubSubGateway, connectionTimeout, tetherDisconnectWindow, testEpoch, activePubSubGateway, pusherKey, pusherOptions, baseURL, didCreateOrJoinPortal}) {
+    function getActivePubSubGateway(activePubSubGateway) {
+      switch(activePubSubGateway) {
+        case 'socketcluster':
+          return new SocketClusterPubSubGateway({})
+          break;
+
+        case 'pusher':
+        default:
+          return new PusherPubSubGateway({key: pusherKey, options: pusherOptions})
+          break;
+      }
+    }
     this.restGateway = restGateway || new RestGateway({baseURL})
-    this.pubSubGateway = pubSubGateway || new PusherPubSubGateway({key: pusherKey, options: pusherOptions})
+    this.pubSubGateway = pubSubGateway || getActivePubSubGateway(activePubSubGateway)
     this.connectionTimeout = connectionTimeout || 5000
     this.tetherDisconnectWindow = tetherDisconnectWindow || DEFAULT_TETHER_DISCONNECT_WINDOW
     this.testEpoch = testEpoch

package.json

@@ -14,6 +14,7 @@
     "event-kit": "^2.3.0",
     "google-protobuf": "^3.5.0",
     "pusher-js": "^4.2.2",
+    "socketcluster-client": "^13.0.0",
     "uuid": "^3.2.1",
     "webrtc-adapter": "~6.1"
   },