feat(filter): reliability monitor as a separate class to handle reliability logic

packages/interfaces/src/filter.ts

@@ -12,6 +12,11 @@ import type {
 } from "./protocols.js";
 import type { IReceiver } from "./receiver.js";
 
+export type SubscriptionCallback<T extends IDecodedMessage> = {
+  decoders: IDecoder<T>[];
+  callback: Callback<T>;
+};
+
 export type SubscribeOptions = {
   keepAlive?: number;
   pingsBeforePeerRenewed?: number;

packages/sdk/src/index.ts

@@ -15,7 +15,7 @@ export {
   createLibp2pAndUpdateOptions
 } from "./create/index.js";
 export { wakuLightPush } from "./protocols/light_push.js";
-export { wakuFilter } from "./protocols/filter.js";
+export { wakuFilter } from "./protocols/filter/index.js";
 export { wakuStore } from "./protocols/store.js";
 
 export * as waku from "@waku/core";

packages/sdk/src/protocols/base_protocol.ts

@@ -33,7 +33,7 @@ export class BaseProtocolSDK implements IBaseProtocolSDK {
 
   public constructor(
     protected core: BaseProtocol,
-    private connectionManager: ConnectionManager,
+    protected connectionManager: ConnectionManager,
     options: Options
   ) {
     this.log = new Logger(`sdk:${core.multicodec}`);