1 files changed, 23 insertions, 10 deletions

diff --git a/app/relay/index.js b/app/relay/index.js
index 2ed8e10..eaec38b 100644
--- a/app/relay/index.js
+++ b/app/relay/index.js
@@ -8,21 +8,27 @@ const Readable = require('stream').Readable;
 let remote = io.connect(process.env.SOCKETIO_REMOTE);
 
 remote.on('cmd', (data) => {
-  if (! data.cmd || ! data.payload) {
+  console.log('cmd data', data)
+  if (! data.cmd) {
     console.log('malformed param...?')
     return
   }
   console.log('got', data.cmd)
   switch (data.cmd) {
     case 'send_param':
+      if (! data.payload) return
       rpc.invoke(data.cmd, data.payload.key, data.payload.value, (err, res, more) => {
-        console.log('sent param', res)
+        console.log('sent param, got response', res)
       })
       break
     case 'get_params':
+    case 'get_last_frame':
       rpc.invoke(data.cmd, (err, res, more) => {
         console.log('got params', res)
-        remote.emit('params', res)
+        remote.emit('res', {
+          cmd: data.cmd,
+          res: res,
+        })
       })
       break
   }
@@ -46,14 +52,19 @@ let relay = new zerorpc.Server({
   send_frame: function (fn, frame, reply) {
     reply()
     console.log('got frame, ' + frame.length + ' bytes')
-    var stream = ss.createStream();
-    ss(remote).emit('frame', stream, {name: fn})
+    remote.emit('frame', fn, frame)
+    // var stream = ss.createStream()
+    // stream.on('data', () => { console.log('stream data...') })
+    // // console.log(stream)
 
-    var s = new Readable();
-    s._read = function noop() {}
-    s.push(frame)
-    s.push(null);
-    s.pipe(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') })
   }
 })
 relay.on("error", function(error) {
@@ -61,3 +72,5 @@ relay.on("error", function(error) {
 })
 relay.bind("tcp://0.0.0.0:" + process.env.RELAY_PORT);
 console.log('Relay listening on port ' + process.env.RELAY_PORT)
+
+module.exports = { relay: relay, remote: remote, }
\ No newline at end of file