Apply some linting to the changes

Cargo.toml

@@ -44,7 +44,6 @@ bytes = "1.4.0"
 chrono = { version = "0.4", default_features = false }
 clap = { version = "3.2.19", features = [ "derive" ] }
 config = "0.13.3"
-rustyline = "12.0"
 
 # PG wire protocol support
 convergence = { git = "https://github.com/splitgraph/convergence", branch = "datafusion-32-upgrade", optional = true }
@@ -78,6 +77,7 @@ reqwest = { version = "0.11.14", features = [ "stream" ] }
 rmp = "0.8.11"
 rmp-serde = "1.1.1"
 rmpv = { version = "1.0.0", features = ["with-serde"] }
+rustyline = "12.0"
 serde = "1.0.156"
 serde_json = "1.0.93"
 sha2 = ">=0.10.1"

src/cli/commands.rs

@@ -1,6 +1,5 @@
 use std::str::FromStr;
 
-
 /// Commands available inside the CLI
 #[derive(Debug)]
 pub enum Command {
@@ -27,4 +26,4 @@ impl FromStr for Command {
             _ => return Err(()),
         })
     }
-}
+}

src/cli/helper.rs

@@ -13,6 +13,7 @@ pub struct CliHelper {}
 // The accompanying helper for SeafowlCli.
 // For now only supports multi-line statements through the `Validator` override.
 impl CliHelper {
+    #[allow(clippy::if_same_then_else)]
     fn validate_input(&self, input: &str) -> Result<ValidationResult> {
         if input.ends_with(';') {
             // TODO: actually perform validation here
@@ -32,7 +33,6 @@ impl Hinter for CliHelper {
     type Hint = String;
 }
 
-
 impl Completer for CliHelper {
     type Candidate = Pair;
 }

src/cli/mod.rs

@@ -3,16 +3,15 @@ mod helper;
 
 use crate::context::{DefaultSeafowlContext, SeafowlContext};
 use arrow::util::pretty::pretty_format_batches_with_options;
+use commands::Command;
 use datafusion_common::Result;
+use helper::CliHelper;
 use rustyline::{error::ReadlineError, Editor};
 use std::sync::Arc;
 use std::time::Instant;
-use commands::Command;
-use helper::CliHelper;
-
 
 pub struct SeafowlCli {
-    ctx: Arc<DefaultSeafowlContext>
+    ctx: Arc<DefaultSeafowlContext>,
 }
 
 impl SeafowlCli {
@@ -62,7 +61,7 @@ impl SeafowlCli {
                     break;
                 }
                 Err(err) => {
-                    eprintln!("Error while reading input: {err:?}", );
+                    eprintln!("Error while reading input: {err:?}",);
                     break;
                 }
             }
@@ -76,8 +75,13 @@ impl SeafowlCli {
         match cmd {
             Command::Help => todo!(),
             Command::ListTables => self.exec_and_print("SHOW TABLES").await,
-            Command::DescribeTable(name) => self.exec_and_print(&format!("SHOW COLUMNS FROM {name}")).await,
-            Command::Quit => panic!("Unexpected quit, this should be handled in the repl loop"),
+            Command::DescribeTable(name) => {
+                self.exec_and_print(&format!("SHOW COLUMNS FROM {name}"))
+                    .await
+            }
+            Command::Quit => {
+                panic!("Unexpected quit, this should be handled in the repl loop")
+            }
         }
     }
 
@@ -90,7 +94,10 @@ impl SeafowlCli {
         // Generate physical plans from the statements
         let mut plans = vec![];
         for statement in statements {
-            let logical = self.ctx.create_logical_plan_from_statement(statement).await?;
+            let logical = self
+                .ctx
+                .create_logical_plan_from_statement(statement)
+                .await?;
             plans.push(self.ctx.create_physical_plan(&logical).await?);
         }
 
@@ -108,4 +115,4 @@ impl SeafowlCli {
 
         Ok(())
     }
-}
+}