feat(aggregator): add delay on error in signature processor

Author: jpraynaud

mithril-aggregator/src/services/signature_processor.rs

@@ -1,4 +1,4 @@
-use std::sync::Arc;
+use std::{sync::Arc, time::Duration};
 
 use slog::{Logger, error, trace, warn};
 
@@ -34,6 +34,8 @@ pub struct SequentialSignatureProcessor {
 }
 
 impl SequentialSignatureProcessor {
+    const ERROR_DELAY_IN_SECONDS: Duration = Duration::from_secs(1);
+
     /// Creates a new `SignatureProcessor` instance.
     pub fn new(
         consumer: Arc<dyn SignatureConsumer>,
@@ -111,7 +113,13 @@ impl SignatureProcessor for SequentialSignatureProcessor {
 
                     return Ok(());
                 }
-                _ = self.process_signatures() => {}
+                res = self.process_signatures() => {
+                    if let Err(e) = res {
+                        error!(self.logger, "Error processing signatures"; "error" => ?e);
+                        error!(self.logger, "Sleep for {} seconds", Self::ERROR_DELAY_IN_SECONDS.as_secs());
+                        tokio::time::sleep(Self::ERROR_DELAY_IN_SECONDS).await;
+                    }
+                }
             }
         }
     }