Skip to content

Commit 8d7184c

Browse files
committed
feat(dmq): update signer command for DMQ messages
1 parent 24e8aa5 commit 8d7184c

File tree

1 file changed

+24
-2
lines changed

1 file changed

+24
-2
lines changed

mithril-relay/src/commands/signer.rs

Lines changed: 24 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
use std::time::Duration;
1+
use std::{path::PathBuf, time::Duration};
22

33
use clap::Parser;
44
use libp2p::Multiaddr;
5-
use mithril_common::StdResult;
5+
use mithril_common::{CardanoNetwork, StdResult};
66
use slog::error;
77

88
use super::CommandContext;
@@ -22,6 +22,24 @@ pub struct SignerCommand {
2222
#[clap(long, env = "DIAL_TO")]
2323
dial_to: Option<Multiaddr>,
2424

25+
/// Path to the DMQ socket file
26+
#[clap(
27+
long,
28+
env = "DMQ_NODE_SOCKET_PATH",
29+
value_name = "PATH",
30+
default_value = "./dmq.socket"
31+
)]
32+
dmq_node_socket_path: PathBuf,
33+
34+
/// Cardano network
35+
#[clap(long, env = "NETWORK")]
36+
pub network: String,
37+
38+
/// Cardano Network Magic number
39+
/// useful for TestNet & DevNet
40+
#[clap(long, env = "NETWORK_MAGIC")]
41+
pub network_magic: Option<u64>,
42+
2543
/// Aggregator endpoint URL.
2644
#[clap(long, env = "AGGREGATOR_ENDPOINT")]
2745
aggregator_endpoint: String,
@@ -50,10 +68,14 @@ impl SignerCommand {
5068
let signature_registration_mode = &self.signature_registration_mode;
5169
let aggregator_endpoint = self.aggregator_endpoint.to_owned();
5270
let signer_repeater_delay = Duration::from_millis(self.signer_repeater_delay);
71+
let cardano_network =
72+
CardanoNetwork::from_code(self.network.to_owned(), self.network_magic)?;
5373

5474
let mut relay = SignerRelay::start(
5575
&addr,
5676
&server_port,
77+
&self.dmq_node_socket_path,
78+
&cardano_network,
5779
signer_registration_mode,
5880
signature_registration_mode,
5981
&aggregator_endpoint,

0 commit comments

Comments
 (0)