AtHeartEngineer/status-benchmarks
1
0
Fork 0
mirror of https://github.com/vacp2p/status-benchmarks.git synced 2026-01-08 15:13:59 -05:00
Code Issues Packages Projects Releases Wiki Activity

Add isolated_traffic_request_to_join (#19)

Browse Source
This commit is contained in:
Alberto Soutullo
2025-09-26 16:12:14 +02:00
committed by GitHub
parent 47a4665b87
commit c8c474294c
1 changed files with 25 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/benchmark_scenarios/communities.py
View File

@@ -246,3 +246,28 @@ async def isolated_traffic_chat_messages_2():
logger.info("Shutting down node connections") logger.info("Shutting down node connections")
await asyncio.gather(*[node.shutdown() for node in relay_nodes.values()]) await asyncio.gather(*[node.shutdown() for node in relay_nodes.values()])
logger.info("Finished store_performance") logger.info("Finished store_performance")
async def isolated_traffic_request_to_join():
# 1 community owner
# 500 user nodes
# 250 in community
# Measure non-joined nodes have minimal traffic not correlated to community request traffic
kube_utils.setup_kubernetes_client()
backend_relay_pods = kube_utils.get_pods("status-backend-relay", "status-go-test")
relay_nodes = await setup_status.initialize_nodes_application(backend_relay_pods)
name = f"test_community_{''.join(random.choices(string.ascii_letters, k=10))}"
logger.info(f"Creating community {name}")
response = await relay_nodes["status-backend-relay-0"].wakuext_service.create_community(name)
community_id = response.get("result", {}).get("communities", [{}])[0].get("id")
logger.info(f"Community {name} created with ID {community_id}")
owner = relay_nodes["status-backend-relay-0"]
nodes = [key for key in relay_nodes.keys() if key != "status-backend-relay-0"]
nodes_250 = nodes[:250]
join_ids = await request_join_nodes_to_community(relay_nodes, nodes_250, community_id)
chat_id = await accept_community_requests(owner, join_ids)
logger.info("Shutting down node connections")
await asyncio.gather(*[node.shutdown() for node in relay_nodes.values()])
logger.info("Finished store_performance")