require('dotenv').config() const io = require('socket.io-client') const ss = require('socket.io-stream') const zerorpc = require('zerorpc') const Readable = require('stream').Readable; let remote = io.connect(process.env.SOCKETIO_REMOTE); remote.on('cmd', (data) => { 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, 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('res', { cmd: data.cmd, res: res, }) }) break } }) let rpc = new zerorpc.Client() rpc.connect("tcp://127.0.0.1:" + process.env.RPC_PORT) rpc.on("error", function(error) { console.error("RPC server error:", error) }) console.log('RPC listening on port ' + process.env.RPC_PORT) let relay = new zerorpc.Server({ // Called when the worker starts up and is ready to receive params. connected: function (msg, reply) { reply() console.log("got connect from " + msg) return true }, 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') }) } }) relay.on("error", function(error) { console.error("Relay server error:", 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, }