Updated browser client

Author: vbaicu

TFPSocketsClient-Browser.js

@@ -1,5 +1,24 @@
 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 TFPSocketsClient {
 
     constructor(url, protocols,cutomws = null) {
@@ -42,17 +61,18 @@ class TFPSocketsClient {
         }
         this.ws.binaryType = "arraybuffer"
         this.ws.onmessage = (data) => {
+            var processedEvent;
             if (isString(data.data)) {
-                //handle incomming message
                 try {
-                    let obj = JSON.parse(data.data);
-                    this.EventStream.emit(obj.eventName, obj)
+                    processedEvent = JSON.parse(data.data);
                 } catch (e) {
                     console.log("Message doesn't repect protocol with exception: ", e)
                 }
             } else {
-                //binary data wip
+                processedEvent = TFPUtils_unpackData(data.data)
             }
+            this.EventStream.emit(processedEvent.eventName, processedEvent)
+            this.EventStream.emit('message',processedEvent)
         }
     }
 
@@ -69,6 +89,14 @@ class TFPSocketsClient {
         }
     }
 
+    sendData(event,payload) {
+        if (this.isOpen) {
+            this.ws.send(TFPUtils_packData(payload,event))
+        } else {
+            console.log("Connection is not opened")
+        }
+    }
+
 }
 
 if (typeof module !== 'undefined' && module.exports) {