Skip to content

Commit 24219ba

Browse files
committed
Drop Listen/Confirm/etc from LiquidityManager
Now that we don't do on-chain tracking in LSPS1, we can drop quite a few `LiquidityManager` parameters and generics, which were only added in anticipation of tracking on-chain state.
1 parent 810f026 commit 24219ba

File tree

5 files changed

+37
-290
lines changed

5 files changed

+37
-290
lines changed

lightning-background-processor/src/lib.rs

Lines changed: 11 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -467,8 +467,6 @@ pub const NO_LIQUIDITY_MANAGER: Option<
467467
NS = &(dyn lightning::sign::NodeSigner + Send + Sync),
468468
AChannelManager = DynChannelManager,
469469
CM = &DynChannelManager,
470-
Filter = dyn chain::Filter + Send + Sync,
471-
C = &(dyn chain::Filter + Send + Sync),
472470
KVStore = DummyKVStore,
473471
K = &DummyKVStore,
474472
TimeProvider = dyn lightning_liquidity::utils::time::TimeProvider + Send + Sync,
@@ -494,8 +492,6 @@ pub const NO_LIQUIDITY_MANAGER_SYNC: Option<
494492
NS = &(dyn lightning::sign::NodeSigner + Send + Sync),
495493
AChannelManager = DynChannelManager,
496494
CM = &DynChannelManager,
497-
Filter = dyn chain::Filter + Send + Sync,
498-
C = &(dyn chain::Filter + Send + Sync),
499495
KVStoreSync = dyn lightning::util::persist::KVStoreSync + Send + Sync,
500496
KS = &(dyn lightning::util::persist::KVStoreSync + Send + Sync),
501497
TimeProvider = dyn lightning_liquidity::utils::time::TimeProvider + Send + Sync,
@@ -823,7 +819,7 @@ use futures_util::{dummy_waker, Joiner, OptionalSelector, Selector, SelectorOutp
823819
/// # type P2PGossipSync<UL> = lightning::routing::gossip::P2PGossipSync<Arc<NetworkGraph>, Arc<UL>, Arc<Logger>>;
824820
/// # type ChannelManager<B, F, FE> = lightning::ln::channelmanager::SimpleArcChannelManager<ChainMonitor<B, F, FE>, B, FE, Logger>;
825821
/// # type OnionMessenger<B, F, FE> = lightning::onion_message::messenger::OnionMessenger<Arc<lightning::sign::KeysManager>, Arc<lightning::sign::KeysManager>, Arc<Logger>, Arc<ChannelManager<B, F, FE>>, Arc<lightning::onion_message::messenger::DefaultMessageRouter<Arc<NetworkGraph>, Arc<Logger>, Arc<lightning::sign::KeysManager>>>, Arc<ChannelManager<B, F, FE>>, lightning::ln::peer_handler::IgnoringMessageHandler, lightning::ln::peer_handler::IgnoringMessageHandler, lightning::ln::peer_handler::IgnoringMessageHandler>;
826-
/// # type LiquidityManager<B, F, FE> = lightning_liquidity::LiquidityManager<Arc<lightning::sign::KeysManager>, Arc<lightning::sign::KeysManager>, Arc<ChannelManager<B, F, FE>>, Arc<F>, Arc<Store>, Arc<DefaultTimeProvider>, Arc<B>>;
822+
/// # type LiquidityManager<B, F, FE> = lightning_liquidity::LiquidityManager<Arc<lightning::sign::KeysManager>, Arc<lightning::sign::KeysManager>, Arc<ChannelManager<B, F, FE>>, Arc<Store>, Arc<DefaultTimeProvider>, Arc<B>>;
827823
/// # type Scorer = RwLock<lightning::routing::scoring::ProbabilisticScorer<Arc<NetworkGraph>, Arc<Logger>>>;
828824
/// # type PeerManager<B, F, FE, UL> = lightning::ln::peer_handler::SimpleArcPeerManager<SocketDescriptor, ChainMonitor<B, F, FE>, B, FE, Arc<UL>, Logger, F, StoreSync>;
829825
/// # type OutputSweeper<B, D, FE, F, O> = lightning::util::sweep::OutputSweeper<Arc<B>, Arc<D>, Arc<FE>, Arc<F>, Arc<Store>, Arc<Logger>, Arc<O>>;
@@ -1872,7 +1868,7 @@ mod tests {
18721868
use core::sync::atomic::{AtomicBool, Ordering};
18731869
use lightning::chain::channelmonitor::ANTI_REORG_DELAY;
18741870
use lightning::chain::transaction::OutPoint;
1875-
use lightning::chain::{chainmonitor, BestBlock, Confirm, Filter};
1871+
use lightning::chain::{chainmonitor, BestBlock, Confirm};
18761872
use lightning::events::{Event, PathFailure, ReplayEvent};
18771873
use lightning::ln::channelmanager;
18781874
use lightning::ln::channelmanager::{
@@ -2008,7 +2004,6 @@ mod tests {
20082004
Arc<KeysManager>,
20092005
Arc<KeysManager>,
20102006
Arc<ChannelManager>,
2011-
Arc<dyn Filter + Sync + Send>,
20122007
Arc<Persister>,
20132008
DefaultTimeProvider,
20142009
Arc<test_utils::TestBroadcaster>,
@@ -2465,8 +2460,6 @@ mod tests {
24652460
Arc::clone(&keys_manager),
24662461
Arc::clone(&keys_manager),
24672462
Arc::clone(&manager),
2468-
None,
2469-
None,
24702463
Arc::clone(&kv_store),
24712464
Arc::clone(&tx_broadcaster),
24722465
None,
@@ -2843,10 +2836,10 @@ mod tests {
28432836
let kv_store = KVStoreSyncWrapper(kv_store_sync);
28442837

28452838
// Yes, you can unsafe { turn off the borrow checker }
2846-
let lm_async: &'static LiquidityManager<_, _, _, _, _, _, _> = unsafe {
2839+
let lm_async: &'static LiquidityManager<_, _, _, _, _, _> = unsafe {
28472840
&*(nodes[0].liquidity_manager.get_lm_async()
2848-
as *const LiquidityManager<_, _, _, _, _, _, _>)
2849-
as &'static LiquidityManager<_, _, _, _, _, _, _>
2841+
as *const LiquidityManager<_, _, _, _, _, _>)
2842+
as &'static LiquidityManager<_, _, _, _, _, _>
28502843
};
28512844
let sweeper_async: &'static OutputSweeper<_, _, _, _, _, _, _> = unsafe {
28522845
&*(nodes[0].sweeper.sweeper_async() as *const OutputSweeper<_, _, _, _, _, _, _>)
@@ -3362,10 +3355,10 @@ mod tests {
33623355
let kv_store = KVStoreSyncWrapper(kv_store_sync);
33633356

33643357
// Yes, you can unsafe { turn off the borrow checker }
3365-
let lm_async: &'static LiquidityManager<_, _, _, _, _, _, _> = unsafe {
3358+
let lm_async: &'static LiquidityManager<_, _, _, _, _, _> = unsafe {
33663359
&*(nodes[0].liquidity_manager.get_lm_async()
3367-
as *const LiquidityManager<_, _, _, _, _, _, _>)
3368-
as &'static LiquidityManager<_, _, _, _, _, _, _>
3360+
as *const LiquidityManager<_, _, _, _, _, _>)
3361+
as &'static LiquidityManager<_, _, _, _, _, _>
33693362
};
33703363
let sweeper_async: &'static OutputSweeper<_, _, _, _, _, _, _> = unsafe {
33713364
&*(nodes[0].sweeper.sweeper_async() as *const OutputSweeper<_, _, _, _, _, _, _>)
@@ -3589,10 +3582,10 @@ mod tests {
35893582
let (exit_sender, exit_receiver) = tokio::sync::watch::channel(());
35903583

35913584
// Yes, you can unsafe { turn off the borrow checker }
3592-
let lm_async: &'static LiquidityManager<_, _, _, _, _, _, _> = unsafe {
3585+
let lm_async: &'static LiquidityManager<_, _, _, _, _, _> = unsafe {
35933586
&*(nodes[0].liquidity_manager.get_lm_async()
3594-
as *const LiquidityManager<_, _, _, _, _, _, _>)
3595-
as &'static LiquidityManager<_, _, _, _, _, _, _>
3587+
as *const LiquidityManager<_, _, _, _, _, _>)
3588+
as &'static LiquidityManager<_, _, _, _, _, _>
35963589
};
35973590
let sweeper_async: &'static OutputSweeper<_, _, _, _, _, _, _> = unsafe {
35983591
&*(nodes[0].sweeper.sweeper_async() as *const OutputSweeper<_, _, _, _, _, _, _>)

0 commit comments

Comments
 (0)