X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=lightning-c-bindings%2Fdemo.cpp;h=2ee7a2938f819d4a9c965815cbb4f6bbae6ed79b;hb=e65ed3dd9d4857fbe286627ef190d803a810bac3;hp=34c4dc9364929fbfc62e58cb47b62b6781a08c50;hpb=18337a0191c3abdca8d51861c328dd3d2d9ca6b7;p=ldk-c-bindings

diff --git a/lightning-c-bindings/demo.cpp b/lightning-c-bindings/demo.cpp
index 34c4dc9..2ee7a29 100644
--- a/lightning-c-bindings/demo.cpp
+++ b/lightning-c-bindings/demo.cpp
@@ -98,8 +98,10 @@ const LDKThirtyTwoBytes genesis_hash = { // We don't care particularly if this i
 	.data = { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1 }
 };
 
-void print_log(const void *this_arg, const char *record) {
-	printf("%p - %s\n", this_arg, record);
+void print_log(const void *this_arg, const LDKRecord *record) {
+	LDK::Str mod = Record_get_module_path(record);
+	LDK::Str str = Record_get_args(record);
+	printf("%p - %.*s:%d - %.*s\n", this_arg, (int)mod->len, mod->chars, Record_get_line(record), (int)str->len, str->chars);
 }
 
 uint32_t get_fee(const void *this_arg, LDKConfirmationTarget target) {
@@ -165,7 +167,7 @@ LDKCResult_NoneChannelMonitorUpdateErrZ update_channel_monitor(const void *this_
 			LDKBroadcasterInterface broadcaster = {
 				.broadcast_transaction = broadcast_tx,
 			};
-			LDK::CResult_NoneMonitorUpdateErrorZ res = ChannelMonitor_update_monitor(&mon.second, &update, &broadcaster, &fee_est, arg->logger);
+			LDK::CResult_NoneNoneZ res = ChannelMonitor_update_monitor(&mon.second, &update, &broadcaster, &fee_est, arg->logger);
 			assert(res->result_ok);
 		}
 	}
@@ -419,13 +421,17 @@ LDKCVec_C2Tuple_PublicKeyTypeZZ create_custom_msg(const void* this_arg) {
 	return ret;
 }
 
-uint64_t get_chan_score(const void *this_arg, uint64_t scid, const LDKNodeId *src, const LDKNodeId *dst) { return 42; }
+uint64_t get_chan_score(const void *this_arg, uint64_t scid, uint64_t htlc_amt,
+LDKCOption_u64Z chan_capacity, const LDKNodeId *src, const LDKNodeId *dst) {
+	LDK::COption_u64Z _capacity(std::move(chan_capacity));
+	return 42;
+}
 
 struct CustomRouteFinderParams {
 	LDKLogger *logger;
 	LDKNetworkGraph *graph_ref;
 };
-struct LDKCResult_RouteLightningErrorZ custom_find_route(const void *this_arg, struct LDKPublicKey payer, const struct LDKRouteParameters *NONNULL_PTR route_params, struct LDKCVec_ChannelDetailsZ *first_hops, const struct LDKScore *NONNULL_PTR scorer) {
+struct LDKCResult_RouteLightningErrorZ custom_find_route(const void *this_arg, struct LDKPublicKey payer, const struct LDKRouteParameters *NONNULL_PTR route_params, const uint8_t (*payment_hash)[32], struct LDKCVec_ChannelDetailsZ *first_hops, const struct LDKScore *NONNULL_PTR scorer) {
 	const struct CustomRouteFinderParams *params = (struct CustomRouteFinderParams *)this_arg;
 	assert(first_hops->datalen == 1);
 	assert(ChannelDetails_get_is_usable(&first_hops->data[0]));
@@ -753,10 +759,13 @@ int main() {
 		{
 			EventQueue queue;
 			LDKEventHandler handler = { .this_arg = &queue, .handle_event = handle_event, .free = NULL };
-			ev1.process_pending_events(ev1.this_arg, handler);
-			assert(queue.events.size() == 1);
+			while (queue.events.size() < 2)
+				ev1.process_pending_events(ev1.this_arg, handler);
+			assert(queue.events.size() == 2);
 			assert(queue.events[0]->tag == LDKEvent_PaymentSent);
 			assert(!memcmp(queue.events[0]->payment_sent.payment_preimage.data, payment_preimage.data, 32));
+			assert(queue.events[1]->tag == LDKEvent_PaymentPathSuccessful);
+			assert(!memcmp(queue.events[1]->payment_path_successful.payment_hash.data, payment_hash.data, 32));
 		}
 
 		conn.stop();
@@ -854,7 +863,7 @@ int main() {
 		.free = NULL,
 	};
 	LDK::Scorer scorer = Scorer_default();
-	LDK::LockableScore scorer_mtx = LockableScore_new(Scorer_as_Score(&scorer));
+	LDK::MultiThreadedLockableScore scorer_mtx = MultiThreadedLockableScore_new(Scorer_as_Score(&scorer));
 	EventQueue queue1;
 	LDKEventHandler handler1 = { .this_arg = &queue1, .handle_event = handle_event, .free = NULL };
 	LDK::InvoicePayer payer = InvoicePayer_new(ChannelManager_as_Payer(&cm1), sending_router, &scorer_mtx, logger1, handler1, RetryAttempts_new(0));
@@ -907,7 +916,7 @@ int main() {
 		std::this_thread::yield();
 	}
 
-	while (queue1.events.size() == 0) {
+	while (queue1.events.size() < 2) {
 		PeerManager_process_events(&net2);
 		PeerManager_process_events(&net1);
 
@@ -915,8 +924,9 @@ int main() {
 		LDK::EventHandler evh1 = InvoicePayer_as_EventHandler(&payer);
 		ev1.process_pending_events(std::move(evh1));
 	}
-	assert(queue1.events.size() == 1);
+	assert(queue1.events.size() == 2);
 	assert(queue1.events[0]->tag == LDKEvent_PaymentSent);
+	assert(queue1.events[1]->tag == LDKEvent_PaymentPathSuccessful);
 
 	// Actually close the channel
 	num_txs_broadcasted = 0;