Function channel_events

plugins/bkpr/sql.c:36–95

}

static struct channel_event **channel_events(const tal_t *ctx,
					     const char *buf,
					     const jsmntok_t *result)
{
	struct channel_event **evs;
	size_t i;
	const jsmntok_t *row, *rows = json_get_member(buf, result, "rows");

	evs = tal_arr(ctx, struct channel_event *, rows->size);
	json_for_each_arr(i, row, rows) {
		bool ok = true;
		struct channel_event *ev;
		u64 created_index;
		const char *account_name;
		const char *primary_tag;
		struct amount_msat credit, debit, fees;
		struct sha256 *payment_id, payment_hash;
		u64 part_id, timestamp;

		const jsmntok_t *val = row + 1;
		assert(row->size == 9);
		ok &= json_to_u64(buf, val, &created_index);
		val = json_next(val);
		account_name = json_strdup(NULL, buf, val);
		val = json_next(val);
		primary_tag = json_strdup(NULL, buf, val);
		val = json_next(val);
		ok &= json_to_msat(buf, val, &credit);
		val = json_next(val);
		ok &= json_to_msat(buf, val, &debit);
		val = json_next(val);
		ok &= json_to_msat(buf, val, &fees);
		val = json_next(val);
		if (json_tok_is_null(buf, val))
			payment_id = NULL;
		else {
			ok &= json_to_sha256(buf, val, &payment_hash);
			payment_id = &payment_hash;
		}
		val = json_next(val);
		if (json_tok_is_null(buf, val))
			part_id = 0;
		else {
			ok &= json_to_u64(buf, val, &part_id);
		}
		val = json_next(val);
		ok &= json_to_u64(buf, val, &timestamp);
		assert(ok);
		ev = new_channel_event(evs,
				       take(primary_tag),
				       credit, debit, fees,
				       payment_id,
				       part_id,
				       timestamp);
		ev->acct_name = tal_steal(ev, account_name);
		ev->db_id = created_index;
		evs[i] = ev;
	}