Support for binary data onnodejs cleint & server; Send all events to onMessage listener

Author: vbaicu

.gitignore

@@ -1,2 +1,3 @@
 node_modules
 .DS_Store
+.vscode

example.js

@@ -2,26 +2,45 @@ const express = require('express');
 const http = require('http');
 const url = require('url');
 const TFPSockets = require('./index')
+const TextEncoder = require('text-encoding').TextEncoder
+const TextDecoder = require('text-encoding').TextDecoder
 
 
 const app = express();
 
 
 const server = http.createServer(app);
 
+const eventFilter = (event,f) => [event].filter(f);
+
 const TFPServer = new TFPSockets.server(server,["chat"])
 TFPServer.on('connection',client => {
   client.on('testEvent', data => {
     console.log("test event payload: ", data.payload)
     client.send('testEventBack',{x:1,y:100})
   })
+
+  client.on('message',event => {
+    console.log("onMessage received event: ",event)
+  })
+
+  client.on('dataEvent', event => {
+    let text = new TextDecoder('utf-8').decode(event.payload)
+    console.log("received data event with payload ", text)
+  })
+
 })
 
 
 const testClient = new TFPSockets.client("ws://localhost:1507",["chat"])
 testClient.on('open', event => {
   console.log("test client open")
   testClient.send('testEvent',{x:10,y:89})
+  testClient.send('event2',{})
+
+  let data = new TextEncoder('utf-8').encode("Hello world as Uint8Array")
+  testClient.sendData('dataEvent',data); 
+
 })
 
 testClient.on('testEventBack', data => {

lib/TFPSockets.js

@@ -1,7 +1,28 @@
 const WebSocket = require('ws')
+const TextEncoder = require('text-encoding').TextEncoder
+const TextDecoder = require('text-encoding').TextDecoder
 
 const isString = s => typeof (s) === 'string' || s instanceof String;
 
+const TFPUtils_packData = (data, eventName) => {
+    if(eventName.length > 255) {
+        throw "Event name length should be < 255"
+        return
+    }
+    let enc = new TextEncoder("utf-8");
+    eventName = enc.encode(eventName)
+    let header = new Uint8Array([eventName.length, ...eventName])
+    return new Uint8Array([...header,...data])
+}
+
+const TFPUtils_unpackData = unpacked => {
+    let headerSize = new Uint8Array(unpacked.slice(0,1))[0]
+    let header = new Uint8Array(unpacked.slice(1,headerSize+1))
+    let data = new Uint8Array(unpacked.slice(headerSize+1))
+    let eventName = new TextDecoder('utf-8').decode(header)
+    return {eventName,payload:data}
+}
+
 class TFPBaseEventStream {
     constructor() {
         this.EventStream = (function () {
@@ -49,17 +70,18 @@ class TFPSocketsClient extends TFPBaseEventStream {
             this.EventStream.emit('open',event)
         })
         this.ws.on('message', (data) => {
+            var processedEvent;
             if (isString(data)) {
-                //handle incomming message
                 try {
-                    let obj = JSON.parse(data);
-                    this.EventStream.emit(obj.eventName, obj)
+                    processedEvent = JSON.parse(data);
                 } catch (e) {
                     console.log("Message doesn't repect protocol with exception: ", e)
                 }
             } else {
-                //binary data wip
+                processedEvent = TFPUtils_unpackData(data)
             }
+            this.EventStream.emit(processedEvent.eventName, processedEvent)
+            this.EventStream.emit('message',processedEvent)
         })
         this.ws.on('close', () => this.EventStream.emit('close') )
     }
@@ -73,6 +95,14 @@ class TFPSocketsClient extends TFPBaseEventStream {
         }
     }
 
+    sendData(event,payload) {
+        if (this.isOpen) {
+            this.ws.send(TFPUtils_packData(payload,event))
+        } else {
+            console.log("Connection is not opened")
+        }
+    }
+
 }
 
 class TFPSocketsServer extends TFPBaseEventStream {

package.json

@@ -19,6 +19,7 @@
   "license": "MIT",
   "dependencies": {
     "express": "^4.16.0",
+    "text-encoding": "^0.6.4",
     "ws": "^3.2.0"
   }
 }