537 lines
97 KiB
Plaintext

2026-03-17 04:36:31.473 DEBUG [tests.conftest] Running fixture setup: test_id
2026-03-17 04:36:31.473 DEBUG [tests.conftest] Running test: test_start_node_with_50_pubsub_topics with id: 2026-03-17_04-36-31__a19a1a6e-c65c-421a-ad86-643dc5d72483
2026-03-17 04:36:31.474 DEBUG [src.steps.common] Running fixture setup: common_setup
2026-03-17 04:36:31.474 DEBUG [src.steps.relay] Running fixture setup: relay_setup
2026-03-17 04:36:31.474 DEBUG [src.steps.sharding] Running fixture setup: sharding_setup
2026-03-17 04:36:31.482 DEBUG [src.node.docker_mananger] Docker client initialized with image wakuorg/nwaku:latest
2026-03-17 04:36:31.482 DEBUG [src.node.waku_node] WakuNode instance initialized with log path ./log/docker/node1_2026-03-17_04-36-31__a19a1a6e-c65c-421a-ad86-643dc5d72483__wakuorg_nwaku:latest.log
2026-03-17 04:36:31.482 DEBUG [src.node.waku_node] Starting Node...
2026-03-17 04:36:31.482 DEBUG [src.node.docker_mananger] Attempting to create or retrieve network waku
2026-03-17 04:36:31.484 DEBUG [src.node.docker_mananger] Network waku already exists
2026-03-17 04:36:31.484 DEBUG [src.node.docker_mananger] Generated random external IP 172.18.51.115
2026-03-17 04:36:31.484 DEBUG [src.node.docker_mananger] Generated ports ['50668', '50669', '50670', '50671', '50672']
2026-03-17 04:36:31.484 DEBUG [src.node.waku_node] Cluster id was resolved to: 2
2026-03-17 04:36:31.484 DEBUG [src.node.waku_node] Removing pubsub-topic from nwaku args
2026-03-17 04:36:31.485 DEBUG [src.node.waku_node] RLN credentials were not set
2026-03-17 04:36:31.485 INFO [src.node.waku_node] RLN credentials not set or credential store not available, starting without RLN
2026-03-17 04:36:31.485 DEBUG [src.node.waku_node] Using volumes []
2026-03-17 04:36:31.485 DEBUG [src.node.docker_mananger] docker run -i -t -p 50668:50668 -p 50669:50669 -p 50670:50670 -p 50671:50671 -p 50672:50672 wakuorg/nwaku:latest --listen-address=0.0.0.0 --rest=true --rest-admin=true --websocket-support=true --log-level=TRACE --rest-relay-cache-capacity=100 --websocket-port=50670 --rest-port=50668 --tcp-port=50669 --discv5-udp-port=50671 --rest-address=0.0.0.0 --nat=extip:172.18.51.115 --peer-exchange=true --discv5-discovery=true --cluster-id=2 --nodekey=1c91aba2d21af1ed7feba08f6c9926e8cbdf898fdcaa9707a4f4e196f35c2be2 --shard=0 --metrics-server=true --metrics-server-address=0.0.0.0 --metrics-server-port=50672 --metrics-logging=true --relay=true --filter=true
2026-03-17 04:36:31.672 ERROR [src.node.docker_mananger] Max retries reached for container bc281584e7a6. Exiting log stream.
2026-03-17 04:36:31.693 DEBUG [src.node.docker_mananger] docker network connect --ip 172.18.51.115 waku bf42b4e7914ea11054161372e050e4ad0e96700e8b7c56b2862751d44e9c9100
2026-03-17 04:36:31.728 DEBUG [src.node.docker_mananger] Container started with ID bf42b4e7914e. Setting up logs at ./log/docker/node1_2026-03-17_04-36-31__a19a1a6e-c65c-421a-ad86-643dc5d72483__wakuorg_nwaku:latest.log
2026-03-17 04:36:31.729 DEBUG [src.node.waku_node] Started container from image wakuorg/nwaku:latest. REST: 50668
2026-03-17 04:36:31.729 DEBUG [src.libs.common] Sleeping for 1 seconds
2026-03-17 04:36:32.211 ERROR [src.node.docker_mananger] Max retries reached for container c1aa86432c36. Exiting log stream.
2026-03-17 04:36:32.732 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:32.743 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:32.843 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:32.846 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"READY","connectionStatus":"Connected","protocolsHealth":[{"Relay":"READY"},{"Lightpush":"NOT_MOUNTED"},{"Legacy Lightpush":"NOT_MOUNTED"},{"Filter":"READY"},{"Store":"NOT_MOUNTED"},{"Legacy Store":"NOT_MOUNTED"},{"Peer Exchange":"READY"},{"Rendezvous":"NOT_READY","desc":"No Rendezvous peers are available yet"},{"Mix":"NOT_MOUNTED"},{"Lightpush Client":"READY"},{"Legacy Lightpush Client":"READY"},{"Store Client":"READY"},{"Legacy Store Client":"NOT_READY","desc":"No Legacy Store service peers are available yet, neither Store service set up for the node"},{"Filter Client":"READY"},{"Rln Relay":"NOT_MOUNTED"}]}'
2026-03-17 04:36:32.847 INFO [src.node.waku_node] Node protocols are initialized !!
2026-03-17 04:36:32.847 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/debug/v1/info" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:32.850 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"listenAddresses":["/ip4/172.18.51.115/tcp/50669/p2p/16Uiu2HAmNN2Ry3pQhhHUqa1Y1PpCKTQVcDkvjSSk3dUTAN6MZgaW","/ip4/172.18.51.115/tcp/50670/ws/p2p/16Uiu2HAmNN2Ry3pQhhHUqa1Y1PpCKTQVcDkvjSSk3dUTAN6MZgaW"],"enrUri":"enr:-L24QCCMw_oj-_oJWzwhCWrMqu9_NSCpQ2AuGMSRjLQXtrqOfWUlg-L84NEBDcK6CPlI8i1AzR46NoAvl_b-0kmeKYwCgmlkgnY0gmlwhKwSM3OKbXVsdGlhZGRyc5YACASsEjNzBsXtAAoErBIzcwbF7t0DgnJzhQACAQAAiXNlY3AyNTZrMaEDkDxZHRGzyc7DNs1MY_aRFMKy5qjWk41k-tMb_-J1KDODdGNwgsXtg3VkcILF74V3YWt1MgU"}'
2026-03-17 04:36:32.850 INFO [src.node.waku_node] REST service is ready !!
2026-03-17 04:36:32.859 DEBUG [src.node.docker_mananger] Docker client initialized with image wakuorg/nwaku:latest
2026-03-17 04:36:32.859 DEBUG [src.node.waku_node] WakuNode instance initialized with log path ./log/docker/node2_2026-03-17_04-36-31__a19a1a6e-c65c-421a-ad86-643dc5d72483__wakuorg_nwaku:latest.log
2026-03-17 04:36:32.860 DEBUG [src.node.waku_node] Starting Node...
2026-03-17 04:36:32.860 DEBUG [src.node.docker_mananger] Attempting to create or retrieve network waku
2026-03-17 04:36:32.861 DEBUG [src.node.docker_mananger] Network waku already exists
2026-03-17 04:36:32.861 DEBUG [src.node.docker_mananger] Generated random external IP 172.18.40.91
2026-03-17 04:36:32.861 DEBUG [src.node.docker_mananger] Generated ports ['3161', '3162', '3163', '3164', '3165']
2026-03-17 04:36:32.862 DEBUG [src.node.waku_node] Cluster id was resolved to: 2
2026-03-17 04:36:32.862 DEBUG [src.node.waku_node] Removing pubsub-topic from nwaku args
2026-03-17 04:36:32.863 DEBUG [src.node.waku_node] RLN credentials were not set
2026-03-17 04:36:32.863 INFO [src.node.waku_node] RLN credentials not set or credential store not available, starting without RLN
2026-03-17 04:36:32.863 DEBUG [src.node.waku_node] Using volumes []
2026-03-17 04:36:32.864 DEBUG [src.node.docker_mananger] docker run -i -t -p 3161:3161 -p 3162:3162 -p 3163:3163 -p 3164:3164 -p 3165:3165 wakuorg/nwaku:latest --listen-address=0.0.0.0 --rest=true --rest-admin=true --websocket-support=true --log-level=TRACE --rest-relay-cache-capacity=100 --websocket-port=3163 --rest-port=3161 --tcp-port=3162 --discv5-udp-port=3164 --rest-address=0.0.0.0 --nat=extip:172.18.40.91 --peer-exchange=true --discv5-discovery=true --cluster-id=2 --nodekey=06aba2fc47caa124dfa3e5ab0c048aeaeac0aef46bcaccf20ba4ea67fb66e507 --shard=0 --metrics-server=true --metrics-server-address=0.0.0.0 --metrics-server-port=3165 --metrics-logging=true --relay=true --discv5-bootstrap-node=enr:-L24QCCMw_oj-_oJWzwhCWrMqu9_NSCpQ2AuGMSRjLQXtrqOfWUlg-L84NEBDcK6CPlI8i1AzR46NoAvl_b-0kmeKYwCgmlkgnY0gmlwhKwSM3OKbXVsdGlhZGRyc5YACASsEjNzBsXtAAoErBIzcwbF7t0DgnJzhQACAQAAiXNlY3AyNTZrMaEDkDxZHRGzyc7DNs1MY_aRFMKy5qjWk41k-tMb_-J1KDODdGNwgsXtg3VkcILF74V3YWt1MgU
2026-03-17 04:36:33.070 DEBUG [src.node.docker_mananger] docker network connect --ip 172.18.40.91 waku 0da35f1fe0ea4f0a5eec967c17c64cb843e27299da720efe59bd9ad2ed632199
2026-03-17 04:36:33.110 DEBUG [src.node.docker_mananger] Container started with ID 0da35f1fe0ea. Setting up logs at ./log/docker/node2_2026-03-17_04-36-31__a19a1a6e-c65c-421a-ad86-643dc5d72483__wakuorg_nwaku:latest.log
2026-03-17 04:36:33.110 DEBUG [src.node.waku_node] Started container from image wakuorg/nwaku:latest. REST: 3161
2026-03-17 04:36:33.110 DEBUG [src.libs.common] Sleeping for 1 seconds
2026-03-17 04:36:34.111 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.114 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:34.214 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.217 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:34.317 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.320 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:34.421 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.424 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:34.525 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.527 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:34.628 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.631 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:34.731 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.734 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:34.835 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.839 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"INITIALIZING","connectionStatus":"Disconnected","protocolsHealth":[]}'
2026-03-17 04:36:34.940 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/health" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.943 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"READY","connectionStatus":"Connected","protocolsHealth":[{"Relay":"READY"},{"Lightpush":"NOT_MOUNTED"},{"Legacy Lightpush":"NOT_MOUNTED"},{"Filter":"NOT_MOUNTED"},{"Store":"NOT_MOUNTED"},{"Legacy Store":"NOT_MOUNTED"},{"Peer Exchange":"READY"},{"Rendezvous":"NOT_READY","desc":"No Rendezvous peers are available yet"},{"Mix":"NOT_MOUNTED"},{"Lightpush Client":"READY"},{"Legacy Lightpush Client":"READY"},{"Store Client":"READY"},{"Legacy Store Client":"NOT_READY","desc":"No Legacy Store service peers are available yet, neither Store service set up for the node"},{"Filter Client":"READY"},{"Rln Relay":"NOT_MOUNTED"}]}'
2026-03-17 04:36:34.943 INFO [src.node.waku_node] Node protocols are initialized !!
2026-03-17 04:36:34.943 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/debug/v1/info" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:34.945 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"listenAddresses":["/ip4/172.18.40.91/tcp/3162/p2p/16Uiu2HAmHXTYnKPvAgckrNpC3PPLNfcRmdxkWFhuYPiw1tdmDUhd","/ip4/172.18.40.91/tcp/3163/ws/p2p/16Uiu2HAmHXTYnKPvAgckrNpC3PPLNfcRmdxkWFhuYPiw1tdmDUhd"],"enrUri":"enr:-L24QP-GEayE-wK84Pf_GBj3G7g1ZXGnPYPYJKHPcPCiPiZkFE-ZL4wPCkApl_PUTLfkr6Y3nGpUnPfBSGCbuKkL62MCgmlkgnY0gmlwhKwSKFuKbXVsdGlhZGRyc5YACASsEihbBgxaAAoErBIoWwYMW90DgnJzhQACAQAAiXNlY3AyNTZrMaEDSFyKi-OebjMW-XmSnJjDZkac3q-gB7Pg4_aq0zSYveCDdGNwggxag3VkcIIMXIV3YWt1MgE"}'
2026-03-17 04:36:34.946 INFO [src.node.waku_node] REST service is ready !!
2026-03-17 04:36:34.946 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:3161/admin/v1/peers" -H "Content-Type: application/json" -d '["/ip4/172.18.51.115/tcp/50669/p2p/16Uiu2HAmNN2Ry3pQhhHUqa1Y1PpCKTQVcDkvjSSk3dUTAN6MZgaW"]'
2026-03-17 04:36:34.973 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:34.973 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/subscriptions" -H "Content-Type: application/json" -d '["/waku/2/rs/2/0", "/waku/2/rs/2/1", "/waku/2/rs/2/2", "/waku/2/rs/2/3", "/waku/2/rs/2/4", "/waku/2/rs/2/5", "/waku/2/rs/2/6", "/waku/2/rs/2/7", "/waku/2/rs/2/8", "/waku/2/rs/2/9", "/waku/2/rs/2/10", "/waku/2/rs/2/11", "/waku/2/rs/2/12", "/waku/2/rs/2/13", "/waku/2/rs/2/14", "/waku/2/rs/2/15", "/waku/2/rs/2/16", "/waku/2/rs/2/17", "/waku/2/rs/2/18", "/waku/2/rs/2/19", "/waku/2/rs/2/20", "/waku/2/rs/2/21", "/waku/2/rs/2/22", "/waku/2/rs/2/23", "/waku/2/rs/2/24", "/waku/2/rs/2/25", "/waku/2/rs/2/26", "/waku/2/rs/2/27", "/waku/2/rs/2/28", "/waku/2/rs/2/29", "/waku/2/rs/2/30", "/waku/2/rs/2/31", "/waku/2/rs/2/32", "/waku/2/rs/2/33", "/waku/2/rs/2/34", "/waku/2/rs/2/35", "/waku/2/rs/2/36", "/waku/2/rs/2/37", "/waku/2/rs/2/38", "/waku/2/rs/2/39", "/waku/2/rs/2/40", "/waku/2/rs/2/41", "/waku/2/rs/2/42", "/waku/2/rs/2/43", "/waku/2/rs/2/44", "/waku/2/rs/2/45", "/waku/2/rs/2/46", "/waku/2/rs/2/47", "/waku/2/rs/2/48", "/waku/2/rs/2/49"]'
2026-03-17 04:36:35.135 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:35.137 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:3161/relay/v1/subscriptions" -H "Content-Type: application/json" -d '["/waku/2/rs/2/0", "/waku/2/rs/2/1", "/waku/2/rs/2/2", "/waku/2/rs/2/3", "/waku/2/rs/2/4", "/waku/2/rs/2/5", "/waku/2/rs/2/6", "/waku/2/rs/2/7", "/waku/2/rs/2/8", "/waku/2/rs/2/9", "/waku/2/rs/2/10", "/waku/2/rs/2/11", "/waku/2/rs/2/12", "/waku/2/rs/2/13", "/waku/2/rs/2/14", "/waku/2/rs/2/15", "/waku/2/rs/2/16", "/waku/2/rs/2/17", "/waku/2/rs/2/18", "/waku/2/rs/2/19", "/waku/2/rs/2/20", "/waku/2/rs/2/21", "/waku/2/rs/2/22", "/waku/2/rs/2/23", "/waku/2/rs/2/24", "/waku/2/rs/2/25", "/waku/2/rs/2/26", "/waku/2/rs/2/27", "/waku/2/rs/2/28", "/waku/2/rs/2/29", "/waku/2/rs/2/30", "/waku/2/rs/2/31", "/waku/2/rs/2/32", "/waku/2/rs/2/33", "/waku/2/rs/2/34", "/waku/2/rs/2/35", "/waku/2/rs/2/36", "/waku/2/rs/2/37", "/waku/2/rs/2/38", "/waku/2/rs/2/39", "/waku/2/rs/2/40", "/waku/2/rs/2/41", "/waku/2/rs/2/42", "/waku/2/rs/2/43", "/waku/2/rs/2/44", "/waku/2/rs/2/45", "/waku/2/rs/2/46", "/waku/2/rs/2/47", "/waku/2/rs/2/48", "/waku/2/rs/2/49"]'
2026-03-17 04:36:35.340 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:35.342 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F0" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:35.357 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:35.358 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:35.459 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.459 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F0" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.463 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195341670531,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.464 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.464 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F0" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.467 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195341670531,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.469 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F1" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:35.478 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:35.479 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:35.581 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.582 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F1" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.584 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195469514700,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.586 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.586 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F1" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.589 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195469514700,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.590 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F2" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:35.600 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:35.601 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:35.701 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.702 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F2" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.717 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195590787692,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.719 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.720 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F2" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.723 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195590787692,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.726 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F3" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:35.735 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:35.736 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:35.837 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.837 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F3" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.840 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195725953924,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.842 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.842 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F3" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.844 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195725953924,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.846 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F4" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:35.855 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:35.856 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:35.956 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.957 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F4" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.960 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195846328766,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.962 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:35.962 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F4" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:35.964 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195846328766,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:35.966 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F5" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:35.976 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:35.976 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:36.077 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.077 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F5" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.080 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195966394779,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.082 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.082 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F5" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.100 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722195966394779,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.103 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F6" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:36.115 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:36.115 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:36.216 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.216 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F6" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.220 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196103598280,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.221 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.221 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F6" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.224 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196103598280,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.225 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F7" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:36.235 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:36.236 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:36.337 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.337 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F7" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.340 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196225730878,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.342 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.342 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F7" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.344 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196225730878,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.346 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F8" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:36.351 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:36.352 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:36.452 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.453 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F8" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.456 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196346622896,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.457 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.457 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F8" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.460 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196346622896,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.463 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F9" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:36.469 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:36.469 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:36.569 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.570 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F9" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.573 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196463124207,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.574 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.575 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F9" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.577 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196463124207,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.579 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F10" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:36.585 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:36.585 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:36.686 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.686 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F10" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.689 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196579243957,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.691 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.691 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F10" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.693 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196579243957,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.695 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F11" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:36.700 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:36.701 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:36.801 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.802 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F11" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.805 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196695543562,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.807 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.807 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F11" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.809 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196695543562,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.811 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F12" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:36.816 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:36.818 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:36.918 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.919 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F12" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.922 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196811631375,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.923 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:36.924 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F12" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:36.926 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196811631375,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:36.928 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F13" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:36.933 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:36.933 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.034 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.034 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F13" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.037 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196928237602,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.039 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.039 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F13" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.042 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722196928237602,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.043 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F14" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.048 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.048 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.149 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.149 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F14" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.153 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197043575366,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.154 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.154 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F14" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.157 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197043575366,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.159 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F15" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.163 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.164 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.265 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.265 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F15" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.268 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197158864675,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.269 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.270 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F15" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.272 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197158864675,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.274 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F16" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.279 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.279 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.380 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.381 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F16" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.384 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197274060004,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.385 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.385 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F16" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.387 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197274060004,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.389 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F17" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.394 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.394 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.495 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.495 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F17" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.498 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197389527556,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.500 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.500 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F17" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.502 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197389527556,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.504 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F18" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.510 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.510 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.610 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.611 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F18" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.614 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197504476106,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.615 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.615 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F18" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.618 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197504476106,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.619 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F19" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.626 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.626 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.726 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.728 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F19" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.735 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197619750321,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.738 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.738 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F19" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.744 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197619750321,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.746 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F20" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.752 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.753 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.853 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.854 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F20" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.857 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197746087422,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.859 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.859 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F20" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.863 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197746087422,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.868 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F21" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.875 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.875 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:37.975 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.976 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F21" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.979 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197868305994,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.980 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:37.981 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F21" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:37.983 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197868305994,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:37.984 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F22" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:37.989 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:37.990 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:38.091 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.092 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F22" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.097 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197984801688,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.099 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.100 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F22" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.106 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722197984801688,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.109 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F23" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:38.123 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:38.124 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:38.224 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.225 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F23" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.228 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198109716622,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.229 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.229 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F23" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.232 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198109716622,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.234 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F24" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:38.239 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:38.240 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:38.341 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.341 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F24" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.344 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198233833856,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.345 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.346 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F24" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.348 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198233833856,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.350 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F25" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:38.356 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:38.356 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:38.456 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.457 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F25" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.460 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198350780822,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.461 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.462 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F25" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.464 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198350780822,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.466 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F26" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:38.472 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:38.472 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:38.573 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.573 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F26" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.577 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198466065996,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.578 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.578 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F26" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.581 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198466065996,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.582 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F27" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:38.587 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:38.588 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:38.688 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.689 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F27" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.692 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198582613359,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.693 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.694 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F27" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.696 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198582613359,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.698 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F28" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:38.703 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:38.705 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:38.805 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.806 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F28" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.808 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198698291798,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.810 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.810 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F28" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.813 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198698291798,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.814 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F29" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:38.820 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:38.820 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:38.920 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.921 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F29" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.923 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198814614073,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.925 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:38.925 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F29" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:38.928 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198814614073,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:38.929 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F30" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:38.934 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:38.935 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.035 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.036 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F30" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.039 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198929743285,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.041 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.041 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F30" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.044 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722198929743285,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.045 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F31" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.050 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.051 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.152 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.152 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F31" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.155 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199045708467,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.156 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.157 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F31" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.159 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199045708467,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.161 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F32" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.166 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.166 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.267 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.268 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F32" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.270 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199161256441,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.272 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.272 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F32" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.275 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199161256441,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.277 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F33" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.282 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.283 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.383 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.384 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F33" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.386 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199277510585,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.388 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.388 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F33" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.391 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199277510585,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.392 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F34" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.398 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.399 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.499 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.500 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F34" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.503 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199392699773,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.504 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.505 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F34" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.507 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199392699773,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.508 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F35" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.514 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.515 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.615 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.616 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F35" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.619 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199508829292,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.620 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.620 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F35" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.623 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199508829292,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.625 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F36" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.629 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.630 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.730 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.731 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F36" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.734 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199624952286,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.735 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.735 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F36" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.738 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199624952286,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.739 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F37" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.745 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.745 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.846 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.846 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F37" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.849 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199739628954,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.851 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.851 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F37" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.853 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199739628954,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.855 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F38" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.859 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.860 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:39.961 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.962 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F38" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.965 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199855220621,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.966 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:39.966 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F38" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:39.969 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199855220621,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:39.970 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F39" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:39.975 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:39.976 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:40.076 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.077 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F39" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.079 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199970784760,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.081 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.081 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F39" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.097 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722199970784760,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.099 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F40" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:40.104 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:40.105 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:40.206 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.206 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F40" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.209 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200099550401,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.211 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.211 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F40" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.213 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200099550401,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.216 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F41" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:40.220 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:40.221 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:40.321 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.322 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F41" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.325 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200216218250,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.326 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.326 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F41" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.329 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200216218250,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.330 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F42" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:40.335 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:40.336 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:40.437 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.437 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F42" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.440 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200330735038,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.441 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.442 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F42" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.444 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200330735038,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.446 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F43" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:40.452 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:40.452 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:40.553 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.553 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F43" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.556 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200446095265,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.557 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.558 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F43" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.560 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200446095265,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.562 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F44" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:40.569 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:40.570 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:40.670 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.671 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F44" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.673 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200562330643,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.675 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.675 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F44" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.677 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200562330643,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.679 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F45" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:40.684 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:40.685 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:40.785 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.785 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F45" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.788 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200679410876,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.790 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.790 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F45" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.792 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200679410876,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.794 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F46" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:40.799 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:40.799 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:40.900 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.901 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F46" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.904 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200793985047,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.905 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:40.905 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F46" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:40.908 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200793985047,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:40.909 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F47" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:40.914 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:40.915 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:41.015 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:41.016 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F47" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:41.018 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200909694972,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:41.020 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:41.020 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F47" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:41.023 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722200909694972,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:41.024 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F48" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:41.029 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:41.030 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:41.131 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:41.131 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F48" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:41.134 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722201024572647,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:41.136 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:41.136 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F48" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:41.138 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722201024572647,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:41.140 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F49" -H "Content-Type: application/json" -d '{"payload": "U2hhcmRpbmcgd29ya3MhIQ==", "contentTopic": "/myapp/1/latest/proto", "timestamp": '$(date +%s%N)'}'
2026-03-17 04:36:41.146 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2026-03-17 04:36:41.146 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2026-03-17 04:36:41.246 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:41.247 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:50668/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F49" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:41.250 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722201140516696,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:41.252 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2026-03-17 04:36:41.252 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:3161/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F49" -H "Content-Type: application/json" -d 'None'
2026-03-17 04:36:41.254 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1773722201140516696,"ephemeral":false,"proof":""}]'
2026-03-17 04:36:41.257 DEBUG [tests.conftest] Running fixture teardown: test_setup
2026-03-17 04:36:41.258 DEBUG [tests.conftest] Running fixture teardown: close_open_nodes
2026-03-17 04:36:41.258 DEBUG [src.node.waku_node] Stopping container with id bf42b4e7914e
2026-03-17 04:36:41.913 DEBUG [src.node.waku_node] Container stopped.
2026-03-17 04:36:41.913 DEBUG [src.node.waku_node] Stopping container with id 0da35f1fe0ea
2026-03-17 04:36:42.535 DEBUG [src.node.waku_node] Container stopped.
2026-03-17 04:36:42.536 DEBUG [tests.conftest] Running fixture teardown: check_waku_log_errors
2026-03-17 04:36:42.725 DEBUG [src.node.docker_mananger] No errors found in the waku logs.
2026-03-17 04:36:42.827 DEBUG [src.node.docker_mananger] No errors found in the waku logs.