X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fldk%2Fstructs%2FEvent.java;h=149e1a1d3b5f2f9c82bcc07794f8bf87322321fa;hb=6fe917116a65d7b62123226c4240d77ea2719783;hp=4c608dda523143edeb67972465001bcaf61cf632;hpb=1854b5cebef22ace9e9e4dd191f609818df9ce08;p=ldk-java

diff --git a/src/main/java/org/ldk/structs/Event.java b/src/main/java/org/ldk/structs/Event.java
index 4c608dda..149e1a1d 100644
--- a/src/main/java/org/ldk/structs/Event.java
+++ b/src/main/java/org/ldk/structs/Event.java
@@ -58,6 +58,9 @@ public class Event extends CommonBase {
 		if (raw_val.getClass() == bindings.LDKEvent.PaymentPathSuccessful.class) {
 			return new PaymentPathSuccessful(ptr, (bindings.LDKEvent.PaymentPathSuccessful)raw_val);
 		}
+		if (raw_val.getClass() == bindings.LDKEvent.OpenChannelRequest.class) {
+			return new OpenChannelRequest(ptr, (bindings.LDKEvent.OpenChannelRequest)raw_val);
+		}
 		assert false; return null; // Unreachable without extending the (internal) bindings interface
 	}
 
@@ -202,7 +205,7 @@ public class Event extends CommonBase {
 	 * Note that this does *not* indicate that all paths for an MPP payment have failed, see
 	 * [`Event::PaymentFailed`] and [`all_paths_failed`].
 	 * 
-	 * [`all_paths_failed`]: Self::all_paths_failed
+	 * [`all_paths_failed`]: Self::PaymentPathFailed::all_paths_failed
 	 */
 	public final static class PaymentPathFailed extends Event {
 		/**
@@ -292,8 +295,9 @@ public class Event extends CommonBase {
 			this.network_update = network_update_hu_conv;
 			this.all_paths_failed = obj.all_paths_failed;
 			long[] path = obj.path;
-			RouteHop[] path_conv_10_arr = new RouteHop[path.length];
-			for (int k = 0; k < path.length; k++) {
+			int path_conv_10_len = path.length;
+			RouteHop[] path_conv_10_arr = new RouteHop[path_conv_10_len];
+			for (int k = 0; k < path_conv_10_len; k++) {
 				long path_conv_10 = path[k];
 				RouteHop path_conv_10_hu_conv = null; if (path_conv_10 < 0 || path_conv_10 > 4096) { path_conv_10_hu_conv = new RouteHop(null, path_conv_10); }
 				path_conv_10_hu_conv.ptrs_to.add(this);
@@ -376,8 +380,9 @@ public class Event extends CommonBase {
 		private SpendableOutputs(long ptr, bindings.LDKEvent.SpendableOutputs obj) {
 			super(null, ptr);
 			long[] outputs = obj.outputs;
-			SpendableOutputDescriptor[] outputs_conv_27_arr = new SpendableOutputDescriptor[outputs.length];
-			for (int b = 0; b < outputs.length; b++) {
+			int outputs_conv_27_len = outputs.length;
+			SpendableOutputDescriptor[] outputs_conv_27_arr = new SpendableOutputDescriptor[outputs_conv_27_len];
+			for (int b = 0; b < outputs_conv_27_len; b++) {
 				long outputs_conv_27 = outputs[b];
 				SpendableOutputDescriptor outputs_conv_27_hu_conv = SpendableOutputDescriptor.constr_from_ptr(outputs_conv_27);
 				outputs_conv_27_hu_conv.ptrs_to.add(this);
@@ -505,8 +510,9 @@ public class Event extends CommonBase {
 			this.payment_id = obj.payment_id;
 			this.payment_hash = obj.payment_hash;
 			long[] path = obj.path;
-			RouteHop[] path_conv_10_arr = new RouteHop[path.length];
-			for (int k = 0; k < path.length; k++) {
+			int path_conv_10_len = path.length;
+			RouteHop[] path_conv_10_arr = new RouteHop[path_conv_10_len];
+			for (int k = 0; k < path_conv_10_len; k++) {
 				long path_conv_10 = path[k];
 				RouteHop path_conv_10_hu_conv = null; if (path_conv_10 < 0 || path_conv_10 > 4096) { path_conv_10_hu_conv = new RouteHop(null, path_conv_10); }
 				path_conv_10_hu_conv.ptrs_to.add(this);
@@ -515,6 +521,51 @@ public class Event extends CommonBase {
 			this.path = path_conv_10_arr;
 		}
 	}
+	/**
+	 * Indicates a request to open a new channel by a peer.
+	 * 
+	 * To accept the request, call [`ChannelManager::accept_inbound_channel`]. To reject the
+	 * request, call [`ChannelManager::force_close_channel`].
+	 * 
+	 * The event is only triggered when a new open channel request is received and the
+	 * [`UserConfig::manually_accept_inbound_channels`] config flag is set to true.
+	 * 
+	 * [`ChannelManager::accept_inbound_channel`]: crate::ln::channelmanager::ChannelManager::accept_inbound_channel
+	 * [`ChannelManager::force_close_channel`]: crate::ln::channelmanager::ChannelManager::force_close_channel
+	 * [`UserConfig::manually_accept_inbound_channels`]: crate::util::config::UserConfig::manually_accept_inbound_channels
+	 */
+	public final static class OpenChannelRequest extends Event {
+		/**
+		 * The temporary channel ID of the channel requested to be opened.
+		 * 
+		 * When responding to the request, the `temporary_channel_id` should be passed
+		 * back to the ChannelManager with [`ChannelManager::accept_inbound_channel`] to accept,
+		 * or to [`ChannelManager::force_close_channel`] to reject.
+		 * 
+		 * [`ChannelManager::accept_inbound_channel`]: crate::ln::channelmanager::ChannelManager::accept_inbound_channel
+		 * [`ChannelManager::force_close_channel`]: crate::ln::channelmanager::ChannelManager::force_close_channel
+		*/
+		public final byte[] temporary_channel_id;
+		/**
+		 * The node_id of the counterparty requesting to open the channel.
+		*/
+		public final byte[] counterparty_node_id;
+		/**
+		 * The channel value of the requested channel.
+		*/
+		public final long funding_satoshis;
+		/**
+		 * Our starting balance in the channel if the request is accepted, in milli-satoshi.
+		*/
+		public final long push_msat;
+		private OpenChannelRequest(long ptr, bindings.LDKEvent.OpenChannelRequest obj) {
+			super(null, ptr);
+			this.temporary_channel_id = obj.temporary_channel_id;
+			this.counterparty_node_id = obj.counterparty_node_id;
+			this.funding_satoshis = obj.funding_satoshis;
+			this.push_msat = obj.push_msat;
+		}
+	}
 	long clone_ptr() {
 		long ret = bindings.Event_clone_ptr(this.ptr);
 		Reference.reachabilityFence(this);
@@ -687,6 +738,21 @@ public class Event extends CommonBase {
 		return ret_hu_conv;
 	}
 
+	/**
+	 * Utility method to constructs a new OpenChannelRequest-variant Event
+	 */
+	public static Event open_channel_request(byte[] temporary_channel_id, byte[] counterparty_node_id, long funding_satoshis, long push_msat) {
+		long ret = bindings.Event_open_channel_request(InternalUtils.check_arr_len(temporary_channel_id, 32), InternalUtils.check_arr_len(counterparty_node_id, 33), funding_satoshis, push_msat);
+		Reference.reachabilityFence(temporary_channel_id);
+		Reference.reachabilityFence(counterparty_node_id);
+		Reference.reachabilityFence(funding_satoshis);
+		Reference.reachabilityFence(push_msat);
+		if (ret >= 0 && ret <= 4096) { return null; }
+		Event ret_hu_conv = Event.constr_from_ptr(ret);
+		ret_hu_conv.ptrs_to.add(ret_hu_conv);
+		return ret_hu_conv;
+	}
+
 	/**
 	 * Serialize the Event object into a byte array which can be read by Event_read
 	 */