splice: Add call to hsmd_sync_outpoint when mutual channel_ready

Author: ksedgwic

channeld/channeld.c

@@ -681,6 +681,22 @@ static bool channel_announcement_negotiate(struct peer *peer)
 	return sent_announcement;
 }
 
+/* Call this method when channel_ready status are changed. */
+static void check_mutual_channel_ready(struct peer *peer)
+{
+	const u8 *msg;
+	if (peer->channel_ready[LOCAL] && peer->channel_ready[REMOTE]) {
+		/* Make sure the hsmd agrees that this outpoint is
+		 * sufficiently buried. */
+		msg = towire_hsmd_sync_outpoint(NULL, &peer->channel->funding);
+		msg = hsm_req(tmpctx, take(msg));
+		if (!fromwire_hsmd_sync_outpoint_reply(msg))
+			status_failed(STATUS_FAIL_HSM_IO,
+				      "Bad hsmd_sync_outpoint_reply: %s",
+				      tal_hex(tmpctx, msg));
+	}
+}
+
 /* Call this method when splice_locked status are changed. If both sides have
  * splice_locked'ed than this function consumes the `splice_locked_ready` values
  * and considers the channel funding to be switched to the splice tx. */
@@ -841,6 +857,7 @@ static void handle_peer_channel_ready(struct peer *peer, const u8 *msg)
 
 	peer->tx_sigs_allowed = false;
 	peer->channel_ready[REMOTE] = true;
+	check_mutual_channel_ready(peer);
 	if (tlvs->short_channel_id != NULL) {
 		status_debug(
 		    "Peer told us that they'll use alias=%s for this channel",
@@ -5238,6 +5255,7 @@ static void handle_funding_depth(struct peer *peer, const u8 *msg)
 			peer_write(peer->pps, take(msg));
 
 			peer->channel_ready[LOCAL] = true;
+			check_mutual_channel_ready(peer);
 		}
 		else if(splicing && !peer->splice_state->locked_ready[LOCAL]) {
 			assert(scid);

openingd/dualopend.c

@@ -424,6 +424,22 @@ static void billboard_update(struct state *state)
 	peer_billboard(false, update);
 }
 
+/* Call this method when channel_ready status are changed. */
+static void check_mutual_channel_ready(struct state *state)
+{
+	u8 *msg;
+	if (state->channel_ready[LOCAL] && state->channel_ready[REMOTE]) {
+		/* Make sure the hsmd agrees that this outpoint is
+		 * sufficiently buried. */
+		msg = towire_hsmd_sync_outpoint(NULL, &state->channel->funding);
+		wire_sync_write(HSM_FD, take(msg));
+		msg = wire_sync_read(tmpctx, HSM_FD);
+		if (!fromwire_hsmd_sync_outpoint_reply(msg))
+			status_failed(STATUS_FAIL_HSM_IO, "Bad hsmd_sync_outpoint_reply %s",
+				      tal_hex(tmpctx, msg));
+	}
+}
+
 static void send_shutdown(struct state *state, const u8 *final_scriptpubkey)
 {
 	u8 *msg;
@@ -1273,6 +1289,7 @@ static u8 *handle_channel_ready(struct state *state, u8 *msg)
 	}
 
 	state->channel_ready[REMOTE] = true;
+	check_mutual_channel_ready(state);
 	billboard_update(state);
 
 	if (state->channel_ready[LOCAL])
@@ -3824,6 +3841,7 @@ static void send_channel_ready(struct state *state)
 	peer_write(state->pps, take(msg));
 
 	state->channel_ready[LOCAL] = true;
+	check_mutual_channel_ready(state);
 	billboard_update(state);
 }