@spider-mesh/tcp - npm Package Compare versions

Comparing version 2.0.19 to 2.0.20

build/src/const.d.ts

 export declare const SPIDERMESH_UDP_BROADCAST_ADDRESS: string | undefined;
 export declare const SPIDERMESH_UDP_BROADCAST_PORT: number;
 export declare const SPIDERMESH_HTTP2_AUTO_LOAD_BALANCE: boolean;
+export declare const SPIDERMESH_UDP_MULTICAST_ADDRESS: string;

build/src/const.js

 export const SPIDERMESH_UDP_BROADCAST_ADDRESS = process.env.SPIDERMESH_UDP_BROADCAST_ADDRESS;
 export const SPIDERMESH_UDP_BROADCAST_PORT = Number(process.env.SPIDERMESH_UDP_BROADCAST_PORT || 20000);
 export const SPIDERMESH_HTTP2_AUTO_LOAD_BALANCE = !process.env.SPIDERMESH_HTTP2_AUTO_LOAD_BALANCE;
+export const SPIDERMESH_UDP_MULTICAST_ADDRESS = process.env.SPIDERMESH_UDP_MULTICAST_ADDRESS || "239.0.0.1";
 //# sourceMappingURL=const.js.map

build/src/const.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"const.js","sourceRoot":"","sources":["../../src/const.ts"],"names":[],"mappings":"AAAA,MAAM,CAAC,MAAM,gCAAgC,GAAG,OAAO,CAAC,GAAG,CAAC,gCAAgC,CAAA;AAC5F,MAAM,CAAC,MAAM,6BAA6B,GAAG,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,6BAA6B,IAAI,KAAK,CAAC,CAAA;AACvG,MAAM,CAAC,MAAM,kCAAkC,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,kCAAkC,CAAA"}
+{"version":3,"file":"const.js","sourceRoot":"","sources":["../../src/const.ts"],"names":[],"mappings":"AAAA,MAAM,CAAC,MAAM,gCAAgC,GAAG,OAAO,CAAC,GAAG,CAAC,gCAAgC,CAAA;AAC5F,MAAM,CAAC,MAAM,6BAA6B,GAAG,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,6BAA6B,IAAI,KAAK,CAAC,CAAA;AACvG,MAAM,CAAC,MAAM,kCAAkC,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,kCAAkC,CAAA;AACjG,MAAM,CAAC,MAAM,gCAAgC,GAAG,OAAO,CAAC,GAAG,CAAC,gCAAgC,IAAK,WAAW,CAAA"}

build/src/UdpDiscovery.d.ts

@@ -7,2 +7,3 @@ import { DiscoveryTransporter, SpiderMeshNode } from "@spider-mesh/core";
     sender_id: string;
+    forwarder_id?: string;
     receiver_id?: string;
@@ -9,0 +10,0 @@ };

build/src/UdpDiscovery.js

 import { createSocket } from "dgram";
 import { DiscoveryTransporter, SpiderMesh } from "@spider-mesh/core";
 import { networkInterfaces } from "os";
-import { SPIDERMESH_UDP_BROADCAST_ADDRESS, SPIDERMESH_UDP_BROADCAST_PORT } from "./const.js";
+import { SPIDERMESH_UDP_BROADCAST_ADDRESS, SPIDERMESH_UDP_BROADCAST_PORT, SPIDERMESH_UDP_MULTICAST_ADDRESS } from "./const.js";
 import { from, map, Observable } from "rxjs";
@@ -12,3 +12,3 @@ import { firstValueFrom } from "rxjs";
     #broadcastAddress = new Set([
-        'localhost',
+        SPIDERMESH_UDP_MULTICAST_ADDRESS,
         ...(SPIDERMESH_UDP_BROADCAST_ADDRESS || '').split(',').map(e => {
@@ -35,34 +35,37 @@ const ppps = e.trim().split('.');
             });
