Skip to content
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
3 changes: 1 addition & 2 deletions lightning-liquidity/src/lsps5/event.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@ use alloc::vec::Vec;
use bitcoin::secp256k1::PublicKey;

use lightning::impl_writeable_tlv_based_enum;
use lightning::util::hash_tables::HashMap;

use super::msgs::LSPS5AppName;
use super::msgs::LSPS5Error;
Expand Down Expand Up @@ -70,7 +69,7 @@ pub enum LSPS5ServiceEvent {
/// - `"x-lsps5-timestamp"`: with the timestamp in RFC3339 format (`"YYYY-MM-DDThh:mm:ss.uuuZ"`).
/// - `"x-lsps5-signature"`: with the signature of the notification payload, signed using the LSP's node ID.
/// Other custom headers may also be included as needed.
headers: HashMap<String, String>,
Copy link
Contributor

Choose a reason for hiding this comment

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

Using a HashMap here is more convenient as the go-to reqwest::HeaderMap type offers a simply TryFrom implementation. I guess the change doesn't hurt too much.

Copy link
Collaborator Author

Choose a reason for hiding this comment

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

This is a lightning::util::hash_tables::HashMap anyway, not an std::collection::HashMap :(

headers: Vec<(String, String)>,
},
}

Expand Down
15 changes: 5 additions & 10 deletions lightning-liquidity/src/lsps5/msgs.rs
Original file line number Diff line number Diff line change
Expand Up @@ -541,34 +541,29 @@ pub struct WebhookNotification {
}

impl WebhookNotification {
/// Create a new webhook notification.
pub fn new(method: WebhookNotificationMethod) -> Self {
Self { method }
}

/// Create a webhook_registered notification.
pub fn webhook_registered() -> Self {
Self::new(WebhookNotificationMethod::LSPS5WebhookRegistered)
Self { method: WebhookNotificationMethod::LSPS5WebhookRegistered }
}

/// Create a payment_incoming notification.
pub fn payment_incoming() -> Self {
Self::new(WebhookNotificationMethod::LSPS5PaymentIncoming)
Self { method: WebhookNotificationMethod::LSPS5PaymentIncoming }
}

/// Create an expiry_soon notification.
pub fn expiry_soon(timeout: u32) -> Self {
Self::new(WebhookNotificationMethod::LSPS5ExpirySoon { timeout })
Self { method: WebhookNotificationMethod::LSPS5ExpirySoon { timeout } }
}

/// Create a liquidity_management_request notification.
pub fn liquidity_management_request() -> Self {
Self::new(WebhookNotificationMethod::LSPS5LiquidityManagementRequest)
Self { method: WebhookNotificationMethod::LSPS5LiquidityManagementRequest }
}

/// Create an onion_message_incoming notification.
pub fn onion_message_incoming() -> Self {
Self::new(WebhookNotificationMethod::LSPS5OnionMessageIncoming)
Self { method: WebhookNotificationMethod::LSPS5OnionMessageIncoming }
}
}

Expand Down
6 changes: 3 additions & 3 deletions lightning-liquidity/src/lsps5/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -629,12 +629,12 @@ where

let signature_hex = self.sign_notification(&notification, &timestamp)?;

let mut headers: HashMap<String, String> = [("Content-Type", "application/json")]
let mut headers: Vec<(String, String)> = [("Content-Type", "application/json")]
.into_iter()
.map(|(k, v)| (k.to_string(), v.to_string()))
.collect();
headers.insert("x-lsps5-timestamp".into(), timestamp.to_rfc3339());
headers.insert("x-lsps5-signature".into(), signature_hex);
headers.push(("x-lsps5-timestamp".into(), timestamp.to_rfc3339()));
headers.push(("x-lsps5-signature".into(), signature_hex));

event_queue_notifier.enqueue(LSPS5ServiceEvent::SendWebhookNotification {
counterparty_node_id,
Expand Down
15 changes: 10 additions & 5 deletions lightning-liquidity/tests/lsps5_integration_tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ use lightning::ln::functional_test_utils::{
};
use lightning::ln::msgs::Init;
use lightning::ln::peer_handler::CustomMessageHandler;
use lightning::util::hash_tables::{HashMap, HashSet};
use lightning::util::hash_tables::HashSet;
use lightning::util::test_utils::TestStore;
use lightning_liquidity::events::LiquidityEvent;
use lightning_liquidity::lsps0::ser::LSPSDateTime;
Expand Down Expand Up @@ -288,15 +288,20 @@ impl TimeProvider for MockTimeProvider {
}
}

fn extract_ts_sig(headers: &HashMap<String, String>) -> (LSPSDateTime, String) {
fn extract_ts_sig(headers: &Vec<(String, String)>) -> (LSPSDateTime, String) {
let timestamp = headers
.get("x-lsps5-timestamp")
.iter()
.find_map(|(key, value)| (key == "x-lsps5-timestamp").then(|| value))
.expect("missing x-lsps5-timestamp header")
.parse::<LSPSDateTime>()
.expect("failed to parse x-lsps5-timestamp header");

let signature =
headers.get("x-lsps5-signature").expect("missing x-lsps5-signature header").to_owned();
let signature = headers
.iter()
.find(|(key, _)| key == "x-lsps5-signature")
.expect("missing x-lsps5-signature header")
.1
.clone();
(timestamp, signature)
}

Expand Down
4 changes: 2 additions & 2 deletions lightning/src/util/anchor_channel_reserves.rs
Original file line number Diff line number Diff line change
Expand Up @@ -290,8 +290,8 @@ pub fn can_support_additional_anchor_channel<
>,
>,
>(
context: &AnchorChannelReserveContext, utxos: &[Utxo], a_channel_manager: &AChannelManagerRef,
chain_monitor: &ChainMonitorRef,
context: &AnchorChannelReserveContext, utxos: &[Utxo], a_channel_manager: AChannelManagerRef,
chain_monitor: ChainMonitorRef,
) -> bool
where
AChannelManagerRef::Target: AChannelManager,
Expand Down
Loading