* chore: remove integration feature for websocket-proxy

* chore: received message metric per upstream source

* fix: ensure we reconnect when we receive a close

* Reformat

* Add a metric to track # of bytes broadcasted

* Restructure the repo as a workspace (#233)

* Add a workspace

* go

* Fix tests concurrency

* Update websocket proxy location

* Fix

* Fix

* Update cargo run commands

* Use workspace dependencies

* Fix issues

* update deny

* More deny stuff

* websocket proxy: Add authenticated endpoint settings (#261)

* Add authenticated endpoint to websocket proxy

* Mark code as dead

* websocket proxy: disconnect downstream client if lagging (#269)

* disconnect client on lag

* add back lagged_connections metric

* Flashblocks with extension trait (#270)

* Add fb crate + block ext api

* Trying to plug builderExt

* Finish with the trait

* Fix lint

* Commit changes

* Address url feedback

* Add missing env vars

* Address feedback

* Add feedback

* Update

* brotli compress each message from upstream before sending downstream

* hide compression behind a feature flag

* remove feature flag, enable_compression arg, fix integration test

* fix clippy errors

* Fix FB race (#307)

* Fix race condition in FB (check that we return flashblocks for correct endpoint)
use std::mem::replace to avoid double locking

* run make fmt

* Add payload cleaning on FCU

* Add test

* chore: overall websocket limits should be per instance (#311)

* Initial batch of metrics for flashblocks service (#300)

* chore: minor tweaks to websocket-proxy (#353)

* chore: remove integration feature for websocket-proxy

* chore: received message metric per upstream source

* fix: ensure we reconnect when we receive a close

* Reformat

* Add a metric to track # of bytes broadcasted

* fix: ensure we ping/pong upstream and disconnect when they become unresponsive

* Add some additional logging

* feat: add ws filtering by addresses and topics with configurable match logic

* feat: add client ping/pong health checks

* Cherry pick ping/pong clients

* Fix initial backoff interval

* Separate rate limiting metrics by limit type

Split the single `rate_limited_requests` metric into two separate counters:
- `per_ip_rate_limited_requests`: Tracks rejections due to per-IP connection limits
- `global_rate_limited_requests`: Tracks rejections due to global instance limits

This provides better observability into which rate limiting mechanism is being
triggered, enabling more targeted monitoring and alerting.

Changes:
- Add RateLimitType enum to distinguish between limit types
- Update RateLimitError to include limit_type field
- Modify server.rs to increment appropriate metric based on limit type
- Update both InMemoryRateLimit and RedisRateLimit implementations

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>

* Log IP address when per-IP rate limit is exceeded

Add structured logging to capture the client IP address whenever a per-IP
rate limit is hit. This provides better observability for identifying which
specific IPs are hitting rate limits for security monitoring and debugging.

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>

* add ping metrics

* Refactor websocket proxy to use Vec<u8> instead of String

* Revert "Refactor websocket proxy to use Vec<u8> instead of String"

This reverts commit 190e68145a818c594cfeca373ca977fc689ff5ef.

* add metrics

* fix

* update comment

* update

* send timeout

* configurable timeout

* update

* fix tests

* fixes for merging websocket proxy

* minimal ci fixes

---------

Co-authored-by: Ferran Borreguero <ferran.borreguero@gmail.com>
Co-authored-by: Haardik <hhaardik@uwaterloo.ca>
Co-authored-by: Haardik H <haardik.haardik@coinbase.com>
Co-authored-by: Solar Mithril <mikawamp@gmail.com>
Co-authored-by: shana <avalonche@protonmail.com>
Co-authored-by: Tobi Akerele <tobi.akerele@coinbase.com>
Co-authored-by: Cody Wang <cody.wang@coinbase.com>
Co-authored-by: Claude <noreply@anthropic.com>

* docs: fix mermaid diagram

* docs: update immutable params

* docs: make doc more comprehensive

* docs: minor updates

* docs: make initalization more clear in terms of initial state

* docs: add types section for new/modified types

* docs: fix mermaid diagram

* docs: update immutable params

* docs: make doc more comprehensive

* docs: minor updates

* docs: make initalization more clear in terms of initial state

* docs: add types section for new/modified types

* docs: fix mermaid diagram

* docs: update immutable params

* docs: make doc more comprehensive

* docs: minor updates

* docs: make initalization more clear in terms of initial state

* docs: add types section for new/modified types

* chore: setup GHA for a release process

* docs: add release process documentation

* simplify process

* check tags existence always

* chore: clean up release scripts

Remove obvious comments and dead code from release scripts.

* Restructure the repo as a workspace (#233)

* Add a workspace

* go

* Fix tests concurrency

* Update websocket proxy location

* Fix

* Fix

* Update cargo run commands

* Use workspace dependencies

* Fix issues

* update deny

* More deny stuff

* websocket proxy: Add authenticated endpoint settings (#261)

* Add authenticated endpoint to websocket proxy

* Mark code as dead

* websocket proxy: disconnect downstream client if lagging (#269)

* disconnect client on lag

* add back lagged_connections metric

* Flashblocks with extension trait (#270)

* Add fb crate + block ext api

* Trying to plug builderExt

* Finish with the trait

* Fix lint

* Commit changes

* Address url feedback

* Add missing env vars

* Address feedback

* Add feedback

* Update

* brotli compress each message from upstream before sending downstream

* hide compression behind a feature flag

* remove feature flag, enable_compression arg, fix integration test

* fix clippy errors

* Fix FB race (#307)

* Fix race condition in FB (check that we return flashblocks for correct endpoint)
use std::mem::replace to avoid double locking

* run make fmt

* Add payload cleaning on FCU

* Add test

* chore: overall websocket limits should be per instance (#311)

* Initial batch of metrics for flashblocks service (#300)

* chore: minor tweaks to websocket-proxy (#353)

* chore: remove integration feature for websocket-proxy

* chore: received message metric per upstream source

* fix: ensure we reconnect when we receive a close

* Reformat

* Add a metric to track # of bytes broadcasted

* fix: ensure we ping/pong upstream and disconnect when they become unresponsive

* Add some additional logging

* feat: add ws filtering by addresses and topics with configurable match logic

* feat: add client ping/pong health checks

* Cherry pick ping/pong clients

* Fix initial backoff interval

* Separate rate limiting metrics by limit type

Split the single `rate_limited_requests` metric into two separate counters:
- `per_ip_rate_limited_requests`: Tracks rejections due to per-IP connection limits
- `global_rate_limited_requests`: Tracks rejections due to global instance limits

This provides better observability into which rate limiting mechanism is being
triggered, enabling more targeted monitoring and alerting.

Changes:
- Add RateLimitType enum to distinguish between limit types
- Update RateLimitError to include limit_type field
- Modify server.rs to increment appropriate metric based on limit type
- Update both InMemoryRateLimit and RedisRateLimit implementations

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>

* Log IP address when per-IP rate limit is exceeded

Add structured logging to capture the client IP address whenever a per-IP
rate limit is hit. This provides better observability for identifying which
specific IPs are hitting rate limits for security monitoring and debugging.

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>

* add ping metrics

* Refactor websocket proxy to use Vec<u8> instead of String

* Revert "Refactor websocket proxy to use Vec<u8> instead of String"

This reverts commit 190e68145a818c594cfeca373ca977fc689ff5ef.

* add metrics

* fix

* update comment

* update

* send timeout

* configurable timeout

* update

* fix tests

* fixes for merging websocket proxy

* minimal ci fixes

---------

Co-authored-by: Ferran Borreguero <ferran.borreguero@gmail.com>
Co-authored-by: Haardik <hhaardik@uwaterloo.ca>
Co-authored-by: Haardik H <haardik.haardik@coinbase.com>
Co-authored-by: Solar Mithril <mikawamp@gmail.com>
Co-authored-by: shana <avalonche@protonmail.com>
Co-authored-by: Tobi Akerele <tobi.akerele@coinbase.com>
Co-authored-by: Cody Wang <cody.wang@coinbase.com>
Co-authored-by: Claude <noreply@anthropic.com>

* docs: fix mermaid diagram

* docs: update immutable params

* docs: make doc more comprehensive

* docs: minor updates

* docs: make initalization more clear in terms of initial state

* docs: add types section for new/modified types

* docs: fix mermaid diagram

* docs: update immutable params

* docs: make doc more comprehensive

* docs: minor updates

* docs: make initalization more clear in terms of initial state

* docs: add types section for new/modified types

* docs: fix mermaid diagram

* docs: update immutable params

* docs: make doc more comprehensive

* docs: minor updates

* docs: make initalization more clear in terms of initial state

* docs: add types section for new/modified types