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

Support default external input parsers #614

Merged
merged 3 commits into from
Dec 20, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion cli/Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion lib/Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
Expand Up @@ -512,6 +512,7 @@ typedef struct wire_cst_config {
uint64_t *zero_conf_max_amount_sat;
struct wire_cst_list_prim_u_8_strict *breez_api_key;
struct wire_cst_list_external_input_parser *external_input_parsers;
bool use_default_external_input_parsers;
} wire_cst_config;

typedef struct wire_cst_connect_request {
Expand Down
1 change: 1 addition & 0 deletions lib/bindings/src/breez_sdk_liquid.udl
Original file line number Diff line number Diff line change
Expand Up @@ -335,6 +335,7 @@ dictionary Config {
string? breez_api_key;
string? cache_dir;
u64? zero_conf_max_amount_sat;
boolean use_default_external_input_parsers = true;
sequence<ExternalInputParser>? external_input_parsers = null;
};

Expand Down
2 changes: 1 addition & 1 deletion lib/core/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ lwk_wollet = { git = "https://github.com/dangeross/lwk", branch = "savage-full-s
#lwk_wollet = "0.7.0"
rusqlite = { version = "0.31", features = ["backup", "bundled"] }
rusqlite_migration = "1.0"
sdk-common = { git = "https://github.com/breez/breez-sdk", rev = "e537feb8ed134bc3c7af5196e10a0a189dd36ac7", features = ["liquid"] }
sdk-common = { git = "https://github.com/breez/breez-sdk", rev = "2208dd5530908d5cf7b607f34f80155669ab299b", features = ["liquid"] }
serde = { version = "1.0.197", features = ["derive"] }
serde_json = "1.0.116"
strum = "0.25"
Expand Down
11 changes: 11 additions & 0 deletions lib/core/src/frb_generated.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2376,6 +2376,7 @@ impl SseDecode for crate::model::Config {
let mut var_breezApiKey = <Option<String>>::sse_decode(deserializer);
let mut var_externalInputParsers =
<Option<Vec<crate::bindings::ExternalInputParser>>>::sse_decode(deserializer);
let mut var_useDefaultExternalInputParsers = <bool>::sse_decode(deserializer);
return crate::model::Config {
liquid_electrum_url: var_liquidElectrumUrl,
bitcoin_electrum_url: var_bitcoinElectrumUrl,
Expand All @@ -2388,6 +2389,7 @@ impl SseDecode for crate::model::Config {
zero_conf_max_amount_sat: var_zeroConfMaxAmountSat,
breez_api_key: var_breezApiKey,
external_input_parsers: var_externalInputParsers,
use_default_external_input_parsers: var_useDefaultExternalInputParsers,
};
}
}
Expand Down Expand Up @@ -4601,6 +4603,9 @@ impl flutter_rust_bridge::IntoDart for crate::model::Config {
self.zero_conf_max_amount_sat.into_into_dart().into_dart(),
self.breez_api_key.into_into_dart().into_dart(),
self.external_input_parsers.into_into_dart().into_dart(),
self.use_default_external_input_parsers
.into_into_dart()
.into_dart(),
]
.into_dart()
}
Expand Down Expand Up @@ -6680,6 +6685,7 @@ impl SseEncode for crate::model::Config {
self.external_input_parsers,
serializer,
);
<bool>::sse_encode(self.use_default_external_input_parsers, serializer);
}
}

