mirror of
https://github.com/logos-messaging/logos-messaging-interop-tests.git
synced 2026-05-25 19:59:26 +00:00
116 lines
21 KiB
Plaintext
116 lines
21 KiB
Plaintext
[35mDEBUG [0m tests.conftest:conftest.py:51 Running fixture setup: test_id
|
||
[35mDEBUG [0m tests.conftest:conftest.py:57 Running test: test_filter_subscribe_to_multiple_pubsub_topic_from_same_cluster with id: 2026-04-23_22-00-22__f4844139-5f69-443d-8b85-3ee4f9b3b0e4
|
||
[35mDEBUG [0m src.steps.common:common.py:19 Running fixture setup: common_setup
|
||
[35mDEBUG [0m src.steps.filter:filter.py:28 Running fixture setup: filter_setup
|
||
[35mDEBUG [0m src.steps.filter:filter.py:34 Running fixture setup: setup_main_relay_node
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:19 Docker client initialized with image wakuorg/nwaku:latest
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:86 WakuNode instance initialized with log path ./log/docker/node1_2026-04-23_22-00-22__f4844139-5f69-443d-8b85-3ee4f9b3b0e4__wakuorg_nwaku:latest.log
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:90 Starting Node...
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:22 Attempting to create or retrieve network waku
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:25 Network waku already exists
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:108 Generated random external IP 172.18.54.30
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:101 Generated ports ['29654', '29655', '29656', '29657', '29658']
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:455 RLN credentials were not set
|
||
[32mINFO [0m src.node.waku_node:waku_node.py:180 RLN credentials not set or credential store not available, starting without RLN
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:186 Using volumes []
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:49 docker run -i -t -p 29654:29654 -p 29655:29655 -p 29656:29656 -p 29657:29657 -p 29658:29658 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=29656 --rest-port=29654 --tcp-port=29655 --discv5-udp-port=29657 --rest-address=0.0.0.0 --nat=extip:172.18.54.30 --peer-exchange=true --discv5-discovery=true --cluster-id=198 --nodekey=b7af194ebd40168eef38e04f1bf257463ca2186c388bdeac9edfccbbfdcfedfc --shard=0 --metrics-server=true --metrics-server-address=0.0.0.0 --metrics-server-port=29658 --metrics-logging=true --relay=true --filter=true
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:55 docker network connect --ip 172.18.54.30 waku 5a7b2322c78108853be46491fcec87eece968de67b6e8eb5f3b45504dfd977c6
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:58 Container started with ID 5a7b2322c781. Setting up logs at ./log/docker/node1_2026-04-23_22-00-22__f4844139-5f69-443d-8b85-3ee4f9b3b0e4__wakuorg_nwaku:latest.log
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:197 Started container from image wakuorg/nwaku:latest. REST: 29654
|
||
[35mDEBUG [0m src.libs.common:common.py:47 Sleeping for 1 seconds
|
||
[31m[1mERROR [0m src.node.docker_mananger:docker_mananger.py:89 Max retries reached for container 5b4895cd81b9. Exiting log stream.
|
||
[31m[1mERROR [0m src.node.docker_mananger:docker_mananger.py:89 Max retries reached for container 50aaa84d94ab. Exiting log stream.
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:29654/health" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"nodeHealth":"READY","connectionStatus":"Disconnected","protocolsHealth":[{"Relay":"NOT_READY","desc":"No connected peers"},{"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"},{"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"},{"Filter Client":"NOT_READY","desc":"No Filter service peer available yet"},{"Rln Relay":"NOT_MOUNTED"}]}'
|
||
[32mINFO [0m src.node.waku_node:waku_node.py:294 Node protocols are initialized !!
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:29654/debug/v1/info" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"listenAddresses":["/ip4/172.18.54.30/tcp/29655/p2p/16Uiu2HAmRcNK3amwzw3NHuFraDQTPyGPZPYYASftNYoEV7nNzfRN","/ip4/172.18.54.30/tcp/29656/ws/p2p/16Uiu2HAmRcNK3amwzw3NHuFraDQTPyGPZPYYASftNYoEV7nNzfRN"],"enrUri":"enr:-L24QFggbMwPFswdk4cz30ji5M4iWsaH6PrTWo9gCX8HL49wR8e2H333iHaPAJqLh6-u6Tn7IFl74v6qiT5Ik-Pr6f0CgmlkgnY0gmlwhKwSNh6KbXVsdGlhZGRyc5YACASsEjYeBnPXAAoErBI2HgZz2N0DgnJzhQDGAQAAiXNlY3AyNTZrMaEDwHwE81An_TXzduCqRD2YpIUdhc1wJK0zp0KqIfN2w7WDdGNwgnPXg3VkcIJz2YV3YWt1MgU"}'
|
||
[32mINFO [0m src.node.waku_node:waku_node.py:299 REST service is ready !!
|
||
[35mDEBUG [0m src.steps.filter:filter.py:39 Running fixture setup: setup_main_filter_node
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:19 Docker client initialized with image wakuorg/nwaku:latest
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:86 WakuNode instance initialized with log path ./log/docker/node2_2026-04-23_22-00-22__f4844139-5f69-443d-8b85-3ee4f9b3b0e4__wakuorg_nwaku:latest.log
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:90 Starting Node...
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:22 Attempting to create or retrieve network waku
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:25 Network waku already exists
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:108 Generated random external IP 172.18.182.189
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:101 Generated ports ['61776', '61777', '61778', '61779', '61780']
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:455 RLN credentials were not set
|
||
[32mINFO [0m src.node.waku_node:waku_node.py:180 RLN credentials not set or credential store not available, starting without RLN
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:186 Using volumes []
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:49 docker run -i -t -p 61776:61776 -p 61777:61777 -p 61778:61778 -p 61779:61779 -p 61780:61780 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=61778 --rest-port=61776 --tcp-port=61777 --discv5-udp-port=61779 --rest-address=0.0.0.0 --nat=extip:172.18.182.189 --peer-exchange=true --discv5-discovery=true --cluster-id=198 --nodekey=eded6bbbeb8e1ff0b5a0fc7cdbf8950841ab2e4cc8c882561367a6f0cfbf687a --shard=0 --metrics-server=true --metrics-server-address=0.0.0.0 --metrics-server-port=61780 --metrics-logging=true --relay=false --discv5-bootstrap-node=enr:-L24QFggbMwPFswdk4cz30ji5M4iWsaH6PrTWo9gCX8HL49wR8e2H333iHaPAJqLh6-u6Tn7IFl74v6qiT5Ik-Pr6f0CgmlkgnY0gmlwhKwSNh6KbXVsdGlhZGRyc5YACASsEjYeBnPXAAoErBI2HgZz2N0DgnJzhQDGAQAAiXNlY3AyNTZrMaEDwHwE81An_TXzduCqRD2YpIUdhc1wJK0zp0KqIfN2w7WDdGNwgnPXg3VkcIJz2YV3YWt1MgU --filternode=/ip4/172.18.54.30/tcp/29655/p2p/16Uiu2HAmRcNK3amwzw3NHuFraDQTPyGPZPYYASftNYoEV7nNzfRN
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:55 docker network connect --ip 172.18.182.189 waku 6dcf3859be1006dcc026b2fe6957e081ca30fb6ab5d44282410f444f9d7f4c49
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:58 Container started with ID 6dcf3859be10. Setting up logs at ./log/docker/node2_2026-04-23_22-00-22__f4844139-5f69-443d-8b85-3ee4f9b3b0e4__wakuorg_nwaku:latest.log
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:197 Started container from image wakuorg/nwaku:latest. REST: 61776
|
||
[35mDEBUG [0m src.libs.common:common.py:47 Sleeping for 1 seconds
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:61776/health" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"nodeHealth":"READY","connectionStatus":"Disconnected","protocolsHealth":[{"Relay":"NOT_MOUNTED"},{"Lightpush":"NOT_MOUNTED"},{"Legacy Lightpush":"NOT_MOUNTED"},{"Filter":"NOT_MOUNTED"},{"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"},{"Filter Client":"NOT_READY","desc":"No Filter service peer available yet"},{"Rln Relay":"NOT_MOUNTED"}]}'
|
||
[32mINFO [0m src.node.waku_node:waku_node.py:294 Node protocols are initialized !!
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:61776/debug/v1/info" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"listenAddresses":["/ip4/172.18.182.189/tcp/61777/p2p/16Uiu2HAmC6FqQ6LgArGinZogpzFpN42HAoq3PimrEBG8iXWfr2V8","/ip4/172.18.182.189/tcp/61778/ws/p2p/16Uiu2HAmC6FqQ6LgArGinZogpzFpN42HAoq3PimrEBG8iXWfr2V8"],"enrUri":"enr:-L24QBwhoGPMYlhIYmfRFaTkbPjPPHFIiNBRc9T-vfKSrWwFAo4hA1VYX5CRAp5HuuloC5zxUwJiVjkSmg1DZtpiMc0CgmlkgnY0gmlwhKwStr2KbXVsdGlhZGRyc5YACASsEra9BvFRAAoErBK2vQbxUt0DgnJzhQDGAQAAiXNlY3AyNTZrMaEC951XgrHimikIi04GJiBgF4nqgqtMh2Nm6XovgFsiT6uDdGNwgvFRg3VkcILxU4V3YWt1MgA"}'
|
||
[32mINFO [0m src.node.waku_node:waku_node.py:299 REST service is ready !!
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:61776/admin/v1/peers" -H "Content-Type: application/json" -d '["/ip4/172.18.54.30/tcp/29655/p2p/16Uiu2HAmRcNK3amwzw3NHuFraDQTPyGPZPYYASftNYoEV7nNzfRN"]'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[35mDEBUG [0m tests.filter.test_subscribe_create:test_subscribe_create.py:21 Running test with pubsub topic: /waku/2/rs/198/0
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/subscriptions" -H "Content-Type: application/json" -d '["/waku/2/rs/198/0"]'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:61776/filter/v2/subscriptions" -H "Content-Type: application/json" -d '{"requestId": "bbbc402d-75b5-4524-b645-284b06bc08a7", "contentFilters": ["/waku/2/rs/198/0"], "pubsubTopic": "/waku/2/rs/198/0"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"requestId":"bbbc402d-75b5-4524-b645-284b06bc08a7","statusDesc":"OK"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/messages/%2Fwaku%2F2%2Frs%2F198%2F0" -H "Content-Type: application/json" -d '{"payload": "RmlsdGVyIHdvcmtzISE=", "contentTopic": "/waku/2/rs/198/0", "timestamp": '$(date +%s%N)'}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[35mDEBUG [0m src.libs.common:common.py:47 Sleeping for 0.1 seconds
|
||
[35mDEBUG [0m src.steps.filter:filter.py:96 Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:61776/filter/v2/messages/%2Fwaku%2F2%2Frs%2F198%2F0" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'[{"payload":"RmlsdGVyIHdvcmtzISE=","contentTopic":"/waku/2/rs/198/0","version":0,"timestamp":1776981625277091580,"ephemeral":false}]'
|
||
[35mDEBUG [0m tests.filter.test_subscribe_create:test_subscribe_create.py:21 Running test with pubsub topic: /waku/2/rs/198/1
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/subscriptions" -H "Content-Type: application/json" -d '["/waku/2/rs/198/1"]'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:61776/filter/v2/subscriptions" -H "Content-Type: application/json" -d '{"requestId": "bfc3b6a5-bf80-4d75-b317-b04c3147a7d2", "contentFilters": ["/waku/2/rs/198/1"], "pubsubTopic": "/waku/2/rs/198/1"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"requestId":"bfc3b6a5-bf80-4d75-b317-b04c3147a7d2","statusDesc":"OK"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/messages/%2Fwaku%2F2%2Frs%2F198%2F1" -H "Content-Type: application/json" -d '{"payload": "RmlsdGVyIHdvcmtzISE=", "contentTopic": "/waku/2/rs/198/1", "timestamp": '$(date +%s%N)'}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[35mDEBUG [0m src.libs.common:common.py:47 Sleeping for 0.1 seconds
|
||
[35mDEBUG [0m src.steps.filter:filter.py:96 Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:61776/filter/v2/messages/%2Fwaku%2F2%2Frs%2F198%2F1" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'[{"payload":"RmlsdGVyIHdvcmtzISE=","contentTopic":"/waku/2/rs/198/1","version":0,"timestamp":1776981625405942333,"ephemeral":false}]'
|
||
[35mDEBUG [0m tests.filter.test_subscribe_create:test_subscribe_create.py:21 Running test with pubsub topic: /waku/2/rs/198/9
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/subscriptions" -H "Content-Type: application/json" -d '["/waku/2/rs/198/9"]'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:61776/filter/v2/subscriptions" -H "Content-Type: application/json" -d '{"requestId": "25fd5224-8de1-464b-9076-34d647bfd7a0", "contentFilters": ["/waku/2/rs/198/9"], "pubsubTopic": "/waku/2/rs/198/9"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"requestId":"25fd5224-8de1-464b-9076-34d647bfd7a0","statusDesc":"OK"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/messages/%2Fwaku%2F2%2Frs%2F198%2F9" -H "Content-Type: application/json" -d '{"payload": "RmlsdGVyIHdvcmtzISE=", "contentTopic": "/waku/2/rs/198/9", "timestamp": '$(date +%s%N)'}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[35mDEBUG [0m src.libs.common:common.py:47 Sleeping for 0.1 seconds
|
||
[35mDEBUG [0m src.steps.filter:filter.py:96 Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:61776/filter/v2/messages/%2Fwaku%2F2%2Frs%2F198%2F9" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'[{"payload":"RmlsdGVyIHdvcmtzISE=","contentTopic":"/waku/2/rs/198/9","version":0,"timestamp":1776981625529074470,"ephemeral":false}]'
|
||
[35mDEBUG [0m tests.filter.test_subscribe_create:test_subscribe_create.py:21 Running test with pubsub topic: /waku/2/rs/198/25
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/subscriptions" -H "Content-Type: application/json" -d '["/waku/2/rs/198/25"]'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:61776/filter/v2/subscriptions" -H "Content-Type: application/json" -d '{"requestId": "1ee13acc-6899-4a78-b867-8218259fc641", "contentFilters": ["/waku/2/rs/198/25"], "pubsubTopic": "/waku/2/rs/198/25"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"requestId":"1ee13acc-6899-4a78-b867-8218259fc641","statusDesc":"OK"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/messages/%2Fwaku%2F2%2Frs%2F198%2F25" -H "Content-Type: application/json" -d '{"payload": "RmlsdGVyIHdvcmtzISE=", "contentTopic": "/waku/2/rs/198/25", "timestamp": '$(date +%s%N)'}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[35mDEBUG [0m src.libs.common:common.py:47 Sleeping for 0.1 seconds
|
||
[35mDEBUG [0m src.steps.filter:filter.py:96 Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:61776/filter/v2/messages/%2Fwaku%2F2%2Frs%2F198%2F25" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'[{"payload":"RmlsdGVyIHdvcmtzISE=","contentTopic":"/waku/2/rs/198/25","version":0,"timestamp":1776981625654948854,"ephemeral":false}]'
|
||
[35mDEBUG [0m tests.filter.test_subscribe_create:test_subscribe_create.py:21 Running test with pubsub topic: /waku/2/rs/198/1000
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/subscriptions" -H "Content-Type: application/json" -d '["/waku/2/rs/198/1000"]'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:61776/filter/v2/subscriptions" -H "Content-Type: application/json" -d '{"requestId": "92b02ddc-8bd3-4ff5-9f01-21b5e1df02f6", "contentFilters": ["/waku/2/rs/198/1000"], "pubsubTopic": "/waku/2/rs/198/1000"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'{"requestId":"92b02ddc-8bd3-4ff5-9f01-21b5e1df02f6","statusDesc":"OK"}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X POST "http://127.0.0.1:29654/relay/v1/messages/%2Fwaku%2F2%2Frs%2F198%2F1000" -H "Content-Type: application/json" -d '{"payload": "RmlsdGVyIHdvcmtzISE=", "contentTopic": "/waku/2/rs/198/1000", "timestamp": '$(date +%s%N)'}'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'OK'
|
||
[35mDEBUG [0m src.libs.common:common.py:47 Sleeping for 0.1 seconds
|
||
[35mDEBUG [0m src.steps.filter:filter.py:96 Checking that peer NODE_2:wakuorg/nwaku:latest can find the published message
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:37 curl -v -X GET "http://127.0.0.1:61776/filter/v2/messages/%2Fwaku%2F2%2Frs%2F198%2F1000" -H "Content-Type: application/json" -d 'None'
|
||
[32mINFO [0m src.node.api_clients.base_client:base_client.py:22 Response status code: 200. Response content: b'[{"payload":"RmlsdGVyIHdvcmtzISE=","contentTopic":"/waku/2/rs/198/1000","version":0,"timestamp":1776981625781723124,"ephemeral":false}]'
|
||
[35mDEBUG [0m tests.conftest:conftest.py:59 Running fixture teardown: test_setup
|
||
[35mDEBUG [0m tests.conftest:conftest.py:83 Running fixture teardown: close_open_nodes
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:241 Stopping container with id 5a7b2322c781
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:248 Container stopped.
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:241 Stopping container with id 6dcf3859be10
|
||
[35mDEBUG [0m src.node.waku_node:waku_node.py:248 Container stopped.
|
||
[35mDEBUG [0m tests.conftest:conftest.py:98 Running fixture teardown: check_waku_log_errors
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:144 No errors found in the waku logs.
|
||
[35mDEBUG [0m src.node.docker_mananger:docker_mananger.py:144 No errors found in the waku logs. |