refactor(aggregator): gate DMQ consumer behind 'future_dmq' feature

Author: jpraynaud

mithril-aggregator/Cargo.toml

@@ -14,6 +14,7 @@ default = ["jemallocator"]
 
 bundle_tls = ["reqwest/native-tls-vendored"]
 jemallocator = ["dep:tikv-jemallocator"]
+future_dmq = ["dep:mithril-dmq-node"]
 
 [dependencies]
 anyhow = { workspace = true }
@@ -29,7 +30,7 @@ mithril-cardano-node-chain = { path = "../internal/cardano-node/mithril-cardano-
 mithril-cardano-node-internal-database = { path = "../internal/cardano-node/mithril-cardano-node-internal-database" }
 mithril-cli-helper = { path = "../internal/mithril-cli-helper" }
 mithril-common = { path = "../mithril-common", features = ["full"] }
-mithril-dmq-node = { path = "../internal/mithril-dmq-node" }
+mithril-dmq-node = { path = "../internal/mithril-dmq-node", optional = true }
 mithril-doc = { path = "../internal/mithril-doc" }
 mithril-era = { path = "../internal/mithril-era" }
 mithril-metric = { path = "../internal/mithril-metric" }

mithril-aggregator/src/dependency_injection/builder/enablers/misc.rs

@@ -7,17 +7,20 @@
 use std::sync::Arc;
 use std::time::Duration;
 
+#[cfg(feature = "future_dmq")]
 use mithril_common::messages::RegisterSignatureMessageDmq;
+#[cfg(feature = "future_dmq")]
 use mithril_dmq_node::DmqConsumerPallas;
 use mithril_signed_entity_lock::SignedEntityTypeLock;
 
 use crate::database::repository::CertificateRepository;
 use crate::dependency_injection::{DependenciesBuilder, Result};
 use crate::get_dependency;
+#[cfg(feature = "future_dmq")]
+use crate::services::SignatureConsumerDmq;
 use crate::services::{
     AggregatorClient, AggregatorHTTPClient, MessageService, MithrilMessageService,
-    SequentialSignatureProcessor, SignatureConsumer, SignatureConsumerDmq, SignatureConsumerNoop,
-    SignatureProcessor,
+    SequentialSignatureProcessor, SignatureConsumer, SignatureConsumerNoop, SignatureProcessor,
 };
 impl DependenciesBuilder {
     async fn build_signed_entity_type_lock(&mut self) -> Result<Arc<SignedEntityTypeLock>> {
@@ -77,17 +80,20 @@ impl DependenciesBuilder {
 
     /// Builds a [SignatureConsumer]
     pub async fn build_signature_consumer(&mut self) -> Result<Arc<dyn SignatureConsumer>> {
-        let signature_consumer =
-            if let Some(dmq_node_socket_path) = self.configuration.dmq_node_socket_path() {
+        #[cfg(feature = "future_dmq")]
+        let signature_consumer = match self.configuration.dmq_node_socket_path() {
+            Some(dmq_node_socket_path) => {
                 let dmq_consumer = Arc::new(DmqConsumerPallas::<RegisterSignatureMessageDmq>::new(
                     dmq_node_socket_path,
                     self.configuration.get_network()?,
                     self.root_logger(),
                 ));
                 Arc::new(SignatureConsumerDmq::new(dmq_consumer)) as Arc<dyn SignatureConsumer>
-            } else {
-                Arc::new(SignatureConsumerNoop) as Arc<dyn SignatureConsumer>
-            };
+            }
+            _ => Arc::new(SignatureConsumerNoop) as Arc<dyn SignatureConsumer>,
+        };
+        #[cfg(not(feature = "future_dmq"))]
+        let signature_consumer = Arc::new(SignatureConsumerNoop) as Arc<dyn SignatureConsumer>;
 
         Ok(signature_consumer)
     }

mithril-aggregator/src/services/signature_consumer/mod.rs

@@ -1,8 +1,10 @@
+#[cfg(feature = "future_dmq")]
 mod dmq;
 mod fake;
 mod interface;
 mod noop;
 
+#[cfg(feature = "future_dmq")]
 pub use dmq::*;
 pub use fake::*;
 pub use interface::*;