@@ -13,10 +13,10 @@ use lightning::ln::channelmanager::MIN_FINAL_CLTV_EXPIRY_DELTA;
13
13
use lightning:: ln:: msgs:: SocketAddress ;
14
14
use lightning:: routing:: router:: { RouteHint , RouteHintHop } ;
15
15
use lightning_invoice:: { Bolt11Invoice , Bolt11InvoiceDescription , InvoiceBuilder , RoutingFees } ;
16
- use lightning_liquidity:: events:: Event ;
17
- use lightning_liquidity:: lsps0:: ser:: RequestId ;
16
+ use lightning_liquidity:: events:: LiquidityEvent ;
17
+ use lightning_liquidity:: lsps0:: ser:: LSPSRequestId ;
18
18
use lightning_liquidity:: lsps2:: event:: LSPS2ClientEvent ;
19
- use lightning_liquidity:: lsps2:: msgs:: OpeningFeeParams ;
19
+ use lightning_liquidity:: lsps2:: msgs:: LSPS2OpeningFeeParams ;
20
20
use lightning_liquidity:: lsps2:: utils:: compute_opening_fee;
21
21
22
22
use bitcoin:: hashes:: { sha256, Hash } ;
@@ -35,8 +35,8 @@ struct LSPS2Service {
35
35
address : SocketAddress ,
36
36
node_id : PublicKey ,
37
37
token : Option < String > ,
38
- pending_fee_requests : Mutex < HashMap < RequestId , oneshot:: Sender < LSPS2FeeResponse > > > ,
39
- pending_buy_requests : Mutex < HashMap < RequestId , oneshot:: Sender < LSPS2BuyResponse > > > ,
38
+ pending_fee_requests : Mutex < HashMap < LSPSRequestId , oneshot:: Sender < LSPS2FeeResponse > > > ,
39
+ pending_buy_requests : Mutex < HashMap < LSPSRequestId , oneshot:: Sender < LSPS2BuyResponse > > > ,
40
40
}
41
41
42
42
pub ( crate ) struct LiquiditySource < L : Deref >
87
87
88
88
pub ( crate ) async fn handle_next_event ( & self ) {
89
89
match self . liquidity_manager . next_event_async ( ) . await {
90
- Event :: LSPS2Client ( LSPS2ClientEvent :: OpeningParametersReady {
90
+ LiquidityEvent :: LSPS2Client ( LSPS2ClientEvent :: OpeningParametersReady {
91
91
request_id,
92
92
counterparty_node_id,
93
93
opening_fee_params_menu,
@@ -137,7 +137,7 @@ where
137
137
) ;
138
138
}
139
139
} ,
140
- Event :: LSPS2Client ( LSPS2ClientEvent :: InvoiceParametersReady {
140
+ LiquidityEvent :: LSPS2Client ( LSPS2ClientEvent :: InvoiceParametersReady {
141
141
request_id,
142
142
counterparty_node_id,
143
143
intercept_scid,
@@ -330,7 +330,7 @@ where
330
330
}
331
331
332
332
async fn lsps2_send_buy_request (
333
- & self , amount_msat : Option < u64 > , opening_fee_params : OpeningFeeParams ,
333
+ & self , amount_msat : Option < u64 > , opening_fee_params : LSPS2OpeningFeeParams ,
334
334
) -> Result < LSPS2BuyResponse , Error > {
335
335
let lsps2_service = self . lsps2_service . as_ref ( ) . ok_or ( Error :: LiquiditySourceUnavailable ) ?;
336
336
@@ -430,7 +430,7 @@ where
430
430
431
431
#[ derive( Debug , Clone ) ]
432
432
pub ( crate ) struct LSPS2FeeResponse {
433
- opening_fee_params_menu : Vec < OpeningFeeParams > ,
433
+ opening_fee_params_menu : Vec < LSPS2OpeningFeeParams > ,
434
434
}
435
435
436
436
#[ derive( Debug , Clone ) ]
0 commit comments