From db74c4104cf0cb3dff06857527214ee3997deec2 Mon Sep 17 00:00:00 2001 From: Jules Laplace Date: Sun, 20 May 2018 11:30:59 +0200 Subject: bidirectional javascript zerorpc client --- app/relay/index.js | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 app/relay/index.js 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) + -- cgit v1.2.3-70-g09d2