Function wallet_begin_old_close_rescan

wallet/wallet.c:7579–7686

}

void wallet_begin_old_close_rescan(struct lightningd *ld)
{
	struct db_stmt *stmt;
	u32 earliest_block = UINT32_MAX;
	struct missing *missing;
	int v = db_get_intvar(ld->wallet->db, "needs_p2wpkh_close_rescan", -1);
	if (v == 0)
		return;
	assert(v == 1);

	/* Channels where we might have already seen a mutual close,
	 * which said their key was only taproot, but we didn't see an
	 * output, may actually have closed to the p2wpkh address.
	 * Some debugging help with ChatGPT here!
	 */
	stmt = db_prepare_v2(ld->wallet->db,
			     SQL("SELECT "
				 " full_channel_id"
				 ", state"
				 ", scid"
				 ", shutdown_keyidx_local"
				 " FROM channels"
				 " JOIN addresses"
				 "  ON channels.shutdown_keyidx_local = addresses.keyidx"
				 " WHERE addresses.addrtype = ?"
				 " AND NOT EXISTS ("
				 "    SELECT 1"
				 "    FROM outputs"
				 "    WHERE outputs.keyindex = addresses.keyidx"
				 ");"));
	db_bind_int(stmt, wallet_addrtype_in_db(ADDR_P2TR));
	db_query_prepared(stmt);

	missing = tal(tmpctx, struct missing);
	missing->num_found = 0;
	missing->addrs = tal_arr(missing, struct missing_addr, 0);
	while (db_step(stmt)) {
		enum channel_state state;
		struct short_channel_id scid;
		struct channel_id cid;
		struct missing_addr maddr;
		struct ext_key ext;

		state = channel_state_in_db(db_col_int(stmt, "state"));
		switch (state) {
		case DUALOPEND_OPEN_INIT:
		case CHANNELD_AWAITING_LOCKIN:
		case CHANNELD_NORMAL:
		case CHANNELD_SHUTTING_DOWN:
		case CLOSINGD_SIGEXCHANGE:
		case DUALOPEND_OPEN_COMMITTED:
		case DUALOPEND_AWAITING_LOCKIN:
		case CHANNELD_AWAITING_SPLICE:
		case DUALOPEND_OPEN_COMMIT_READY:
			db_col_ignore(stmt, "full_channel_id");
			db_col_ignore(stmt, "scid");
			db_col_ignore(stmt, "shutdown_keyidx_local");
			continue;