Fmt

Author: matthewmturner

src/tui/handlers/mod.rs

@@ -241,7 +241,10 @@ pub fn app_event_handler(app: &mut App, event: AppEvent) -> Result<()> {
                 if let Some(current_page) = app.state.sql_tab.current_page() {
                     let next_page = current_page + 1;
                     if app.state.sql_tab.needs_more_batches_for_page(next_page) {
-                        info!("Still need more batches for page {}, fetching next batch", next_page);
+                        info!(
+                            "Still need more batches for page {}, fetching next batch",
+                            next_page
+                        );
                         let execution = Arc::clone(&app.execution);
                         let sql = query.clone();
                         let _event_tx = app.event_tx();

src/tui/state/tabs/sql.rs

@@ -243,19 +243,17 @@ impl SQLTabState<'_> {
     }
 
     pub fn current_page_results(&self) -> Option<RecordBatch> {
-        use std::sync::Arc;
         use datafusion::arrow::datatypes::Schema;
+        use std::sync::Arc;
 
         match (self.current_page, self.result_batches.as_ref()) {
-            (Some(page), Some(batches)) => {
-                match extract_page(batches, page, PAGE_SIZE) {
-                    Ok(batch) => Some(batch),
-                    Err(err) => {
-                        log::error!("Error getting page {}: {}", page, err);
-                        None
-                    }
+            (Some(page), Some(batches)) => match extract_page(batches, page, PAGE_SIZE) {
+                Ok(batch) => Some(batch),
+                Err(err) => {
+                    log::error!("Error getting page {}: {}", page, err);
+                    None
                 }
-            }
+            },
             _ => Some(RecordBatch::new_empty(Arc::new(Schema::empty()))),
         }
     }

tests/tui_cases/sql_pagination.rs

@@ -58,9 +58,7 @@ fn create_values_query_offset(num: usize, offset: usize) -> String {
 async fn single_page() {
     let mut test_app = TestApp::new().await;
 
-    test_app
-        .handle_app_event(AppEvent::NewExecution)
-        .unwrap();
+    test_app.handle_app_event(AppEvent::NewExecution).unwrap();
     let res1 = create_execution_results("SELECT 1").await;
     let event1 = AppEvent::ExecutionResultsNextBatch(res1);
     test_app.handle_app_event(event1).unwrap();
@@ -97,9 +95,7 @@ async fn multiple_pages_forward_and_back() {
     let res1 = create_execution_results(&query).await;
     let event1 = AppEvent::ExecutionResultsNextBatch(res1);
 
-    test_app
-        .handle_app_event(AppEvent::NewExecution)
-        .unwrap();
+    test_app.handle_app_event(AppEvent::NewExecution).unwrap();
     test_app.handle_app_event(event1).unwrap();
 
     {
@@ -165,9 +161,7 @@ async fn multiple_pages_forward_and_back_and_forward() {
     let res1 = create_execution_results(&query).await;
     let event1 = AppEvent::ExecutionResultsNextBatch(res1);
 
-    test_app
-        .handle_app_event(AppEvent::NewExecution)
-        .unwrap();
+    test_app.handle_app_event(AppEvent::NewExecution).unwrap();
     test_app.handle_app_event(event1).unwrap();
 
     {
@@ -219,9 +213,7 @@ async fn multiple_pages_forward_and_back_and_forward() {
 async fn multiple_batches_lazy_loading() {
     let mut test_app = TestApp::new().await;
 
-    test_app
-        .handle_app_event(AppEvent::NewExecution)
-        .unwrap();
+    test_app.handle_app_event(AppEvent::NewExecution).unwrap();
 
     // Send only first batch initially (lazy loading)
     let batch1 = create_execution_results(&create_values_query(60)).await;
@@ -277,9 +269,7 @@ async fn multiple_batches_lazy_loading() {
 async fn multiple_small_batches_auto_load() {
     let mut test_app = TestApp::new().await;
 
-    test_app
-        .handle_app_event(AppEvent::NewExecution)
-        .unwrap();
+    test_app.handle_app_event(AppEvent::NewExecution).unwrap();
 
     // Send first batch: 100 rows (fills page 0)
     let batch1 = create_execution_results(&create_values_query(100)).await;
@@ -359,9 +349,7 @@ async fn multiple_small_batches_auto_load() {
 async fn exact_batches_for_page() {
     let mut test_app = TestApp::new().await;
 
-    test_app
-        .handle_app_event(AppEvent::NewExecution)
-        .unwrap();
+    test_app.handle_app_event(AppEvent::NewExecution).unwrap();
 
     // Send first batch: 50 rows
     let batch1 = create_execution_results(&create_values_query(50)).await;