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
[ingest] use full network cfg, oops
+10
-2
+10
-2
src/ingest/mod.rs
+10
-2
src/ingest/mod.rs
···
15
15
pub struct Ingestor {
16
16
state: Arc<AppState>,
17
17
relay_host: SmolStr,
18
+
full_network: bool,
18
19
}
19
20
20
21
impl Ingestor {
21
-
pub fn new(state: Arc<AppState>, relay_host: SmolStr, _full_network: bool) -> Self {
22
-
Self { state, relay_host }
22
+
pub fn new(state: Arc<AppState>, relay_host: SmolStr, full_network: bool) -> Self {
23
+
Self {
24
+
state,
25
+
relay_host,
26
+
full_network,
27
+
}
23
28
}
24
29
25
30
pub async fn run(mut self) -> Result<()> {
···
122
127
}
123
128
124
129
async fn should_process(&self, did: &Did<'_>) -> Result<bool> {
130
+
if self.full_network {
131
+
return Ok(true);
132
+
}
125
133
let did_key = keys::repo_key(did);
126
134
Db::contains_key(self.state.db.repos.clone(), did_key).await
127
135
}