Function do_account_events

plugins/bkpr/bookkeeper.c:772–823

};

static struct command_result *do_account_events(struct command *cmd,
						struct account_events_info *info)
{
	struct json_stream *res;
	struct account *acct;
	struct bitcoin_txid *tx_id;
	struct channel_event **channel_events;
	struct chain_event **chain_events;
	struct onchain_fee **onchain_fees;
	struct bkpr *bkpr = bkpr_of(cmd->plugin);

	if (info->acct_name && info->payment_id != NULL) {
		return command_fail(cmd, JSONRPC2_INVALID_PARAMS,
				    "Can only specify one of "
				    "{account} or {payment_id}");
	}

	if (info->acct_name) {
		acct = find_account(bkpr, info->acct_name);
		if (!acct)
			return command_fail(cmd, JSONRPC2_INVALID_PARAMS,
					    "Account '%s' not found",
					    info->acct_name);
	} else
		acct = NULL;

	if (acct) {
		channel_events = account_get_channel_events(cmd, bkpr, cmd, acct);
		chain_events = account_get_chain_events(cmd, bkpr, cmd, acct);
		onchain_fees = account_get_chain_fees(tmpctx, bkpr, acct->name);
	} else if (info->payment_id != NULL) {
		channel_events = get_channel_events_by_id(cmd, bkpr, cmd, info->payment_id);

		tx_id = tal(cmd, struct bitcoin_txid);
		tx_id->shad.sha = *info->payment_id;
		/* Transaction ids are stored as big-endian in the database */
		reverse_bytes(tx_id->shad.sha.u.u8, sizeof(tx_id->shad.sha.u.u8));

		chain_events = find_chain_events_bytxid(cmd, bkpr, cmd, tx_id);
		onchain_fees = get_chain_fees_by_txid(cmd, bkpr, tx_id);
	} else {
		channel_events = list_channel_events(cmd, bkpr, cmd);
		chain_events = list_chain_events(cmd, bkpr, cmd);
		onchain_fees = list_chain_fees(cmd, bkpr);
	}

	res = jsonrpc_stream_success(cmd);
	json_array_start(res, "events");
	json_add_events(res, bkpr, channel_events, chain_events, onchain_fees);
	json_array_end(res);
	return command_finished(cmd, res);
}

/* Find all the events for this account, ordered by timestamp */
static struct command_result *json_list_account_events(struct command *cmd,