fmt

Author: MarinPostma

libsql-server/src/lib.rs

@@ -1025,7 +1025,12 @@ where
 
         let make_replication_svc = Box::new({
             let disable_namespaces = self.disable_namespaces;
-            move |store, client_auth, idle_shutdown, collect_stats, is_internal| -> BoxReplicationService {
+            move |store,
+                  client_auth,
+                  idle_shutdown,
+                  collect_stats,
+                  is_internal|
+                  -> BoxReplicationService {
                 Box::new(ReplicationLogService::new(
                     store,
                     idle_shutdown,
@@ -1058,7 +1063,12 @@ where
 
         let make_replication_svc = Box::new({
             let disable_namespaces = self.disable_namespaces;
-            move |store, client_auth, idle_shutdown, collect_stats, is_internal| -> BoxReplicationService {
+            move |store,
+                  client_auth,
+                  idle_shutdown,
+                  collect_stats,
+                  is_internal|
+                  -> BoxReplicationService {
                 Box::new(ReplicationLogService::new(
                     store,
                     idle_shutdown,

libsql-server/src/rpc/replication/replication_log.rs

@@ -76,15 +76,17 @@ impl ReplicationLogService {
         req: &tonic::Request<T>,
         namespace: NamespaceName,
     ) -> Result<(), Status> {
-        if self.service_internal && req.metadata().get("libsql-proxied").is_some() || !self.service_internal {
+        if self.service_internal && req.metadata().get("libsql-proxied").is_some()
+            || !self.service_internal
+        {
             super::auth::authenticate(
                 &self.namespaces,
                 req,
                 namespace,
                 &self.user_auth_strategy,
                 true,
             )
-                .await
+            .await
         } else {
             Ok(())
         }

libsql-server/src/rpc/replication/replication_log_proxy.rs

@@ -21,7 +21,8 @@ impl ReplicationLogProxyService {
 }
 
 fn mark_proxied<T>(mut req: tonic::Request<T>) -> tonic::Request<T> {
-    req.metadata_mut().insert("libsql-proxied", AsciiMetadataValue::from_static("true"));
+    req.metadata_mut()
+        .insert("libsql-proxied", AsciiMetadataValue::from_static("true"));
     req
 }
 

libsql-server/tests/embedded_replica/mod.rs

@@ -1481,7 +1481,7 @@ fn replicate_auth() {
 
         assert!(db.sync().await.is_err());
 
-        // auth 
+        // auth
         let tmp = tempdir().unwrap();
         let db = Database::open_with_remote_sync_connector(
             tmp.path().join("embedded").to_str().unwrap(),