style: fmt

crates/api/src/rpc.rs

@@ -42,15 +42,19 @@ fn serve_on(url: &str, listener: TcpListener) -> Server {
         .build()
         .unwrap();
 
-    let ctx = Context { client: Arc::new(gen::client::Client::with_client(url, client)) };
+    let ctx = Context {
+        client: Arc::new(gen::client::Client::with_client(url, client)),
+    };
 
     let app = Router::new().route("/rpc", post(handle_request)).with_state(ctx);
 
     let (tx, rx) = oneshot::channel::<()>();
     let port = listener.local_addr().unwrap().port();
     let jh = tokio::spawn(async move {
         axum::serve(listener, app.into_make_service())
-            .with_graceful_shutdown(async move { let _ = rx.await; })
+            .with_graceful_shutdown(async move {
+                let _ = rx.await;
+            })
             .await
             .unwrap();
     });
@@ -260,13 +264,25 @@ impl gen::Rpc for Context {
         key: StorageKey,
         block_id: BlockId,
     ) -> std::result::Result<Felt, jsonrpc::Error> {
-        let result = self.client
-            .getStorageAt(contract_address.clone(), key.clone(), block_id.clone())
+        let result = self
+            .client
+            .getStorageAt(
+                contract_address.clone(),
+                key.clone(),
+                block_id.clone(),
+            )
             .await?;
-        tracing::info!(?contract_address, ?key, ?block_id, ?result, "getStorageAt");
+        tracing::info!(
+            ?contract_address,
+            ?key,
+            ?block_id,
+            ?result,
+            "getStorageAt"
+        );
         let felt = Felt::try_new(key.as_ref())?;
         let keys = vec![Address(felt)];
-        let proof = self.client.getProof(block_id, contract_address, keys).await?;
+        let proof =
+            self.client.getProof(block_id, contract_address, keys).await?;
         tracing::info!(?proof, "getStorageAt");
         // TODO: validate proof
         Ok(result)

crates/api/tests/common/mod.rs

@@ -1,4 +1,7 @@
-use beerus_api::{gen::client::Client, rpc::{serve, Server}};
+use beerus_api::{
+    gen::client::Client,
+    rpc::{serve, Server},
+};
 
 use async_once_cell::OnceCell;
 
@@ -8,7 +11,9 @@ pub enum Error {
 }
 
 impl From<iamgroot::jsonrpc::Error> for Error {
-    fn from(error: iamgroot::jsonrpc::Error) -> Self { Self::Rpc(error) }
+    fn from(error: iamgroot::jsonrpc::Error) -> Self {
+        Self::Rpc(error)
+    }
 }
 
 pub struct Context {
@@ -21,7 +26,7 @@ async fn setup() -> Option<Context> {
 
     let url = std::env::var("TEST_URL").ok()?;
     let server = serve(&url, "127.0.0.1:0").await;
-    tracing::info!(port=server.port(), "test server is up");
+    tracing::info!(port = server.port(), "test server is up");
 
     let url = format!("http://localhost:{}/rpc", server.port());
     let client = Client::new(&url);

crates/api/tests/rpc.rs

@@ -5,7 +5,9 @@ mod common;
 #[tokio::test]
 #[allow(non_snake_case)]
 async fn test_specVersion() -> Result<(), common::Error> {
-    let Some(ctx) = common::ctx().await else { return Ok(()); };
+    let Some(ctx) = common::ctx().await else {
+        return Ok(());
+    };
     assert_eq!(ctx.client.specVersion().await?, "0.6.0");
     Ok(())
 }