feat!: use ShardingParams on subscriptions, make Decoder/Encoder auto sharding friendly by default

packages/core/src/lib/filter/index.ts

@@ -444,7 +444,9 @@ class Filter extends BaseProtocol implements IReceiver {
     decoders: IDecoder<T> | IDecoder<T>[],
     callback: Callback<T>
   ): Promise<Unsubscribe> {
-    const subscription = await this.createSubscription();
+    const subscription = await this.createSubscription(
+      this.pubsubTopics?.[0] || DefaultPubsubTopic
+    );
 
     await subscription.subscribe(decoders, callback);
 

packages/interfaces/src/waku.ts

@@ -1,5 +1,5 @@
 import type { PeerId, Stream } from "@libp2p/interface";
-import type { Multiaddr } from "@multiformats/multiaddr";
+import type { MultiaddrInput } from "@multiformats/multiaddr";
 
 import { IConnectionManager } from "./connection_manager.js";
 import type { IFilter } from "./filter.js";
@@ -18,7 +18,7 @@ export interface Waku {
 
   connectionManager: IConnectionManager;
 
-  dial(peer: PeerId | Multiaddr, protocols?: Protocols[]): Promise<Stream>;
+  dial(peer: PeerId | MultiaddrInput, protocols?: Protocols[]): Promise<Stream>;
 
   start(): Promise<void>;