@therms/rpc-server - npm Package Compare versions

Comparing version 2.7.0 to 2.8.0

CHANGELOG.md

@@ -0,1 +1,8 @@
+# [2.8.0](https://bitbucket.org/thermsio/rpc-server-ts/compare/v2.7.0...v2.8.0) (2022-06-13)
+
+
+### Features
+
+* refactor logic for RPC client websocket identity change ([9ddd791](https://bitbucket.org/thermsio/rpc-server-ts/commits/9ddd7914b09c8488a09a4b5be4419641098e7c2a))
+
 # [2.7.0](https://bitbucket.org/thermsio/rpc-server-ts/compare/v2.6.0...v2.7.0) (2022-06-13)
@@ -2,0 +9,0 @@

dist/index.js

@@ -15,2 +15,3 @@ 'use strict';
 var uuid = require('node-uuid');
+var lodashEs = require('lodash-es');
 var os = require('os');
@@ -964,9 +965,12 @@ var lodash = require('lodash');
                     }
-                    if (!identity?.authorization && clientMsg.identity?.authorization) {
-                        if (this.options.config?.gatewayServer?.websocket?.onClientConnect) {
-                            this.options.config.gatewayServer.websocket.onClientConnect({
-                                connectionId: websocketId,
-                                identity: clientMsg.identity,
-                                ip: wsIp,
-                            });
+                    if (clientMsg.identity) {
+                        if (this.options.config?.gatewayServer?.websocket
+                            ?.onClientConnectionIdentityChanged) {
+                            if (!lodashEs.isEqual(clientMsg.identity, identity)) {
+                                this.options.config.gatewayServer.websocket.onClientConnectionIdentityChanged({
+                                    connectionId: websocketId,
+                                    identity: clientMsg.identity,
+                                    ip: wsIp,
+                                });
+                            }
                         }
@@ -973,0 +977,0 @@ }

dist/RPCServer/GatewayServers/WebSocketServer.js

@@ -9,2 +9,3 @@ import WsServer from 'ws';
 import uuid from 'node-uuid';
+import { isEqual } from 'lodash-es';
 const debug = Debug('rpc:WebSocketServer');
@@ -141,9 +142,12 @@ export class WebSocketServer {
                     }
-                    if (!identity?.authorization && clientMsg.identity?.authorization) {
-                        if (this.options.config?.gatewayServer?.websocket?.onClientConnect) {
-                            this.options.config.gatewayServer.websocket.onClientConnect({
-                                connectionId: websocketId,
-                                identity: clientMsg.identity,
-                                ip: wsIp,
-                            });
+                    if (clientMsg.identity) {
+                        if (this.options.config?.gatewayServer?.websocket
+                            ?.onClientConnectionIdentityChanged) {
+                            if (!isEqual(clientMsg.identity, identity)) {
+                                this.options.config.gatewayServer.websocket.onClientConnectionIdentityChanged({
+                                    connectionId: websocketId,
+                                    identity: clientMsg.identity,
+                                    ip: wsIp,
+                                });
+                            }
                         }
@@ -150,0 +154,0 @@ }

dist/RPCServer/RPCServer.d.ts

@@ -32,2 +32,7 @@ import { HandlerRegistrationInfo, RPCServerHandler } from '../Handler';
             }) => void;
+            onClientConnectionIdentityChanged?: (connection: {
+                connectionId: string;
+                identity?: RPCClientIdentity;
+                ip?: string;
+            }) => void;
             onClientDisconnect?: (connection: {
@@ -34,0 +39,0 @@ connectionId: string;

package.json

 {
   "name": "@therms/rpc-server",
-  "version": "2.7.0",
+  "version": "2.8.0",
   "description": "RPC framework, Node.js lib",
@@ -5,0 +5,0 @@ "private": false,

No alert changes

Improved metrics

Total package byte prevSize

981166

increased by0.12%

Lines of code

5749

increased by0.23%

No dependency changes