fix(consumer): formatting and clippy

consumer/src/backfill/mod.rs

···
             return Err(diesel::result::Error::RollbackTransaction.into());
         };
 
-        counter!("backfilled_commits", "collection" => collection.to_string())
-            .increment(1);
+        counter!("backfilled_commits", "collection" => collection.to_string()).increment(1);
 
         let full_path = format!("at://{did}/{path}");
 
-        indexer::index_op(conn, &mut delta_store, did, cid, record, &full_path, rkey)
-            .await?
+        indexer::index_op(conn, &mut delta_store, did, cid, record, &full_path, rkey).await?
     }
 
     db::update_repo_sync_state(conn, did, ActorSyncState::Synced).await?;

consumer/src/cmd.rs

···
 
 pub fn parse() -> Cli {
     Cli::parse()
-}
+}

consumer/src/indexer/mod.rs

···
     let expected_in_doc = did_doc.also_known_as.is_some_and(|v| {
         v.iter()
             .filter_map(|v| v.strip_prefix("at://"))
-            .find(|v| v == &expected)
-            .is_some()
+            .any(|v| v == &expected)
     });
 
     // if it isn't, set to invalid.
···
     // in theory, we can use com.atproto.identity.resolveHandle against a PDS, but that seems
     // like a way to end up with really sus handles.
     let Some(handle_did) = state.resolver.resolve_handle(&expected).await? else {
-        Ok(Some(None))
+        return Ok(Some(None));
     };
 
     // finally, check if the event did matches the handle, if not, set invalid, otherwise set the handle.

consumer/src/main.rs

···
             idxc_tx,
             resolver.clone(),
             relay_firehose,
-            indexer_opts
+            indexer_opts,
         )
         .await?;