logos-messaging/js-waku
1
0
Fork 0
mirror of https://github.com/logos-messaging/js-waku.git synced 2026-01-15 12:13:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: update incomingMessageHander

Browse Source
This commit is contained in:
Danish Arora 2024-09-10 18:28:18 +05:30
parent 72a521f4e1
commit adf1bb3d98
No known key found for this signature in database
GPG Key ID: 1C6EF37CDAE1426E
3 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
packages/interfaces/src/filter.ts
View File

@ -67,6 +67,11 @@ export type IFilterSDK = IReceiver &
message: WakuMessage,
peerIdStr: PeerIdStr
) => void;
readonly defaultHandleIncomingMessage: (
pubsubTopic: ContentTopic,
message: WakuMessage,
peerIdStr: PeerIdStr
) => void;
};
export type SubscribeResult = SubscriptionSuccess | SubscriptionError;

5
packages/sdk/src/protocols/filter/index.ts
View File

@ -39,7 +39,7 @@ class FilterSDK extends BaseProtocolSDK implements IFilterSDK {
public activeSubscriptions = new Map<PubsubTopic, SubscriptionManager>();
public handleIncomingMessage = (
public readonly defaultHandleIncomingMessage = (
pubsubTopic: PubsubTopic,
message: WakuMessage,
peerIdStr: PeerIdStr
@ -54,6 +54,8 @@ class FilterSDK extends BaseProtocolSDK implements IFilterSDK {
void subscription.processIncomingMessage(message);
};
public handleIncomingMessage = this.defaultHandleIncomingMessage;
public constructor(
connectionManager: ConnectionManager,
libp2p: Libp2p,
@ -78,6 +80,7 @@ class FilterSDK extends BaseProtocolSDK implements IFilterSDK {
) => void
): void {
this.handleIncomingMessage = handler;
this.protocol.incomingMessageHandler = handler;
}
/**

5
packages/sdk/src/protocols/message_reliability_monitor.ts
View File

@ -38,10 +38,7 @@ export class MessageReliabilityMonitor {
all: new Set(),
nodes: {}
};
this.initializeListeners();
}
private initializeListeners(): void {
this.filter.setIncomingMessageHandler(this.handleFilterMessage.bind(this));
}
@ -61,7 +58,7 @@ export class MessageReliabilityMonitor {
void this.validatePreviousMessage();
this.filter.handleIncomingMessage(pubsubTopic, message, peerIdStr);
this.filter.defaultHandleIncomingMessage(pubsubTopic, message, peerIdStr);
}
private isMessageAlreadyReceived(