Compare commits
3 Commits
v0.1.0-dev
...
v0.1.0-dev
Author | SHA1 | Date |
---|---|---|
semantic-release-bot | 31465e3a63 | |
Derrick Hammer | e821da5a27 | |
Derrick Hammer | fabda024ad |
|
@ -1,3 +1,10 @@
|
||||||
|
# [0.1.0-develop.31](https://git.lumeweb.com/LumeWeb/libs5/compare/v0.1.0-develop.30...v0.1.0-develop.31) (2023-09-02)
|
||||||
|
|
||||||
|
|
||||||
|
### Bug Fixes
|
||||||
|
|
||||||
|
* fix iteration of peers ([fabda02](https://git.lumeweb.com/LumeWeb/libs5/commit/fabda024ad788fcb00e398e73f75afb3e944db30))
|
||||||
|
|
||||||
# [0.1.0-develop.30](https://git.lumeweb.com/LumeWeb/libs5/compare/v0.1.0-develop.29...v0.1.0-develop.30) (2023-09-02)
|
# [0.1.0-develop.30](https://git.lumeweb.com/LumeWeb/libs5/compare/v0.1.0-develop.29...v0.1.0-develop.30) (2023-09-02)
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -1,12 +1,12 @@
|
||||||
{
|
{
|
||||||
"name": "@lumeweb/libs5",
|
"name": "@lumeweb/libs5",
|
||||||
"version": "0.1.0-develop.30",
|
"version": "0.1.0-develop.31",
|
||||||
"lockfileVersion": 3,
|
"lockfileVersion": 3,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"packages": {
|
"packages": {
|
||||||
"": {
|
"": {
|
||||||
"name": "@lumeweb/libs5",
|
"name": "@lumeweb/libs5",
|
||||||
"version": "0.1.0-develop.30",
|
"version": "0.1.0-develop.31",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@noble/curves": "^1.1.0",
|
"@noble/curves": "^1.1.0",
|
||||||
"@noble/hashes": "^1.3.1",
|
"@noble/hashes": "^1.3.1",
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
{
|
{
|
||||||
"name": "@lumeweb/libs5",
|
"name": "@lumeweb/libs5",
|
||||||
"version": "0.1.0-develop.30",
|
"version": "0.1.0-develop.31",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"main": "lib/index.js",
|
"main": "lib/index.js",
|
||||||
"repository": {
|
"repository": {
|
||||||
|
|
|
@ -100,7 +100,7 @@ export class RegistryService {
|
||||||
this.logger.verbose("[registry] broadcastEntry");
|
this.logger.verbose("[registry] broadcastEntry");
|
||||||
const updateMessage = this.serializeRegistryEntry(sre);
|
const updateMessage = this.serializeRegistryEntry(sre);
|
||||||
|
|
||||||
for (const p of Object.values(this.node.services.p2p.peers)) {
|
for (const p of [...this.node.services.p2p.peers.values()]) {
|
||||||
if (receivedFrom == null || p.id !== receivedFrom.id) {
|
if (receivedFrom == null || p.id !== receivedFrom.id) {
|
||||||
p.sendMessage(updateMessage);
|
p.sendMessage(updateMessage);
|
||||||
}
|
}
|
||||||
|
@ -116,7 +116,7 @@ export class RegistryService {
|
||||||
const req = p.takeBytes();
|
const req = p.takeBytes();
|
||||||
|
|
||||||
// TODO: Use shard system if there are more than X peers
|
// TODO: Use shard system if there are more than X peers
|
||||||
for (const peer of Object.values(this.node.services.p2p.peers)) {
|
for (const peer of [...this.node.services.p2p.peers.values()]) {
|
||||||
peer.sendMessage(req);
|
peer.sendMessage(req);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue