Skip to content

Commit 59f5e45

Browse files
committed
[Java] Update batteries and tests to latest LDK API
1 parent 209f789 commit 59f5e45

File tree

2 files changed

+148
-77
lines changed

2 files changed

+148
-77
lines changed

src/main/java/org/ldk/batteries/ChannelManagerConstructor.java

Lines changed: 26 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -173,15 +173,22 @@ public Result_RouteLightningErrorZ find_route_with_id(byte[] payer, RouteParamet
173173
}
174174

175175
@Override
176-
public Result_CVec_C2Tuple_BlindedPayInfoBlindedPathZZNoneZ create_blinded_payment_paths(byte[] recipient, ChannelDetails[] first_hops, ReceiveTlvs tlvs, long amount_msats) {
176+
public Result_CVec_BlindedPaymentPathZNoneZ create_blinded_payment_paths(byte[] recipient, ChannelDetails[] first_hops, ReceiveTlvs tlvs, long amount_msats) {
177177
return default_router.as_Router().create_blinded_payment_paths(recipient, first_hops, tlvs, amount_msats);
178178
}
179179
}, new MessageRouter.MessageRouterInterface() {
180180
@Override public Result_OnionMessagePathNoneZ find_path(byte[] sender, byte[][] peers, Destination destination) {
181181
return default_router.as_MessageRouter().find_path(sender, peers, destination);
182182
}
183-
@Override public Result_CVec_BlindedPathZNoneZ create_blinded_paths(byte[] recipient, byte[][] peers) {
184-
return default_router.as_MessageRouter().create_blinded_paths(recipient, peers);
183+
184+
@Override
185+
public Result_CVec_BlindedMessagePathZNoneZ create_blinded_paths(byte[] recipient, MessageContext context, byte[][] peers) {
186+
return default_router.as_MessageRouter().create_blinded_paths(recipient, context, peers);
187+
}
188+
189+
@Override
190+
public Result_CVec_BlindedMessagePathZNoneZ create_compact_blinded_paths(byte[] recipient, MessageContext context, MessageForwardNode[] peers) {
191+
return default_router.as_MessageRouter().create_compact_blinded_paths(recipient, context, peers);
185192
}
186193
});
187194
} else {
@@ -251,15 +258,22 @@ public ChannelManagerConstructor(Network network, UserConfig config, byte[] curr
251258
}
252259

253260
@Override
254-
public Result_CVec_C2Tuple_BlindedPayInfoBlindedPathZZNoneZ create_blinded_payment_paths(byte[] recipient, ChannelDetails[] first_hops, ReceiveTlvs tlvs, long amount_msats) {
261+
public Result_CVec_BlindedPaymentPathZNoneZ create_blinded_payment_paths(byte[] recipient, ChannelDetails[] first_hops, ReceiveTlvs tlvs, long amount_msats) {
255262
return default_router.as_Router().create_blinded_payment_paths(recipient, first_hops, tlvs, amount_msats);
256263
}
257264
}, new MessageRouter.MessageRouterInterface() {
258265
@Override public Result_OnionMessagePathNoneZ find_path(byte[] sender, byte[][] peers, Destination destination) {
259266
return default_router.as_MessageRouter().find_path(sender, peers, destination);
260267
}
261-
@Override public Result_CVec_BlindedPathZNoneZ create_blinded_paths(byte[] recipient, byte[][] peers) {
262-
return default_router.as_MessageRouter().create_blinded_paths(recipient, peers);
268+
269+
@Override
270+
public Result_CVec_BlindedMessagePathZNoneZ create_blinded_paths(byte[] recipient, MessageContext context, byte[][] peers) {
271+
return default_router.as_MessageRouter().create_blinded_paths(recipient, context, peers);
272+
}
273+
274+
@Override
275+
public Result_CVec_BlindedMessagePathZNoneZ create_compact_blinded_paths(byte[] recipient, MessageContext context, MessageForwardNode[] peers) {
276+
return default_router.as_MessageRouter().create_compact_blinded_paths(recipient, context, peers);
263277
}
264278
});
265279
} else {
@@ -280,7 +294,7 @@ public Result_CVec_C2Tuple_BlindedPayInfoBlindedPathZZNoneZ create_blinded_payme
280294
* a background thread is started which will automatically call these methods for you when events occur.
281295
*/
282296
public interface EventHandler {
283-
void handle_event(Event events);
297+
Result_NoneReplayEventZ handle_event(Event events);
284298
void persist_manager(byte[] channel_manager_bytes);
285299
void persist_network_graph(byte[] network_graph);
286300
void persist_scorer(byte[] scorer_bytes);
@@ -314,7 +328,10 @@ public void chain_sync_completed(EventHandler event_handler, boolean use_p2p_gra
314328
routing_msg_handler = graph_msg_handler.as_RoutingMessageHandler();
315329
else
316330
routing_msg_handler = ignoring_handler.as_RoutingMessageHandler();
317-
OnionMessenger messenger = OnionMessenger.of(this.entropy_source, this.node_signer, this.logger, this.channel_manager.as_NodeIdLookUp(), this.router.get_message_router(), channel_manager.as_OffersMessageHandler(), IgnoringMessageHandler.of().as_CustomOnionMessageHandler());
331+
OnionMessenger messenger = OnionMessenger.of(this.entropy_source, this.node_signer, this.logger,
332+
this.channel_manager.as_NodeIdLookUp(), this.router.get_message_router(),
333+
channel_manager.as_OffersMessageHandler(), IgnoringMessageHandler.of().as_AsyncPaymentsMessageHandler(),
334+
IgnoringMessageHandler.of().as_CustomOnionMessageHandler());
318335
this.peer_manager = PeerManager.of(channel_manager.as_ChannelMessageHandler(),
319336
routing_msg_handler, messenger.as_OnionMessageHandler(),
320337
ignoring_handler.as_CustomMessageHandler(), (int)(System.currentTimeMillis() / 1000),
@@ -352,7 +369,7 @@ public Result_NoneIOErrorZ persist_scorer(WriteableScore scorer) {
352369
event_handler.persist_scorer(scorer.write());
353370
return Result_NoneIOErrorZ.ok();
354371
}
355-
}), ldk_handler, this.chain_monitor, this.channel_manager, gossip_sync, peer_manager, this.logger, writeable_score);
372+
}), ldk_handler, this.chain_monitor, this.channel_manager, messenger, gossip_sync, peer_manager, this.logger, writeable_score);
356373
}
357374

358375
/**

0 commit comments

Comments
 (0)