Skip to content

add message subscription service with logos-delivery-js#122

Open
delphamk wants to merge 1 commit into
logos-messaging:masterfrom
delphamk:update
Open

add message subscription service with logos-delivery-js#122
delphamk wants to merge 1 commit into
logos-messaging:masterfrom
delphamk:update

Conversation

@delphamk

@delphamk delphamk commented Jun 5, 2026

Copy link
Copy Markdown

rest-traffic service (write messages):

  • Rename to traffic-post
  • Update message payload to version 0 instead of 1 (waku-js fails to parse version 1)
  • Update Python to use uv package manager and update Dockerfile
  • Added steps to README.md to run the service outside of Docker

traffic-subscribe service (read messages):

  • Created waku-js service to listen to messages on the cluster
  • The service calls running waku nodes and fetches the enrUri. Cluster multiaddrs are decoded from the ENR string, then waku-js connects to the cluster.
  • When a message is received, it logs the payload size in bytes. This can be changed to log the payload for debugging.
  • Added steps to README.md to run the service outside of Docker

waku nodes:

  • Enable WebSocket support for waku-js
  • Enable filter for waku-js subscription
# .env config tested with
export LD_IMAGE=wakuorg/nwaku:v0.38.0
export NUM_LD_NODES=3
export MSG_SIZE_KBYTES=10
export TRAFFIC_DELAY_SECONDS=6
export WATCHTOWER_ENABLED=false
export RPC_URL=http://foundry:8545
export PRIVATE_KEY=0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80
export ETH_FROM=0xf39fd6e51aad88f6f4ce6ab8827279cfffb92266
export RLN_RELAY_MSG_LIMIT=100
export RLN_RELAY_EPOCH_SEC=600
export RLN_CREDENTIAL_PASSWORD=passw123

@delphamk delphamk mentioned this pull request Jun 5, 2026
4 tasks
# rest-traffic

Test utility for [nwaku](https://github.com/waku-org/nwaku).
Given the REST API endpoint, it injects traffic with a given message size at a given rate.

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

need to update this message

Comment thread docker-compose.yml
--multiple-nodes=http://logos-delivery-simulator-nwaku-[1..${NUM_LD_NODES:-5}]:8645
--msg-size-kbytes=${MSG_SIZE_KBYTES:-10}
--delay-seconds=${TRAFFIC_DELAY_SECONDS:-15}
--delay-seconds=${TRAFFIC_DELAY_SECONDS:-30}

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

small difference but can revert this to 15

Comment thread docker-compose.yml
build:
context: ./tools/traffic-subscribe
dockerfile: Dockerfile
command: --multiple-nodes=http://logos-delivery-simulator-nwaku-[1..${NUM_LD_NODES:-5}]:8645

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

can add topic argument here and to traffic-post. --topic=$TOPIC:my-topic to be more verbose

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant