feat(aggregator): add a 'SignatureProcessor' trait

Author: jpraynaud

mithril-aggregator/src/services/mod.rs

@@ -16,6 +16,8 @@ mod epoch_service;
 mod message;
 mod prover;
 mod signable_builder;
+mod signature_consumer;
+mod signature_processor;
 mod signed_entity;
 mod signer_registration;
 mod snapshotter;
@@ -30,6 +32,8 @@ pub use epoch_service::*;
 pub use message::*;
 pub use prover::*;
 pub use signable_builder::*;
+pub use signature_consumer::*;
+pub use signature_processor::*;
 pub use signed_entity::*;
 pub use signer_registration::*;
 pub use snapshotter::*;

mithril-aggregator/src/services/signature_processor.rs

@@ -0,0 +1,19 @@
+use mithril_common::StdResult;
+
+/// A signature processor which receives signature and processes them.
+#[cfg_attr(test, mockall::automock)]
+#[async_trait::async_trait]
+pub trait SignatureProcessor: Sync + Send {
+    /// Processes the signatures received from the consumer.
+    async fn process_signatures(&self) -> StdResult<()>;
+
+    /// Starts the processor, which will run indefinitely, processing signatures as they arrive.
+    async fn run(&self) -> StdResult<()> {
+        loop {
+            self.process_signatures().await?;
+        }
+    }
+
+    /// Stops the processor. This method should be called to gracefully shut down the processor.
+    async fn stop(&self) -> StdResult<()>;
+}