Function json_listhtlcs

lightningd/peer_htlcs.c:3232–3288

}

static struct command_result *json_listhtlcs(struct command *cmd,
					     const char *buffer,
					     const jsmntok_t *obj UNNEEDED,
					     const jsmntok_t *params)
{
	struct json_stream *response;
	struct channel *chan;
	struct wallet_htlc_iter *i;
	struct short_channel_id scid;
	u64 htlc_id, created_index, updated_index;
	int cltv_expiry;
	enum side owner;
	struct amount_msat msat;
	struct sha256 payment_hash;
	enum htlc_state hstate;
	enum wait_index *listindex;
	u64 *liststart;
	u32 *listlimit;

	if (!param(cmd, buffer, params,
		   p_opt("id", param_channel, &chan),
		   p_opt("index", param_index, &listindex),
		   p_opt_def("start", param_u64, &liststart, 0),
		   p_opt("limit", param_u32, &listlimit),
		   NULL))
		return command_param_failed();

	response = json_stream_success(cmd);
	json_array_start(response, "htlcs");
	for (i = wallet_htlcs_first(cmd, cmd->ld->wallet, chan,
				    listindex, *liststart, listlimit,
				    &scid, &htlc_id, &cltv_expiry, &owner, &msat,
				    &payment_hash, &hstate,
				    &created_index, &updated_index);
	     i;
	     i = wallet_htlcs_next(cmd->ld->wallet, i,
				   &scid, &htlc_id, &cltv_expiry, &owner, &msat,
				   &payment_hash, &hstate,
				   &created_index, &updated_index)) {
		json_object_start(response, NULL);
		json_add_u64(response, "created_index", created_index);
		if (updated_index != 0)
			json_add_u64(response, "updated_index", updated_index);
		json_add_short_channel_id(response, "short_channel_id", scid);
		json_add_u64(response, "id", htlc_id);
		json_add_u32(response, "expiry", cltv_expiry);
		json_add_string(response, "direction",
				owner == LOCAL ? "out": "in");
		json_add_amount_msat(response, "amount_msat", msat);
		json_add_sha256(response, "payment_hash", &payment_hash);
		json_add_string(response, "state", htlc_state_name(hstate));
		json_object_end(response);
	}
	json_array_end(response);

	return command_success(cmd, response);
}