+2 -2

crates/consumer/src/backfill/mod.rs

reviewed

··· 135 135 136 136 /// returns `true` if backfill should stop. 137 137 async fn do_actor_duplicate_check(rc: &mut MultiplexedConnection, did: &str) -> bool { 138 138 - match rc.sismember(BF_DUPL_SET, &did).await { 138 138 + match rc.sismember(BF_DUPL_SET, did).await { 139 139 Ok(true) => { 140 140 tracing::info!("skipping duplicate repo {did}"); 141 141 true 142 142 } 143 143 Ok(false) => { 144 144 - if let Err(e) = rc.sadd(BF_DUPL_SET, &did).await { 144 144 + if let Err(e) = rc.sadd(BF_DUPL_SET, did).await { 145 145 tracing::error!("failed to update bf_duplicate: {e}"); 146 146 true 147 147 } else {

+2 -2

crates/consumer/src/backfill/utils.rs

reviewed

··· 195 195 } 196 196 }; 197 197 198 198 - let _ = rc.zadd(BF_REM_KEY, &pds, new_rem).await; 199 199 - let _ = rc.zadd(BF_RESET_KEY, &pds, new_reset).await; 198 198 + let _ = rc.zadd(BF_REM_KEY, pds, new_rem).await; 199 199 + let _ = rc.zadd(BF_RESET_KEY, pds, new_reset).await; 200 200 201 201 Ok(()) 202 202 }

+3 -3

crates/consumer/src/indexer/mod.rs

reviewed

··· 205 205 } 206 206 } 207 207 208 208 - let tgt_idx = self.hasher.hash_one(&did) % threads; 208 208 + let tgt_idx = self.hasher.hash_one(did) % threads; 209 209 210 210 if let Err(e) = submit[tgt_idx as usize].send(event).await { 211 211 tracing::error!("Error sending event: {e}"); ··· 272 272 273 273 // finally, check if the event did matches the handle, if not, set invalid, otherwise set the handle. 274 274 if did == &*handle_did { 275 275 - return Ok(Some(handle)); 275 275 + Ok(Some(handle)) 276 276 } else { 277 277 - return Ok(None); 277 277 + Ok(None) 278 278 } 279 279 } 280 280

+1 -1

crates/parakeet/src/xrpc/app_bsky/feed/posts.rs

reviewed

··· 96 96 }; 97 97 let skeleton = get_feed_skeleton( 98 98 &query.feed, 99 99 - &endpoint, 99 99 + endpoint, 100 100 maybe_tok.as_ref(), 101 101 query.limit, 102 102 query.cursor,

+1 -2

crates/parakeet/src/xrpc/app_bsky/unspecced/thread_v2.rs

reviewed

··· 406 406 fn labels_has_nounauth(labels: &[Label]) -> bool { 407 407 labels 408 408 .iter() 409 409 - .find(|label| label.val == "!no-unauthenticated") 410 410 - .is_some() 409 409 + .any(|label| label.val == "!no-unauthenticated") 411 410 }