Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm
log tweaks
+2
-4
+2
-4
ufos/src/store.rs
+2
-4
ufos/src/store.rs
···
5
5
6
6
pub async fn receive(mut receiver: Receiver<EventBatch>) -> anyhow::Result<()> {
7
7
loop {
8
-
eprintln!("receive loop, sleeping:");
9
8
sleep(Duration::from_secs_f64(0.5)).await;
10
-
eprintln!("slept.");
11
9
if let Some(batch) = receiver.recv().await {
12
-
eprintln!("got batch");
13
10
summarize(batch)
14
11
} else {
15
12
anyhow::bail!("receive channel closed")
···
23
20
record_deletes,
24
21
account_removes,
25
22
} = batch;
23
+
let total_records: usize = records.values().map(|v| v.len()).sum();
26
24
println!(
27
-
"got batch with {} collections, {} record deletes, {} account removes",
25
+
"got batch with {total_records} records in {} collections, {} record deletes, {} account removes",
28
26
records.len(),
29
27
record_deletes.len(),
30
28
account_removes.len()