fix: formatting

Author: riazus

libsql-server/src/namespace/configurator/helpers.rs

@@ -296,7 +296,7 @@ fn tokenize_sql_keywords(text: &str) -> Vec<String> {
     let mut current_token = String::new();
     let mut in_string_literal = false;
     let mut string_delimiter = '\0';
-    
+
     while let Some(ch) = chars.next() {
         match ch {
             '\'' | '"' => {
@@ -328,15 +328,15 @@ fn tokenize_sql_keywords(text: &str) -> Vec<String> {
     if !current_token.is_empty() && !in_string_literal {
         tokens.push(current_token.to_uppercase());
     }
-    
+
     tokens
 }
 
 fn is_complete_sql_statement(sql: &str) -> bool {
     let tokens = tokenize_sql_keywords(sql);
     let mut begin_end_depth = 0;
     let mut case_depth = 0;
-    
+
     for (i, token) in tokens.iter().enumerate() {
         match token.as_str() {
             "CASE" => {
@@ -358,7 +358,8 @@ fn is_complete_sql_statement(sql: &str) -> bool {
                     case_depth -= 1;
                 } else {
                     // This is a block-ending END (BEGIN/END, IF/END IF, etc.)
-                    let is_control_flow_end = tokens.get(i + 1)
+                    let is_control_flow_end = tokens
+                        .get(i + 1)
                         .map(|next| matches!(next.as_str(), "IF" | "LOOP" | "WHILE"))
                         .unwrap_or(false);
 

libsql-server/tests/namespaces/dumps.rs

@@ -461,7 +461,11 @@ fn load_dump_with_trigger() {
             .unwrap();
         assert_eq!(resp.status(), StatusCode::OK);
 
-        let db = Database::open_remote_with_connector("http://debug_test.primary:8080", "", TurmoilConnector)?;
+        let db = Database::open_remote_with_connector(
+            "http://debug_test.primary:8080",
+            "",
+            TurmoilConnector,
+        )?;
         let conn = db.connect()?;
 
         // Original INSERT: 1, Trigger INSERT: 999 = 2 total rows
@@ -518,7 +522,11 @@ fn load_dump_with_case_trigger() {
             .unwrap();
         assert_eq!(resp.status(), StatusCode::OK);
 
-        let db = Database::open_remote_with_connector("http://case_test.primary:8080", "", TurmoilConnector)?;
+        let db = Database::open_remote_with_connector(
+            "http://case_test.primary:8080",
+            "",
+            TurmoilConnector,
+        )?;
         let conn = db.connect()?;
 
         let mut rows = conn.query("SELECT id, rate FROM test", ()).await?;
@@ -580,16 +588,23 @@ fn load_dump_with_nested_case() {
             .unwrap();
         assert_eq!(resp.status(), StatusCode::OK);
 
-        let db = Database::open_remote_with_connector("http://nested_test.primary:8080", "", TurmoilConnector)?;
+        let db = Database::open_remote_with_connector(
+            "http://nested_test.primary:8080",
+            "",
+            TurmoilConnector,
+        )?;
         let conn = db.connect()?;
 
-        conn.execute("UPDATE orders SET status = 'completed' WHERE id = 1", ()).await?;
-        let mut rows = conn.query("SELECT amount FROM orders WHERE id = 1", ()).await?;
+        conn.execute("UPDATE orders SET status = 'completed' WHERE id = 1", ())
+            .await?;
+        let mut rows = conn
+            .query("SELECT amount FROM orders WHERE id = 1", ())
+            .await?;
         let row = rows.next().await?.unwrap();
         assert!((row.get::<f64>(0)? - 90.0).abs() < 0.001);
 
         Ok(())
     });
 
     sim.run().unwrap();
-}
+}