Function wallet_forwarded_payment_update

wallet/wallet.c:5349–5411

}

static bool wallet_forwarded_payment_update(struct wallet *w,
					    const struct htlc_in *in,
					    const struct htlc_out *out,
					    enum forward_status state,
					    enum onion_wire failcode,
					    struct timeabs *resolved_time,
					    enum forward_style forward_style)
{
	struct db_stmt *stmt;
	bool changed;

	/* We update based solely on the htlc_in since an HTLC cannot be
	 * associated with more than one forwarded payment. This saves us from
	 * having to have two versions of the update statement (one with and
	 * one without the htlc_out restriction).*/
	stmt = db_prepare_v2(w->db,
			     SQL("UPDATE forwards SET"
				 "  updated_index=?"
				 ", in_msatoshi=?"
				 ", out_msatoshi=?"
				 ", state=?"
				 ", resolved_time=?"
				 ", failcode=?"
				 ", forward_style=?"
				 " WHERE in_htlc_id=? AND in_channel_scid=?"));
	/* This may not work so don't increment index yet! */
	db_bind_u64(stmt, w->ld->indexes[WAIT_SUBSYSTEM_FORWARD].i[WAIT_INDEX_UPDATED] + 1);
	db_bind_amount_msat(stmt, in->msat);

	if (out) {
		db_bind_amount_msat(stmt, out->msat);
	} else {
		db_bind_null(stmt);
	}

	db_bind_int(stmt, wallet_forward_status_in_db(state));

	if (resolved_time != NULL) {
		db_bind_timeabs(stmt, *resolved_time);
	} else {
		db_bind_null(stmt);
	}

	if (failcode != 0) {
		assert(state == FORWARD_FAILED || state == FORWARD_LOCAL_FAILED);
		db_bind_int(stmt, (int)failcode);
	} else {
		db_bind_null(stmt);
	}

	/* This can happen for malformed onions, reload from db. */
	if (forward_style == FORWARD_STYLE_UNKNOWN)
		db_bind_null(stmt);
	else
		db_bind_int(stmt, forward_style_in_db(forward_style));
	db_bind_u64(stmt, in->key.id);
	db_bind_short_channel_id(stmt, channel_scid_or_local_alias(in->key.channel));
	db_exec_prepared_v2(stmt);