feat(l1): add eth_subscribe/eth_unsubscribe WebSocket subscription support by avilagaston9 · Pull Request #6496 · lambdaclass/ethrex

Add eth_subscribe/eth_unsubscribe WebSocket subscription support

avilagaston9

committed

Resolve ws_addr from L1 options inside init_rpc_api instead of passing

avilagaston9

committed

Use a single new_heads_sender variable and clone when needed, instead of

avilagaston9

committed

Refine Credible Layer integration: boolean gate flag, log levels, and doc improvements

avilagaston9

committed

Combine ws_socket_opts and new_heads_sender into a single conditional block

avilagaston9

committed

Introduce WebSocketConfig struct to bundle WS address and broadcast

avilagaston9

committed

Clean up WebSocketConfig usage: add explicit imports instead of full

avilagaston9

committed

Replace broadcast channel with SubscriptionManager actor for WebSocket subscriptions

avilagaston9

committed

Remove unnecessary delegation comments in L2 WS handler

avilagaston9

committed

Move block header serialization into SubscriptionManager actor.

avilagaston9

committed

Subscribe only on eth_subscribe, not on every WS connection.

avilagaston9

committed

Deduplicate WS handling: L2 reuses L1's handle_websocket directly.

avilagaston9

committed

Remove handle_websocket wrapper in L2 — call L1 directly from the axum closure

avilagaston9

committed

Remove duplicate doc comment on handle_websocket

avilagaston9

committed

Use bounded channel (capacity 512) for subscriber notifications instead

avilagaston9

committed

Fix import ordering (cargo fmt)

avilagaston9

committed

Remove accidentally committed .claude directory

avilagaston9

committed

Allow too_many_arguments on BlockProducer::spawn

avilagaston9

committed

Allow multiple subscriptions per WebSocket connection and add SubscriptionManager tests

avilagaston9

committed

Use correct JSON-RPC error codes in WebSocket handler: return

avilagaston9

committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat(l1): add eth_subscribe/eth_unsubscribe WebSocket subscription support#6496

feat(l1): add eth_subscribe/eth_unsubscribe WebSocket subscription support#6496
avilagaston9 wants to merge 25 commits intomainfrom
feat/l1/ws-subscriptions

Commits on Apr 16, 2026

Add eth_subscribe/eth_unsubscribe WebSocket subscription support

Resolve ws_addr from L1 options inside init_rpc_api instead of passing

Use a single new_heads_sender variable and clone when needed, instead of

Refine Credible Layer integration: boolean gate flag, log levels, and doc improvements

Combine ws_socket_opts and new_heads_sender into a single conditional block

Introduce WebSocketConfig struct to bundle WS address and broadcast

Clean up WebSocketConfig usage: add explicit imports instead of full

Replace broadcast channel with SubscriptionManager actor for WebSocket subscriptions

Remove unnecessary delegation comments in L2 WS handler

Move block header serialization into SubscriptionManager actor.

Subscribe only on eth_subscribe, not on every WS connection.

Deduplicate WS handling: L2 reuses L1's handle_websocket directly.

Remove handle_websocket wrapper in L2 — call L1 directly from the axum closure

Remove duplicate doc comment on handle_websocket

Use bounded channel (capacity 512) for subscriber notifications instead

Fix import ordering (cargo fmt)

Remove accidentally committed .claude directory

Allow too_many_arguments on BlockProducer::spawn

Allow multiple subscriptions per WebSocket connection and add SubscriptionManager tests

Use correct JSON-RPC error codes in WebSocket handler: return

Commits on Apr 17, 2026

Fix formatting in subscription_manager_tests.rs (cargo fmt)

Use random subscription IDs, add per-connection subscription limit,

Make handle_websocket generic over a request-routing function so L2

Revert .claude/ addition to .gitignore since it should not be part

Make build_subscription_notification private since it is only used within the