fix build

Author: avalonche

src/proxy.rs

@@ -60,6 +60,7 @@ where
     fn call(&mut self, req: HttpRequest<HttpBody>) -> Self::Future {
         match req.uri().path() {
             "/healthz" => return Box::pin(async { Ok(Self::Response::new(HttpBody::from("OK"))) }),
+            "/metrics" => {}
             _ => {}
         };
 
@@ -91,7 +92,10 @@ where
                 message = "received json rpc request for",
                 method = method.method
             );
-            if PROXY_METHODS.iter().any(|&m| method.method.starts_with(m)) {
+            if MULTIPLEX_METHODS
+                .iter()
+                .any(|&m| method.method.starts_with(m))
+            {
                 // let rpc server handle engine rpc requests
                 let res = inner.call(req).await.map_err(|e| e.into())?;
                 Ok(res)
@@ -136,6 +140,7 @@ mod tests {
         proxy_success().await;
         proxy_failure().await;
         does_not_proxy_engine_method().await;
+        does_not_proxy_eth_send_raw_transaction_method().await;
         health_check().await;
     }
 
@@ -161,6 +166,12 @@ mod tests {
         assert_eq!(response.unwrap(), "engine response");
     }
 
+    async fn does_not_proxy_eth_send_raw_transaction_method() {
+        let response = send_request("eth_sendRawTransaction").await;
+        assert!(response.is_ok());
+        assert_eq!(response.unwrap(), "raw transaction response");
+    }
+
     async fn health_check() {
         let proxy_server = spawn_proxy_server().await;
         // Create a new HTTP client
@@ -171,7 +182,13 @@ mod tests {
         let health_check_url = format!("http://{ADDR}:{PORT}/healthz");
         let health_response = client.get(health_check_url.parse::<Uri>().unwrap()).await;
         assert!(health_response.is_ok());
-        let b = health_response.unwrap().into_body().collect().await.unwrap().to_bytes();
+        let b = health_response
+            .unwrap()
+            .into_body()
+            .collect()
+            .await
+            .unwrap()
+            .to_bytes();
         // Convert the collected bytes to a string
         let body_string = String::from_utf8(b.to_vec()).unwrap();
         assert_eq!(body_string, "OK");
@@ -234,6 +251,11 @@ mod tests {
         module
             .register_method("engine_method", |_, _, _| "engine response")
             .unwrap();
+        module
+            .register_method("eth_sendRawTransaction", |_, _, _| {
+                "raw transaction response"
+            })
+            .unwrap();
         module
             .register_method("non_existent_method", |_, _, _| "no proxy response")
             .unwrap();