ptr.pet
at protocol indexer with flexible filtering, xrpc queries, and a cursor-backed event stream, built on fjall
at-protocol
atproto
indexer
rust
fjall
[backfill] add signal filter debug logging
+6
src/backfill/mod.rs
+6
src/backfill/mod.rs
···
570
}
571
572
let mut signal_seen = filter.mode != FilterMode::Signal;
573
574
for (key, cid) in leaves {
575
let val_bytes = tokio::runtime::Handle::current()
···
584
}
585
586
if !signal_seen && filter.matches_signal(collection) {
587
signal_seen = true;
588
}
589
···
659
}
660
661
if !signal_seen {
662
return Ok::<_, miette::Report>(None);
663
}
664
···
570
}
571
572
let mut signal_seen = filter.mode != FilterMode::Signal;
573
+
debug!(
574
+
"backfilling {did}: signal_seen initial={signal_seen}, mode={:?}, signals={:?}",
575
+
filter.mode, filter.signals
576
+
);
577
578
for (key, cid) in leaves {
579
let val_bytes = tokio::runtime::Handle::current()
···
588
}
589
590
if !signal_seen && filter.matches_signal(collection) {
591
+
debug!("backfill {did}: signal matched on {collection}");
592
signal_seen = true;
593
}
594
···
664
}
665
666
if !signal_seen {
667
+
debug!("backfill {did}: no signal-matching records found, discarding repo");
668
return Ok::<_, miette::Report>(None);
669
}
670