Expand Down Expand Up @@ -8774,6 +8780,9 @@ mod io {
zero_conf_max_amount_sat: self.zero_conf_max_amount_sat.cst_decode(),
breez_api_key: self.breez_api_key.cst_decode(),
external_input_parsers: self.external_input_parsers.cst_decode(),
use_default_external_input_parsers: self
.use_default_external_input_parsers
.cst_decode(),
}
}
}
Expand Down Expand Up @@ -10231,6 +10240,7 @@ mod io {
zero_conf_max_amount_sat: core::ptr::null_mut(),
breez_api_key: core::ptr::null_mut(),
external_input_parsers: core::ptr::null_mut(),
use_default_external_input_parsers: Default::default(),
}
}
}
Expand Down Expand Up @@ -12268,6 +12278,7 @@ mod io {
zero_conf_max_amount_sat: *mut u64,
breez_api_key: *mut wire_cst_list_prim_u_8_strict,
external_input_parsers: *mut wire_cst_list_external_input_parser,
use_default_external_input_parsers: bool,
}
#[repr(C)]
#[derive(Clone, Copy)]
Expand Down
25 changes: 25 additions & 0 deletions lib/core/src/model.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ use serde::{Deserialize, Serialize};
use strum_macros::{Display, EnumString};

use crate::error::{PaymentError, SdkError, SdkResult};
use crate::prelude::DEFAULT_EXTERNAL_INPUT_PARSERS;
use crate::receive_swap::{
DEFAULT_ZERO_CONF_MAX_SAT, DEFAULT_ZERO_CONF_MIN_FEE_RATE_MAINNET,
DEFAULT_ZERO_CONF_MIN_FEE_RATE_TESTNET,
Expand Down Expand Up @@ -57,6 +58,10 @@ pub struct Config {
/// is not recognized. See [ExternalInputParser] for more details on how to configure
/// external parsing.
pub external_input_parsers: Option<Vec<ExternalInputParser>>,
/// The SDK includes some default external input parsers
/// ([DEFAULT_EXTERNAL_INPUT_PARSERS](crate::sdk::DEFAULT_EXTERNAL_INPUT_PARSERS)).
/// Set this to false in order to prevent their use.
pub use_default_external_input_parsers: bool,
}

impl Config {
Expand All @@ -73,6 +78,7 @@ impl Config {
zero_conf_max_amount_sat: None,
breez_api_key: Some(breez_api_key),
external_input_parsers: None,
use_default_external_input_parsers: true,
}
}

Expand All @@ -89,6 +95,7 @@ impl Config {
zero_conf_max_amount_sat: None,
breez_api_key,
external_input_parsers: None,
use_default_external_input_parsers: true,
danielgranhao marked this conversation as resolved.
Show resolved Hide resolved
}
}

Expand Down Expand Up @@ -121,6 +128,24 @@ impl Config {
LiquidNetwork::Testnet => None,
}
}

pub(crate) fn get_all_external_input_parsers(&self) -> Vec<ExternalInputParser> {
let mut external_input_parsers = Vec::new();
if self.use_default_external_input_parsers {
let default_parsers = DEFAULT_EXTERNAL_INPUT_PARSERS
.iter()
.map(|(id, regex, url)| ExternalInputParser {
provider_id: id.to_string(),
input_regex: regex.to_string(),
parser_url: url.to_string(),
})
.collect::<Vec<_>>();
external_input_parsers.extend(default_parsers);
}
external_input_parsers.extend(self.external_input_parsers.clone().unwrap_or_default());

external_input_parsers
}
}

/// Network chosen for this Liquid SDK instance. Note that it represents both the Liquid and the
Expand Down
20 changes: 16 additions & 4 deletions lib/core/src/sdk.rs
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,14 @@ pub const DEFAULT_DATA_DIR: &str = ".data";
/// Number of blocks to monitor a swap after its timeout block height
pub const CHAIN_SWAP_MONITORING_PERIOD_BITCOIN_BLOCKS: u32 = 4320;

/// A list of external input parsers that are used by default.
/// To opt-out, set `use_default_external_input_parsers` in [Config] to false.
pub const DEFAULT_EXTERNAL_INPUT_PARSERS: &[(&str, &str, &str)] = &[(
danielgranhao marked this conversation as resolved.
Show resolved Hide resolved
"picknpay",
"(.*)(za.co.electrum.picknpay)(.*)",
"https://cryptoqr.net/.well-known/lnurlp/<input>",
)];

