@@ -13,16 +13,16 @@ use ldk_node::bitcoin::base64::Engine;
1313use ldk_node:: bitcoin:: base64:: prelude:: BASE64_STANDARD ;
1414use ldk_node:: bitcoin:: secp256k1:: PublicKey ;
1515use ldk_node:: bitcoin:: { Address , Network } ;
16+ use ldk_node:: config:: { AsyncPaymentsRole , BackgroundSyncConfig } ;
1617use ldk_node:: lightning:: ln:: channelmanager:: PaymentId ;
1718use ldk_node:: lightning:: ln:: msgs:: SocketAddress ;
1819use ldk_node:: lightning:: util:: logger:: Logger as _;
19- use ldk_node:: lightning:: util:: persist:: KVStore ;
2020use ldk_node:: lightning:: { log_debug, log_error, log_info} ;
2121use ldk_node:: lightning_invoice:: { Bolt11Invoice , Bolt11InvoiceDescription , Description } ;
2222use ldk_node:: payment:: {
2323 ConfirmationStatus , PaymentDetails , PaymentDirection , PaymentKind , PaymentStatus ,
2424} ;
25- use ldk_node:: { DynStore , NodeError , UserChannelId , lightning } ;
25+ use ldk_node:: { DynStore , NodeError , UserChannelId } ;
2626
2727use graduated_rebalancer:: { LightningBalance , ReceivedLightningPayment } ;
2828
@@ -133,37 +133,14 @@ impl LightningWallet {
133133 } ,
134134 } ;
135135
136+ builder. set_async_payments_role ( Some ( AsyncPaymentsRole :: Client ) ) ?;
137+
136138 builder. set_custom_logger ( Arc :: clone ( & logger) as Arc < dyn ldk_node:: logger:: LogWriter > ) ;
137139
138140 builder. set_runtime ( runtime. get_handle ( ) ) ;
139141
140- // download scorer and write to storage
141- // todo switch to https://github.com/lightningdevkit/ldk-node/pull/449 once available
142142 if let Some ( url) = config. scorer_url {
143- let fetch = tokio:: time:: timeout ( std:: time:: Duration :: from_secs ( 10 ) , reqwest:: get ( url) ) ;
144- let res = fetch. await . map_err ( |e| {
145- log_error ! ( logger, "Timed out downloading scorer: {e}" ) ;
146- InitFailure :: LdkNodeStartFailure ( NodeError :: InvalidUri )
147- } ) ?;
148-
149- let req = res. map_err ( |e| {
150- log_error ! ( logger, "Failed to download scorer: {e}" ) ;
151- InitFailure :: LdkNodeStartFailure ( NodeError :: InvalidUri )
152- } ) ?;
153-
154- let bytes = req. bytes ( ) . await . map_err ( |e| {
155- log_debug ! ( logger, "Failed to read scorer bytes: {e}" ) ;
156- InitFailure :: LdkNodeStartFailure ( NodeError :: InvalidUri )
157- } ) ?;
158-
159- KVStore :: write (
160- store. as_ref ( ) ,
161- lightning:: util:: persist:: SCORER_PERSISTENCE_PRIMARY_NAMESPACE ,
162- lightning:: util:: persist:: SCORER_PERSISTENCE_SECONDARY_NAMESPACE ,
163- lightning:: util:: persist:: SCORER_PERSISTENCE_KEY ,
164- bytes. to_vec ( ) ,
165- )
166- . await ?;
143+ builder. set_pathfinding_scores_source ( url) ;
167144 }
168145
169146 let ldk_node = Arc :: new ( builder. build_with_store ( Arc :: clone ( & store) ) ?) ;
0 commit comments