Function find_close_account_name

plugins/bkpr/recorder.c:245–282

}

const char *find_close_account_name(const tal_t *ctx,
				    const struct bkpr *bkpr,
				    struct command *cmd,
				    const struct bitcoin_txid *txid)
{
	const char *buf;
	const jsmntok_t *result, *rows, *row;
	size_t i;
	const char *acct_name = NULL;

	/* We look for a CHANNEL_CLOSE spend, but ignore “spliced” close events. */
	result = sql_req(ctx, cmd, &buf,
			 "SELECT account_id"
			 " FROM chainmoves cm"
			 " WHERE cm.primary_tag = '%s'"
			 "   AND cm.spending_txid = X'%s'"
			 "   AND NOT EXISTS ("
			 "         SELECT 1 FROM chainmoves_extra_tags et"
			 "         WHERE et.row = cm.created_index"
			 "           AND et.extra_tags = 'spliced'"
			 "       )"
			 "   AND"
			 "    cm.created_index <= %"PRIu64
			 " LIMIT 1",
			 sql_string(tmpctx, mvt_tag_str(MVT_CHANNEL_CLOSE)),
			 fmt_bitcoin_txid(tmpctx, txid),
			 bkpr->chainmoves_index);

	rows = json_get_member(buf, result, "rows");
	json_for_each_arr(i, row, rows) {
		/* Single column => row->size == 1; first value token is row+1 */
		const jsmntok_t *val = row + 1;
		acct_name = json_strdup(ctx, buf, val);
		break; /* only need the first row */
	}

	return acct_name; /* NULL if none found */
}

u64 account_onchain_closeheight(const struct bkpr *bkpr,
				struct command *cmd,