@@ -205,11 +205,11 @@ impl Builder {
205
205
let bdk_data_dir = format ! ( "{}/bdk" , config. storage_dir_path) ;
206
206
fs:: create_dir_all ( bdk_data_dir. clone ( ) ) . expect ( "Failed to create BDK data directory" ) ;
207
207
208
- // Step 0: Initialize the Logger
208
+ // Initialize the Logger
209
209
let log_file_path = format ! ( "{}/ldk_node.log" , config. storage_dir_path) ;
210
210
let logger = Arc :: new ( FilesystemLogger :: new ( log_file_path) ) ;
211
211
212
- // Step 1: Initialize the on-chain wallet and chain access
212
+ // Initialize the on-chain wallet and chain access
213
213
let seed = io_utils:: read_or_generate_seed_file ( config. as_ref ( ) ) ;
214
214
let xprv = bitcoin:: util:: bip32:: ExtendedPrivKey :: new_master ( config. network , & seed)
215
215
. expect ( "Failed to read wallet master key" ) ;
@@ -243,10 +243,10 @@ impl Builder {
243
243
244
244
let wallet = Arc :: new ( Wallet :: new ( blockchain, bdk_wallet, Arc :: clone ( & logger) ) ) ;
245
245
246
- // Step 3: Initialize Persist
246
+ // Initialize Persist
247
247
let persister = Arc :: new ( FilesystemPersister :: new ( ldk_data_dir. clone ( ) ) ) ;
248
248
249
- // Step 4: Initialize the ChainMonitor
249
+ // Initialize the ChainMonitor
250
250
let chain_monitor: Arc < ChainMonitor > = Arc :: new ( chainmonitor:: ChainMonitor :: new (
251
251
Some ( Arc :: clone ( & tx_sync) ) ,
252
252
Arc :: clone ( & wallet) ,
@@ -255,7 +255,7 @@ impl Builder {
255
255
Arc :: clone ( & persister) ,
256
256
) ) ;
257
257
258
- // Step 5: Initialize the KeysManager
258
+ // Initialize the KeysManager
259
259
let cur_time = SystemTime :: now ( )
260
260
. duration_since ( SystemTime :: UNIX_EPOCH )
261
261
. expect ( "System time error: Clock may have gone backwards" ) ;
@@ -266,7 +266,7 @@ impl Builder {
266
266
Arc :: clone ( & wallet) ,
267
267
) ) ;
268
268
269
- // Step 12: Initialize the network graph, scorer, and router
269
+ // Initialize the network graph, scorer, and router
270
270
let network_graph = Arc :: new (
271
271
io_utils:: read_network_graph ( config. as_ref ( ) , Arc :: clone ( & logger) )
272
272
. expect ( "Failed to read the network graph" ) ,
@@ -284,12 +284,12 @@ impl Builder {
284
284
Arc :: clone ( & scorer) ,
285
285
) ) ;
286
286
287
- // Step 6: Read ChannelMonitor state from disk
287
+ // Read ChannelMonitor state from disk
288
288
let mut channel_monitors = persister
289
289
. read_channelmonitors ( Arc :: clone ( & keys_manager) , Arc :: clone ( & keys_manager) )
290
290
. expect ( "Failed to read channel monitors from disk" ) ;
291
291
292
- // Step 7: Initialize the ChannelManager
292
+ // Initialize the ChannelManager
293
293
let mut user_config = UserConfig :: default ( ) ;
294
294
user_config. channel_handshake_limits . force_announced_channel_preference = false ;
295
295
let channel_manager = {
@@ -341,20 +341,20 @@ impl Builder {
341
341
342
342
let channel_manager = Arc :: new ( channel_manager) ;
343
343
344
- // Step 8: Give ChannelMonitors to ChainMonitor
344
+ // Give ChannelMonitors to ChainMonitor
345
345
for ( _blockhash, channel_monitor) in channel_monitors. into_iter ( ) {
346
346
let funding_outpoint = channel_monitor. get_funding_txo ( ) . 0 ;
347
347
chain_monitor. watch_channel ( funding_outpoint, channel_monitor) ;
348
348
}
349
349
350
- // Step 10: Initialize the P2PGossipSync
350
+ // Initialize the P2PGossipSync
351
351
let gossip_sync = Arc :: new ( P2PGossipSync :: new (
352
352
Arc :: clone ( & network_graph) ,
353
353
None :: < Arc < dyn UtxoLookup + Send + Sync > > ,
354
354
Arc :: clone ( & logger) ,
355
355
) ) ;
356
356
357
- //// Step 11: Initialize the PeerManager
357
+ // Initialize the PeerManager
358
358
let onion_messenger: Arc < OnionMessenger > = Arc :: new ( OnionMessenger :: new (
359
359
Arc :: clone ( & keys_manager) ,
360
360
Arc :: clone ( & keys_manager) ,
@@ -380,12 +380,12 @@ impl Builder {
380
380
Arc :: clone ( & keys_manager) ,
381
381
) ) ;
382
382
383
- // Step 13: Init payment info storage
383
+ // Init payment info storage
384
384
// TODO: persist payment info to disk
385
385
let inbound_payments = Arc :: new ( Mutex :: new ( HashMap :: new ( ) ) ) ;
386
386
let outbound_payments = Arc :: new ( Mutex :: new ( HashMap :: new ( ) ) ) ;
387
387
388
- // Step 14: Restore event handler from disk or create a new one.
388
+ // Restore event handler from disk or create a new one.
389
389
let event_queue = if let Ok ( mut f) =
390
390
fs:: File :: open ( format ! ( "{}/{}" , ldk_data_dir, event:: EVENTS_PERSISTENCE_KEY ) )
391
391
{
0 commit comments