diff options
| -rw-r--r-- | app/relay/index.js | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/app/relay/index.js b/app/relay/index.js new file mode 100644 index 0000000..22dc85f --- /dev/null +++ b/app/relay/index.js @@ -0,0 +1,30 @@ +const zerorpc = require('zerorpc') +require('dotenv').config() + +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({ + send_file: function (file, reply) { + reply() + console.log('got file, ' + file.length + ' bytes') + }, + connected: function (msg, reply) { + reply() + console.log("got connect, trying to call back.") + rpc.invoke("send_param", "foo", "bar", (err, res, more) => { + console.log('sent param') + }) + return true + } +}) +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) + |