Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[r2r] use avg_blocktime from platform/utxo coin for l2/lightning #1606

Merged
merged 2 commits into from
Jan 11, 2023
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
5 changes: 4 additions & 1 deletion mm2src/coins/lightning.rs
Original file line number Diff line number Diff line change
Expand Up @@ -153,6 +153,9 @@ impl Transaction for PaymentHash {
impl LightningCoin {
pub fn platform_coin(&self) -> &UtxoStandardCoin { &self.platform.coin }

#[inline]
fn avg_blocktime(&self) -> u64 { self.platform.avg_blocktime }

#[inline]
fn my_node_id(&self) -> String { self.channel_manager.get_our_node_id().to_string() }

Expand Down Expand Up @@ -479,7 +482,7 @@ impl LightningCoin {
}
}

fn estimate_blocks_from_duration(&self, duration: u64) -> u64 { duration / self.platform.avg_block_time }
fn estimate_blocks_from_duration(&self, duration: u64) -> u64 { duration / self.avg_blocktime() }

async fn swap_payment_instructions(
&self,
Expand Down
1 change: 0 additions & 1 deletion mm2src/coins/lightning/ln_conf.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ pub struct PlatformCoinConfirmationTargets {
pub struct LightningProtocolConf {
pub platform_coin_ticker: String,
pub network: BlockchainNetwork,
pub avg_block_time: u64,
pub confirmation_targets: PlatformCoinConfirmationTargets,
}

Expand Down
13 changes: 10 additions & 3 deletions mm2src/coins/lightning/ln_platform.rs
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,7 @@ pub struct Platform {
/// Main/testnet/signet/regtest Needed for lightning node to know which network to connect to
pub network: BlockchainNetwork,
/// The average time in seconds needed to mine a new block for the blockchain network.
pub avg_block_time: u64,
pub avg_blocktime: u64,
/// The best block height.
pub best_block_height: AtomicU64,
/// Number of blocks for every Confirmation target. This is used in the FeeEstimator.
Expand All @@ -179,17 +179,24 @@ impl Platform {
pub fn new(
coin: UtxoStandardCoin,
network: BlockchainNetwork,
avg_block_time: u64,
confirmations_targets: PlatformCoinConfirmationTargets,
) -> EnableLightningResult<Self> {
// This should never return an error since it's validated that avg_blocktime is in platform coin config in a previous step of lightning activation.
// But an error is returned here just in case.
let avg_blocktime = coin
.as_ref()
.conf
.avg_blocktime
.ok_or_else(|| EnableLightningError::Internal("`avg_blocktime` can't be None!".into()))?;

// Create an abortable system linked to the base `coin` so if the base coin is disabled,
// all spawned futures related to `LightCoin` will be aborted as well.
let abortable_system = coin.as_ref().abortable_system.create_subsystem()?;

Ok(Platform {
coin,
network,
avg_block_time,
avg_blocktime,
best_block_height: AtomicU64::new(0),
confirmations_targets,
latest_fees: LatestFees {
Expand Down
1 change: 0 additions & 1 deletion mm2src/coins/lp_coins.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2473,7 +2473,6 @@ pub enum CoinProtocol {
LIGHTNING {
platform: String,
network: BlockchainNetwork,
avg_block_time: u64,
confirmation_targets: PlatformCoinConfirmationTargets,
},
#[cfg(not(target_arch = "wasm32"))]
Expand Down
2 changes: 2 additions & 0 deletions mm2src/coins/utxo.rs
Original file line number Diff line number Diff line change
Expand Up @@ -562,6 +562,8 @@ pub struct UtxoCoinConf {
/// where the full `BIP44` address has the following structure:
/// `m/purpose'/coin_type'/account'/change/address_index`.
pub derivation_path: Option<StandardHDPathToCoin>,
/// The average time in seconds needed to mine a new block for this coin.
pub avg_blocktime: Option<u64>,
}

pub struct UtxoCoinFields {
Expand Down
4 changes: 4 additions & 0 deletions mm2src/coins/utxo/utxo_builder/utxo_conf_builder.rs
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,7 @@ impl<'a> UtxoConfBuilder<'a> {
let enable_spv_proof = self.enable_spv_proof();
let block_headers_verification_params = self.block_headers_verification_params();
let derivation_path = self.derivation_path()?;
let avg_blocktime = self.avg_blocktime();

Ok(UtxoCoinConf {
ticker: self.ticker.to_owned(),
Expand Down Expand Up @@ -123,6 +124,7 @@ impl<'a> UtxoConfBuilder<'a> {
enable_spv_proof,
block_headers_verification_params,
derivation_path,
avg_blocktime,
})
}

Expand Down Expand Up @@ -293,4 +295,6 @@ impl<'a> UtxoConfBuilder<'a> {
json::from_value(self.conf["derivation_path"].clone())
.map_to_mm(|e| UtxoConfError::ErrorDeserializingDerivationPath(e.to_string()))
}

fn avg_blocktime(&self) -> Option<u64> { self.conf["avg_blocktime"].as_u64() }
}
1 change: 1 addition & 0 deletions mm2src/coins/utxo/utxo_common_tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -123,6 +123,7 @@ pub(super) fn utxo_coin_fields_for_test(
enable_spv_proof: false,
block_headers_verification_params: None,
derivation_path: None,
avg_blocktime: None,
},
decimals: TEST_COIN_DECIMALS,
dust_amount: UTXO_DUST_AMOUNT,
Expand Down
6 changes: 6 additions & 0 deletions mm2src/coins_activation/src/l2/init_l2_error.rs
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,11 @@ pub enum InitL2Error {
platform_coin_ticker: String,
l2_ticker: String,
},
#[display(fmt = "Invalid config for platform coin: {}, error: {}", platform_coin_ticker, err)]
InvalidPlatformConfiguration {
platform_coin_ticker: String,
err: String,
},
#[display(fmt = "Layer 2 configuration parsing failed: {}", _0)]
L2ConfigParseError(String),
#[display(fmt = "Initialization task has timed out {:?}", duration)]
Expand Down Expand Up @@ -80,6 +85,7 @@ impl HttpStatusCode for InitL2Error {
InitL2Error::TaskTimedOut { .. } => StatusCode::REQUEST_TIMEOUT,
InitL2Error::L2ProtocolParseError { .. }
| InitL2Error::UnsupportedPlatformCoin { .. }
| InitL2Error::InvalidPlatformConfiguration { .. }
| InitL2Error::L2ConfigParseError(_)
| InitL2Error::Transport(_)
| InitL2Error::Internal(_) => StatusCode::INTERNAL_SERVER_ERROR,
Expand Down
25 changes: 21 additions & 4 deletions mm2src/coins_activation/src/lightning_activation.rs
Original file line number Diff line number Diff line change
Expand Up @@ -83,12 +83,10 @@ impl TryFromCoinProtocol for LightningProtocolConf {
CoinProtocol::LIGHTNING {
platform,
network,
avg_block_time,
confirmation_targets,
} => Ok(LightningProtocolConf {
platform_coin_ticker: platform,
network,
avg_block_time,
confirmation_targets,
}),
proto => MmError::err(proto),
Expand Down Expand Up @@ -153,8 +151,15 @@ pub struct LightningActivationResult {
#[derive(Clone, Debug, Display, Serialize, SerializeErrorType)]
#[serde(tag = "error_type", content = "error_data")]
pub enum LightningInitError {
CoinIsAlreadyActivated { ticker: String },
CoinIsAlreadyActivated {
ticker: String,
},
InvalidConfiguration(String),
#[display(fmt = "Error while validating {} configuration: {}", platform_coin_ticker, err)]
InvalidPlatformConfiguration {
platform_coin_ticker: String,
err: String,
},
EnableLightningError(EnableLightningError),
LightningValidationErr(LightningValidationErr),
MyBalanceError(BalanceError),
Expand All @@ -171,6 +176,13 @@ impl From<LightningInitError> for InitL2Error {
match err {
LightningInitError::CoinIsAlreadyActivated { ticker } => InitL2Error::L2IsAlreadyActivated(ticker),
LightningInitError::InvalidConfiguration(err) => InitL2Error::L2ConfigParseError(err),
LightningInitError::InvalidPlatformConfiguration {
platform_coin_ticker,
err,
} => InitL2Error::InvalidPlatformConfiguration {
platform_coin_ticker,
err,
},
LightningInitError::EnableLightningError(enable_err) => match enable_err {
EnableLightningError::RpcError(rpc_err) => InitL2Error::Transport(rpc_err),
enable_error => InitL2Error::Internal(enable_error.to_string()),
Expand Down Expand Up @@ -238,6 +250,12 @@ impl InitL2ActivationOps for LightningCoin {
LightningValidationErr::UnsupportedMode("Lightning network".into(), "segwit".into()).into(),
);
}
if platform_coin.as_ref().conf.avg_blocktime.is_none() {
return MmError::err(LightningInitError::InvalidPlatformConfiguration {
platform_coin_ticker: platform_coin.ticker().to_string(),
err: "'avg_blocktime' field is not found in platform coin config".into(),
});
}
Ok(())
}

Expand Down Expand Up @@ -323,7 +341,6 @@ async fn start_lightning(
let platform = Arc::new(Platform::new(
platform_coin.clone(),
protocol_conf.network.clone(),
protocol_conf.avg_block_time,
protocol_conf.confirmation_targets,
)?);
task_handle.update_in_progress_status(LightningInProgressStatus::GettingFeesFromRPC)?;
Expand Down
6 changes: 3 additions & 3 deletions mm2src/mm2_main/tests/mm2_tests/lightning_tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,7 @@ fn start_lightning_nodes(enable_0_confs: bool) -> (MarketMakerIt, MarketMakerIt,
"estimate_fee_mode": "ECONOMICAL",
"mm2": 1,
"required_confirmations": 0,
"avg_blocktime": 600,
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Could you use constant variable for all avg_blocktime fields in this module for same reason as #1601 (comment)

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Done

"protocol": {
"type": "UTXO"
}
Expand All @@ -84,7 +85,6 @@ fn start_lightning_nodes(enable_0_confs: bool) -> (MarketMakerIt, MarketMakerIt,
"protocol_data":{
"platform": "tBTC-TEST-segwit",
"network": "testnet",
"avg_block_time": 600,
"confirmation_targets": {
"background": 12,
"normal": 6,
Expand Down Expand Up @@ -170,6 +170,7 @@ fn test_enable_lightning() {
"estimate_fee_mode": "ECONOMICAL",
"mm2": 1,
"required_confirmations": 0,
"avg_blocktime": 600,
"protocol": {
"type": "UTXO"
}
Expand All @@ -183,7 +184,6 @@ fn test_enable_lightning() {
"protocol_data":{
"platform": "tBTC-TEST-segwit",
"network": "testnet",
"avg_block_time": 600,
"confirmation_targets": {
"background": 12,
"normal": 6,
Expand Down Expand Up @@ -744,6 +744,7 @@ fn test_sign_verify_message_lightning() {
"estimate_fee_mode": "ECONOMICAL",
"mm2": 1,
"required_confirmations": 0,
"avg_blocktime": 600,
"protocol": {
"type": "UTXO"
}
Expand All @@ -758,7 +759,6 @@ fn test_sign_verify_message_lightning() {
"protocol_data":{
"platform": "tBTC-TEST-segwit",
"network": "testnet",
"avg_block_time": 600,
"confirmation_targets": {
"background": 12,
"normal": 6,
Expand Down