feat(signer): add support for skipping the signature delayer

Author: jpraynaud

mithril-signer/src/configuration.rs

@@ -25,6 +25,13 @@ pub struct SignaturePublisherConfig {
 
     /// Delay (in milliseconds) between two separate publications done by the delayer signature publisher
     pub delayer_delay_ms: u64,
+
+    /// Whether to skip the delayer when publishing the signature
+    ///
+    /// If set to true, the signatures will be published only once:
+    /// - if the 'future_dmq` feature is used to compile, the signatures will be published only with the DMQ protocol
+    /// - if the `future_dmq` feature is not used, the signatures will be published with the regular HTTP protocol
+    pub skip_delayer: bool,
 }
 
 /// Client configuration
@@ -137,7 +144,7 @@ pub struct Configuration {
     pub preloading_refresh_interval_in_seconds: u64,
 
     /// Signature publisher configuration
-    #[example = "`{ retry_attempts: 3, retry_delay_ms: 2000, delayer_delay_ms: 10000 }`"]
+    #[example = "`{ retry_attempts: 3, retry_delay_ms: 2000, delayer_delay_ms: 10000, skip_delayer: false }`"]
     pub signature_publisher_config: SignaturePublisherConfig,
 }
 
@@ -183,6 +190,7 @@ impl Configuration {
                 retry_attempts: 1,
                 retry_delay_ms: 1,
                 delayer_delay_ms: 1,
+                skip_delayer: false,
             },
         }
     }

mithril-signer/src/dependency_injection/builder.rs

@@ -459,12 +459,20 @@ impl<'a> DependenciesBuilder<'a> {
                 },
             );
 
-            Arc::new(SignaturePublisherDelayer::new(
-                Arc::new(first_publisher),
-                Arc::new(second_publisher),
-                Duration::from_millis(self.config.signature_publisher_config.delayer_delay_ms),
-                self.root_logger(),
-            ))
+            if self.config.signature_publisher_config.skip_delayer {
+                if cfg!(feature = "future_dmq") {
+                    Arc::new(first_publisher) as Arc<dyn SignaturePublisher>
+                } else {
+                    Arc::new(second_publisher) as Arc<dyn SignaturePublisher>
+                }
+            } else {
+                Arc::new(SignaturePublisherDelayer::new(
+                    Arc::new(first_publisher),
+                    Arc::new(second_publisher),
+                    Duration::from_millis(self.config.signature_publisher_config.delayer_delay_ms),
+                    self.root_logger(),
+                )) as Arc<dyn SignaturePublisher>
+            }
         };
 
         let certifier = Arc::new(SignerCertifierService::new(

mithril-signer/src/main.rs

@@ -108,6 +108,19 @@ pub struct Args {
         default_value_t = 10_000
     )]
     signature_publisher_delayer_delay_ms: u64,
+
+    /// Whether to skip the delayer when publishing the signature
+    ///
+    /// If set to true, the signatures will be published only once:
+    /// - if the 'future_dmq` feature is used to compile, the signatures will be published only with the DMQ protocol
+    /// - if the `future_dmq` feature is not used, the signatures will be published with the regular HTTP protocol
+
+    #[clap(
+        long,
+        env = "SIGNATURE_PUBLISHER_SKIP_DELAYER",
+        default_value_t = false
+    )]
+    signature_publisher_skip_delayer: bool,
 }
 
 impl Args {
@@ -207,6 +220,10 @@ async fn main() -> StdResult<()> {
             "signature_publisher_config.delayer_delay_ms",
             args.signature_publisher_delayer_delay_ms,
         )?
+        .set_default(
+            "signature_publisher_config.skip_delayer",
+            args.signature_publisher_skip_delayer,
+        )?
         .add_source(DefaultConfiguration::default())
         .add_source(
             config::File::with_name(&format!(