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

…bility logic (#2117)

* chore: move SubscriptionManager to a separate file

* feat: introduce ReliabilityMonitor

* fix: peer data updates

* fix: logical error when returning includesMessage

* chore: handle edge case

* chore: move ping failures handling inside monitor

* chore: move renewal logic to monitor

* chore: improve structuring

* chore: update logger

* chore: readd connectionListener() logic from merge

* chore: minor fixes

* chore: improve

* chore: setup destruction of ReliabilityMonitors

* fix: condition for ping failure

* fix: setters

* chore: handle race condition & fix test

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}`);