@brainstack/bridge-server - npm Package Compare versions

Comparing version 1.0.5 to 1.0.6

dist/implementation.d.ts

@@ -1,2 +0,2 @@
-import { BridgeServerFactory } from "./abstraction";
+import { BridgeServerFactory } from './abstraction';
 /**
@@ -3,0 +3,0 @@ * Factory function that creates a bridge server instance.

dist/implementation.js

@@ -25,4 +25,4 @@ "use strict";
 const onListening = (logger, hub, options) => {
-    logger.info(`🚀 Bridge server started on ${options.host}:${options.port}`);
-    hub.emit("start");
+    logger.info(`🚀 Bridge server started on `, options.host, options.port);
+    hub.emit('start');
 };
@@ -36,9 +36,15 @@ /**
 const onConnection = (logger, hub, ws) => {
-    const { remoteAddress, remotePort } = ws;
-    logger.info(`🔗 Client connected: ${remoteAddress}:${remotePort}`);
-    hub.emit("connection", ws);
-    ws.on("message", (message) => {
-        const _a = JSON.parse(message.toString()), { event = "unknown" } = _a, payload = __rest(_a, ["event"]);
-        logger.log(`💬 Message Received: `, event, payload);
-        hub.emit(event, payload);
+    const { url } = ws;
+    logger.info(`🔗 Client connected: `, url);
+    hub.emit('connection', ws);
+    ws.on('message', (message) => {
+        var _a;
+        logger.log(`💬 Message Received: `, message);
+        try {
+            const _b = JSON.parse(((_a = message === null || message === void 0 ? void 0 : message.data) === null || _a === void 0 ? void 0 : _a.toString()) || '{}'), { event = 'unknown' } = _b, payload = __rest(_b, ["event"]);
+            hub.emit(event, payload);
+        }
+        catch (err) {
+            hub.emit("message", message);
+        }
     });
@@ -53,3 +59,3 @@ };
     logger.info(`⚠️ Bridge server closed`);
-    hub.emit("close");
+    hub.emit('close');
 };
@@ -64,3 +70,3 @@ /**
     logger.error(`❌Bridge server error: ${error}`);
-    hub.emit("error", error);
+    hub.emit('error', error);
 };
@@ -83,16 +89,16 @@ /**
     /**
-      * Starts listening for incoming connections on the specified host and port.
-      *
-      * @function
-      * @param {object} options - Configuration options for the server.
-      * @param {string} options.host - Host address to listen on.
-      * @param {number} options.port - Port number to listen on.
-      * @returns {WebSocket.Server} - The WebSocket server instance used for connections.
-      */
+     * Starts listening for incoming connections on the specified host and port.
+     *
+     * @function
+     * @param {object} options - Configuration options for the server.
+     * @param {string} options.host - Host address to listen on.
+     * @param {number} options.port - Port number to listen on.
+     * @returns {WebSocket.Server} - The WebSocket server instance used for connections.
+     */
     const listen = (options) => {
         const server = ws_server || new ws_1.Server(options);
-        server.on("listening", () => onListening(logger, hub, options));
-        server.on("connection", (ws) => onConnection(logger, hub, ws));
-        server.on("close", () => onClose(logger, hub));
-        server.on("error", (error) => onError(logger, hub, error));
+        server.on('listening', () => onListening(logger, hub, options));
+        server.on('connection', (ws) => onConnection(logger, hub, ws));
+        server.on('close', () => onClose(logger, hub));
+        server.on('error', (error) => onError(logger, hub, error));
         return server;
@@ -99,0 +105,0 @@ };

package.json

 {
   "name": "@brainstack/bridge-server",
-  "version": "1.0.5",
+  "version": "1.0.6",
   "description": "Brainstack Bridge Server",
@@ -31,7 +31,7 @@ "main": "dist/index.js",
   "dependencies": {
-    "@brainstack/hub": "^1.1.48",
-    "@brainstack/log": "^1.1.51",
+    "@brainstack/hub": "^1.1.49",
+    "@brainstack/log": "^1.1.52",
     "ws": "^8.13.0"
   },
-  "gitHead": "c80ba8b552954dcfba2dbebaf0d229c1ed45204c"
+  "gitHead": "3be7f14f6fa3f3f36d5c963b569660925c556bcc"
 }

src/implementation.ts

@@ -17,3 +17,3 @@ import { WebSocket, Server } from 'ws';
 ): void => {
-  logger.info(`🚀 Bridge server started on ${options.host}:${options.port}`);
+  logger.info(`🚀 Bridge server started on `, options.host, options.port);
   hub.emit('start');
@@ -31,3 +31,3 @@ };
 
-  logger.info(`🔗 Client connected: ${url}`);
+  logger.info(`🔗 Client connected: `, url);
   hub.emit('connection', ws);
@@ -34,0 +34,0 @@

No alert changes

Improved metrics

Total package byte prevSize

24387

increased by0.68%

Lines of code

593

increased by1.02%

Dependency changes

• Updated@brainstack/hub@^1.1.49

• Updated@brainstack/log@^1.1.52