logos-messaging/logos-messaging-interop-tests
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-interop-tests.git synced 2026-06-07 02:09:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Ignore S19

Browse Source
This commit is contained in:
Aya Hassan 2026-04-30 19:02:57 +02:00
parent 16bef0354b
commit 5d1614f93b
1 changed files with 5 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tests/wrappers_tests/test_send_e2e.py
View File

@ -194,26 +194,17 @@ class TestSendBeforeRelay(StepsStore):
f"Collected events: {sender_collector.events}" f"Collected events: {sender_collector.events}"
) )
@pytest.mark.ignore("scenario might be not possible to simulate")
def test_s19_store_peer_appears_after_propagation(self, node_config): def test_s19_store_peer_appears_after_propagation(self, node_config):
""" """
S19: a store peer comes online later. S19: a store peer comes online later.
question for Zoltan , is reliability = true mandatory for the store peer ?
what is the effect of the reliability here ?
- send() returns Ok(RequestId) immediately - send() returns Ok(RequestId) immediately
- Propagated --- relay peer - Propagated --- relay peer
- Sent when store peer is reachable - Sent when store peer is reachable
""" """
sender_collector = EventCollector() sender_collector = EventCollector()
node_config.update( node_config.update({"relay": True, "store": False, "discv5Discovery": False, "numShardsInNetwork": 1, "reliabilityEnabled": True})
{
"relay": True,
"store": False,
"discv5Discovery": False,
"numShardsInNetwork": 1,
# "p2preliability": True,
}
)
sender_result = WrapperManager.create_and_start( sender_result = WrapperManager.create_and_start(
config=node_config, config=node_config,
@ -228,7 +219,7 @@ class TestSendBeforeRelay(StepsStore):
"staticnodes": [get_node_multiaddr(sender_node)], "staticnodes": [get_node_multiaddr(sender_node)],
"portsshift": 1, "portsshift": 1,
"store": False, "store": False,
# "p2preliability": False, # commented as the option not supported "reliabilityEnabled": True,
} }
relay_result = WrapperManager.create_and_start(config=relay_config) relay_result = WrapperManager.create_and_start(config=relay_config)
@ -262,11 +253,12 @@ class TestSendBeforeRelay(StepsStore):
# Store peer # Store peer
store_node = WakuNode(NODE_2, f"store_node") store_node = WakuNode(NODE_2, f"store_node")
store_node.start(relay="true", store="true", discv5_discovery="false") store_node.start(relay="true", store="true", discv5_discovery="false", cluster_id=node_config["clusterId"], shard=0)
store_node.set_relay_subscriptions([self.test_pubsub_topic]) store_node.set_relay_subscriptions([self.test_pubsub_topic])
relay_multiaddr = get_node_multiaddr(relay_peer) relay_multiaddr = get_node_multiaddr(relay_peer)
sender_multiaddr = get_node_multiaddr(sender_node) sender_multiaddr = get_node_multiaddr(sender_node)
store_node.add_peers([relay_multiaddr, sender_multiaddr]) store_node.add_peers([relay_multiaddr, sender_multiaddr])
self.wait_for_autoconnection([store_node], hard_wait=10)
delay(3) delay(3)
sent_event = wait_for_sent( sent_event = wait_for_sent(