logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-02-27 21:53:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Disable event listener code for edge (not supported yet) to try to fix CI

Browse Source
This commit is contained in:
Fabiana Cecin 2026-02-25 08:12:46 -03:00
parent fd6370f3fa
commit d3293dc404
No known key found for this signature in database
GPG Key ID: BCAB8A55CB51B6C7
2 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
waku/node/delivery_service/recv_service/recv_service.nim
View File

@ -159,7 +159,8 @@ proc new*(T: typedesc[RecvService], node: WakuNode, s: SubscriptionService): T =
pubsubTopic: PubsubTopic, message: WakuMessage
) {.async, closure.} =
## Captures all the messages received through filter
recvService.processIncomingMessageOfInterest(pubSubTopic, message)
# TODO: re-enable for MAPI edge support.
#recvService.processIncomingMessageOfInterest(pubSubTopic, message)
node.wakuFilterClient.registerPushHandler(filterPushHandler)

14
waku/node/delivery_service/subscription_service.nim
View File

@ -85,13 +85,17 @@ proc stopProvidersAndListeners*(self: SubscriptionService) =
OnFilterUnsubscribeEvent.dropListener(self.node.brokerCtx, self.filterUnsubListener)
proc start*(self: SubscriptionService) =
self.startProvidersAndListeners().isOkOr:
error "Fatal error in SubscriptionService.startProvidersAndListeners(): ",
error = error
raise newException(ValueError, "SubscriptionService.start() failed: " & error)
# TODO: re-enable for MAPI edge support.
#self.startProvidersAndListeners().isOkOr:
# error "Fatal error in SubscriptionService.startProvidersAndListeners(): ",
# error = error
# raise newException(ValueError, "SubscriptionService.start() failed: " & error)
discard
proc stop*(self: SubscriptionService) =
self.stopProvidersAndListeners()
# TODO: re-enable for MAPI edge support.
#self.stopProvidersAndListeners()
discard
proc getActiveSubscriptions*(
self: SubscriptionService