Skip to content

Commit f387f59

Browse files
chore: handle edge case
1 parent 2b61774 commit f387f59

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

packages/sdk/src/protocols/filter/reliability_monitor.ts

+8-3
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,7 @@ import { Logger } from "@waku/utils";
66

77
type ReceivedMessageHashes = {
88
all: Set<string>;
9-
nodes: {
10-
[peerId: PeerIdStr]: Set<string>;
11-
};
9+
nodes: Record<PeerIdStr, Set<string>>;
1210
};
1311

1412
const DEFAULT_MAX_MISSED_MESSAGES_THRESHOLD = 3;
@@ -60,6 +58,13 @@ export class ReliabilityMonitor {
6058
this.receivedMessagesHashes.all.add(hashedMessageStr);
6159

6260
if (peerIdStr) {
61+
const x = this.receivedMessagesHashes.nodes[peerIdStr];
62+
if (!x) {
63+
log.warn(
64+
`Peer ${peerIdStr} not initialized in receivedMessagesHashes.nodes, adding it.`
65+
);
66+
this.receivedMessagesHashes.nodes[peerIdStr] = new Set();
67+
}
6368
this.receivedMessagesHashes.nodes[peerIdStr].add(hashedMessageStr);
6469
}
6570

0 commit comments

Comments
 (0)