2025-12-10 04:11:42.644 DEBUG [tests.conftest] Running fixture setup: test_id
2025-12-10 04:11:42.644 DEBUG [tests.conftest] Running test: test_resubscribe_to_unsubscribed_pubsub_topics with id: 2025-12-10_04-11-42__b422b73e-72e2-4834-9539-2643c884961a
2025-12-10 04:11:42.645 DEBUG [src.steps.common] Running fixture setup: common_setup
2025-12-10 04:11:42.645 DEBUG [src.steps.relay] Running fixture setup: relay_setup
2025-12-10 04:11:42.645 DEBUG [src.steps.sharding] Running fixture setup: sharding_setup
2025-12-10 04:11:42.652 DEBUG [src.node.docker_mananger] Docker client initialized with image wakuorg/nwaku:latest
2025-12-10 04:11:42.652 DEBUG [src.node.waku_node] WakuNode instance initialized with log path ./log/docker/node1_2025-12-10_04-11-42__b422b73e-72e2-4834-9539-2643c884961a__wakuorg_nwaku:latest.log
2025-12-10 04:11:42.652 DEBUG [src.node.waku_node] Starting Node...
2025-12-10 04:11:42.652 DEBUG [src.node.docker_mananger] Attempting to create or retrieve network waku
2025-12-10 04:11:42.654 DEBUG [src.node.docker_mananger] Network waku already exists
2025-12-10 04:11:42.654 DEBUG [src.node.docker_mananger] Generated random external IP 172.18.136.104
2025-12-10 04:11:42.654 DEBUG [src.node.docker_mananger] Generated ports ['62482', '62483', '62484', '62485', '62486']
2025-12-10 04:11:42.655 DEBUG [src.node.waku_node] Removing pubsub-topic from nwaku args
2025-12-10 04:11:42.655 DEBUG [src.node.waku_node] RLN credentials were not set
2025-12-10 04:11:42.655 INFO [src.node.waku_node] RLN credentials not set or credential store not available, starting without RLN
2025-12-10 04:11:42.655 DEBUG [src.node.waku_node] Using volumes []
2025-12-10 04:11:42.655 DEBUG [src.node.docker_mananger] docker run -i -t -p 62482:62482 -p 62483:62483 -p 62484:62484 -p 62485:62485 -p 62486:62486 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=62484 --rest-port=62482 --tcp-port=62483 --discv5-udp-port=62485 --rest-address=0.0.0.0 --nat=extip:172.18.136.104 --peer-exchange=true --discv5-discovery=true --cluster-id=2 --nodekey=735aacd11c5c48c46f4459fc9fef97ace8fed1edb7163dffd43cacccd1418ccd --shard=0 --metrics-server=true --metrics-server-address=0.0.0.0 --metrics-server-port=62486 --metrics-logging=true --relay=true --filter=true
2025-12-10 04:11:42.845 DEBUG [src.node.docker_mananger] docker network connect --ip 172.18.136.104 waku e3cd5c9374ec808005efdfa28638f02183a4ca0179ea1243b3a6510c5f151549
2025-12-10 04:11:42.877 DEBUG [src.node.docker_mananger] Container started with ID e3cd5c9374ec. Setting up logs at ./log/docker/node1_2025-12-10_04-11-42__b422b73e-72e2-4834-9539-2643c884961a__wakuorg_nwaku:latest.log
2025-12-10 04:11:42.877 DEBUG [src.node.waku_node] Started container from image wakuorg/nwaku:latest. REST: 62482
2025-12-10 04:11:42.878 DEBUG [src.libs.common] Sleeping for 1 seconds
2025-12-10 04:11:43.450 ERROR [src.node.docker_mananger] Max retries reached for container 3a9037cca8db. Exiting log stream.
2025-12-10 04:11:43.880 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/health" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:43.883 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"READY","protocolsHealth":[{"Relay":"NOT_READY","desc":"No connected peers"},{"Rln Relay":"NOT_MOUNTED"},{"Lightpush":"NOT_MOUNTED"},{"Legacy Lightpush":"NOT_MOUNTED"},{"Filter":"NOT_READY","desc":"Relay is not ready, filter will not be able to sort out messages"},{"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":"NOT_READY","desc":"No Lightpush service peer available yet"},{"Legacy Lightpush Client":"NOT_READY","desc":"No Lightpush service peer available yet"},{"Store Client":"NOT_READY","desc":"No Store service peer available yet, neither Store service set up for the node"},{"Legacy Store Client":"NOT_READY","desc":"No Legacy Store service peers are available yet, neither Store service set up for the node"},{"Filter Client":"NOT_READY","desc":"No Filter service peer available yet"}]}'
2025-12-10 04:11:43.883 INFO [src.node.waku_node] Node protocols are initialized !!
2025-12-10 04:11:43.883 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/debug/v1/info" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:43.886 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"listenAddresses":["/ip4/172.18.136.104/tcp/62483/p2p/16Uiu2HAmSaBdw2W63UryXwiR61JnBarScv7cy5nUMqx6GJySyAUK","/ip4/172.18.136.104/tcp/62484/ws/p2p/16Uiu2HAmSaBdw2W63UryXwiR61JnBarScv7cy5nUMqx6GJySyAUK"],"enrUri":"enr:-L24QKDAOu05npWYaFOuRPfC-FKgAQwdjKetO8K1x0F0CANKKFwLvQepBN9TZpor5LahRIpscrN5Fmy2p8JBKd4ErcECgmlkgnY0gmlwhKwSiGiKbXVsdGlhZGRyc5YACASsEohoBvQTAAoErBKIaAb0FN0DgnJzhQACAQAAiXNlY3AyNTZrMaEDzsh5oIGEz7tYtmTLzwZatsB6ZJsxWRxY80IcMlZbaYSDdGNwgvQTg3VkcIL0FYV3YWt1MgU"}'
2025-12-10 04:11:43.886 INFO [src.node.waku_node] REST service is ready !!
2025-12-10 04:11:43.892 DEBUG [src.node.docker_mananger] Docker client initialized with image wakuorg/nwaku:latest
2025-12-10 04:11:43.893 DEBUG [src.node.waku_node] WakuNode instance initialized with log path ./log/docker/node2_2025-12-10_04-11-42__b422b73e-72e2-4834-9539-2643c884961a__wakuorg_nwaku:latest.log
2025-12-10 04:11:43.893 DEBUG [src.node.waku_node] Starting Node...
2025-12-10 04:11:43.893 DEBUG [src.node.docker_mananger] Attempting to create or retrieve network waku
2025-12-10 04:11:43.894 DEBUG [src.node.docker_mananger] Network waku already exists
2025-12-10 04:11:43.894 DEBUG [src.node.docker_mananger] Generated random external IP 172.18.33.187
2025-12-10 04:11:43.894 DEBUG [src.node.docker_mananger] Generated ports ['31234', '31235', '31236', '31237', '31238']
2025-12-10 04:11:43.895 DEBUG [src.node.waku_node] Removing pubsub-topic from nwaku args
2025-12-10 04:11:43.895 DEBUG [src.node.waku_node] RLN credentials were not set
2025-12-10 04:11:43.895 INFO [src.node.waku_node] RLN credentials not set or credential store not available, starting without RLN
2025-12-10 04:11:43.895 DEBUG [src.node.waku_node] Using volumes []
2025-12-10 04:11:43.895 DEBUG [src.node.docker_mananger] docker run -i -t -p 31234:31234 -p 31235:31235 -p 31236:31236 -p 31237:31237 -p 31238:31238 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=31236 --rest-port=31234 --tcp-port=31235 --discv5-udp-port=31237 --rest-address=0.0.0.0 --nat=extip:172.18.33.187 --peer-exchange=true --discv5-discovery=true --cluster-id=2 --nodekey=53bceffbce00baf3297f8fbb2e9ceedf1e4f5220b2661b6dadc4ba6c01ce3ceb --shard=0 --metrics-server=true --metrics-server-address=0.0.0.0 --metrics-server-port=31238 --metrics-logging=true --relay=true --discv5-bootstrap-node=enr:-L24QKDAOu05npWYaFOuRPfC-FKgAQwdjKetO8K1x0F0CANKKFwLvQepBN9TZpor5LahRIpscrN5Fmy2p8JBKd4ErcECgmlkgnY0gmlwhKwSiGiKbXVsdGlhZGRyc5YACASsEohoBvQTAAoErBKIaAb0FN0DgnJzhQACAQAAiXNlY3AyNTZrMaEDzsh5oIGEz7tYtmTLzwZatsB6ZJsxWRxY80IcMlZbaYSDdGNwgvQTg3VkcIL0FYV3YWt1MgU
2025-12-10 04:11:44.081 DEBUG [src.node.docker_mananger] docker network connect --ip 172.18.33.187 waku 7dd18ea794f5b23a8534a7143be4a5458d7367d3fab79b4bd26bd832462fe8a9
2025-12-10 04:11:44.110 DEBUG [src.node.docker_mananger] Container started with ID 7dd18ea794f5. Setting up logs at ./log/docker/node2_2025-12-10_04-11-42__b422b73e-72e2-4834-9539-2643c884961a__wakuorg_nwaku:latest.log
2025-12-10 04:11:44.111 DEBUG [src.node.waku_node] Started container from image wakuorg/nwaku:latest. REST: 31234
2025-12-10 04:11:44.111 DEBUG [src.libs.common] Sleeping for 1 seconds
2025-12-10 04:11:45.111 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/health" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.122 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"nodeHealth":"READY","protocolsHealth":[{"Relay":"NOT_READY","desc":"No connected peers"},{"Rln Relay":"NOT_MOUNTED"},{"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":"NOT_READY","desc":"No Lightpush service peer available yet"},{"Legacy Lightpush Client":"NOT_READY","desc":"No Lightpush service peer available yet"},{"Store Client":"NOT_READY","desc":"No Store service peer available yet, neither Store service set up for the node"},{"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"}]}'
2025-12-10 04:11:45.123 INFO [src.node.waku_node] Node protocols are initialized !!
2025-12-10 04:11:45.124 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/debug/v1/info" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.127 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'{"listenAddresses":["/ip4/172.18.33.187/tcp/31235/p2p/16Uiu2HAmQ9C97NqRB8q7vj9cw1mYcXNW2Mb9GSxn43pCqM4YJDKa","/ip4/172.18.33.187/tcp/31236/ws/p2p/16Uiu2HAmQ9C97NqRB8q7vj9cw1mYcXNW2Mb9GSxn43pCqM4YJDKa"],"enrUri":"enr:-L24QJHJ9oCEoX3z5sHlVhkMlUstSRj5_j5pUQPCKuLvxjYyQET39wJDWZa5DICoF01JjSW1c0pBnglsfvPKCrBKMKECgmlkgnY0gmlwhKwSIbuKbXVsdGlhZGRyc5YACASsEiG7BnoDAAoErBIhuwZ6BN0DgnJzhQACAQAAiXNlY3AyNTZrMaEDqqomXQDiN9hW-ATtJuMC9IjBtfOOWIQoX1erHkZhyl2DdGNwgnoDg3VkcIJ6BYV3YWt1MgE"}'
2025-12-10 04:11:45.129 INFO [src.node.waku_node] REST service is ready !!
2025-12-10 04:11:45.129 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:31234/admin/v1/peers" -H "Content-Type: application/json" -d '["/ip4/172.18.136.104/tcp/62483/p2p/16Uiu2HAmSaBdw2W63UryXwiR61JnBarScv7cy5nUMqx6GJySyAUK"]'
2025-12-10 04:11:45.132 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.133 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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"]'
2025-12-10 04:11:45.141 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.141 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:31234/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"]'
2025-12-10 04:11:45.152 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.153 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:45.165 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.166 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:45.266 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.267 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F0" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.269 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905153429645,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.271 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.271 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F0" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.273 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905153429645,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.275 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:45.280 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.280 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:45.380 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.381 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F1" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.383 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905275330957,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.384 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.385 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F1" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.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":1765339905275330957,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.388 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:45.393 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.393 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:45.493 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.494 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F2" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.496 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905388767656,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.497 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.498 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F2" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.500 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905388767656,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.501 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:45.505 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.505 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:45.606 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.606 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F3" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.609 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905501458940,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.610 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.610 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F3" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.612 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905501458940,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.615 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:45.619 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.619 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:45.719 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.720 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F4" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.722 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905615243832,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.723 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.724 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F4" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.726 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905615243832,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.727 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:45.732 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.732 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:45.832 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.833 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F5" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.835 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905727671064,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.836 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.836 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F5" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.838 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905727671064,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.840 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:45.844 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.845 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:45.945 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.945 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F6" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.948 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905840360685,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.950 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:45.950 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F6" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:45.952 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905840360685,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:45.954 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:45.958 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:45.959 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:46.059 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.059 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F7" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.062 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905953987156,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.063 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.063 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F7" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.065 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339905953987156,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.067 INFO [src.node.api_clients.base_client] curl -v -X DELETE "http://127.0.0.1:62482/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"]'
2025-12-10 04:11:46.080 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.081 INFO [src.node.api_clients.base_client] curl -v -X DELETE "http://127.0.0.1:31234/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"]'
2025-12-10 04:11:46.095 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.096 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.101 ERROR [src.node.api_clients.base_client] HTTP error occurred: 400 Client Error: Bad Request for url: http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F0. Response content: b'Failed to publish: Node not subscribed to topic: /waku/2/rs/2/0'
2025-12-10 04:11:46.105 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.107 ERROR [src.node.api_clients.base_client] HTTP error occurred: 400 Client Error: Bad Request for url: http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F1. Response content: b'Failed to publish: Node not subscribed to topic: /waku/2/rs/2/1'
2025-12-10 04:11:46.109 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.111 ERROR [src.node.api_clients.base_client] HTTP error occurred: 400 Client Error: Bad Request for url: http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F2. Response content: b'Failed to publish: Node not subscribed to topic: /waku/2/rs/2/2'
2025-12-10 04:11:46.113 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.115 ERROR [src.node.api_clients.base_client] HTTP error occurred: 400 Client Error: Bad Request for url: http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F3. Response content: b'Failed to publish: Node not subscribed to topic: /waku/2/rs/2/3'
2025-12-10 04:11:46.116 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.118 ERROR [src.node.api_clients.base_client] HTTP error occurred: 400 Client Error: Bad Request for url: http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F4. Response content: b'Failed to publish: Node not subscribed to topic: /waku/2/rs/2/4'
2025-12-10 04:11:46.120 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.122 ERROR [src.node.api_clients.base_client] HTTP error occurred: 400 Client Error: Bad Request for url: http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F5. Response content: b'Failed to publish: Node not subscribed to topic: /waku/2/rs/2/5'
2025-12-10 04:11:46.123 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.125 ERROR [src.node.api_clients.base_client] HTTP error occurred: 400 Client Error: Bad Request for url: http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F6. Response content: b'Failed to publish: Node not subscribed to topic: /waku/2/rs/2/6'
2025-12-10 04:11:46.127 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.129 ERROR [src.node.api_clients.base_client] HTTP error occurred: 400 Client Error: Bad Request for url: http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F7. Response content: b'Failed to publish: Node not subscribed to topic: /waku/2/rs/2/7'
2025-12-10 04:11:46.130 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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"]'
2025-12-10 04:11:46.138 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.138 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:31234/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"]'
2025-12-10 04:11:46.149 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.150 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.155 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.155 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:46.255 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.256 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F0" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.258 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906150397248,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.259 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.260 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F0" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.262 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906150397248,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.263 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.268 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.268 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:46.369 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.369 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F1" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.371 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906263730245,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.372 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.373 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F1" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.375 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906263730245,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.376 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.381 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.381 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:46.481 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.482 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F2" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.484 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906376793634,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.485 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.485 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F2" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.487 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906376793634,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.489 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.493 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.493 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:46.594 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.594 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F3" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.596 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906489323972,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.598 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.598 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F3" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.600 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906489323972,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.602 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.606 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.607 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:46.707 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.707 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F4" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.710 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906602412823,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.711 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.711 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F4" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.713 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906602412823,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.715 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.720 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.720 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:46.820 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.820 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F5" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.823 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906715277666,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.824 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.824 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F5" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.826 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906715277666,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.828 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.832 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.833 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:46.933 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.933 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F6" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.936 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906828380930,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.937 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:46.937 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F6" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:46.939 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906828380930,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:46.941 INFO [src.node.api_clients.base_client] curl -v -X POST "http://127.0.0.1:62482/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)'}'
2025-12-10 04:11:46.945 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'OK'
2025-12-10 04:11:46.945 DEBUG [src.libs.common] Sleeping for 0.1 seconds
2025-12-10 04:11:47.045 DEBUG [src.steps.sharding] Checking that peer NODE_1:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:47.046 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:62482/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F7" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:47.048 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906941137765,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:47.049 DEBUG [src.steps.sharding] Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
2025-12-10 04:11:47.050 INFO [src.node.api_clients.base_client] curl -v -X GET "http://127.0.0.1:31234/relay/v1/messages/%2Fwaku%2F2%2Frs%2F2%2F7" -H "Content-Type: application/json" -d 'None'
2025-12-10 04:11:47.052 INFO [src.node.api_clients.base_client] Response status code: 200. Response content: b'[{"payload":"U2hhcmRpbmcgd29ya3MhIQ==","contentTopic":"/myapp/1/latest/proto","version":0,"timestamp":1765339906941137765,"ephemeral":false,"proof":""}]'
2025-12-10 04:11:47.054 DEBUG [tests.conftest] Running fixture teardown: test_setup
2025-12-10 04:11:47.055 DEBUG [tests.conftest] Running fixture teardown: close_open_nodes
2025-12-10 04:11:47.055 DEBUG [src.node.waku_node] Stopping container with id e3cd5c9374ec
2025-12-10 04:11:47.618 DEBUG [src.node.waku_node] Container stopped.
2025-12-10 04:11:47.620 DEBUG [src.node.waku_node] Stopping container with id 7dd18ea794f5
2025-12-10 04:11:48.146 DEBUG [src.node.waku_node] Container stopped.
2025-12-10 04:11:48.148 DEBUG [tests.conftest] Running fixture teardown: check_waku_log_errors
2025-12-10 04:11:48.175 DEBUG [src.node.docker_mananger] No errors found in the waku logs.
2025-12-10 04:11:48.189 DEBUG [src.node.docker_mananger] No errors found in the waku logs.