Function account_onchain_closeheight

plugins/bkpr/recorder.c:284–351

}

u64 account_onchain_closeheight(const struct bkpr *bkpr,
				struct command *cmd,
				const struct account *acct)
{
	const u8 *ctx = tal(NULL, u8);
	struct txo_set **sets;
	struct chain_event *close_ev;
	u64 height;

	assert(acct->closed_count > 0);

	close_ev = find_chain_event_by_id(ctx, bkpr, cmd,
					 *acct->closed_event_db_id);

	if (find_txo_chain(ctx, bkpr, cmd, acct, &sets)) {
		/* Ok now we find the max block height of the
		 * spending chain_events for this channel */
		bool ok;
		const char *buf;
		const jsmntok_t *result, *rows, *row;
		size_t i;

		/* Have we accounted for all the outputs */
		ok = false;
		for (i = 0; i < tal_count(sets); i++) {
			if (bitcoin_txid_eq(sets[i]->txid,
					    close_ev->spending_txid)) {

				ok = tal_count(sets[i]->pairs)
						== acct->closed_count;
				break;
			}
		}

		if (!ok) {
			tal_free(ctx);
			return 0;
		}

		result = sql_req(tmpctx, cmd, &buf,
				 "SELECT blockheight"
				 " FROM chainmoves"
				 " WHERE account_id = '%s'"
				 "   AND spending_txid IS NOT NULL"
				 "   AND created_index <= %"PRIu64
				 " ORDER BY blockheight DESC"
				 " LIMIT 1",
				 sql_string(tmpctx, acct->name),
				 bkpr->chainmoves_index);

		rows = json_get_member(buf, result, "rows");
		assert(rows && rows->type == JSMN_ARRAY);

		height = 0;
		json_for_each_arr(i, row, rows) {
			const jsmntok_t *val = row + 1;
			assert(row->size == 1);
			ok = json_to_u64(buf, val, &height);