Factor aggregation job handling to seperate state machine

cloudflare · Jan 3, 2025 · 933aaba · 933aaba
1 parent 595155c
commit 933aaba
Show file tree

Hide file tree

Showing 4 changed files with 489 additions and 310 deletions.
diff --git a/crates/daphne/src/protocol/mod.rs b/crates/daphne/src/protocol/mod.rs
@@ -11,7 +11,7 @@ pub(crate) mod report_init;
 
 /// checks if an iterator has no duplicate items, returns the ok if there are no dups or an error
 /// with the first offending item.
-fn no_duplicates<I>(iterator: I) -> Result<(), I::Item>
+pub(crate) fn no_duplicates<I>(iterator: I) -> Result<(), I::Item>
 where
     I: Iterator,
     I::Item: Eq + std::hash::Hash,

diff --git a/crates/daphne/src/roles/helper.rs b/crates/daphne/src/roles/helper.rs