@spider-mesh/tcp
Advanced tools
@@ -12,3 +12,3 @@ import { createSocket } from "dgram"; | ||
| #broadcastAddress = new Set([ | ||
| '255.255.255.255', | ||
| 'localhost', | ||
| ...(SPIDERMESH_UDP_BROADCAST_ADDRESS || '').split(',').map(e => { | ||
@@ -43,5 +43,7 @@ const ppps = e.trim().split('.'); | ||
| const msg = pack(data); | ||
| const ips = target ? [this.#localAddress.has(target) ? '255.255.255.255' : target] : this.#broadcastAddress; | ||
| const ips = target ? [this.#localAddress.has(target) ? 'localhost' : target] : this.#broadcastAddress; | ||
| for (const ip of ips) | ||
| udp4.send(msg, 0, msg.length, SPIDERMESH_UDP_BROADCAST_PORT, ip); | ||
| udp4.send(msg, 0, msg.length, SPIDERMESH_UDP_BROADCAST_PORT, ip, e => { | ||
| e && console.error('UDP Broadcast error', e); | ||
| }); | ||
| }; | ||
@@ -61,3 +63,3 @@ udp4.on('message', async (raw, r) => { | ||
| return; | ||
| is_remote && await broadcast(node, hi, '255.255.255.255', receiver_id); | ||
| is_remote && await broadcast(node, hi, 'localhost', receiver_id); | ||
| if (receiver_id && receiver_id != metadata.node_id) | ||
@@ -64,0 +66,0 @@ return; |
@@ -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;AAYvC,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,iBAAiB;QACjB,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,iBAAiB,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,iBAAiB,CAAA;gBAC3G,KAAK,MAAM,EAAE,IAAI,GAAG;oBAAE,IAAI,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,EAAE,GAAG,CAAC,MAAM,EAAE,6BAA6B,EAAE,EAAE,CAAC,CAAA;YAC1F,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,iBAAiB,EAAE,WAAW,CAAC,CAAA;oBAGtE,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,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"} |
+1
-1
| { | ||
| "name": "@spider-mesh/tcp", | ||
| "type": "module", | ||
| "version": "2.0.18", | ||
| "version": "2.0.19", | ||
| "description": "Lightweight microservice framework for typescript, auto discovery, load-balancing, fault-torrent, multiple transporters", | ||
@@ -6,0 +6,0 @@ "main": "./build/src/index.js", |
Network access
Supply chain riskThis module accesses the network.
Found 1 instance in 1 package
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 3 instances in 1 package
URL strings
Supply chain riskPackage contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.
Found 1 instance in 1 package
Network access
Supply chain riskThis module accesses the network.
Found 1 instance in 1 package
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 3 instances in 1 package
URL strings
Supply chain riskPackage contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.
Found 1 instance in 1 package
47832
0.36%618
0.32%