Adds REMOTE_SB env to server

which connects to the specified remote redux-scuttlebutt server

Author: grrowl

README.md

@@ -69,7 +69,7 @@ The store enhancer takes an options object, including the key
 ```js
 scuttlebutt({
   // uri of a scuttlebutt peer or server
-  uri: 'http://localhost:3000',
+  uri: `${window.location.protocol}//${window.location.host}`,
 
   // options for primus.io <https://github.com/primus/primus#getting-started>
   primusOptions: {},

src/index.js

@@ -6,7 +6,7 @@ export { META_SOURCE, META_TIMESTAMP, REWIND_ACTION } from './constants'
 
 // Applies default options.
 const defaultOptions = {
-  uri: 'http://localhost:3000',
+  uri: (typeof window === 'object' && `${window.location.protocol}//${window.location.host}`),
   primusOptions: {},
   primus: (typeof window === 'object' && window.Primus),
   dispatcherOptions: {},

src/server.js

@@ -1,7 +1,8 @@
 import fs from 'fs'
 
 const INFILE = process.env['INFILE'],
-  OUTFILE = process.env['OUTFILE']
+  OUTFILE = process.env['OUTFILE'],
+  REMOTE_SB = process.env['REMOTE_SB']
 
 export default function scuttlebuttServer(server) {
   const primusServer = new (require('primus'))(server, {}),
@@ -55,38 +56,70 @@ export default function scuttlebuttServer(server) {
 
   }, 10000) // max 6/minute
 
+  // connect dispatcher to redux
   connectRedux(gossip)
 
-  if (INFILE || OUTFILE) {
-    if (INFILE) {
-      const gossipWriteSteam = gossip.createWriteStream()
-      fs.createReadStream(INFILE).pipe(gossipWriteSteam)
+  // read actions from file
+  if (INFILE) {
+    const gossipWriteSteam = gossip.createWriteStream()
+    fs.createReadStream(INFILE).pipe(gossipWriteSteam)
 
-      console.log('📼  Reading from ' + INFILE)
-    }
+    console.log('📼  Reading from ' + INFILE)
+  }
 
-    if (OUTFILE) {
-      const gossipReadSteam = gossip.createReadStream()
+  // stream actions to file -- this will include all actions in INFILE
+  if (OUTFILE) {
+    const gossipReadSteam = gossip.createReadStream()
 
-      // For some reason, we're not getting any 'sync' events from Dispatcher,
-      // so we'll listen for it in the datastream and write to disk after it
-      // <https://github.com/dominictarr/scuttlebutt#persistence>
+    // For some reason, we're not getting any 'sync' events from Dispatcher,
+    // so we'll listen for it in the datastream and write to disk after it
+    // <https://github.com/dominictarr/scuttlebutt#persistence>
 
-      gossipReadSteam.on('data', (data) => {
-        if (data === '"SYNC"\n') {
-          console.log('📼  Writing to ' + OUTFILE)
-          gossipReadSteam.pipe(fs.createWriteStream(OUTFILE))
-        }
-      })
-
-      // this doesn't fire.
-      gossip.on('sync', function () {
-        console.log('📼  [NATURAL SYNC] Writing to ' + OUTFILE)
+    gossipReadSteam.on('data', (data) => {
+      if (data === '"SYNC"\n') {
+        console.log('📼  Writing to ' + OUTFILE)
         gossipReadSteam.pipe(fs.createWriteStream(OUTFILE))
-      })
+      }
+    })
+
+    // this doesn't fire.
+    gossip.on('sync', function () {
+      console.log('📼  [NATURAL SYNC] Writing to ' + OUTFILE)
+      gossipReadSteam.pipe(fs.createWriteStream(OUTFILE))
+    })
+
+    console.log('📼  Ready to write to ' + OUTFILE)
+  }
+
+  // connect to remote redux-scuttlebutt instance
+  if (REMOTE_SB) {
+    var remoteStream = gossip.createStream(),
+      remoteClient = new primusServer.Socket(REMOTE_SB)
 
-      console.log('📼  Ready to write to ' + OUTFILE)
+    console.log('💡  connecting to remote '+ REMOTE_SB)
+
+    remoteClient.pipe(remoteStream).pipe(remoteClient)
+
+    statistics['REMOTE_SB'] = {
+      recv: 0, sent: 0, s: 'remote'
     }
+
+    remoteClient.on('data', function recv(data) {
+      // console.log('[io]', 'REMOTE_SB', '<-', data);
+      statistics['REMOTE_SB'].recv++
+      statisticsDirty = true
+    });
+
+    remoteStream.on('data', (data) => {
+      // console.log('[io]', 'REMOTE_SB' || 'origin', '->', data);
+      statistics['REMOTE_SB'].sent++
+      statisticsDirty = true
+    })
+
+    remoteStream.on('error', (error) => {
+      console.log('[io]', 'REMOTE_SB', 'ERROR:', error);
+      remoteClient.end('Disconnecting due to error', { reconnect: true })
+    })
   }
 
   primusServer.on('connection', (spark) => {