diff --git a/waku/factory/node_factory.nim b/waku/factory/node_factory.nim index 0dc4c8f89..8f4bba310 100644 --- a/waku/factory/node_factory.nim +++ b/waku/factory/node_factory.nim @@ -197,6 +197,9 @@ proc setupProtocols( except CatchableError: return err("failed to mount waku store protocol: " & getCurrentExceptionMsg()) + let storeService = ServiceInfo(id: WakuStoreCodec, data: @[]) + providedServices.add(storeService) + if storeServiceConf.storeSyncConf.isSome(): let confStoreSync = storeServiceConf.storeSyncConf.get() @@ -209,6 +212,11 @@ proc setupProtocols( ).isOkOr: return err("failed to mount waku store sync protocol: " & $error) + let reconciliationService = ServiceInfo(id: WakuReconciliationCodec, data: @[]) + let transferService = ServiceInfo(id: WakuTransferCodec, data: @[]) + providedServices.add(reconciliationService) + providedServices.add(transferService) + if conf.remoteStoreNode.isSome(): let storeNode = parsePeerInfo(conf.remoteStoreNode.get()).valueOr: return err("failed to set node waku store-sync peer: " & error) @@ -292,10 +300,16 @@ proc setupProtocols( protectedShard = shardKey.shard, publicKey = shardKey.key node.wakuRelay.addSignedShardsValidator(subscribedProtectedShards, conf.clusterId) + let relayService = ServiceInfo(id: WakuRelayCodec, data: @[]) + providedServices.add(relayService) + if conf.rendezvous: await node.mountRendezvous(conf.clusterId, shards) await node.mountRendezvousClient(conf.clusterId) + let rendezvousService = ServiceInfo(id: WakuRendezVousCodec, data: @[]) + providedServices.add(rendezvousService) + # Keepalive mounted on all nodes try: await mountLibp2pPing(node) @@ -332,6 +346,9 @@ proc setupProtocols( except CatchableError: return err("failed to mount waku lightpush protocol: " & getCurrentExceptionMsg()) + let lightpushService = ServiceInfo(id: WakuLightPushCodec, data: @[]) + providedServices.add(lightpushService) + mountLightPushClient(node) mountLegacyLightPushClient(node) if conf.remoteLightPushNode.isSome(): @@ -354,6 +371,9 @@ proc setupProtocols( except CatchableError: return err("failed to mount waku filter protocol: " & getCurrentExceptionMsg()) + let filterService = ServiceInfo(id: WakuFilterPushCodec, data: @[]) + providedServices.add(filterService) + await node.mountFilterClient() if conf.remoteFilterNode.isSome(): let filterNode = parsePeerInfo(conf.remoteFilterNode.get()).valueOr: @@ -374,6 +394,9 @@ proc setupProtocols( return err("failed to mount waku peer-exchange protocol: " & getCurrentExceptionMsg()) + let peerXchangeService = ServiceInfo(id: WakuPeerExchangeCodec, data: @[]) + providedServices.add(peerXchangeService) + if conf.remotePeerExchangeNode.isSome(): let peerExchangeNode = parsePeerInfo(conf.remotePeerExchangeNode.get()).valueOr: return err("failed to set node waku peer-exchange peer: " & error)