var tx_broadcaster: ldk.BroadcasterInterface;
const tx_broadcasted: Promise<Uint8Array> = new Promise((resolve, _reject) => {
tx_broadcaster = ldk.BroadcasterInterface.new_impl({
- broadcast_transaction(tx: Uint8Array): void { console.log("Tx Broadcast: " + tx); resolve(tx); }
+ broadcast_transactions(txn: Uint8Array[]): void {
+ for (const tx of txn) {
+ console.log("Tx Broadcast: " + tx); resolve(tx);
+ }
+ }
} as ldk.BroadcasterInterfaceInterface);
});
const logger = ldk.Logger.new_impl({
const keys_manager = ldk.KeysManager.constructor_new(seed, BigInt(42), 42);
const net_graph = ldk.NetworkGraph.constructor_new(ldk.Network.LDKNetwork_Testnet, logger);
- const scorer = ldk.ProbabilisticScorer.constructor_new(ldk.ProbabilisticScoringParameters.constructor_default(), net_graph, logger);
+ const scorer = ldk.ProbabilisticScorer.constructor_new(ldk.ProbabilisticScoringDecayParameters.constructor_default(), net_graph, logger);
const lockable_score = ldk.MultiThreadedLockableScore.constructor_new(scorer.as_Score());
- const router = ldk.DefaultRouter.constructor_new(net_graph, logger, keys_manager.as_EntropySource().get_secure_random_bytes(), lockable_score.as_LockableScore());
+ const router = ldk.DefaultRouter.constructor_new(net_graph, logger, keys_manager.as_EntropySource().get_secure_random_bytes(), lockable_score.as_LockableScore(), ldk.ProbabilisticScoringFeeParameters.constructor_default());
const config = ldk.UserConfig.constructor_default();
const params = ldk.ChainParameters.constructor_new(ldk.Network.LDKNetwork_Testnet, ldk.BestBlock.constructor_from_network(ldk.Network.LDKNetwork_Testnet));
- const chan_man = ldk.ChannelManager.constructor_new(fee_est, chain_watch, tx_broadcaster!, router.as_Router(), logger,
- keys_manager.as_EntropySource(), keys_manager.as_NodeSigner(), keys_manager.as_SignerProvider(), config, params);
+ const chan_man = ldk.ChannelManager.constructor_new(fee_est, chain_watch, tx_broadcaster!, router.as_Router(),
+ logger, keys_manager.as_EntropySource(), keys_manager.as_NodeSigner(), keys_manager.as_SignerProvider(),
+ config, params, 42);
return new Node(chan_man, tx_broadcasted, logger, keys_manager);
}
const features = a.chan_man.as_ChannelMessageHandler().provided_init_features(b.chan_man.get_our_node_id());
- a.chan_man.as_ChannelMessageHandler().peer_connected(b.chan_man.get_our_node_id(), ldk.Init.constructor_new(features, ldk.Option_NetAddressZ.constructor_none()), false);
- b.chan_man.as_ChannelMessageHandler().peer_connected(a.chan_man.get_our_node_id(), ldk.Init.constructor_new(features, ldk.Option_NetAddressZ.constructor_none()), true);
+ a.chan_man.as_ChannelMessageHandler().peer_connected(b.chan_man.get_our_node_id(), ldk.Init.constructor_new(features, ldk.Option_CVec_ThirtyTwoBytesZZ.constructor_none(), ldk.Option_SocketAddressZ.constructor_none()), false);
+ b.chan_man.as_ChannelMessageHandler().peer_connected(a.chan_man.get_our_node_id(), ldk.Init.constructor_new(features, ldk.Option_CVec_ThirtyTwoBytesZZ.constructor_none(), ldk.Option_SocketAddressZ.constructor_none()), true);
const chan_create_err = a.chan_man.create_channel(b.chan_man.get_our_node_id(), BigInt(0), BigInt(400), BigInt(0), ldk.UserConfig.constructor_default());
if (chan_create_err.is_ok()) return false;
- if (!(chan_create_err instanceof ldk.Result__u832APIErrorZ_Err)) return false;
+ if (!(chan_create_err instanceof ldk.Result_ThirtyTwoBytesAPIErrorZ_Err)) return false;
if (!(chan_create_err.err instanceof ldk.APIError_APIMisuseError)) return false;
if (chan_create_err.err.err != "Channel value must be at least 1000 satoshis. It was 0") return false;
const b = get_chanman();
const ignorer = ldk.IgnoringMessageHandler.constructor_new();
- const pm_a = ldk.PeerManager.constructor_new(a.chan_man.as_ChannelMessageHandler(), ignorer.as_RoutingMessageHandler(), ignorer.as_OnionMessageHandler(),
- 0xdeadbeef, a.keys_manager.as_EntropySource().get_secure_random_bytes(), a.logger, ignorer.as_CustomMessageHandler(), a.keys_manager.as_NodeSigner());
- const pm_b = ldk.PeerManager.constructor_new(b.chan_man.as_ChannelMessageHandler(), ignorer.as_RoutingMessageHandler(), ignorer.as_OnionMessageHandler(),
- 0xdeadbeef, b.keys_manager.as_EntropySource().get_secure_random_bytes(), b.logger, ignorer.as_CustomMessageHandler(), b.keys_manager.as_NodeSigner());
+ const pm_a = ldk.PeerManager.constructor_new(a.chan_man.as_ChannelMessageHandler(), ignorer.as_RoutingMessageHandler(),
+ ignorer.as_OnionMessageHandler(), ignorer.as_CustomMessageHandler(),
+ 0xdeadbeef, a.keys_manager.as_EntropySource().get_secure_random_bytes(), a.logger, a.keys_manager.as_NodeSigner());
+ const pm_b = ldk.PeerManager.constructor_new(b.chan_man.as_ChannelMessageHandler(), ignorer.as_RoutingMessageHandler(),
+ ignorer.as_OnionMessageHandler(), ignorer.as_CustomMessageHandler(),
+ 0xdeadbeef, b.keys_manager.as_EntropySource().get_secure_random_bytes(), b.logger, b.keys_manager.as_NodeSigner());
var sock_b: ldk.SocketDescriptor;
const sock_a = ldk.SocketDescriptor.new_impl({
}
} as ldk.SocketDescriptorInterface);
- const update_fut = a.chan_man.get_persistable_update_future();
+ const update_fut = a.chan_man.get_event_or_persistence_needed_future();
var update_done = false;
update_fut.register_callback_fn(ldk.FutureCallback.new_impl({
call(): void { update_done = true; }
}));
if (update_done) return false;
- const v4_netaddr = ldk.NetAddress.constructor_ipv4(Uint8Array.from([42,0,42,1]), 9735);
- assert(pm_b.new_inbound_connection(sock_b, ldk.Option_NetAddressZ.constructor_some(v4_netaddr)) instanceof ldk.Result_NonePeerHandleErrorZ_OK);
- const init_bytes = pm_a.new_outbound_connection(b.node_id, sock_a, ldk.Option_NetAddressZ.constructor_none());
+ const v4_netaddr = ldk.SocketAddress.constructor_tcp_ip_v4(Uint8Array.from([42,0,42,1]), 9735);
+ assert(pm_b.new_inbound_connection(sock_b, ldk.Option_SocketAddressZ.constructor_some(v4_netaddr)) instanceof ldk.Result_NonePeerHandleErrorZ_OK);
+ const init_bytes = pm_a.new_outbound_connection(b.node_id, sock_a, ldk.Option_SocketAddressZ.constructor_none());
if (!(init_bytes instanceof ldk.Result_CVec_u8ZPeerHandleErrorZ_OK)) return false;
assert(pm_b.read_event(sock_b, init_bytes.res) instanceof ldk.Result_boolPeerHandleErrorZ_OK);
var a_handled_msg = false;
const om_handler_a = ldk.CustomOnionMessageHandler.new_impl({
- read_custom_message(message_type: bigint, buffer: Uint8Array): ldk.Result_COption_CustomOnionMessageContentsZDecodeErrorZ {
+ read_custom_message(message_type: bigint, buffer: Uint8Array): ldk.Result_COption_OnionMessageContentsZDecodeErrorZ {
assert(message_type == 4343n);
assert(buffer.length == 44);
for (var i = 0; i < 44; i++) assert(buffer[i] == 67);
- return ldk.Result_COption_CustomOnionMessageContentsZDecodeErrorZ.constructor_ok(ldk.Option_CustomOnionMessageContentsZ.constructor_some(ldk.CustomOnionMessageContents.new_impl({
+ return ldk.Result_COption_OnionMessageContentsZDecodeErrorZ.constructor_ok(ldk.Option_OnionMessageContentsZ.constructor_some(ldk.OnionMessageContents.new_impl({
tlv_type(): bigint { return 9998n; },
write(): Uint8Array { throw new Error(); }
- } as ldk.CustomOnionMessageContentsInterface)));
+ } as ldk.OnionMessageContentsInterface)));
},
- handle_custom_message(msg: ldk.CustomOnionMessageContents) {
+ handle_custom_message(msg: ldk.OnionMessageContents) {
assert(msg.tlv_type() == 9998n);
a_handled_msg = true;
},
+ release_pending_custom_messages(): ldk.ThreeTuple_OnionMessageContentsDestinationBlindedPathZ[] {
+ return [];
+ },
} as ldk.CustomOnionMessageHandlerInterface);
- const underlying_om_a = ldk.OnionMessenger.constructor_new(a.keys_manager.as_EntropySource(), a.keys_manager.as_NodeSigner(), a.logger, om_handler_a);
- const om_provider_a = {
- next_onion_message_for_peer(peer_node_id: Uint8Array): ldk.OnionMessage {
- return underlying_om_a.as_OnionMessageProvider().next_onion_message_for_peer(peer_node_id);
- }
- } as ldk.OnionMessageProviderInterface;
+ const underlying_om_a = ldk.OnionMessenger.constructor_new(a.keys_manager.as_EntropySource(),
+ a.keys_manager.as_NodeSigner(), a.logger, ldk.DefaultMessageRouter.constructor_new().as_MessageRouter(),
+ ignorer.as_OffersMessageHandler(), om_handler_a);
const om_a = ldk.OnionMessageHandler.new_impl({
handle_onion_message(peer_node_id: Uint8Array, msg: ldk.OnionMessage) {
underlying_om_a.as_OnionMessageHandler().handle_onion_message(peer_node_id, msg);
},
provided_init_features(their_node_id: Uint8Array): ldk.InitFeatures {
return underlying_om_a.as_OnionMessageHandler().provided_init_features(their_node_id);
- }
- } as ldk.OnionMessageHandlerInterface, om_provider_a);
+ },
+ next_onion_message_for_peer(peer_node_id: Uint8Array): ldk.OnionMessage {
+ return underlying_om_a.as_OnionMessageHandler().next_onion_message_for_peer(peer_node_id);
+ },
+ } as ldk.OnionMessageHandlerInterface);
var b_handled_msg = false;
const om_handler_b = ldk.CustomOnionMessageHandler.new_impl({
- read_custom_message(message_type: bigint, buffer: Uint8Array): ldk.Result_COption_CustomOnionMessageContentsZDecodeErrorZ {
+ read_custom_message(message_type: bigint, buffer: Uint8Array): ldk.Result_COption_OnionMessageContentsZDecodeErrorZ {
assert(message_type == 4242n);
assert(buffer.length == 43);
for (var i = 0; i < 43; i++) assert(buffer[i] == 66);
- return ldk.Result_COption_CustomOnionMessageContentsZDecodeErrorZ.constructor_ok(ldk.Option_CustomOnionMessageContentsZ.constructor_some(ldk.CustomOnionMessageContents.new_impl({
+ return ldk.Result_COption_OnionMessageContentsZDecodeErrorZ.constructor_ok(ldk.Option_OnionMessageContentsZ.constructor_some(ldk.OnionMessageContents.new_impl({
tlv_type(): bigint { return 9999n; },
write(): Uint8Array { throw new Error(); }
- } as ldk.CustomOnionMessageContentsInterface)));
+ } as ldk.OnionMessageContentsInterface)));
},
- handle_custom_message(msg: ldk.CustomOnionMessageContents) {
+ handle_custom_message(msg: ldk.OnionMessageContents) {
assert(msg.tlv_type() == 9999n);
b_handled_msg = true;
},
+ release_pending_custom_messages(): ldk.ThreeTuple_OnionMessageContentsDestinationBlindedPathZ[] {
+ return [];
+ }
} as ldk.CustomOnionMessageHandlerInterface);
- const om_b = ldk.OnionMessenger.constructor_new(b.keys_manager.as_EntropySource(), b.keys_manager.as_NodeSigner(), b.logger, om_handler_b);
+ const om_b = ldk.OnionMessenger.constructor_new(b.keys_manager.as_EntropySource(), b.keys_manager.as_NodeSigner(),
+ b.logger, ldk.DefaultMessageRouter.constructor_new().as_MessageRouter(), ignorer.as_OffersMessageHandler(),
+ om_handler_b);
- const pm_a = ldk.PeerManager.constructor_new(a.chan_man.as_ChannelMessageHandler(), ignorer.as_RoutingMessageHandler(), om_a,
- 0xdeadbeef, a.keys_manager.as_EntropySource().get_secure_random_bytes(), a.logger, ignorer.as_CustomMessageHandler(), a.keys_manager.as_NodeSigner());
- const pm_b = ldk.PeerManager.constructor_new(b.chan_man.as_ChannelMessageHandler(), ignorer.as_RoutingMessageHandler(), om_b.as_OnionMessageHandler(),
- 0xdeadbeef, b.keys_manager.as_EntropySource().get_secure_random_bytes(), b.logger, ignorer.as_CustomMessageHandler(), b.keys_manager.as_NodeSigner());
+ const pm_a = ldk.PeerManager.constructor_new(a.chan_man.as_ChannelMessageHandler(), ignorer.as_RoutingMessageHandler(),
+ om_a, ignorer.as_CustomMessageHandler(), 0xdeadbeef,
+ a.keys_manager.as_EntropySource().get_secure_random_bytes(), a.logger, a.keys_manager.as_NodeSigner());
+ const pm_b = ldk.PeerManager.constructor_new(b.chan_man.as_ChannelMessageHandler(), ignorer.as_RoutingMessageHandler(),
+ om_b.as_OnionMessageHandler(), ignorer.as_CustomMessageHandler(), 0xdeadbeef,
+ b.keys_manager.as_EntropySource().get_secure_random_bytes(), b.logger, b.keys_manager.as_NodeSigner());
var sock_b: ldk.SocketDescriptor;
const sock_a = ldk.SocketDescriptor.new_impl({
}
} as ldk.SocketDescriptorInterface);
- const v4_netaddr = ldk.NetAddress.constructor_ipv4(Uint8Array.from([42,0,42,1]), 9735);
- assert(pm_b.new_inbound_connection(sock_b, ldk.Option_NetAddressZ.constructor_some(v4_netaddr)) instanceof ldk.Result_NonePeerHandleErrorZ_OK);
- const init_bytes = pm_a.new_outbound_connection(b.node_id, sock_a, ldk.Option_NetAddressZ.constructor_none());
+ const v4_netaddr = ldk.SocketAddress.constructor_tcp_ip_v4(Uint8Array.from([42,0,42,1]), 9735);
+ assert(pm_b.new_inbound_connection(sock_b, ldk.Option_SocketAddressZ.constructor_some(v4_netaddr)) instanceof ldk.Result_NonePeerHandleErrorZ_OK);
+ const init_bytes = pm_a.new_outbound_connection(b.node_id, sock_a, ldk.Option_SocketAddressZ.constructor_none());
if (!(init_bytes instanceof ldk.Result_CVec_u8ZPeerHandleErrorZ_OK)) return false;
assert(pm_b.read_event(sock_b, init_bytes.res) instanceof ldk.Result_boolPeerHandleErrorZ_OK);
assert(pm_a.get_peer_node_ids().length == 1);
assert(pm_b.get_peer_node_ids().length == 1);
- underlying_om_a.send_onion_message([], ldk.Destination.constructor_node(b.node_id),
- ldk.OnionMessageContents.constructor_custom(ldk.CustomOnionMessageContents.new_impl({
+ underlying_om_a.send_onion_message(
+ ldk.OnionMessagePath.constructor_new([], ldk.Destination.constructor_node(b.node_id)),
+ ldk.OnionMessageContents.new_impl({
tlv_type(): bigint { return 4242n; },
write(): Uint8Array {
const ret = new Uint8Array(43);
for (var i = 0; i < 43; i++) ret[i] = 66;
return ret;
}
- } as ldk.CustomOnionMessageContentsInterface)), null);
+ } as ldk.OnionMessageContentsInterface), null);
pm_a.process_events();
assert(b_handled_msg);
- om_b.send_onion_message([], ldk.Destination.constructor_node(a.node_id),
- ldk.OnionMessageContents.constructor_custom(ldk.CustomOnionMessageContents.new_impl({
+ om_b.send_onion_message(
+ ldk.OnionMessagePath.constructor_new([], ldk.Destination.constructor_node(a.node_id)),
+ ldk.OnionMessageContents.new_impl({
tlv_type(): bigint { return 4343n; },
write(): Uint8Array {
const ret = new Uint8Array(44);
for (var i = 0; i < 44; i++) ret[i] = 67;
return ret;
}
- } as ldk.CustomOnionMessageContentsInterface)), null);
+ } as ldk.OnionMessageContentsInterface), null);
pm_b.process_events();
assert(a_handled_msg);
projects / ldk-java / blobdiff