pub struct LiquidSdk {
pub(crate) config: Config,
pub(crate) onchain_wallet: Arc<dyn OnchainWallet>,
Expand All @@ -72,6 +80,7 @@ pub struct LiquidSdk {
pub(crate) receive_swap_handler: ReceiveSwapHandler,
pub(crate) chain_swap_handler: Arc<ChainSwapHandler>,
pub(crate) buy_bitcoin_service: Arc<dyn BuyBitcoinApi>,
pub(crate) external_input_parsers: Vec<ExternalInputParser>,
}

impl LiquidSdk {
Expand Down Expand Up @@ -216,6 +225,8 @@ impl LiquidSdk {
let buy_bitcoin_service =
Arc::new(BuyBitcoinService::new(config.clone(), breez_server.clone()));

let external_input_parsers = config.get_all_external_input_parsers();

let sdk = Arc::new(LiquidSdk {
config: config.clone(),
onchain_wallet,
Expand All @@ -234,6 +245,7 @@ impl LiquidSdk {
receive_swap_handler,
chain_swap_handler,
buy_bitcoin_service,
external_input_parsers,
});
Ok(sdk)
}
Expand Down Expand Up @@ -2553,8 +2565,8 @@ impl LiquidSdk {
SuccessAction::Aes { data } => {
let PaymentDetails::Lightning { preimage, .. } = &payment.details else {
return Err(LnUrlPayError::Generic {
err: format!("Invalid payment type: expected type `PaymentDetails::Lightning`, got payment details {:?}.", payment.details),
});
err: format!("Invalid payment type: expected type `PaymentDetails::Lightning`, got payment details {:?}.", payment.details),
});
};

let preimage_str = preimage.clone().ok_or(LnUrlPayError::Generic {
Expand Down Expand Up @@ -2764,8 +2776,8 @@ impl LiquidSdk {
});
}

let external_parsers = &self.config.external_input_parsers;
parse(input, external_parsers.as_deref())
let external_parsers = &self.external_input_parsers;
parse(input, Some(external_parsers))
.await
.map_err(|e| PaymentError::generic(&e.to_string()))
}
Expand Down
1 change: 1 addition & 0 deletions lib/core/src/test_utils/sdk.rs
Original file line number Diff line number Diff line change
Expand Up @@ -109,5 +109,6 @@ pub(crate) fn new_liquid_sdk_with_chain_services(
receive_swap_handler,
chain_swap_handler,
buy_bitcoin_service,
external_input_parsers: Vec::new(),
})
}
8 changes: 6 additions & 2 deletions packages/dart/lib/src/frb_generated.dart
Original file line number Diff line number Diff line change
Expand Up @@ -1693,7 +1693,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
Config dco_decode_config(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 11) throw Exception('unexpected arr length: expect 11 but see ${arr.length}');
if (arr.length != 12) throw Exception('unexpected arr length: expect 12 but see ${arr.length}');
return Config(
liquidElectrumUrl: dco_decode_String(arr[0]),
bitcoinElectrumUrl: dco_decode_String(arr[1]),
Expand All @@ -1706,6 +1706,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
zeroConfMaxAmountSat: dco_decode_opt_box_autoadd_u_64(arr[8]),
breezApiKey: dco_decode_opt_String(arr[9]),
externalInputParsers: dco_decode_opt_list_external_input_parser(arr[10]),
useDefaultExternalInputParsers: dco_decode_bool(arr[11]),
);
}

Expand Down Expand Up @@ -3615,6 +3616,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
var var_zeroConfMaxAmountSat = sse_decode_opt_box_autoadd_u_64(deserializer);
var var_breezApiKey = sse_decode_opt_String(deserializer);
var var_externalInputParsers = sse_decode_opt_list_external_input_parser(deserializer);
var var_useDefaultExternalInputParsers = sse_decode_bool(deserializer);
return Config(
liquidElectrumUrl: var_liquidElectrumUrl,
bitcoinElectrumUrl: var_bitcoinElectrumUrl,
Expand All @@ -3626,7 +3628,8 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
zeroConfMinFeeRateMsat: var_zeroConfMinFeeRateMsat,
zeroConfMaxAmountSat: var_zeroConfMaxAmountSat,
breezApiKey: var_breezApiKey,
externalInputParsers: var_externalInputParsers);
externalInputParsers: var_externalInputParsers,
useDefaultExternalInputParsers: var_useDefaultExternalInputParsers);
}

