diff --git a/waku/waku_filter/protocol.nim b/waku/waku_filter/protocol.nim index 6ec7ad7fa..b3c53b8e0 100644 --- a/waku/waku_filter/protocol.nim +++ b/waku/waku_filter/protocol.nim @@ -120,14 +120,6 @@ proc new*(T: type WakuFilterLegacy, wf.initProtocolHandler() return wf -proc init*(T: type WakuFilterLegacy, - peerManager: PeerManager, - rng: ref rand.HmacDrbgContext, - timeout: Duration = WakuLegacyFilterTimeout): T {. - deprecated: "WakuFilterLegacy.new()' instead".} = - WakuFilterLegacy.new(peerManager, rng, timeout) - - proc sendFilterRpc(wf: WakuFilterLegacy, rpc: FilterRPC, peer: PeerId|RemotePeerInfo): Future[WakuFilterResult[void]] {.async, gcsafe.}= let connOpt = await wf.peerManager.dialPeer(peer, WakuLegacyFilterCodec) if connOpt.isNone(): diff --git a/waku/waku_filter_v2/protocol.nim b/waku/waku_filter_v2/protocol.nim index a0d9d2cdc..fd422e6fc 100644 --- a/waku/waku_filter_v2/protocol.nim +++ b/waku/waku_filter_v2/protocol.nim @@ -261,7 +261,7 @@ proc new*(T: type WakuFilter, const MaintainSubscriptionsInterval* = 1.minutes -proc startMaintainingSubscriptions*(wf: WakuFilter, interval: Duration) = +proc startMaintainingSubscriptions(wf: WakuFilter, interval: Duration) = trace "starting to maintain subscriptions" var maintainSubs: CallbackFunc maintainSubs = CallbackFunc( diff --git a/waku/waku_lightpush/protocol.nim b/waku/waku_lightpush/protocol.nim index 746262667..d62dc0b79 100644 --- a/waku/waku_lightpush/protocol.nim +++ b/waku/waku_lightpush/protocol.nim @@ -62,7 +62,7 @@ proc handleRequest*(wl: WakuLightPush, peerId: PeerId, buffer: seq[byte]): Futur let rpc = PushRPC(requestId: requestId, response: some(response)) return rpc -proc initProtocolHandler*(wl: WakuLightPush) = +proc initProtocolHandler(wl: WakuLightPush) = proc handle(conn: Connection, proto: string) {.async.} = let buffer = await conn.readLp(MaxRpcSize.int) let rpc = await handleRequest(wl, conn.peerId, buffer) diff --git a/waku/waku_metadata/protocol.nim b/waku/waku_metadata/protocol.nim index 1fbe1e271..ff4eaa29b 100644 --- a/waku/waku_metadata/protocol.nim +++ b/waku/waku_metadata/protocol.nim @@ -68,7 +68,7 @@ proc request*(m: WakuMetadata, conn: Connection): Future[Result[WakuMetadataResp return ok(response) -proc initProtocolHandler*(m: WakuMetadata) = +proc initProtocolHandler(m: WakuMetadata) = proc handle(conn: Connection, proto: string) {.async, gcsafe, closure.} = let res = catch: await conn.readLp(RpcResponseMaxBytes) let buffer = res.valueOr: diff --git a/waku/waku_relay/protocol.nim b/waku/waku_relay/protocol.nim index cef60cb13..aea62105e 100644 --- a/waku/waku_relay/protocol.nim +++ b/waku/waku_relay/protocol.nim @@ -196,7 +196,7 @@ proc isSubscribed*(w: WakuRelay, topic: PubsubTopic): bool = proc subscribedTopics*(w: WakuRelay): seq[PubsubTopic] = return toSeq(GossipSub(w).topics.keys()) -proc generateOrderedValidator*(w: WakuRelay): auto {.gcsafe.} = +proc generateOrderedValidator(w: WakuRelay): auto {.gcsafe.} = # rejects messages that are not WakuMessage let wrappedValidator = proc(pubsubTopic: string, message: messages.Message): Future[ValidationResult] {.async.} =