Fix lints

Author: Jake-Shadle

.antithesis/client/rust-load-generator/src/main.rs

@@ -198,7 +198,7 @@ async fn query(addr: String, tripwire: Tripwire) -> eyre::Result<()> {
                         .query_typed::<TeamStats>(
                             &Statement::WithParams(
                                 TEAM_QUERY.into(),
-                                vec![format!("%{}%", letter).into()],
+                                vec![format!("%{letter}%").into()],
                             ),
                             None,
                         )

crates/corro-agent/src/agent/handlers.rs

@@ -1024,7 +1024,7 @@ mod tests {
             db_conn.execute_batch("PRAGMA auto_vacuum = INCREMENTAL")?;
         }
 
-        println!("temp db: {:?}", db_path);
+        println!("temp db: {db_path:?}");
         let write_sema = Arc::new(Semaphore::new(1));
         let pool = SplitPool::create(db_path, write_sema.clone()).await?;
 

crates/corro-client/src/lib.rs

@@ -53,9 +53,7 @@ impl CorrosionApiClient {
         statement: &Statement,
         timeout: Option<u64>,
     ) -> Result<QueryStream<T>, Error> {
-        let params = timeout
-            .map(|t| format!("?timeout={}", t))
-            .unwrap_or_default();
+        let params = timeout.map(|t| format!("?timeout={t}")).unwrap_or_default();
         let req = hyper::Request::builder()
             .method(hyper::Method::POST)
             .uri(format!("http://{}/v1/queries{}", self.api_addr, params))
@@ -115,7 +113,7 @@ impl CorrosionApiClient {
             )
             .try_into()?
         } else {
-            format!("/v1/subscriptions?skip_rows={}", skip_rows).try_into()?
+            format!("/v1/subscriptions?skip_rows={skip_rows}").try_into()?
         };
         let url = hyper::Uri::builder()
             .scheme("http")
@@ -179,7 +177,7 @@ impl CorrosionApiClient {
             )
             .try_into()?
         } else {
-            format!("/v1/subscriptions/{id}?skip_rows={}", skip_rows).try_into()?
+            format!("/v1/subscriptions/{id}?skip_rows={skip_rows}").try_into()?
         };
         let url = hyper::Uri::builder()
             .scheme("http")
@@ -227,7 +225,7 @@ impl CorrosionApiClient {
         &self,
         table: &str,
     ) -> Result<UpdatesStream<T>, Error> {
-        let p_and_q: PathAndQuery = format!("/v1/updates/{}", table).try_into()?;
+        let p_and_q: PathAndQuery = format!("/v1/updates/{table}").try_into()?;
 
         let url = hyper::Uri::builder()
             .scheme("http")

crates/corro-devcluster/src/main.rs

@@ -104,7 +104,7 @@ fn main() {
 }
 
 fn run_simple_topology(topo: Simple, bin_path: String, state_dir: PathBuf, schema_dir: PathBuf) {
-    println!("//// Creating topology: \n{:#?}", topo);
+    println!("//// Creating topology: \n{topo:#?}");
     let nodes = topo.get_all_nodes();
 
     let mut port_map = BTreeMap::default();
@@ -140,10 +140,7 @@ fn run_simple_topology(topo: Simple, bin_path: String, state_dir: PathBuf, schem
             bootstrap_set,
         );
 
-        println!(
-            "Generated config for node '{}': \n{}",
-            node_name, node_config
-        );
+        println!("Generated config for node '{node_name}': \n{node_config}",);
 
         let mut config_file = File::create(node_state.join("config.toml"))
             .expect("failed to create node config file");

crates/corro-types/src/pubsub.rs

@@ -2845,7 +2845,7 @@ mod tests {
             let mut rx = created.evt_rx;
 
             let matcher_id = matcher.id().as_simple().to_string();
-            println!("matcher restored w/ id: {}", matcher_id);
+            println!("matcher restored w/ id: {matcher_id}");
 
             let (catch_up_tx, mut catch_up_rx) = mpsc::channel(1);
 

crates/corro-types/src/schema.rs

@@ -500,7 +500,7 @@ pub fn apply_schema(
                         }
                         .into());
                     }
-                    tx.execute_batch(&format!("ALTER TABLE {name} ADD COLUMN {}", col))?;
+                    tx.execute_batch(&format!("ALTER TABLE {name} ADD COLUMN {col}"))?;
                 }
 
                 if require_migration {

rust-toolchain.toml

@@ -1,2 +1,3 @@
 [toolchain]
 channel = "1.88"
+components = ["rustfmt", "clippy"]