wooooo streaming files over a series of sockets!!

1 files changed, 2 insertions, 15 deletions

diff --git a/app/relay/index.js b/app/relay/index.js
index eaec38b..a5a01b9 100644
--- a/app/relay/index.js
+++ b/app/relay/index.js
@@ -1,7 +1,6 @@
 require('dotenv').config()
 
 const io = require('socket.io-client')
-const ss = require('socket.io-stream')
 const zerorpc = require('zerorpc')
 const Readable = require('stream').Readable;
 
@@ -51,20 +50,8 @@ let relay = new zerorpc.Server({
 
   send_frame: function (fn, frame, reply) {
     reply()
-    console.log('got frame, ' + frame.length + ' bytes')
-    remote.emit('frame', fn, frame)
-    // var stream = ss.createStream()
-    // stream.on('data', () => { console.log('stream data...') })
-    // // console.log(stream)
-
-    // var rs = new Readable()
-    // rs.on('data', (d) => { console.log('rs data...', d.length) })
-    // rs._read = function noop() {}
-    // rs.pipe(stream)
-    // rs.push(frame)
-    // rs.push(null)
-    // ss(remote).on('frame', () => console.log('frame??'))
-    // ss(remote).emit('frame', stream, {name: fn}, function(){ console.log('where am i') })
+    // console.log('got frame, ' + frame.length + ' bytes')
+    remote.emit('frame', { fn: fn, frame: frame })
   }
 })
 relay.on("error", function(error) {