-            const broadcast = async (node, hi, target, receiver_id) => {
-                const data = {
-                    sender_id: metadata.node_id,
-                    node,
-                    hi,
-                    receiver_id
-                };
+            const broadcast = async (data, ips = [...this.#broadcastAddress]) => {
                 const msg = pack(data);
-                const ips = target ? [this.#localAddress.has(target) ? 'localhost' : target] : this.#broadcastAddress;
-                for (const ip of ips)
+                for (const ip of ips) {
                     udp4.send(msg, 0, msg.length, SPIDERMESH_UDP_BROADCAST_PORT, ip, e => {
                         e && console.error('UDP Broadcast error', e);
                     });
+                }
             };
             udp4.on('message', async (raw, r) => {
                 try {
-                    const { node, hi, sender_id, receiver_id } = unpack(raw);
-                    if (node.node_id == metadata.node_id)
+                    const msg = unpack(raw);
+                    if (msg.node.node_id == metadata.node_id)
                         return;
-                    if (sender_id == metadata.node_id)
+                    if (msg.sender_id == metadata.node_id)
                         return;
-                    if (node.namespace != metadata.namespace)
+                    if (msg.forwarder_id == metadata.node_id)
                         return;
-                    node.host = node.host || r.address;
+                    if (msg.node.namespace != metadata.namespace)
+                        return;
+                    const node = { ...msg.node, host: msg.node.host || r.address };
                     const is_remote = !this.#localAddress.has(r.address);
-                    if (is_remote && !this.#broadcastAddress.has(r.address))
+                    is_remote && !msg.forwarder_id && await broadcast({
+                        ...msg,
+                        node,
+                        forwarder_id: metadata.node_id
+                    }, [SPIDERMESH_UDP_MULTICAST_ADDRESS]);
+                    if (msg.receiver_id && msg.receiver_id != metadata.node_id)
                         return;
-                    is_remote && await broadcast(node, hi, 'localhost', receiver_id);
-                    if (receiver_id && receiver_id != metadata.node_id)
-                        return;
+                    msg.hi && await broadcast({
+                        node: metadata,
+                        hi: false,
+                        sender_id: metadata.node_id,
+                        receiver_id: msg.sender_id
+                    }, [is_remote ? r.address : SPIDERMESH_UDP_MULTICAST_ADDRESS]);
                     o.next(node);
-                    hi && await broadcast(await firstValueFrom(metadata$), false, node.host, node.node_id);
                 }
@@ -73,4 +76,9 @@ catch (e) {
             udp4.on('listening', () => {
-                udp4.setBroadcast(true);
-                const s = metadata$.pipe(debounceTime(1000), map((metadata, index) => broadcast(metadata, index == 0))).subscribe();
+                udp4.setMulticastInterface("127.0.0.1");
+                udp4.addMembership(SPIDERMESH_UDP_MULTICAST_ADDRESS, "127.0.0.1");
+                const s = metadata$.pipe(debounceTime(1000), map(node => broadcast({
+                    node,
+                    hi: true,
+                    sender_id: metadata.node_id
+                }))).subscribe();
                 o.add(() => s.unsubscribe());
@@ -77,0 +85,0 @@ });

build/src/UdpDiscovery.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"UdpDiscovery.js","sourceRoot":"","sources":["../../src/UdpDiscovery.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,YAAY,EAAE,MAAM,OAAO,CAAC;AACrC,OAAO,EAAE,oBAAoB,EAAE,UAAU,EAAkB,MAAM,mBAAmB,CAAC;AACrF,OAAO,EAAE,iBAAiB,EAAE,MAAM,IAAI,CAAC;AACvC,OAAO,EAAE,gCAAgC,EAAE,6BAA6B,EAAE,MAAM,YAAY,CAAC;AAC7F,OAAO,EAAE,IAAI,EAAE,GAAG,EAAE,UAAU,EAAE,MAAM,MAAM,CAAC;AAC7C,OAAO,EAAE,cAAc,EAAE,MAAM,MAAM,CAAC;AACtC,OAAO,EAAE,YAAY,EAAE,QAAQ,EAAE,MAAM,gBAAgB,CAAC;AACxD,OAAO,EAAE,MAAM,EAAE,IAAI,EAAE,MAAM,UAAU,CAAA;AAUvC,MAAM,OAAO,YAAa,SAAQ,oBAAoB;IAElD,aAAa,GAAG,IAAI,GAAG,CACnB,MAAM,CAAC,MAAM,CAAC,iBAAiB,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,EAAE,OAAO,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,CAClF,CAAA;IACD,iBAAiB,GAAG,IAAI,GAAG,CAAC;QACxB,WAAW;QACX,GAAG,CAAC,gCAAgC,IAAI,EAAE,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE;YAC3D,MAAM,IAAI,GAAG,CAAC,CAAC,IAAI,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;YAChC,IAAI,IAAI,CAAC,MAAM,IAAI,CAAC;gBAAE,OAAO,CAAC,CAAC,IAAI,EAAE,CAAA;YACrC,IAAI,IAAI,CAAC,MAAM,IAAI,CAAC;gBAAE,OAAO,IAAI,KAAK,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,KAAK,EAAE,EAAE;oBACjE,OAAO,GAAG,CAAC,CAAC,IAAI,EAAE,IAAI,KAAK,EAAE,CAAA;gBACjC,CAAC,CAAC,CAAA;YACF,OAAO,EAAE,CAAA;QACb,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC;KACb,CAAC,CAAA;IAEF;QACI,KAAK,EAAE,CAAA;QACP,UAAU,CAAC,eAAe,CAAC,IAAI,CAAC,CAAA;IACpC,CAAC;IAGD,IAAI,CAAC,SAAqC;QAEtC,OAAO,IAAI,CAAC,cAAc,CAAC,SAAS,CAAC,CAAC,CAAC,IAAI,CACvC,QAAQ,CAAC,QAAQ,CAAC,EAAE,CAAC,IAAI,UAAU,CAAiB,CAAC,CAAC,EAAE;YAEpD,MAAM,IAAI,GAAG,YAAY,CAAC;gBACtB,IAAI,EAAE,MAAM;gBACZ,SAAS,EAAE,IAAI;aAClB,CAAC,CAAA;YAGF,MAAM,SAAS,GAAG,KAAK,EAAE,IAAoB,EAAE,EAAW,EAAE,MAAe,EAAE,WAAoB,EAAE,EAAE;gBAEjG,MAAM,IAAI,GAAgB;oBACtB,SAAS,EAAE,QAAQ,CAAC,OAAO;oBAC3B,IAAI;oBACJ,EAAE;oBACF,WAAW;iBACd,CAAA;gBACD,MAAM,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,CAAA;gBACtB,MAAM,GAAG,GAAG,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,iBAAiB,CAAA;gBACrG,KAAK,MAAM,EAAE,IAAI,GAAG;oBAAE,IAAI,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,EAAE,GAAG,CAAC,MAAM,EAAE,6BAA6B,EAAE,EAAE,EAAE,CAAC,CAAC,EAAE;wBACvF,CAAC,IAAI,OAAO,CAAC,KAAK,CAAC,qBAAqB,EAAE,CAAC,CAAC,CAAA;oBAChD,CAAC,CAAC,CAAA;YACN,CAAC,CAAA;YAED,IAAI,CAAC,EAAE,CAAC,SAAS,EAAE,KAAK,EAAE,GAAW,EAAE,CAAC,EAAE,EAAE;gBACxC,IAAI,CAAC;oBACD,MAAM,EAAE,IAAI,EAAE,EAAE,EAAE,SAAS,EAAE,WAAW,EAAE,GAAG,MAAM,CAAC,GAAG,CAAgB,CAAA;oBACvE,IAAI,IAAI,CAAC,OAAO,IAAI,QAAQ,CAAC,OAAO;wBAAE,OAAM;oBAC5C,IAAI,SAAS,IAAI,QAAQ,CAAC,OAAO;wBAAE,OAAM;oBACzC,IAAI,IAAI,CAAC,SAAS,IAAI,QAAQ,CAAC,SAAS;wBAAE,OAAM;oBAChD,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,IAAI,CAAC,CAAC,OAAO,CAAA;oBAClC,MAAM,SAAS,GAAG,CAAC,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,OAAO,CAAC,CAAA;oBACpD,IAAI,SAAS,IAAI,CAAC,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,CAAC,CAAC,OAAO,CAAC;wBAAE,OAAM;oBAG/D,SAAS,IAAI,MAAM,SAAS,CAAC,IAAI,EAAE,EAAE,EAAE,WAAW,EAAE,WAAW,CAAC,CAAA;oBAGhE,IAAI,WAAW,IAAI,WAAW,IAAI,QAAQ,CAAC,OAAO;wBAAE,OAAM;oBAC1D,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;oBACZ,EAAE,IAAI,MAAM,SAAS,CAAC,MAAM,cAAc,CAAC,SAAS,CAAC,EAAE,KAAK,EAAE,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,OAAO,CAAC,CAAA;gBAC1F,CAAC;gBAAC,OAAO,CAAC,EAAE,CAAC;gBACb,CAAC;YACL,CAAC,CAAC,CAAA;YAEF,IAAI,CAAC,EAAE,CAAC,WAAW,EAAE,GAAG,EAAE;gBACtB,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,CAAA;gBAEvB,MAAM,CAAC,GAAG,SAAS,CAAC,IAAI,CACpB,YAAY,CAAC,IAAI,CAAC,EAClB,GAAG,CAAC,CAAC,QAAQ,EAAE,KAAK,EAAE,EAAE,CAAC,SAAS,CAAC,QAAQ,EAAE,KAAK,IAAI,CAAC,CAAC,CAAC,CAC5D,CAAC,SAAS,EAAE,CAAA;gBAEb,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,CAAC,CAAC,WAAW,EAAE,CAAC,CAAA;YAEhC,CAAC,CAAC,CAAA;YACF,IAAI,CAAC,EAAE,CAAC,OAAO,EAAE,CAAC,CAAC,EAAE,EAAE;gBACnB,MAAM,CAAC,CAAA;YACX,CAAC,CAAC,CAAA;YACF,IAAI,CAAC,IAAI,CAAC,6BAA6B,EAAE,SAAS,CAAC,CAAA;YACnD,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,KAAK,EAAE,CAAA;QAC7B,CAAC,CAAC,CACD,CACJ,CAAA;IACL,CAAC;CAEJ"}
+{"version":3,"file":"UdpDiscovery.js","sourceRoot":"","sources":["../../src/UdpDiscovery.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,YAAY,EAAE,MAAM,OAAO,CAAC;AACrC,OAAO,EAAE,oBAAoB,EAAE,UAAU,EAAkB,MAAM,mBAAmB,CAAC;AACrF,OAAO,EAAE,iBAAiB,EAAE,MAAM,IAAI,CAAC;AACvC,OAAO,EAAE,gCAAgC,EAAE,6BAA6B,EAAE,gCAAgC,EAAE,MAAM,YAAY,CAAC;AAC/H,OAAO,EAAE,IAAI,EAAE,GAAG,EAAE,UAAU,EAAE,MAAM,MAAM,CAAC;AAC7C,OAAO,EAAE,cAAc,EAAE,MAAM,MAAM,CAAC;AACtC,OAAO,EAAE,YAAY,EAAE,QAAQ,EAAE,MAAM,gBAAgB,CAAC;AACxD,OAAO,EAAE,MAAM,EAAE,IAAI,EAAE,MAAM,UAAU,CAAA;AAWvC,MAAM,OAAO,YAAa,SAAQ,oBAAoB;IAElD,aAAa,GAAG,IAAI,GAAG,CACnB,MAAM,CAAC,MAAM,CAAC,iBAAiB,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,EAAE,OAAO,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,CAClF,CAAA;IACD,iBAAiB,GAAG,IAAI,GAAG,CAAC;QACxB,gCAAgC;QAChC,GAAG,CAAC,gCAAgC,IAAI,EAAE,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE;YAC3D,MAAM,IAAI,GAAG,CAAC,CAAC,IAAI,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;YAChC,IAAI,IAAI,CAAC,MAAM,IAAI,CAAC;gBAAE,OAAO,CAAC,CAAC,IAAI,EAAE,CAAA;YACrC,IAAI,IAAI,CAAC,MAAM,IAAI,CAAC;gBAAE,OAAO,IAAI,KAAK,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,KAAK,EAAE,EAAE;oBACjE,OAAO,GAAG,CAAC,CAAC,IAAI,EAAE,IAAI,KAAK,EAAE,CAAA;gBACjC,CAAC,CAAC,CAAA;YACF,OAAO,EAAE,CAAA;QACb,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC;KACb,CAAC,CAAA;IAEF;QACI,KAAK,EAAE,CAAA;QACP,UAAU,CAAC,eAAe,CAAC,IAAI,CAAC,CAAA;IACpC,CAAC;IAGD,IAAI,CAAC,SAAqC;QAEtC,OAAO,IAAI,CAAC,cAAc,CAAC,SAAS,CAAC,CAAC,CAAC,IAAI,CACvC,QAAQ,CAAC,QAAQ,CAAC,EAAE,CAAC,IAAI,UAAU,CAAiB,CAAC,CAAC,EAAE;YAEpD,MAAM,IAAI,GAAG,YAAY,CAAC;gBACtB,IAAI,EAAE,MAAM;gBACZ,SAAS,EAAE,IAAI;aAClB,CAAC,CAAA;YAGF,MAAM,SAAS,GAAG,KAAK,EAAE,IAAiB,EAAE,MAAgB,CAAC,GAAG,IAAI,CAAC,iBAAiB,CAAC,EAAE,EAAE;gBACvF,MAAM,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,CAAA;gBACtB,KAAK,MAAM,EAAE,IAAI,GAAG,EAAE,CAAC;oBACnB,IAAI,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,EAAE,GAAG,CAAC,MAAM,EAAE,6BAA6B,EAAE,EAAE,EAAE,CAAC,CAAC,EAAE;wBACjE,CAAC,IAAI,OAAO,CAAC,KAAK,CAAC,qBAAqB,EAAE,CAAC,CAAC,CAAA;oBAChD,CAAC,CAAC,CAAA;gBACN,CAAC;YACL,CAAC,CAAA;YAED,IAAI,CAAC,EAAE,CAAC,SAAS,EAAE,KAAK,EAAE,GAAW,EAAE,CAAC,EAAE,EAAE;gBACxC,IAAI,CAAC;oBACD,MAAM,GAAG,GAAG,MAAM,CAAC,GAAG,CAAgB,CAAA;oBACtC,IAAI,GAAG,CAAC,IAAI,CAAC,OAAO,IAAI,QAAQ,CAAC,OAAO;wBAAE,OAAM;oBAChD,IAAI,GAAG,CAAC,SAAS,IAAI,QAAQ,CAAC,OAAO;wBAAE,OAAM;oBAC7C,IAAI,GAAG,CAAC,YAAY,IAAI,QAAQ,CAAC,OAAO;wBAAE,OAAM;oBAChD,IAAI,GAAG,CAAC,IAAI,CAAC,SAAS,IAAI,QAAQ,CAAC,SAAS;wBAAE,OAAM;oBAGpD,MAAM,IAAI,GAAG,EAAE,GAAG,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,CAAC,IAAI,IAAI,CAAC,CAAC,OAAO,EAAE,CAAA;oBAC9D,MAAM,SAAS,GAAG,CAAC,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC;oBACrD,SAAS,IAAI,CAAC,GAAG,CAAC,YAAY,IAAI,MAAM,SAAS,CAAC;wBAC9C,GAAG,GAAG;wBACN,IAAI;wBACJ,YAAY,EAAE,QAAQ,CAAC,OAAO;qBACjC,EAAE,CAAC,gCAAgC,CAAC,CAAC,CAAC;oBAGvC,IAAI,GAAG,CAAC,WAAW,IAAI,GAAG,CAAC,WAAW,IAAI,QAAQ,CAAC,OAAO;wBAAE,OAAO;oBAGnE,GAAG,CAAC,EAAE,IAAI,MAAM,SAAS,CAAC;wBACtB,IAAI,EAAE,QAAQ;wBACd,EAAE,EAAE,KAAK;wBACT,SAAS,EAAE,QAAQ,CAAC,OAAO;wBAC3B,WAAW,EAAE,GAAG,CAAC,SAAS;qBAC7B,EAAE,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,gCAAgC,CAAC,CAAC,CAAC;oBAG/D,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;gBAEjB,CAAC;gBAAC,OAAO,CAAC,EAAE,CAAC;gBACb,CAAC;YACL,CAAC,CAAC,CAAA;YAEF,IAAI,CAAC,EAAE,CAAC,WAAW,EAAE,GAAG,EAAE;gBACtB,IAAI,CAAC,qBAAqB,CAAC,WAAW,CAAC,CAAC;gBACxC,IAAI,CAAC,aAAa,CAAC,gCAAgC,EAAE,WAAW,CAAC,CAAC;gBAClE,MAAM,CAAC,GAAG,SAAS,CAAC,IAAI,CACpB,YAAY,CAAC,IAAI,CAAC,EAClB,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC,SAAS,CAAC;oBAClB,IAAI;oBACJ,EAAE,EAAE,IAAI;oBACR,SAAS,EAAE,QAAQ,CAAC,OAAO;iBAC9B,CAAC,CAAC,CACN,CAAC,SAAS,EAAE,CAAA;gBAEb,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,CAAC,CAAC,WAAW,EAAE,CAAC,CAAA;YAEhC,CAAC,CAAC,CAAA;YACF,IAAI,CAAC,EAAE,CAAC,OAAO,EAAE,CAAC,CAAC,EAAE,EAAE;gBACnB,MAAM,CAAC,CAAA;YACX,CAAC,CAAC,CAAA;YACF,IAAI,CAAC,IAAI,CAAC,6BAA6B,EAAE,SAAS,CAAC,CAAA;YACnD,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,KAAK,EAAE,CAAA;QAC7B,CAAC,CAAC,CACD,CACJ,CAAA;IACL,CAAC;CAEJ"}

package.json

 {
   "name": "@spider-mesh/tcp",
   "type": "module",
-  "version": "2.0.19",
+  "version": "2.0.20",
   "description": "Lightweight microservice framework for typescript, auto discovery, load-balancing, fault-torrent, multiple transporters",
@@ -6,0 +6,0 @@ "main": "./build/src/index.js",

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 4 instances in 1 package

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 3 instances in 1 package

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

48540

1.48%

Lines of code

629

1.78%

Worsened metrics

Number of low supply chain risk alerts

6

20%

No dependency changes