very fast at protocol indexer with flexible filtering, xrpc queries, cursor-backed event stream, and more, built on fjall
rust
fjall
at-protocol
atproto
indexer
[relay] log sync failure errors with debug instead of warn
+7
-9
+7
-9
src/ingest/relay.rs
+7
-9
src/ingest/relay.rs
···
606
606
miette::bail!("can't get pds host???");
607
607
};
608
608
609
-
if expected.as_str() == source_host {
610
-
Ok(AuthorityOutcome::WasStale)
611
-
} else {
612
-
Ok(AuthorityOutcome::WrongHost { expected })
613
-
}
609
+
Ok((expected.as_str() == source_host)
610
+
.then_some(AuthorityOutcome::WasStale)
611
+
.unwrap_or(AuthorityOutcome::WrongHost { expected }))
614
612
}
615
613
616
614
fn refresh_doc(&mut self, did: &Did, repo_state: &mut RepoState) -> Result<()> {
···
645
643
}
646
644
Err(CommitValidationError::SigFailure) => {}
647
645
Err(e) => {
648
-
warn!(err = %e, "commit rejected");
646
+
debug!(err = %e, "commit rejected");
649
647
return Ok(None);
650
648
}
651
649
}
···
655
653
match self.vctx.validate_commit(commit, repo_state, key.as_ref()) {
656
654
Ok(v) => Ok(Some(v)),
657
655
Err(e) => {
658
-
warn!(err = %e, "commit rejected after key refresh");
656
+
debug!(err = %e, "commit rejected after key refresh");
659
657
Ok(None)
660
658
}
661
659
}
···
672
670
Ok(v) => return Ok(Some(v)),
673
671
Err(SyncValidationError::SigFailure) => {}
674
672
Err(e) => {
675
-
warn!(err = %e, "sync rejected");
673
+
debug!(err = %e, "sync rejected");
676
674
return Ok(None);
677
675
}
678
676
}
···
682
680
match self.vctx.validate_sync(sync, key.as_ref()) {
683
681
Ok(v) => Ok(Some(v)),
684
682
Err(e) => {
685
-
warn!(err = %e, "sync rejected after key refresh");
683
+
debug!(err = %e, "sync rejected after key refresh");
686
684
Ok(None)
687
685
}
688
686
}