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

fix: add stop() to IRelayAPI and IStore interfaces, implement in SDK wrappers

Browse Source
This commit is contained in:
Levente Kiss 2025-10-31 19:09:27 +13:00 committed by fryorcraken
parent a97e7eceb9
commit dd1977455d
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
4 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
packages/interfaces/src/relay.ts
View File

@ -16,6 +16,7 @@ export interface IRelayAPI {
readonly pubsubTopics: Set<PubsubTopic>; readonly pubsubTopics: Set<PubsubTopic>;
readonly gossipSub: GossipSub; readonly gossipSub: GossipSub;
start: () => Promise<void>; start: () => Promise<void>;
stop: () => Promise<void>;
waitForPeers: () => Promise<void>; waitForPeers: () => Promise<void>;
getMeshPeers: (topic?: TopicStr) => PeerIdStr[]; getMeshPeers: (topic?: TopicStr) => PeerIdStr[];
} }

1
packages/interfaces/src/store.ts
View File

@ -99,6 +99,7 @@ export type QueryRequestParams = {
export type IStore = { export type IStore = {
readonly multicodec: string; readonly multicodec: string;
stop(): void;
createCursor(message: IDecodedMessage): StoreCursor; createCursor(message: IDecodedMessage): StoreCursor;
queryGenerator: <T extends IDecodedMessage>( queryGenerator: <T extends IDecodedMessage>(
decoders: IDecoder<T>[], decoders: IDecoder<T>[],

1
packages/sdk/src/light_push/light_push.ts
View File

@ -65,6 +65,7 @@ export class LightPush implements ILightPush {
public stop(): void { public stop(): void {
this.retryManager.stop(); this.retryManager.stop();
this.protocol.stop();
} }
public async send( public async send(

4
packages/sdk/src/store/store.ts
View File

@ -46,6 +46,10 @@ export class Store implements IStore {
return this.protocol.multicodec; return this.protocol.multicodec;
} }
public stop(): void {
this.protocol.stop();
}
/** /**
* Queries the Waku Store for historical messages using the provided decoders and options. * Queries the Waku Store for historical messages using the provided decoders and options.
* Returns an asynchronous generator that yields promises of decoded messages. * Returns an asynchronous generator that yields promises of decoded messages.