fixed CORS issue for playground openrpc

Author: maximevanhees

Cargo.lock

@@ -26,13 +26,15 @@ thiserror = "1.0"
 clap = "2.33"
 git-version = "0.3.5"
 command-group = "1.0.8"
-hyper = "1.6.0"
-axum = { version = "0.7.4", features = ["http1"] }
+hyper = "1.6"
+# axum = { version = "0.7.4", features = ["http1"] }
 bytes = "1.0"
 jsonrpsee = { version = "0.24.9", features = ["server", "client", "macros"] }
 memchr = "2.5.0"
 async-trait = "0.1.88"
 reth-ipc = { git = "https://github.com/paradigmxyz/reth", package = "reth-ipc" }
+tower-http = { version = "0.5", features = ["cors"] }
+tower = "0.4"
 
 [dev-dependencies]
 tokio = { version = "1.14.0", features = ["full", "test-util"] }

Cargo.toml

@@ -1,13 +1,17 @@
+use super::rpc::{
+    ZinitLoggingApiServer, ZinitRpcApiServer, ZinitServiceApiServer, ZinitSystemApiServer,
+};
 use crate::zinit::ZInit;
 use anyhow::{bail, Context, Result};
 use jsonrpsee::server::ServerHandle;
 use reth_ipc::server::Builder;
 use serde::{Deserialize, Serialize};
 use serde_json::Value;
 use std::collections::HashMap;
-use super::rpc::{ZinitLoggingApiServer, ZinitRpcApiServer, ZinitServiceApiServer, ZinitSystemApiServer};
 use std::sync::Arc;
 use tokio::sync::Mutex;
+use tower_http::cors::{Any, CorsLayer};
+use tower_http::cors::{AllowMethods, AllowHeaders};
 
 #[derive(Clone, Debug, Deserialize, Serialize)]
 #[serde(rename_all = "lowercase")]
@@ -52,30 +56,37 @@ impl Api {
     }
 
     pub async fn serve(&self, endpoint: String) -> Result<ApiServer> {
-
         let server = Builder::default().build(endpoint);
         let mut module = ZinitRpcApiServer::into_rpc(self.clone());
         module.merge(ZinitSystemApiServer::into_rpc(self.clone()))?;
         module.merge(ZinitServiceApiServer::into_rpc(self.clone()))?;
         module.merge(ZinitLoggingApiServer::into_rpc(self.clone()))?;
 
-
         let _handle = server.start(module).await?;
 
         Ok(ApiServer { _handle })
     }
-    
+
     /// Start an HTTP/RPC server at a specified address
     pub async fn start_http_server(&self, address: String) -> Result<String> {
         // Parse the address string
-        let socket_addr = address.parse::<std::net::SocketAddr>()
+        let socket_addr = address
+            .parse::<std::net::SocketAddr>()
             .context("Failed to parse socket address")?;
-            
-        // Create the JSON-RPC server
-        let server_rpc = jsonrpsee::server::ServerBuilder::default()
+
+        let cors = CorsLayer::new()
+            // Allow `POST` when accessing the resource
+            .allow_methods(AllowMethods::any())
+            // Allow requests from any origin
+            .allow_origin(Any)
+            .allow_headers(AllowHeaders::any());
+        let middleware = tower::ServiceBuilder::new().layer(cors);
+
+        // Create the JSON-RPC server with CORS support
+        let server_rpc = jsonrpsee::server::ServerBuilder::default().set_http_middleware(middleware)
             .build(socket_addr)
             .await?;
-            
+
         // Create and merge all API modules
         let mut rpc_module = ZinitRpcApiServer::into_rpc(self.clone());
         rpc_module.merge(ZinitSystemApiServer::into_rpc(self.clone()))?;
@@ -84,18 +95,18 @@ impl Api {
 
         // Start the server
         let handle = server_rpc.start(rpc_module);
-        
+
         // Store the handle
         let mut http_handle = self.http_server_handle.lock().await;
         *http_handle = Some(handle);
-        
+
         Ok(format!("HTTP/RPC server started at {}", address))
     }
-    
+
     /// Stop the HTTP/RPC server if running
     pub async fn stop_http_server(&self) -> Result<()> {
         let mut http_handle = self.http_server_handle.lock().await;
-        
+
         if http_handle.is_some() {
             // The handle is automatically dropped, which should stop the server
             *http_handle = None;
@@ -104,4 +115,4 @@ impl Api {
             bail!("No HTTP/RPC server is currently running")
         }
     }
-}
+}