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

chore: remove fitler codec initiator in filter core (#2443)

Browse Source
This commit is contained in:
Sasha 2025-07-03 13:28:32 +02:00 committed by GitHub
parent 058f2ff620
commit bfda249aa6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
packages/core/src/lib/filter/filter.ts
View File

@ -37,12 +37,11 @@ type IncomingMessageHandler = (
export class FilterCore { export class FilterCore {
private streamManager: StreamManager; private streamManager: StreamManager;
private static handleIncomingMessage?: IncomingMessageHandler;
public readonly multicodec = FilterCodecs.SUBSCRIBE; public readonly multicodec = FilterCodecs.SUBSCRIBE;
public constructor( public constructor(
handleIncomingMessage: IncomingMessageHandler, private handleIncomingMessage: IncomingMessageHandler,
public readonly pubsubTopics: PubsubTopic[], public readonly pubsubTopics: PubsubTopic[],
libp2p: Libp2p libp2p: Libp2p
) { ) {
@ -51,29 +50,6 @@ export class FilterCore {
libp2p.components libp2p.components
); );
// TODO(weboko): remove when @waku/sdk 0.0.33 is released
const prevHandler = FilterCore.handleIncomingMessage;
FilterCore.handleIncomingMessage = !prevHandler
? handleIncomingMessage
: async (pubsubTopic, message, peerIdStr): Promise<void> => {
try {
await prevHandler(pubsubTopic, message, peerIdStr);
} catch (e) {
log.error(
"Previous FilterCore incoming message handler failed ",
e
);
}
try {
await handleIncomingMessage(pubsubTopic, message, peerIdStr);
} catch (e) {
log.error("Present FilterCore incoming message handler failed ", e);
}
return;
};
libp2p libp2p
.handle(FilterCodecs.PUSH, this.onRequest.bind(this), { .handle(FilterCodecs.PUSH, this.onRequest.bind(this), {
maxInboundStreams: 100 maxInboundStreams: 100
@ -327,7 +303,7 @@ export class FilterCore {
return; return;
} }
await FilterCore.handleIncomingMessage?.( await this.handleIncomingMessage(
pubsubTopic, pubsubTopic,
wakuMessage, wakuMessage,
connection.remotePeer.toString() connection.remotePeer.toString()