@protected
Expand Down Expand Up @@ -5695,6 +5698,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
sse_encode_opt_box_autoadd_u_64(self.zeroConfMaxAmountSat, serializer);
sse_encode_opt_String(self.breezApiKey, serializer);
sse_encode_opt_list_external_input_parser(self.externalInputParsers, serializer);
sse_encode_bool(self.useDefaultExternalInputParsers, serializer);
}

@protected
Expand Down
4 changes: 4 additions & 0 deletions packages/dart/lib/src/frb_generated.io.dart
Original file line number Diff line number Diff line change
Expand Up @@ -2212,6 +2212,7 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
wireObj.zero_conf_max_amount_sat = cst_encode_opt_box_autoadd_u_64(apiObj.zeroConfMaxAmountSat);
wireObj.breez_api_key = cst_encode_opt_String(apiObj.breezApiKey);
wireObj.external_input_parsers = cst_encode_opt_list_external_input_parser(apiObj.externalInputParsers);
wireObj.use_default_external_input_parsers = cst_encode_bool(apiObj.useDefaultExternalInputParsers);
}

@protected
Expand Down Expand Up @@ -6070,6 +6071,9 @@ final class wire_cst_config extends ffi.Struct {
external ffi.Pointer<wire_cst_list_prim_u_8_strict> breez_api_key;

external ffi.Pointer<wire_cst_list_external_input_parser> external_input_parsers;

@ffi.Bool()
external bool use_default_external_input_parsers;
}

