added nodejs tfwconnector which implements the basic connection to th…

nodejs/tfwconnector/MessageSender.js

@@ -0,0 +1,59 @@
+'use strict';
+let TFWConnector = require('./TWFConnector');
+
+
+class MessageSender{
+
+    constructor(connector){
+        if(connector instanceof TFWConnector){
+            this.connector = connector;
+        }else{
+            console.error("MessageSender require an instance of TFWConnector!");
+        }
+    }
+
+    send(key, data){
+        let messageToSend = createTFWMessage(data);
+        this.connector.pushSocket.send(messageToSend);
+    }
+
+    sendMessage(message, name = "avataobot") {
+        let key = "message";
+        let data = {
+            key: key,
+            data: {
+                originator: name,
+                timestamp: Date.now(),
+                message: message
+            }
+        };
+        let messageToSend = createTFWMessage(data);
+        this.connector.pushSocket.send(messageToSend);
+    }
+    //TODO waiting for it to be implemented by core team
+    sendMessages(messages){
+        if(Array.isArray(messages) && messages.length > 0){
+            messages.forEach(message=>{
+                console.log("Sending message: " + message);
+                setTimeout(this.sendMessage(message), 1000);
+            });
+        }
+    }
+
+    sendToEventHandlers(message){
+        let key = "mirror";
+        let data = {
+            key: key,
+            data: message
+        };
+        let messageToSend = createTFWMessage(data);
+        this.connector.pushSocket.send(messageToSend);
+    }
+
+}
+
+let createTFWMessage = (message) => {
+    return [Buffer.from(message.key), Buffer.from(JSON.stringify(message))]
+};
+
+module.exports = MessageSender;

nodejs/tfwconnector/TWFConnector.js

@@ -0,0 +1,28 @@
+'use strict';
+const zmq = require('zeromq'),
+    subSock = zmq.socket('sub'),
+    pushSock = zmq.socket('push');
+
+const SUB_PORT = process.env.TFW_PUBLISHER_PORT || 7654,
+    PUSH_PORT = process.env.TFW_RECEIVER_PORT || 8765;
+
+const SUB_ADDRESS = "tcp://localhost:" + SUB_PORT,
+      PUSH_ADDRESS = "tcp://localhost:" + PUSH_PORT;
+
+
+class TFWConnector {
+
+    constructor() {
+        this.pushSocket = pushSock.connect(PUSH_ADDRESS);
+        this.subSocket = subSock.connect(SUB_ADDRESS);
+        console.log("Push socket connected to: " + PUSH_ADDRESS + "\n" + "Subscribe socket connected to: " + SUB_ADDRESS);
+    }
+
+    subscribe(key) {
+        this.subSocket.subscribe(key);
+    }
+
+}
+
+
+module.exports = TFWConnector;

nodejs/tfwconnector/Utilities.js

@@ -0,0 +1,65 @@
+'use strict';
+let MessageSender = require('./MessageSender');
+
+
+class Utilities{
+
+    constructor(messageSender){
+        if(messageSender instanceof MessageSender){
+            this.messageSender = messageSender;
+        }else{
+            console.error("Utilities class needs an instance of MessageSender!");
+        }
+    }
+
+    setView(viewType) {
+        let key = "dashboard";
+        let data = {
+            key: key,
+            data: {
+                command: "layout",
+                value: viewType
+            }
+        };
+        this.messageSender.send(key, data);
+    }
+
+    writeShell(command) {
+        let data = {
+                key: "shell",
+                data:{
+                    command: "write",
+                    value: command
+                }
+        };
+        this.messageSender.sendToEventHandlers(data);
+    }
+
+    stepNextState(){
+        let key = "";
+        let data = {
+            key: key,
+            data: {
+                event: "Stepping FSM to next state, from node event handler"
+            },
+            trigger: "step_next"
+        };
+        this.messageSender.send(key,data);
+    }
+
+    stepToState(state){
+        let key = "";
+        let data = {
+            key: key,
+            data: {
+                event: "Stepping FSM to next state, from node event handler"
+            },
+            trigger: "to_"+state
+        };
+        this.messageSender.send(key,data);
+    }
+
+
+}
+
+module.exports = Utilities;