import javax.annotation.Nullable;
import org.ldk.enums.Network;
+import org.ldk.enums.Recipient;
import org.ldk.structs.*;
-import org.ldk.util.TwoTuple;
import java.io.IOException;
import java.util.HashSet;
this.logger = logger;
byte[] random_data = keys_interface.get_secure_random_bytes();
this.net_graph = net_graph;
+ Result_SecretKeyNoneZ node_secret = keys_interface.get_node_secret(Recipient.LDKRecipient_Node);
+ assert node_secret.is_ok();
if (net_graph != null) {
//TODO: We really need to expose the Access here to let users prevent DoS issues
this.graph_msg_handler = NetGraphMsgHandler.of(net_graph, Option_AccessZ.none(), logger);
this.peer_manager = PeerManager.of(channel_manager.as_ChannelMessageHandler(),
graph_msg_handler.as_RoutingMessageHandler(),
- keys_interface.get_node_secret(), random_data, logger, no_custom_messages.as_CustomMessageHandler());
+ ((Result_SecretKeyNoneZ.Result_SecretKeyNoneZ_OK)node_secret).res,
+ random_data, logger, no_custom_messages.as_CustomMessageHandler());
} else {
this.graph_msg_handler = null;
this.peer_manager = PeerManager.of(channel_manager.as_ChannelMessageHandler(), no_custom_messages.as_RoutingMessageHandler(),
- keys_interface.get_node_secret(), random_data, logger, no_custom_messages.as_CustomMessageHandler());
+ ((Result_SecretKeyNoneZ.Result_SecretKeyNoneZ_OK)node_secret).res,
+ random_data, logger, no_custom_messages.as_CustomMessageHandler());
}
NioPeerHandler nio_peer_handler = null;
try {
this.logger = logger;
byte[] random_data = keys_interface.get_secure_random_bytes();
this.net_graph = net_graph;
+ Result_SecretKeyNoneZ node_secret = keys_interface.get_node_secret(Recipient.LDKRecipient_Node);
+ assert node_secret.is_ok();
if (net_graph != null) {
//TODO: We really need to expose the Access here to let users prevent DoS issues
this.graph_msg_handler = NetGraphMsgHandler.of(net_graph, Option_AccessZ.none(), logger);
this.peer_manager = PeerManager.of(channel_manager.as_ChannelMessageHandler(),
graph_msg_handler.as_RoutingMessageHandler(),
- keys_interface.get_node_secret(), random_data, logger, no_custom_messages.as_CustomMessageHandler());
+ ((Result_SecretKeyNoneZ.Result_SecretKeyNoneZ_OK)node_secret).res,
+ random_data, logger, no_custom_messages.as_CustomMessageHandler());
} else {
this.graph_msg_handler = null;
this.peer_manager = PeerManager.of(channel_manager.as_ChannelMessageHandler(), no_custom_messages.as_RoutingMessageHandler(),
- keys_interface.get_node_secret(), random_data, logger, no_custom_messages.as_CustomMessageHandler());
+ ((Result_SecretKeyNoneZ.Result_SecretKeyNoneZ_OK)node_secret).res,
+ random_data, logger, no_custom_messages.as_CustomMessageHandler());
}
NioPeerHandler nio_peer_handler = null;
try {
* This also spawns a background thread which will call the appropriate methods on the provided
* EventHandler as required.
*/
- public void chain_sync_completed(EventHandler event_handler, @Nullable LockableScore scorer) {
+ public void chain_sync_completed(EventHandler event_handler, @Nullable MultiThreadedLockableScore scorer) {
if (background_processor != null) { return; }
for (TwoTuple_BlockHashChannelMonitorZ monitor: channel_monitors) {
this.chain_monitor.as_Watch().watch_channel(monitor.get_b().get_funding_txo().get_a(), monitor.get_b());
* Interrupt the background thread, stopping the background handling of events.
*/
public void interrupt() {
- this.background_processor.stop();
this.nio_peer_handler.interrupt();
+ this.background_processor.stop();
}
}