fmt

RingsNetwork · Mar 17, 2024 · 7166252 · 7166252
1 parent 74864f9
commit 7166252
Show file tree

Hide file tree

Showing 5 changed files with 22 additions and 11 deletions.
diff --git a/crates/core/src/swarm/mod.rs b/crates/core/src/swarm/mod.rs
@@ -350,7 +350,7 @@ impl PayloadSender for Swarm {
 
         let result = if data.len() > TRANSPORT_MTU {
             let chunks = ChunkList::<TRANSPORT_MTU>::from(&data);
-	    tracing::info!("data splited to chunk, len {}", chunks.to_vec().len());
+            tracing::info!("data split to chunk, len {}", chunks.to_vec().len());
             for chunk in chunks {
                 let data =
                     MessagePayload::new_send(Message::Chunk(chunk), &self.session_sk, did, did)?

diff --git a/crates/node/src/backend/snark/browser.rs b/crates/node/src/backend/snark/browser.rs
@@ -176,7 +176,11 @@ impl SNARKBehaviour {
         let ins = self.clone();
         future_to_promise(async move {
             let ret = ins
-                .send_proof_task(provider.inner().clone(), task.as_ref(), Did::from_str(&did)?)
+                .send_proof_task(
+                    provider.inner().clone(),
+                    task.as_ref(),
+                    Did::from_str(&did)?,
+                )
                 .await
                 .map_err(JsError::from)?;
             Ok(JsValue::from(ret))

diff --git a/crates/node/src/backend/snark/mod.rs b/crates/node/src/backend/snark/mod.rs
@@ -939,7 +939,12 @@ impl MessageHandler<SNARKTaskMessage> for SNARKBehaviour {
                 }
                 .into();
                 let params = resp.into_send_backend_message_request(verifier)?;
-		provider.request_internal(Method::SendBackendMessage.to_string(), serde_json::to_value(params)?).await?;
+                provider
+                    .request_internal(
+                        Method::SendBackendMessage.to_string(),
+                        serde_json::to_value(params)?,
+                    )
+                    .await?;
                 Ok(())
             }
             SNARKTask::SNARKVerify(t) => {

diff --git a/crates/node/src/provider/browser/provider.rs b/crates/node/src/provider/browser/provider.rs
@@ -70,28 +70,27 @@ impl TryFrom<&Peer> for JsValue {
     }
 }
 
-
 /// A wrapper of Arc Ref of Provider
 #[derive(Clone)]
 #[wasm_export]
 pub struct ProviderRef {
-    inner: Arc<Provider>
+    inner: Arc<Provider>,
 }
 
 impl ProviderRef {
     /// get wrapped arc, this is useful for wasm case
     pub fn inner(&self) -> Arc<Provider> {
-	self.inner.clone()
+        self.inner.clone()
     }
 }
 
 #[wasm_export]
 impl Provider {
     /// make provider as an As arc ref
     pub fn as_ref(&self) -> ProviderRef {
-	ProviderRef {
-	    inner: Arc::new(self.clone())
-	}
+        ProviderRef {
+            inner: Arc::new(self.clone()),
+        }
     }
 }
 

diff --git a/crates/node/src/tests/wasm/snark.rs b/crates/node/src/tests/wasm/snark.rs
@@ -65,7 +65,10 @@ async fn test_send_snark_backend_message() {
     console_log!("wait for register");
     js_utils::window_sleep(1000).await.unwrap();
     console_log!("gen snark task and send");
-    let promise =
-        snark_behaviour.gen_and_send_proof_task_to(provider1.as_ref(), circuits, provider2.address());
+    let promise = snark_behaviour.gen_and_send_proof_task_to(
+        provider1.as_ref(),
+        circuits,
+        provider2.address(),
+    );
     wasm_bindgen_futures::JsFuture::from(promise).await.unwrap();
 }