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

Author: tobidae-cb

Cargo.lock

@@ -11,6 +11,7 @@ tracing-subscriber.workspace = true
 clap.workspace = true
 futures.workspace = true
 thiserror.workspace = true
+serde.workspace = true
 serde_json.workspace = true
 metrics.workspace = true
 tokio.workspace = true

crates/websocket-proxy/Cargo.toml

@@ -1,3 +1,4 @@
+use crate::filter::FilterType;
 use crate::rate_limit::Ticket;
 use axum::extract::ws::WebSocket;
 use axum::Error;
@@ -7,14 +8,16 @@ pub struct ClientConnection {
     client_addr: IpAddr,
     _ticket: Ticket,
     pub(crate) websocket: WebSocket,
+    pub filter: FilterType,
 }
 
 impl ClientConnection {
-    pub fn new(client_addr: IpAddr, ticket: Ticket, websocket: WebSocket) -> Self {
+    pub fn new(client_addr: IpAddr, ticket: Ticket, websocket: WebSocket, filter: FilterType) -> Self {
         Self {
             client_addr,
             _ticket: ticket,
             websocket,
+            filter,
         }
     }