From 4c0cdc7a4faa2a0dc690f3e081012cdab4440bce Mon Sep 17 00:00:00 2001
From: Timothy Quilling <teqed@shatteredsky.net>
Date: Fri, 14 Nov 2025 09:41:51 -0500
Subject: [PATCH] fix: lints

---
 .../database_writer/operations/executor.rs    |  2 +-
 .../backfill/constellation_enrichment.rs      |  5 ++---
 consumer/src/workers/backfill/repo.rs         | 22 +++++++++----------
 3 files changed, 13 insertions(+), 16 deletions(-)

diff --git a/consumer/src/database_writer/operations/executor.rs b/consumer/src/database_writer/operations/executor.rs
index fdcf380a..afb2d460 100644
--- a/consumer/src/database_writer/operations/executor.rs
+++ b/consumer/src/database_writer/operations/executor.rs
@@ -772,10 +772,10 @@ pub async fn execute_operation(
             Ok((vec![], vec![]))
         }
         DatabaseOperation::DeleteRecord {
-            at_uri: _,
             repo,
             collection,
             rkey,
+            ..
         } => {
             use crate::relay::types::CollectionType;
 
diff --git a/consumer/src/workers/backfill/constellation_enrichment.rs b/consumer/src/workers/backfill/constellation_enrichment.rs
index 2a43712c..5258a7f6 100644
--- a/consumer/src/workers/backfill/constellation_enrichment.rs
+++ b/consumer/src/workers/backfill/constellation_enrichment.rs
@@ -174,12 +174,11 @@ pub async fn enrich_from_constellation_dbfree(
 
     // STEP 4: Queue stats recalculation (async - doesn't block)
     // This counts follows we inserted and provides accurate counts
-    if let Ok(_) = index_client
+    let _ = index_client
         .recalculate_stats_async(parakeet_index::RecalcStatsAsyncReq {
             jobs: vec![format!("profile:{}", did)],
         })
-        .await
-    {}
+        .await;
 
     counter!("constellation_enrichment_success").increment(1);
 
diff --git a/consumer/src/workers/backfill/repo.rs b/consumer/src/workers/backfill/repo.rs
index 5742d9a5..5c1faa08 100644
--- a/consumer/src/workers/backfill/repo.rs
+++ b/consumer/src/workers/backfill/repo.rs
@@ -264,19 +264,17 @@ fn extract_tids_from_record(record: &RecordTypes) -> Vec<String> {
             }
 
             // Extract TID from quote embed (app.bsky.embed.record)
-            if let Some(embed_outer) = &post.embed {
-                if let crate::types::records::EmbedOuter::Bsky(embed) = embed_outer {
-                    // Check for direct record embed (quote post)
-                    if let crate::types::records::AppBskyEmbed::Record(record_embed) = embed {
-                        if let Some(tid) = extract_tid_from_uri(&record_embed.record.uri) {
-                            tids.push(tid);
-                        }
+            if let Some(crate::types::records::EmbedOuter::Bsky(embed)) = &post.embed {
+                // Check for direct record embed (quote post)
+                if let crate::types::records::AppBskyEmbed::Record(record_embed) = embed {
+                    if let Some(tid) = extract_tid_from_uri(&record_embed.record.uri) {
+                        tids.push(tid);
                     }
-                    // Check for recordWithMedia (quote post with image/video)
-                    else if let crate::types::records::AppBskyEmbed::RecordWithMedia(rwm) = embed {
-                        if let Some(tid) = extract_tid_from_uri(&rwm.record.record.uri) {
-                            tids.push(tid);
-                        }
+                }
+                // Check for recordWithMedia (quote post with image/video)
+                else if let crate::types::records::AppBskyEmbed::RecordWithMedia(rwm) = embed {
+                    if let Some(tid) = extract_tid_from_uri(&rwm.record.record.uri) {
+                        tids.push(tid);
                     }
                 }
             }
-- 
2.51.2