Merge pull request #2862 from input-output-hk/jpraynaud/2833-activate-future-dmq

feat: activate DMQ protocol

Author: jpraynaud

.github/workflows/ci.yml

@@ -184,9 +184,9 @@ jobs:
 
         include:
           - os: ubuntu-24.04
-            test-args: --features full,unstable,future_dmq --workspace
+            test-args: --features full,unstable --workspace
           - os: ubuntu-24.04-arm
-            test-args: --features full,unstable,future_dmq --workspace
+            test-args: --features full,unstable --workspace
           # Exclude nodes not officially supported on Windows and macOS (only mithril-client is supported)
           - os: macos-14
             test-args: >
@@ -392,6 +392,14 @@ jobs:
         extra_args: ["--aggregate-signature-type=Concatenation"]
 
         include:
+          # Include a test for partial decentralization with leader/follower signer registration and P2P signature registration with fake DMQ node
+          - mode: "leader-follower"
+            era: ${{ fromJSON(needs.build-ubuntu.outputs.eras)[0] }}
+            next_era: [""]
+            cardano_node_version: "10.5.1"
+            hard_fork_latest_era_at_epoch: 0
+            run_id: "#1"
+            extra_args: "--number-of-aggregators=2 --use-relays --relay-signer-registration-mode=passthrough --relay-signature-registration-mode=p2p --aggregate-signature-type=Concatenation --use-dmq --dmq-node-flavor=fake"
           # Include a test for partial decentralization with leader/follower signer registration and P2P signature registration
           - mode: "leader-follower"
             era: ${{ fromJSON(needs.build-ubuntu.outputs.eras)[0] }}

CHANGELOG.md

@@ -23,6 +23,8 @@ As a minor extension, we have adopted a slightly different versioning convention
 
   - **BREAKING**: Progress bars and spinners of the client CLI are now outputted to stderr instead of stdout.
 
+- Support for DMQ protocol in the signer, aggregator and relay.
+
 - Support for removal of `cardano_transactions_signing_config` from the diffused mithril network configuration.
 
 - Decentralization of the configuration parameters of Mithril networks:

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-cardano-node-chain"
-version = "0.1.11"
+version = "0.1.12"
 authors.workspace = true
 documentation.workspace = true
 edition.workspace = true
@@ -14,11 +14,11 @@ async-trait = { workspace = true }
 hex = { workspace = true }
 mithril-common = { path = "../../../mithril-common" }
 nom = "8.0.0"
-pallas-addresses = { version = "0.33.0" }
-pallas-codec = { version = "0.33.0" }
-pallas-network = { version = "0.33.0" }
-pallas-primitives = { version = "0.33.0" }
-pallas-traverse = { version = "0.33.0" }
+pallas-addresses = { version = "0.34.0" }
+pallas-codec = { version = "0.34.0" }
+pallas-network = { version = "0.34.0" }
+pallas-primitives = { version = "0.34.0" }
+pallas-traverse = { version = "0.34.0" }
 rand_core = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
@@ -33,7 +33,7 @@ kes-summed-ed25519 = { version = "0.2.1", features = [
     "sk_clone_enabled",
 ] }
 mockall = { workspace = true }
-pallas-crypto = "0.33.0"
+pallas-crypto = "0.34.0"
 slog-async = { workspace = true }
 slog-term = { workspace = true }
 tokio = { workspace = true, features = ["macros"] }

internal/cardano-node/mithril-cardano-node-chain/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "mithril-dmq"
 description = "Mechanisms to publish and consume messages of a 'Decentralized Message Queue network' through a DMQ node"
-version = "0.1.15"
+version = "0.1.16"
 authors.workspace = true
 documentation.workspace = true
 edition.workspace = true
@@ -21,8 +21,8 @@ bincode = { version = "2.0.1" }
 blake2 = "0.10.6"
 mithril-cardano-node-chain = { path = "../cardano-node/mithril-cardano-node-chain" }
 mithril-common = { path = "../../mithril-common" }
-pallas-codec = { git = "https://github.com/txpipe/pallas.git", branch = "main" }
-pallas-network = { git = "https://github.com/txpipe/pallas.git", branch = "main" }
+pallas-codec = { version = "0.34.0" }
+pallas-network = { version = "0.34.0" }
 serde = { workspace = true }
 serde_bytes = "0.11.19"
 slog = { workspace = true }

internal/mithril-dmq/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-aggregator"
-version = "0.7.96"
+version = "0.8.0"
 description = "A Mithril Aggregator server"
 authors = { workspace = true }
 edition = { workspace = true }
@@ -14,7 +14,6 @@ default = ["jemallocator"]
 
 bundle_tls = ["reqwest/native-tls-vendored"]
 jemallocator = ["dep:tikv-jemallocator"]
-future_dmq = ["dep:mithril-dmq"]
 
 [dependencies]
 anyhow = { workspace = true }
@@ -31,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" }
-mithril-dmq = { path = "../internal/mithril-dmq", optional = true }
+mithril-dmq = { path = "../internal/mithril-dmq" }
 mithril-doc = { path = "../internal/mithril-doc" }
 mithril-era = { path = "../internal/mithril-era" }
 mithril-metric = { path = "../internal/mithril-metric" }