use std::path::PathBuf;
use bitcoin::hashes::{sha256, Hash};
use cdk::nuts::{CurrencyUnit, PublicKey};
use cdk::Amount;
use cdk_axum::cache;
use cdk_common::common::QuoteTTL;
use config::{Config, ConfigError, File};
use serde::{Deserialize, Serialize};
#[derive(Debug, Serialize, Deserialize, Clone, PartialEq, Default)]
#[serde(rename_all = "lowercase")]
pub enum LoggingOutput {
Stderr,
File,
#[default]
Both,
}
impl std::str::FromStr for LoggingOutput {
type Err = String;
fn from_str(s: &str) -> Result<Self, Self::Err> {
match s.to_lowercase().as_str() {
"stderr" => Ok(LoggingOutput::Stderr),
"file" => Ok(LoggingOutput::File),
"both" => Ok(LoggingOutput::Both),
_ => Err(format!(
"Unknown logging output: {s}. Valid options: stdout, file, both"
)),
}
}
}
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct LoggingConfig {
#[serde(default)]
pub output: LoggingOutput,
pub console_level: Option<String>,
pub file_level: Option<String>,
}
#[derive(Clone, Serialize, Deserialize)]
pub struct Info {
pub url: String,
pub listen_host: String,
pub listen_port: u16,
pub seed: Option<String>,
pub mnemonic: Option<String>,
pub signatory_url: Option<String>,
pub signatory_certs: Option<String>,
pub input_fee_ppk: Option<u64>,
pub use_keyset_v2: Option<bool>,
pub http_cache: cache::Config,
#[serde(default)]
pub logging: LoggingConfig,
pub enable_swagger_ui: Option<bool>,
pub enable_info_page: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub quote_ttl: Option<QuoteTTL>,
}
impl Default for Info {
fn default() -> Self {
Info {
url: String::new(),
listen_host: "127.0.0.1".to_string(),
listen_port: 8091, seed: None,
mnemonic: None,
signatory_url: None,
signatory_certs: None,
input_fee_ppk: None,
use_keyset_v2: None,
http_cache: cache::Config::default(),
enable_swagger_ui: None,
enable_info_page: Some(true),
logging: LoggingConfig::default(),
quote_ttl: None,
}
}
}
impl std::fmt::Debug for Info {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mnemonic_display: String = {
if let Some(mnemonic) = self.mnemonic.as_ref() {
let hash = sha256::Hash::hash(mnemonic.as_bytes());
format!("<hashed: {hash}>")
} else {
format!("<url: {}>", self.signatory_url.clone().unwrap_or_default())
}
};
f.debug_struct("Info")
.field("url", &self.url)
.field("listen_host", &self.listen_host)
.field("listen_port", &self.listen_port)
.field("mnemonic", &mnemonic_display)
.field("input_fee_ppk", &self.input_fee_ppk)
.field("use_keyset_v2", &self.use_keyset_v2)
.field("http_cache", &self.http_cache)
.field("logging", &self.logging)
.field("enable_swagger_ui", &self.enable_swagger_ui)
.field("enable_info_page", &self.enable_info_page)
.finish()
}
}
#[derive(Debug, Serialize, Deserialize, Clone, PartialEq, Default)]
#[serde(rename_all = "lowercase")]
pub enum LnBackend {
#[default]
None,
#[cfg(feature = "cln")]
Cln,
#[cfg(feature = "lnbits")]
LNbits,
#[cfg(feature = "fakewallet")]
FakeWallet,
#[cfg(feature = "lnd")]
Lnd,
#[cfg(feature = "ldk-node")]
LdkNode,
#[cfg(feature = "grpc-processor")]
GrpcProcessor,
}
impl std::str::FromStr for LnBackend {
type Err = String;
fn from_str(s: &str) -> Result<Self, Self::Err> {
match s.to_lowercase().as_str() {
#[cfg(feature = "cln")]
"cln" => Ok(LnBackend::Cln),
#[cfg(feature = "lnbits")]
"lnbits" => Ok(LnBackend::LNbits),
#[cfg(feature = "fakewallet")]
"fakewallet" => Ok(LnBackend::FakeWallet),
#[cfg(feature = "lnd")]
"lnd" => Ok(LnBackend::Lnd),
#[cfg(feature = "ldk-node")]
"ldk-node" | "ldknode" => Ok(LnBackend::LdkNode),
#[cfg(feature = "grpc-processor")]
"grpcprocessor" => Ok(LnBackend::GrpcProcessor),
_ => Err(format!("Unknown Lightning backend: {s}")),
}
}
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Ln {
pub ln_backend: LnBackend,
pub invoice_description: Option<String>,
pub min_mint: Amount,
pub max_mint: Amount,
pub min_melt: Amount,
pub max_melt: Amount,
}
impl Default for Ln {
fn default() -> Self {
Ln {
ln_backend: LnBackend::default(),
invoice_description: None,
min_mint: 1.into(),
max_mint: 500_000.into(),
min_melt: 1.into(),
max_melt: 500_000.into(),
}
}
}
#[cfg(feature = "lnbits")]
#[derive(Clone, Serialize, Deserialize)]
pub struct LNbits {
pub admin_api_key: String,
pub invoice_api_key: String,
pub lnbits_api: String,
#[serde(default = "default_fee_percent")]
pub fee_percent: f32,
#[serde(default = "default_reserve_fee_min")]
pub reserve_fee_min: Amount,
}
#[cfg(feature = "lnbits")]
impl std::fmt::Debug for LNbits {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct("LNbits")
.field("admin_api_key", &"[REDACTED]")
.field("invoice_api_key", &"[REDACTED]")
.field("lnbits_api", &self.lnbits_api)
.field("fee_percent", &self.fee_percent)
.field("reserve_fee_min", &self.reserve_fee_min)
.finish()
}
}
#[cfg(feature = "lnbits")]
impl Default for LNbits {
fn default() -> Self {
Self {
admin_api_key: String::new(),
invoice_api_key: String::new(),
lnbits_api: String::new(),
fee_percent: 0.02,
reserve_fee_min: 2.into(),
}
}
}
#[cfg(feature = "cln")]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Cln {
pub rpc_path: PathBuf,
#[serde(default = "default_cln_bolt12")]
pub bolt12: bool,
#[serde(default)]
pub expose_private_channels: bool,
#[serde(default = "default_fee_percent")]
pub fee_percent: f32,
#[serde(default = "default_reserve_fee_min")]
pub reserve_fee_min: Amount,
}
#[cfg(feature = "cln")]
impl Default for Cln {
fn default() -> Self {
Self {
rpc_path: PathBuf::new(),
bolt12: true,
expose_private_channels: false,
fee_percent: 0.02,
reserve_fee_min: 2.into(),
}
}
}
#[cfg(feature = "cln")]
fn default_cln_bolt12() -> bool {
true
}
#[cfg(feature = "lnd")]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Lnd {
pub address: String,
pub cert_file: PathBuf,
pub macaroon_file: PathBuf,
#[serde(default = "default_fee_percent")]
pub fee_percent: f32,
#[serde(default = "default_reserve_fee_min")]
pub reserve_fee_min: Amount,
}
#[cfg(feature = "lnd")]
impl Default for Lnd {
fn default() -> Self {
Self {
address: String::new(),
cert_file: PathBuf::new(),
macaroon_file: PathBuf::new(),
fee_percent: 0.02,
reserve_fee_min: 2.into(),
}
}
}
#[cfg(feature = "ldk-node")]
#[derive(Clone, Serialize, Deserialize)]
pub struct LdkNode {
#[serde(default = "default_ldk_fee_percent")]
pub fee_percent: f32,
#[serde(default = "default_ldk_reserve_fee_min")]
pub reserve_fee_min: Amount,
pub bitcoin_network: Option<String>,
pub chain_source_type: Option<String>,
pub esplora_url: Option<String>,
pub bitcoind_rpc_host: Option<String>,
pub bitcoind_rpc_port: Option<u16>,
pub bitcoind_rpc_user: Option<String>,
pub bitcoind_rpc_password: Option<String>,
pub storage_dir_path: Option<String>,
pub log_dir_path: Option<String>,
pub ldk_node_host: Option<String>,
pub ldk_node_port: Option<u16>,
pub ldk_node_announce_addresses: Option<Vec<String>>,
pub gossip_source_type: Option<String>,
pub rgs_url: Option<String>,
#[serde(default = "default_webserver_host")]
pub webserver_host: Option<String>,
#[serde(default = "default_webserver_port")]
pub webserver_port: Option<u16>,
pub ldk_node_mnemonic: Option<String>,
}
#[cfg(feature = "ldk-node")]
impl Default for LdkNode {
fn default() -> Self {
Self {
fee_percent: default_ldk_fee_percent(),
reserve_fee_min: default_ldk_reserve_fee_min(),
bitcoin_network: None,
chain_source_type: None,
esplora_url: None,
bitcoind_rpc_host: None,
bitcoind_rpc_port: None,
bitcoind_rpc_user: None,
ldk_node_announce_addresses: None,
bitcoind_rpc_password: None,
storage_dir_path: None,
ldk_node_host: None,
log_dir_path: None,
ldk_node_port: None,
gossip_source_type: None,
rgs_url: None,
webserver_host: default_webserver_host(),
webserver_port: default_webserver_port(),
ldk_node_mnemonic: None,
}
}
}
#[cfg(feature = "ldk-node")]
impl std::fmt::Debug for LdkNode {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct("LdkNode")
.field("fee_percent", &self.fee_percent)
.field("reserve_fee_min", &self.reserve_fee_min)
.field("bitcoin_network", &self.bitcoin_network)
.field("chain_source_type", &self.chain_source_type)
.field("esplora_url", &self.esplora_url)
.field("bitcoind_rpc_host", &self.bitcoind_rpc_host)
.field("bitcoind_rpc_port", &self.bitcoind_rpc_port)
.field("bitcoind_rpc_user", &self.bitcoind_rpc_user)
.field("bitcoind_rpc_password", &"[REDACTED]")
.field("storage_dir_path", &self.storage_dir_path)
.field("log_dir_path", &self.log_dir_path)
.field("ldk_node_host", &self.ldk_node_host)
.field("ldk_node_port", &self.ldk_node_port)
.field(
"ldk_node_announce_addresses",
&self.ldk_node_announce_addresses,
)
.field("gossip_source_type", &self.gossip_source_type)
.field("rgs_url", &self.rgs_url)
.field("webserver_host", &self.webserver_host)
.field("webserver_port", &self.webserver_port)
.field("ldk_node_mnemonic", &"[REDACTED]")
.finish()
}
}
#[cfg(feature = "ldk-node")]
fn default_ldk_fee_percent() -> f32 {
0.04
}
#[cfg(feature = "ldk-node")]
fn default_ldk_reserve_fee_min() -> Amount {
4.into()
}
#[cfg(feature = "ldk-node")]
fn default_webserver_host() -> Option<String> {
Some("127.0.0.1".to_string())
}
#[cfg(feature = "ldk-node")]
fn default_webserver_port() -> Option<u16> {
Some(8091)
}
#[cfg(feature = "fakewallet")]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct FakeWalletKeysetRotation {
pub unit: CurrencyUnit,
#[serde(default)]
pub input_fee_ppk: u64,
#[serde(default = "default_keyset_version")]
pub version: String,
#[serde(default)]
pub expired: bool,
}
#[cfg(feature = "fakewallet")]
fn default_keyset_version() -> String {
"v1".to_string()
}
#[cfg(feature = "fakewallet")]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct FakeWallet {
pub supported_units: Vec<CurrencyUnit>,
pub fee_percent: f32,
pub reserve_fee_min: Amount,
#[serde(default = "default_min_delay_time")]
pub min_delay_time: u64,
#[serde(default = "default_max_delay_time")]
pub max_delay_time: u64,
#[serde(default)]
pub keyset_rotations: Vec<FakeWalletKeysetRotation>,
}
#[cfg(feature = "fakewallet")]
impl Default for FakeWallet {
fn default() -> Self {
Self {
supported_units: vec![CurrencyUnit::Sat],
fee_percent: 0.02,
reserve_fee_min: 2.into(),
min_delay_time: 1,
max_delay_time: 3,
keyset_rotations: Vec::new(),
}
}
}
#[cfg(any(feature = "cln", feature = "lnbits", feature = "lnd"))]
fn default_fee_percent() -> f32 {
0.02
}
#[cfg(any(feature = "cln", feature = "lnbits", feature = "lnd"))]
fn default_reserve_fee_min() -> Amount {
2.into()
}
#[cfg(feature = "fakewallet")]
fn default_min_delay_time() -> u64 {
1
}
#[cfg(feature = "fakewallet")]
fn default_max_delay_time() -> u64 {
3
}
#[derive(Debug, Serialize, Deserialize, Clone, PartialEq)]
pub struct GrpcProcessor {
#[serde(default)]
pub supported_units: Vec<CurrencyUnit>,
#[serde(default = "default_grpc_addr")]
pub addr: String,
#[serde(default = "default_grpc_port")]
pub port: u16,
#[serde(default)]
pub tls_dir: Option<PathBuf>,
}
impl Default for GrpcProcessor {
fn default() -> Self {
Self {
supported_units: Vec::new(),
addr: default_grpc_addr(),
port: default_grpc_port(),
tls_dir: None,
}
}
}
fn default_grpc_addr() -> String {
"127.0.0.1".to_string()
}
fn default_grpc_port() -> u16 {
50051
}
#[derive(Debug, Serialize, Deserialize, Clone, PartialEq, Default)]
#[serde(rename_all = "lowercase")]
pub enum DatabaseEngine {
#[default]
Sqlite,
Postgres,
}
impl std::str::FromStr for DatabaseEngine {
type Err = String;
fn from_str(s: &str) -> Result<Self, Self::Err> {
match s.to_lowercase().as_str() {
"sqlite" => Ok(DatabaseEngine::Sqlite),
"postgres" => Ok(DatabaseEngine::Postgres),
_ => Err(format!("Unknown database engine: {s}")),
}
}
}
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct Database {
pub engine: DatabaseEngine,
pub postgres: Option<PostgresConfig>,
}
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct AuthDatabase {
pub postgres: Option<PostgresAuthConfig>,
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PostgresAuthConfig {
pub url: String,
pub tls_mode: Option<String>,
pub max_connections: Option<usize>,
pub connection_timeout_seconds: Option<u64>,
}
impl Default for PostgresAuthConfig {
fn default() -> Self {
Self {
url: String::new(),
tls_mode: Some("disable".to_string()),
max_connections: Some(20),
connection_timeout_seconds: Some(10),
}
}
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PostgresConfig {
pub url: String,
pub tls_mode: Option<String>,
pub max_connections: Option<usize>,
pub connection_timeout_seconds: Option<u64>,
}
impl Default for PostgresConfig {
fn default() -> Self {
Self {
url: String::new(),
tls_mode: Some("disable".to_string()),
max_connections: Some(20),
connection_timeout_seconds: Some(10),
}
}
}
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq, Default)]
#[serde(rename_all = "lowercase")]
pub enum AuthType {
Clear,
Blind,
#[default]
None,
}
impl std::str::FromStr for AuthType {
type Err = String;
fn from_str(s: &str) -> Result<Self, Self::Err> {
match s.to_lowercase().as_str() {
"clear" => Ok(AuthType::Clear),
"blind" => Ok(AuthType::Blind),
"none" => Ok(AuthType::None),
_ => Err(format!("Unknown auth type: {s}")),
}
}
}
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct Auth {
#[serde(default)]
pub auth_enabled: bool,
pub openid_discovery: String,
pub openid_client_id: String,
pub mint_max_bat: u64,
#[serde(default = "default_blind")]
pub mint: AuthType,
#[serde(default)]
pub get_mint_quote: AuthType,
#[serde(default)]
pub check_mint_quote: AuthType,
#[serde(default)]
pub melt: AuthType,
#[serde(default)]
pub get_melt_quote: AuthType,
#[serde(default)]
pub check_melt_quote: AuthType,
#[serde(default = "default_blind")]
pub swap: AuthType,
#[serde(default = "default_blind")]
pub restore: AuthType,
#[serde(default)]
pub check_proof_state: AuthType,
#[serde(default = "default_blind")]
pub websocket_auth: AuthType,
}
fn default_blind() -> AuthType {
AuthType::Blind
}
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct Settings {
pub info: Info,
pub mint_info: MintInfo,
pub ln: Ln,
#[serde(default)]
pub limits: Limits,
#[cfg(feature = "cln")]
pub cln: Option<Cln>,
#[cfg(feature = "lnbits")]
pub lnbits: Option<LNbits>,
#[cfg(feature = "lnd")]
pub lnd: Option<Lnd>,
#[cfg(feature = "ldk-node")]
pub ldk_node: Option<LdkNode>,
#[cfg(feature = "fakewallet")]
pub fake_wallet: Option<FakeWallet>,
pub grpc_processor: Option<GrpcProcessor>,
pub database: Database,
pub auth_database: Option<AuthDatabase>,
#[cfg(feature = "management-rpc")]
pub mint_management_rpc: Option<MintManagementRpc>,
pub auth: Option<Auth>,
#[cfg(feature = "prometheus")]
pub prometheus: Option<Prometheus>,
}
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
#[cfg(feature = "prometheus")]
pub struct Prometheus {
pub enabled: bool,
pub address: Option<String>,
pub port: Option<u16>,
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Limits {
#[serde(default = "default_max_inputs")]
pub max_inputs: usize,
#[serde(default = "default_max_outputs")]
pub max_outputs: usize,
}
impl Default for Limits {
fn default() -> Self {
Self {
max_inputs: 1000,
max_outputs: 1000,
}
}
}
fn default_max_inputs() -> usize {
1000
}
fn default_max_outputs() -> usize {
1000
}
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct MintInfo {
pub name: String,
pub pubkey: Option<PublicKey>,
pub description: String,
pub description_long: Option<String>,
pub icon_url: Option<String>,
pub motd: Option<String>,
pub contact_nostr_public_key: Option<String>,
pub contact_email: Option<String>,
pub tos_url: Option<String>,
}
#[cfg(feature = "management-rpc")]
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
pub struct MintManagementRpc {
pub enabled: bool,
pub address: Option<String>,
pub port: Option<u16>,
pub tls_dir_path: Option<PathBuf>,
}
impl Settings {
#[must_use]
pub fn new<P>(config_file_name: Option<P>) -> Self
where
P: Into<PathBuf>,
{
let default_settings = Self::default();
let from_file = Self::new_from_default(&default_settings, config_file_name);
match from_file {
Ok(f) => f,
Err(e) => {
tracing::error!(
"Error reading config file, falling back to defaults. Error: {e:?}"
);
default_settings
}
}
}
fn new_from_default<P>(
default: &Settings,
config_file_name: Option<P>,
) -> Result<Self, ConfigError>
where
P: Into<PathBuf>,
{
let mut default_config_file_name = home::home_dir()
.ok_or(ConfigError::NotFound("Config Path".to_string()))?
.join("cashu-rs-mint");
default_config_file_name.push("config.toml");
let config: String = match config_file_name {
Some(value) => value.into().to_string_lossy().to_string(),
None => default_config_file_name.to_string_lossy().to_string(),
};
let builder = Config::builder();
let config: Config = builder
.add_source(Config::try_from(default)?)
.add_source(File::with_name(&config))
.build()?;
let settings: Settings = config.try_deserialize()?;
Ok(settings)
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_info_debug_impl() {
let info = Info {
url: "http://example.com".to_string(),
listen_host: "127.0.0.1".to_string(),
listen_port: 8080,
mnemonic: Some("test secret mnemonic phrase".to_string()),
input_fee_ppk: Some(100),
..Default::default()
};
let debug_output = format!("{info:?}");
assert!(debug_output.contains("url: \"http://example.com\""));
assert!(debug_output.contains("listen_host: \"127.0.0.1\""));
assert!(debug_output.contains("listen_port: 8080"));
assert!(!debug_output.contains("test secret mnemonic phrase"));
assert!(debug_output.contains("<hashed: "));
assert!(debug_output.contains("input_fee_ppk: Some(100)"));
}
#[test]
fn test_info_debug_with_empty_mnemonic() {
let info = Info {
url: "http://example.com".to_string(),
listen_host: "127.0.0.1".to_string(),
listen_port: 8080,
mnemonic: Some("".to_string()), enable_swagger_ui: Some(false),
..Default::default()
};
let debug_output = format!("{:?}", info);
assert!(debug_output.contains("<hashed: "));
}
#[test]
fn test_info_debug_with_special_chars() {
let info = Info {
url: "http://example.com".to_string(),
listen_host: "127.0.0.1".to_string(),
listen_port: 8080,
mnemonic: Some("特殊å—符 !@#$%^&*()".to_string()), ..Default::default()
};
let debug_output = format!("{:?}", info);
assert!(!debug_output.contains("特殊å—符 !@#$%^&*()"));
assert!(debug_output.contains("<hashed: "));
}
#[test]
fn test_env_var_only_config_all_backends() {
#[cfg(feature = "lnd")]
test_lnd_env_config();
#[cfg(feature = "cln")]
test_cln_env_config();
#[cfg(feature = "lnbits")]
test_lnbits_env_config();
#[cfg(feature = "fakewallet")]
test_fakewallet_env_config();
#[cfg(feature = "grpc-processor")]
test_grpc_processor_env_config();
#[cfg(feature = "ldk-node")]
test_ldk_node_env_config();
}
#[cfg(feature = "lnd")]
fn test_lnd_env_config() {
use std::path::PathBuf;
use std::{env, fs};
let temp_dir = env::temp_dir().join("cdk_test_env_vars");
fs::create_dir_all(&temp_dir).expect("Failed to create temp dir");
let config_path = temp_dir.join("config.toml");
let config_content = r#"
[ln]
backend = "lnd"
min_mint = 1
max_mint = 500000
min_melt = 1
max_melt = 500000
"#;
fs::write(&config_path, config_content).expect("Failed to write config file");
env::set_var(crate::env_vars::ENV_LN_BACKEND, "lnd");
env::set_var(crate::env_vars::ENV_LND_ADDRESS, "https://localhost:10009");
env::set_var(crate::env_vars::ENV_LND_CERT_FILE, "/tmp/test_tls.cert");
env::set_var(
crate::env_vars::ENV_LND_MACAROON_FILE,
"/tmp/test_admin.macaroon",
);
env::set_var(crate::env_vars::ENV_LND_FEE_PERCENT, "0.01");
env::set_var(crate::env_vars::ENV_LND_RESERVE_FEE_MIN, "4");
let mut settings = Settings::new(Some(&config_path));
settings.from_env().expect("Failed to apply env vars");
assert!(settings.lnd.is_some());
let lnd_config = settings.lnd.as_ref().unwrap();
assert_eq!(lnd_config.address, "https://localhost:10009");
assert_eq!(lnd_config.cert_file, PathBuf::from("/tmp/test_tls.cert"));
assert_eq!(
lnd_config.macaroon_file,
PathBuf::from("/tmp/test_admin.macaroon")
);
assert_eq!(lnd_config.fee_percent, 0.01);
let reserve_fee_u64: u64 = lnd_config.reserve_fee_min.into();
assert_eq!(reserve_fee_u64, 4);
env::remove_var(crate::env_vars::ENV_LN_BACKEND);
env::remove_var(crate::env_vars::ENV_LND_ADDRESS);
env::remove_var(crate::env_vars::ENV_LND_CERT_FILE);
env::remove_var(crate::env_vars::ENV_LND_MACAROON_FILE);
env::remove_var(crate::env_vars::ENV_LND_FEE_PERCENT);
env::remove_var(crate::env_vars::ENV_LND_RESERVE_FEE_MIN);
let _ = fs::remove_dir_all(&temp_dir);
}
#[cfg(feature = "cln")]
fn test_cln_env_config() {
use std::path::PathBuf;
use std::{env, fs};
let temp_dir = env::temp_dir().join("cdk_test_env_vars_cln");
fs::create_dir_all(&temp_dir).expect("Failed to create temp dir");
let config_path = temp_dir.join("config.toml");
let config_content = r#"
[ln]
backend = "cln"
min_mint = 1
max_mint = 500000
min_melt = 1
max_melt = 500000
"#;
fs::write(&config_path, config_content).expect("Failed to write config file");
env::set_var(crate::env_vars::ENV_LN_BACKEND, "cln");
env::set_var(crate::env_vars::ENV_CLN_RPC_PATH, "/tmp/lightning-rpc");
env::set_var(crate::env_vars::ENV_CLN_BOLT12, "false");
env::set_var(crate::env_vars::ENV_CLN_FEE_PERCENT, "0.01");
env::set_var(crate::env_vars::ENV_CLN_RESERVE_FEE_MIN, "4");
let mut settings = Settings::new(Some(&config_path));
settings.from_env().expect("Failed to apply env vars");
assert!(settings.cln.is_some());
let cln_config = settings.cln.as_ref().unwrap();
assert_eq!(cln_config.rpc_path, PathBuf::from("/tmp/lightning-rpc"));
assert!(!cln_config.bolt12);
assert_eq!(cln_config.fee_percent, 0.01);
let reserve_fee_u64: u64 = cln_config.reserve_fee_min.into();
assert_eq!(reserve_fee_u64, 4);
env::remove_var(crate::env_vars::ENV_LN_BACKEND);
env::remove_var(crate::env_vars::ENV_CLN_RPC_PATH);
env::remove_var(crate::env_vars::ENV_CLN_BOLT12);
env::remove_var(crate::env_vars::ENV_CLN_FEE_PERCENT);
env::remove_var(crate::env_vars::ENV_CLN_RESERVE_FEE_MIN);
let _ = fs::remove_dir_all(&temp_dir);
}
#[cfg(feature = "lnbits")]
fn test_lnbits_env_config() {
use std::{env, fs};
let temp_dir = env::temp_dir().join("cdk_test_env_vars_lnbits");
fs::create_dir_all(&temp_dir).expect("Failed to create temp dir");
let config_path = temp_dir.join("config.toml");
let config_content = r#"
[ln]
backend = "lnbits"
min_mint = 1
max_mint = 500000
min_melt = 1
max_melt = 500000
"#;
fs::write(&config_path, config_content).expect("Failed to write config file");
env::set_var(crate::env_vars::ENV_LN_BACKEND, "lnbits");
env::set_var(crate::env_vars::ENV_LNBITS_ADMIN_API_KEY, "test_admin_key");
env::set_var(
crate::env_vars::ENV_LNBITS_INVOICE_API_KEY,
"test_invoice_key",
);
env::set_var(
crate::env_vars::ENV_LNBITS_API,
"https://lnbits.example.com",
);
env::set_var(crate::env_vars::ENV_LNBITS_FEE_PERCENT, "0.02");
env::set_var(crate::env_vars::ENV_LNBITS_RESERVE_FEE_MIN, "5");
let mut settings = Settings::new(Some(&config_path));
settings.from_env().expect("Failed to apply env vars");
assert!(settings.lnbits.is_some());
let lnbits_config = settings.lnbits.as_ref().unwrap();
assert_eq!(lnbits_config.admin_api_key, "test_admin_key");
assert_eq!(lnbits_config.invoice_api_key, "test_invoice_key");
assert_eq!(lnbits_config.lnbits_api, "https://lnbits.example.com");
assert_eq!(lnbits_config.fee_percent, 0.02);
let reserve_fee_u64: u64 = lnbits_config.reserve_fee_min.into();
assert_eq!(reserve_fee_u64, 5);
env::remove_var(crate::env_vars::ENV_LN_BACKEND);
env::remove_var(crate::env_vars::ENV_LNBITS_ADMIN_API_KEY);
env::remove_var(crate::env_vars::ENV_LNBITS_INVOICE_API_KEY);
env::remove_var(crate::env_vars::ENV_LNBITS_API);
env::remove_var(crate::env_vars::ENV_LNBITS_FEE_PERCENT);
env::remove_var(crate::env_vars::ENV_LNBITS_RESERVE_FEE_MIN);
let _ = fs::remove_dir_all(&temp_dir);
}
#[cfg(feature = "fakewallet")]
fn test_fakewallet_env_config() {
use std::{env, fs};
let temp_dir = env::temp_dir().join("cdk_test_env_vars_fakewallet");
fs::create_dir_all(&temp_dir).expect("Failed to create temp dir");
let config_path = temp_dir.join("config.toml");
let config_content = r#"
[ln]
backend = "fakewallet"
min_mint = 1
max_mint = 500000
min_melt = 1
max_melt = 500000
"#;
fs::write(&config_path, config_content).expect("Failed to write config file");
env::set_var(crate::env_vars::ENV_LN_BACKEND, "fakewallet");
env::set_var(crate::env_vars::ENV_FAKE_WALLET_SUPPORTED_UNITS, "sat,msat");
env::set_var(crate::env_vars::ENV_FAKE_WALLET_FEE_PERCENT, "0.0");
env::set_var(crate::env_vars::ENV_FAKE_WALLET_RESERVE_FEE_MIN, "0");
env::set_var(crate::env_vars::ENV_FAKE_WALLET_MIN_DELAY, "0");
env::set_var(crate::env_vars::ENV_FAKE_WALLET_MAX_DELAY, "5");
let mut settings = Settings::new(Some(&config_path));
settings.from_env().expect("Failed to apply env vars");
assert!(settings.fake_wallet.is_some());
let fakewallet_config = settings.fake_wallet.as_ref().unwrap();
assert_eq!(fakewallet_config.fee_percent, 0.0);
let reserve_fee_u64: u64 = fakewallet_config.reserve_fee_min.into();
assert_eq!(reserve_fee_u64, 0);
assert_eq!(fakewallet_config.min_delay_time, 0);
assert_eq!(fakewallet_config.max_delay_time, 5);
env::remove_var(crate::env_vars::ENV_LN_BACKEND);
env::remove_var(crate::env_vars::ENV_FAKE_WALLET_SUPPORTED_UNITS);
env::remove_var(crate::env_vars::ENV_FAKE_WALLET_FEE_PERCENT);
env::remove_var(crate::env_vars::ENV_FAKE_WALLET_RESERVE_FEE_MIN);
env::remove_var(crate::env_vars::ENV_FAKE_WALLET_MIN_DELAY);
env::remove_var(crate::env_vars::ENV_FAKE_WALLET_MAX_DELAY);
let _ = fs::remove_dir_all(&temp_dir);
}
#[cfg(feature = "grpc-processor")]
fn test_grpc_processor_env_config() {
use std::{env, fs};
let temp_dir = env::temp_dir().join("cdk_test_env_vars_grpc");
fs::create_dir_all(&temp_dir).expect("Failed to create temp dir");
let config_path = temp_dir.join("config.toml");
let config_content = r#"
[ln]
backend = "grpcprocessor"
min_mint = 1
max_mint = 500000
min_melt = 1
max_melt = 500000
"#;
fs::write(&config_path, config_content).expect("Failed to write config file");
env::set_var(crate::env_vars::ENV_LN_BACKEND, "grpcprocessor");
env::set_var(
crate::env_vars::ENV_GRPC_PROCESSOR_SUPPORTED_UNITS,
"sat,msat",
);
env::set_var(crate::env_vars::ENV_GRPC_PROCESSOR_ADDRESS, "localhost");
env::set_var(crate::env_vars::ENV_GRPC_PROCESSOR_PORT, "50051");
let mut settings = Settings::new(Some(&config_path));
settings.from_env().expect("Failed to apply env vars");
assert!(settings.grpc_processor.is_some());
let grpc_config = settings.grpc_processor.as_ref().unwrap();
assert_eq!(grpc_config.addr, "localhost");
assert_eq!(grpc_config.port, 50051);
env::remove_var(crate::env_vars::ENV_LN_BACKEND);
env::remove_var(crate::env_vars::ENV_GRPC_PROCESSOR_SUPPORTED_UNITS);
env::remove_var(crate::env_vars::ENV_GRPC_PROCESSOR_ADDRESS);
env::remove_var(crate::env_vars::ENV_GRPC_PROCESSOR_PORT);
let _ = fs::remove_dir_all(&temp_dir);
}
#[cfg(feature = "ldk-node")]
fn test_ldk_node_env_config() {
use std::{env, fs};
let temp_dir = env::temp_dir().join("cdk_test_env_vars_ldk");
fs::create_dir_all(&temp_dir).expect("Failed to create temp dir");
let config_path = temp_dir.join("config.toml");
let config_content = r#"
[ln]
backend = "ldknode"
min_mint = 1
max_mint = 500000
min_melt = 1
max_melt = 500000
"#;
fs::write(&config_path, config_content).expect("Failed to write config file");
env::set_var(crate::env_vars::ENV_LN_BACKEND, "ldknode");
env::set_var(crate::env_vars::LDK_NODE_FEE_PERCENT_ENV_VAR, "0.01");
env::set_var(crate::env_vars::LDK_NODE_RESERVE_FEE_MIN_ENV_VAR, "4");
env::set_var(crate::env_vars::LDK_NODE_BITCOIN_NETWORK_ENV_VAR, "regtest");
env::set_var(
crate::env_vars::LDK_NODE_CHAIN_SOURCE_TYPE_ENV_VAR,
"esplora",
);
env::set_var(
crate::env_vars::LDK_NODE_ESPLORA_URL_ENV_VAR,
"http://localhost:3000",
);
env::set_var(
crate::env_vars::LDK_NODE_STORAGE_DIR_PATH_ENV_VAR,
"/tmp/ldk",
);
let mut settings = Settings::new(Some(&config_path));
settings.from_env().expect("Failed to apply env vars");
assert!(settings.ldk_node.is_some());
let ldk_config = settings.ldk_node.as_ref().unwrap();
assert_eq!(ldk_config.fee_percent, 0.01);
let reserve_fee_u64: u64 = ldk_config.reserve_fee_min.into();
assert_eq!(reserve_fee_u64, 4);
assert_eq!(ldk_config.bitcoin_network, Some("regtest".to_string()));
assert_eq!(ldk_config.chain_source_type, Some("esplora".to_string()));
assert_eq!(
ldk_config.esplora_url,
Some("http://localhost:3000".to_string())
);
assert_eq!(ldk_config.storage_dir_path, Some("/tmp/ldk".to_string()));
env::remove_var(crate::env_vars::ENV_LN_BACKEND);
env::remove_var(crate::env_vars::LDK_NODE_FEE_PERCENT_ENV_VAR);
env::remove_var(crate::env_vars::LDK_NODE_RESERVE_FEE_MIN_ENV_VAR);
env::remove_var(crate::env_vars::LDK_NODE_BITCOIN_NETWORK_ENV_VAR);
env::remove_var(crate::env_vars::LDK_NODE_CHAIN_SOURCE_TYPE_ENV_VAR);
env::remove_var(crate::env_vars::LDK_NODE_ESPLORA_URL_ENV_VAR);
env::remove_var(crate::env_vars::LDK_NODE_STORAGE_DIR_PATH_ENV_VAR);
let _ = fs::remove_dir_all(&temp_dir);
}
}