X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=ts%2Fstructs%2FPeerManager.ts;h=d527dfed994f55e26f94c025f7c1e20e27c3dd44;hb=b3302d48f4dec85e9d23d9b6324d33b7c8619770;hp=165440cf0f4564d635fa8d9433715883e36c3d92;hpb=fed2245c60159f6c074c9ed5c0f3ce273ad9841b;p=ldk-java diff --git a/ts/structs/PeerManager.ts b/ts/structs/PeerManager.ts index 165440cf..d527dfed 100644 --- a/ts/structs/PeerManager.ts +++ b/ts/structs/PeerManager.ts @@ -18,13 +18,14 @@ import * as bindings from '../bindings' // TODO: figure out location bindings.PeerManager_free(this.ptr); } } - public static PeerManager constructor_new(ChannelMessageHandler message_handler_chan_handler_arg, RoutingMessageHandler message_handler_route_handler_arg, Uint8Array our_node_secret, Uint8Array ephemeral_random_data, Logger logger) { - number ret = bindings.PeerManager_new(bindings.MessageHandler_new(message_handler_chan_handler_arg == null ? 0 : message_handler_chan_handler_arg.ptr, message_handler_route_handler_arg == null ? 0 : message_handler_route_handler_arg.ptr), our_node_secret, ephemeral_random_data, logger == null ? 0 : logger.ptr); + public static PeerManager constructor_new(ChannelMessageHandler message_handler_chan_handler_arg, RoutingMessageHandler message_handler_route_handler_arg, Uint8Array our_node_secret, Uint8Array ephemeral_random_data, Logger logger, CustomMessageHandler custom_message_handler) { + number ret = bindings.PeerManager_new(bindings.MessageHandler_new(message_handler_chan_handler_arg == null ? 0 : message_handler_chan_handler_arg.ptr, message_handler_route_handler_arg == null ? 0 : message_handler_route_handler_arg.ptr), our_node_secret, ephemeral_random_data, logger == null ? 0 : logger.ptr, custom_message_handler == null ? 0 : custom_message_handler.ptr); const ret_hu_conv: PeerManager = new PeerManager(null, ret); ret_hu_conv.ptrs_to.add(ret_hu_conv); ret_hu_conv.ptrs_to.add(message_handler_chan_handler_arg); ret_hu_conv.ptrs_to.add(message_handler_route_handler_arg); ret_hu_conv.ptrs_to.add(logger); + ret_hu_conv.ptrs_to.add(custom_message_handler); return ret_hu_conv; } @@ -70,8 +71,12 @@ import * as bindings from '../bindings' // TODO: figure out location this.ptrs_to.add(descriptor); } - public void timer_tick_occured() { - bindings.PeerManager_timer_tick_occured(this.ptr); + public void disconnect_by_node_id(Uint8Array node_id, boolean no_connection_possible) { + bindings.PeerManager_disconnect_by_node_id(this.ptr, node_id, no_connection_possible); + } + + public void timer_tick_occurred() { + bindings.PeerManager_timer_tick_occurred(this.ptr); } }