logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-04-15 04:33:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

add service for all protos

Browse Source
This commit is contained in:
SionoiS 2026-03-23 08:44:53 -04:00
parent e1ec7ba57a
commit a856ebc22a
No known key found for this signature in database
GPG Key ID: C9458A8CB1852951
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
waku/factory/node_factory.nim
View File

@ -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)