From 3a469e535a56180ab5c189b55eb85c1dfb07333c Mon Sep 17 00:00:00 2001 From: phil Date: Wed, 19 Aug 2026 23:52:05 -0400 Subject: [PATCH] oop --- moots-0-counts/src/sync.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/moots-0-counts/src/sync.rs b/moots-0-counts/src/sync.rs index 4f92379..8bd29af 100644 --- a/moots-0-counts/src/sync.rs +++ b/moots-0-counts/src/sync.rs @@ -167,6 +167,7 @@ impl SimpleSyncConsumer for Moots { // then: reinsert all our follows from scratch (in same batch) let mut following_total = 0; + let mut decode_fails = 0; while let Some(chunk) = data.walk.next_chunk(4096)? { for entry in chunk { let Some((collection, rkey)) = entry.key.split_once('/') else { @@ -178,7 +179,7 @@ impl SimpleSyncConsumer for Moots { } let Ok(follow) = drisl::from_slice::(&entry.data) else { // failed to decode: ignore this record - tracing::debug!("failed to decode follow record, ignoring it"); + decode_fails += 1; continue; }; following_total += 1; @@ -197,6 +198,10 @@ impl SimpleSyncConsumer for Moots { } } + if decode_fails > 0 { + tracing::debug!(%our_did, "failed to decode {decode_fails} follow records"); + } + tracing::debug!(%our_did, "resynced"); Ok(()) } -- 2.51.2