From 1ad877fc23428328447fb826f4dd329fed5a7f3c Mon Sep 17 00:00:00 2001 From: Fabiana Cecin Date: Fri, 29 May 2026 17:45:31 -0300 Subject: [PATCH] Restore libwaku kernel_api semantics for interop tests --- waku/node/kernel_api/relay.nim | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/waku/node/kernel_api/relay.nim b/waku/node/kernel_api/relay.nim index ef2c999ce..30fc22ec3 100644 --- a/waku/node/kernel_api/relay.nim +++ b/waku/node/kernel_api/relay.nim @@ -71,13 +71,14 @@ proc subscribe*( error "Invalid API call to `subscribe`. WakuRelay not mounted." return err("Invalid API call to `subscribe`. WakuRelay not mounted.") - let (pubsubTopic, contentTopicOp) = getTopicOfSubscriptionEvent(node, subscription).valueOr: + let (pubsubTopic, _) = getTopicOfSubscriptionEvent(node, subscription).valueOr: error "Failed to decode subscription event", error = error return err("Failed to decode subscription event: " & error) - if contentTopicOp.isSome(): - return - node.subscriptionManager.subscribe(pubsubTopic, contentTopicOp.get(), handler) + # strict version + #if contentTopicOp.isSome(): + # return + # node.subscriptionManager.subscribe(pubsubTopic, contentTopicOp.get(), handler) return node.subscriptionManager.subscribeShard(pubsubTopic, handler) proc unsubscribe*( @@ -91,12 +92,13 @@ proc unsubscribe*( error "Invalid API call to `unsubscribe`. WakuRelay not mounted." return err("Invalid API call to `unsubscribe`. WakuRelay not mounted.") - let (pubsubTopic, contentTopicOp) = getTopicOfSubscriptionEvent(node, subscription).valueOr: + let (pubsubTopic, _) = getTopicOfSubscriptionEvent(node, subscription).valueOr: error "Failed to decode unsubscribe event", error = error return err("Failed to decode unsubscribe event: " & error) - if contentTopicOp.isSome(): - return node.subscriptionManager.unsubscribe(pubsubTopic, contentTopicOp.get()) + # strict version + #if contentTopicOp.isSome(): + # return node.subscriptionManager.unsubscribe(pubsubTopic, contentTopicOp.get()) return node.subscriptionManager.unsubscribeAll(pubsubTopic) proc isSubscribed*(