WIP

src/liquidity.rs

@@ -1,6 +1,6 @@
 use crate::logger::log_error;
 use crate::types::{ChannelManager, LiquidityManager, PeerManager};
-use crate::Error;
+use crate::{Error, UserChannelId};
 
 use lightning::ln::features::{InitFeatures, NodeFeatures};
 use lightning::ln::msgs::SocketAddress;
@@ -13,11 +13,14 @@ use lightning_liquidity::events::Event;
 use lightning_liquidity::lsps0::msgs::RawLSPSMessage;
 use lightning_liquidity::lsps2::event::LSPS2ClientEvent;
 use lightning_liquidity::lsps2::msgs::OpeningFeeParams;
+use lightning_liquidity::lsps2::utils::compute_opening_fee;
 
 use bitcoin::secp256k1::PublicKey;
 
 use tokio::sync::oneshot;
 
+use rand::Rng;
+
 use std::collections::HashMap;
 use std::ops::Deref;
 use std::sync::{Arc, Mutex};
@@ -177,17 +180,37 @@ where
 		}
 	}
 
-	pub(crate) fn lsps2_receive_to_inbound_channel(&self) -> Result<Bolt11Invoice, Error> {
+	pub(crate) fn lsps2_receive_to_inbound_channel(
+		&self,
+	) -> Result<(Bolt11Invoice, UserChannelId), Error> {
 		match self {
 			Self::None => Err(Error::LiquiditySourceUnavailable),
-			Self::LSPS2 { liquidity_manager, pending_fee_requests, pending_buy_requests } => {
+			Self::LSPS2 {
+				liquidity_manager,
+				pending_fee_requests,
+				pending_buy_requests,
+				logger,
+				..
+			} => {
+				let user_channel_id: u128 = rand::thread_rng().gen::<u128>();
 				// First, get the current opening fee from the LSP and check whether we want to
 				// proceed.
-				//
 				{
 					let (fee_request_sender, fee_request_receiver) = oneshot::channel();
-					self.pending
+					pending_fee_requests
+						.lock()
+						.unwrap()
+						.insert(user_channel_id, fee_request_sender);
+
+					let fee_response = fee_request_receiver.blocking_recv().map_err(|e| {
+						log_error!(
+							logger,
+							"Failed to handle response from liquidity service: {:?}",
+							e
+						);
+					});
 				}
+				Err(Error::LiquiditySourceUnavailable)
 			}
 		}
 	}