Function wallet_forwarded_payments_get

wallet/wallet.c:4554–4693

}

const struct forwarding *wallet_forwarded_payments_get(struct wallet *w,
						       const tal_t *ctx,
						       enum forward_status status,
						       const struct short_channel_id *chan_in,
						       const struct short_channel_id *chan_out)
{
	struct forwarding *results = tal_arr(ctx, struct forwarding, 0);
	size_t count = 0;
	struct db_stmt *stmt;

	// placeholder for any parameter, the value doesn't matter because it's discarded by sql
	const int any = -1;

	stmt = db_prepare_v2(
	    w->db,
	    SQL("SELECT"
		"  state"
		", in_msatoshi"
		", out_msatoshi"
		", in_channel_scid"
		", out_channel_scid"
		", in_htlc_id"
		", out_htlc_id"
		", received_time"
		", resolved_time"
		", failcode "
		", forward_style "
		"FROM forwards "
		"WHERE (1 = ? OR state = ?) AND "
		"(1 = ? OR in_channel_scid = ?) AND "
		"(1 = ? OR out_channel_scid = ?)"));

	if (status == FORWARD_ANY) {
		// any status
		db_bind_int(stmt, 0, 1);
		db_bind_int(stmt, 1, any);
	} else {
		// specific forward status
		db_bind_int(stmt, 0, 0);
		db_bind_int(stmt, 1, status);
	}

	if (chan_in) {
		// specific in_channel
		db_bind_int(stmt, 2, 0);
		db_bind_scid(stmt, 3, chan_in);
	} else {
		// any in_channel
		db_bind_int(stmt, 2, 1);
		db_bind_int(stmt, 3, any);
	}

	if (chan_out) {
		// specific out_channel
		db_bind_int(stmt, 4, 0);
		db_bind_scid(stmt, 5, chan_out);
	} else {
		// any out_channel