Data implementation: First setup.

Author: margau

Diff for: .gitignore

@@ -60,3 +60,4 @@ typings/
 # next.js build output
 .next
 dist
+clienttest.js

Diff for: package-lock.json

@@ -29,9 +29,11 @@
   },
   "homepage": "https://showcomposer.de",
   "devDependencies": {
-    "@types/node": "^10.12.25",
+    "@types/node": "^10.12.26",
     "tslint": "^5.12.0",
     "typescript": "^3.1.1"
   },
-  "dependencies": {}
+  "dependencies": {
+    "uuid": "^3.3.2"
+  }
 }

Diff for: package.json

@@ -1,7 +1,116 @@
 // SC broker
 // Init global variables
-const config = {port: 6789};
+const config = { port: 6789 };
 const data = {};
+const subscriber = {};
+
+const sendTypes = ["INIT","INIT_REUSE","PING","SET","DEL","SUB","UNSUB","DUMP"];
+const responseTypes = ["INIT_ACK","PONG","SET_RES","DEL_RES","SUB_RES","UNSUB_RES","DUMP_RES"];
 
 // import settings
 import * as net from "net";
+import * as readline from "readline";
+import * as uuid from "uuid/v4";
+
+// Client class, handling incoming connections
+class Client {
+  socket: net.Socket;
+  uuid: any;
+  pingInt: any;
+  reqId = 0;
+  reqWait = 0;
+  reqArray = {};
+  inputReader: any;
+  pingResponse: Number;
+  pingSuccess: Number;
+  // Constructor run by every new connection
+  constructor(socket: net.Socket) {
+    this.uuid = uuid();
+    this.socket = socket;
+    // Setup regular ping
+    this.pingInt = setInterval(() => {this.ping();},2000);
+
+    // Prepare Input processing
+    this.inputReader = readline.createInterface({
+      input: this.socket
+    });
+
+    this.inputReader.on('line', (l)=> {
+      this.handleLine(l);
+    });
+
+    // Add this receiver to subscibers
+    subscriber[this.uuid] = this;
+
+    this.socket.setNoDelay();
+    // Handle closing
+    socket.on('close', () => {
+      console.log('client disconnected');
+      this.close();
+    });
+  }
+  // Periodically Ping
+  ping() {
+    const start = process.hrtime()[1];
+    this.send("PING","",(c) => {
+      if(c[1] === "PONG") {
+        this.pingResponse = (process.hrtime()[1]-start)/1000;
+        this.pingSuccess = Date.now();
+      }
+    });
+  }
+  // Close everything
+  close() {
+    delete subscriber[this.uuid];
+    clearInterval(this.pingInt);
+    if(!this.socket.destroyed) {
+      this.socket.destroy();
+    }
+  }
+  // Handle input
+  handleLine(c) {
+    const m=c.toString('utf8').split(' ');
+    if(m.length<2) {
+      return;
+    }
+    const type=parseInt(m[0],10)
+    if(isNaN(type)) {
+      return;
+    }
+    if(!m[2]) {
+      m[2] = "";
+    }
+    // Determine if it's new req or response
+    if(responseTypes.includes(m[1])) {
+      // It's a response
+      // Check if id exists and handle
+      if(this.reqArray[m[0]]) {
+        this.reqArray[m[0]](m);
+        delete this.reqArray[m[0]];
+      }
+    }
+    if(sendTypes.includes(m[1])) {
+      // ToDo: Handle Requests
+    }
+    // Else: drop
+  }
+  // Build pkg
+  send(type = "PING", payload = "", cb = (res: any) => {}) {
+    this.reqId++;
+    this.socket.write(this.reqId+" "+type+" "+payload+"\r\n");
+    this.reqArray[this.reqId] = cb;
+  }
+  // Build pkg res
+  sendRes(id = 0, type = "PONG", payload = "") {
+    this.socket.write(id+" "+type+" "+payload+"\r\n");
+  }
+}
+
+// Create Server
+var server = new net.Server();
+server.on('connection', (s) => {
+  new Client(s);
+});
+server.listen(config.port, () => {
+  console.log("Listening on port " + config.port);
+});