+3 -3

consumer/src/backfill/downloader.rs

··· 84 85 // has the repo already been downloaded? 86 if rc.sismember(DL_DUP_KEY, &did).await.unwrap_or_default() { 87 - tracing::warn!("skipping duplicate repo {did}"); 88 continue; 89 } 90 ··· 92 match db::actor_get_statuses(&mut conn, &did).await { 93 Ok(Some((_, state))) => { 94 if state == ActorSyncState::Synced || state == ActorSyncState::Processing { 95 - tracing::warn!("skipping duplicate repo {did}"); 96 continue; 97 } 98 } ··· 206 let _ = rc.zadd(BF_REM_KEY, &pds, rem).await; 207 let _ = rc.zadd(BF_RESET_KEY, &pds, reset).await; 208 } 209 - Ok(_) => tracing::warn!(pds, "got response with no ratelimit headers."), 210 Err(e) => { 211 tracing::error!(pds, did, "failed to download repo: {e}"); 212 continue;

··· 84 85 // has the repo already been downloaded? 86 if rc.sismember(DL_DUP_KEY, &did).await.unwrap_or_default() { 87 + tracing::info!("skipping duplicate repo {did}"); 88 continue; 89 } 90 ··· 92 match db::actor_get_statuses(&mut conn, &did).await { 93 Ok(Some((_, state))) => { 94 if state == ActorSyncState::Synced || state == ActorSyncState::Processing { 95 + tracing::info!("skipping duplicate repo {did}"); 96 continue; 97 } 98 } ··· 206 let _ = rc.zadd(BF_REM_KEY, &pds, rem).await; 207 let _ = rc.zadd(BF_RESET_KEY, &pds, reset).await; 208 } 209 + Ok(_) => tracing::debug!(pds, "got response with no ratelimit headers."), 210 Err(e) => { 211 tracing::error!(pds, did, "failed to download repo: {e}"); 212 continue;

+1 -4

consumer/src/backfill/repo.rs

··· 53 54 match block { 55 CarEntry::Commit(_) => { 56 - tracing::warn!("got commit entry that was not in root") 57 } 58 CarEntry::Record(CarRecordEntry::Known(record)) => { 59 if let Some(path) = mst_nodes.remove(&cid) { ··· 169 } 170 RecordTypes::AppBskyFeedThreadgate(record) => { 171 if !at_uri_is_by(&record.post, did) { 172 - tracing::warn!("tried to create a threadgate on a post we don't control!"); 173 return Ok(()); 174 } 175 ··· 194 RecordTypes::AppBskyGraphListItem(rec) => { 195 let split_aturi = rec.list.rsplitn(4, '/').collect::<Vec<_>>(); 196 if did != split_aturi[2] { 197 - // it's also probably a bad idea to log *all* the attempts to do this... 198 - tracing::warn!("tried to create a listitem on a list we don't control!"); 199 return Ok(()); 200 } 201

··· 53 54 match block { 55 CarEntry::Commit(_) => { 56 + tracing::debug!("got commit entry that was not in root") 57 } 58 CarEntry::Record(CarRecordEntry::Known(record)) => { 59 if let Some(path) = mst_nodes.remove(&cid) { ··· 169 } 170 RecordTypes::AppBskyFeedThreadgate(record) => { 171 if !at_uri_is_by(&record.post, did) { 0 172 return Ok(()); 173 } 174 ··· 193 RecordTypes::AppBskyGraphListItem(rec) => { 194 let split_aturi = rec.list.rsplitn(4, '/').collect::<Vec<_>>(); 195 if did != split_aturi[2] { 0 0 196 return Ok(()); 197 } 198

-4

consumer/src/indexer/mod.rs

··· 640 } 641 RecordTypes::AppBskyFeedPostgate(record) => { 642 if !at_uri_is_by(&record.post, repo) { 643 - tracing::warn!("tried to create a postgate on a post we don't control!"); 644 return Ok(()); 645 } 646 ··· 670 } 671 RecordTypes::AppBskyFeedThreadgate(record) => { 672 if !at_uri_is_by(&record.post, repo) { 673 - tracing::warn!("tried to create a threadgate on a post we don't control!"); 674 return Ok(()); 675 } 676 ··· 710 } 711 RecordTypes::AppBskyGraphListItem(record) => { 712 if !at_uri_is_by(&record.list, repo) { 713 - // it's also probably a bad idea to log *all* the attempts to do this... 714 - tracing::warn!("tried to create a listitem on a list we don't control!"); 715 return Ok(()); 716 } 717

··· 640 } 641 RecordTypes::AppBskyFeedPostgate(record) => { 642 if !at_uri_is_by(&record.post, repo) { 0 643 return Ok(()); 644 } 645 ··· 669 } 670 RecordTypes::AppBskyFeedThreadgate(record) => { 671 if !at_uri_is_by(&record.post, repo) { 0 672 return Ok(()); 673 } 674 ··· 708 } 709 RecordTypes::AppBskyGraphListItem(record) => { 710 if !at_uri_is_by(&record.list, repo) { 0 0 711 return Ok(()); 712 } 713