final class wire_cst_connect_request extends ffi.Struct {
Expand Down
12 changes: 10 additions & 2 deletions packages/dart/lib/src/model.dart
Original file line number Diff line number Diff line change
Expand Up @@ -146,6 +146,11 @@ class Config {
/// external parsing.
final List<ExternalInputParser>? externalInputParsers;

/// The SDK includes some default external input parsers
/// ([DEFAULT_EXTERNAL_INPUT_PARSERS](crate::sdk::DEFAULT_EXTERNAL_INPUT_PARSERS)).
/// Set this to false in order to prevent their use.
final bool useDefaultExternalInputParsers;

const Config({
required this.liquidElectrumUrl,
required this.bitcoinElectrumUrl,
Expand All @@ -158,6 +163,7 @@ class Config {
this.zeroConfMaxAmountSat,
this.breezApiKey,
this.externalInputParsers,
required this.useDefaultExternalInputParsers,
});

@override
Expand All @@ -172,7 +178,8 @@ class Config {
zeroConfMinFeeRateMsat.hashCode ^
zeroConfMaxAmountSat.hashCode ^
breezApiKey.hashCode ^
externalInputParsers.hashCode;
externalInputParsers.hashCode ^
useDefaultExternalInputParsers.hashCode;

@override
bool operator ==(Object other) =>
Expand All @@ -189,7 +196,8 @@ class Config {
zeroConfMinFeeRateMsat == other.zeroConfMinFeeRateMsat &&
zeroConfMaxAmountSat == other.zeroConfMaxAmountSat &&
breezApiKey == other.breezApiKey &&
externalInputParsers == other.externalInputParsers;
externalInputParsers == other.externalInputParsers &&
useDefaultExternalInputParsers == other.useDefaultExternalInputParsers;
}

/// An argument when calling [crate::sdk::LiquidSdk::connect].
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4570,6 +4570,9 @@ final class wire_cst_config extends ffi.Struct {
external ffi.Pointer<wire_cst_list_prim_u_8_strict> breez_api_key;

external ffi.Pointer<wire_cst_list_external_input_parser> external_input_parsers;

@ffi.Bool()
external bool use_default_external_input_parsers;
}

final class wire_cst_connect_request extends ffi.Struct {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -248,6 +248,7 @@ fun asConfig(config: ReadableMap): Config? {
"network",
"paymentTimeoutSec",
"zeroConfMinFeeRateMsat",
"useDefaultExternalInputParsers",
),
)
) {
Expand All @@ -272,6 +273,7 @@ fun asConfig(config: ReadableMap): Config? {
} else {
null
}
val useDefaultExternalInputParsers = config.getBoolean("useDefaultExternalInputParsers")
val externalInputParsers =
if (hasNonNullKey(config, "externalInputParsers")) {
config.getArray("externalInputParsers")?.let {
Expand All @@ -291,6 +293,7 @@ fun asConfig(config: ReadableMap): Config? {
breezApiKey,
cacheDir,
zeroConfMaxAmountSat,
useDefaultExternalInputParsers,
externalInputParsers,
)
}
Expand All @@ -307,6 +310,7 @@ fun readableMapOf(config: Config): ReadableMap =
"breezApiKey" to config.breezApiKey,
"cacheDir" to config.cacheDir,
"zeroConfMaxAmountSat" to config.zeroConfMaxAmountSat,
"useDefaultExternalInputParsers" to config.useDefaultExternalInputParsers,
"externalInputParsers" to config.externalInputParsers?.let { readableArrayOf(it) },
)

Expand Down
6 changes: 5 additions & 1 deletion packages/react-native/ios/BreezSDKLiquidMapper.swift
Original file line number Diff line number Diff line change
Expand Up @@ -328,12 +328,15 @@ enum BreezSDKLiquidMapper {
}
zeroConfMaxAmountSat = zeroConfMaxAmountSatTmp
}
guard let useDefaultExternalInputParsers = config["useDefaultExternalInputParsers"] as? Bool else {
throw SdkError.Generic(message: errMissingMandatoryField(fieldName: "useDefaultExternalInputParsers", typeName: "Config"))
}
var externalInputParsers: [ExternalInputParser]?
if let externalInputParsersTmp = config["externalInputParsers"] as? [[String: Any?]] {
externalInputParsers = try asExternalInputParserList(arr: externalInputParsersTmp)
}

return Config(liquidElectrumUrl: liquidElectrumUrl, bitcoinElectrumUrl: bitcoinElectrumUrl, mempoolspaceUrl: mempoolspaceUrl, workingDir: workingDir, network: network, paymentTimeoutSec: paymentTimeoutSec, zeroConfMinFeeRateMsat: zeroConfMinFeeRateMsat, breezApiKey: breezApiKey, cacheDir: cacheDir, zeroConfMaxAmountSat: zeroConfMaxAmountSat, externalInputParsers: externalInputParsers)
return Config(liquidElectrumUrl: liquidElectrumUrl, bitcoinElectrumUrl: bitcoinElectrumUrl, mempoolspaceUrl: mempoolspaceUrl, workingDir: workingDir, network: network, paymentTimeoutSec: paymentTimeoutSec, zeroConfMinFeeRateMsat: zeroConfMinFeeRateMsat, breezApiKey: breezApiKey, cacheDir: cacheDir, zeroConfMaxAmountSat: zeroConfMaxAmountSat, useDefaultExternalInputParsers: useDefaultExternalInputParsers, externalInputParsers: externalInputParsers)
}

static func dictionaryOf(config: Config) -> [String: Any?] {
Expand All @@ -348,6 +351,7 @@ enum BreezSDKLiquidMapper {
"breezApiKey": config.breezApiKey == nil ? nil : config.breezApiKey,
"cacheDir": config.cacheDir == nil ? nil : config.cacheDir,
"zeroConfMaxAmountSat": config.zeroConfMaxAmountSat == nil ? nil : config.zeroConfMaxAmountSat,
"useDefaultExternalInputParsers": config.useDefaultExternalInputParsers,
"externalInputParsers": config.externalInputParsers == nil ? nil : arrayOf(externalInputParserList: config.externalInputParsers!),
]
}
Expand Down
Loading
Loading