Function process_interactivetx_updates

common/interactivetx.c:392–859

}

char *process_interactivetx_updates(const tal_t *ctx,
			 	    struct interactivetx_context *ictx,
				    bool *received_tx_complete,
				    u8 **abort_msg)
{
	bool we_complete = false, they_complete = false;
	u8 *msg;
	char *error = NULL;
	struct wally_psbt *next_psbt;

	*abort_msg = NULL;

	if (received_tx_complete)
		they_complete = *received_tx_complete;

	/* Build change_set and handle PSBT variables */
	ictx->change_set = tal_free(ictx->change_set);

	/* Call next_update_fn or default to 'desired_psbt' */
	next_psbt = ictx->next_update_fn(ictx, ictx);

	/* Returning NULL from next_update_fn is the same as using `current_psbt`
	 * with no changes -- both indicate no changes */
	if (!next_psbt)
		next_psbt = ictx->current_psbt;

	SUPERVERBOSE("itx get_changes %zu inputs -> %zu inputs",
		     ictx->current_psbt->num_inputs,
		     next_psbt->num_inputs);

	SUPERVERBOSE("current_psbt inputs:");
	for(size_t i = 0; i < ictx->current_psbt->num_inputs; i++) {
		u64 serial_id;
		if (!psbt_get_serial_id(&ictx->current_psbt->inputs[i].unknowns,
					&serial_id))
			return "interactivetx ADD_INPUT PSBT has invalid"
			       " serial_id.";
		SUPERVERBOSE("txhash: "SHA_FMT", index: %"PRIu32", serial_id: %s",
			     SHA_VALS(ictx->current_psbt->inputs[i].txhash),
			     ictx->current_psbt->inputs[i].index,
			     tal_hexstr(ctx, &serial_id, sizeof(serial_id)));
	}

	SUPERVERBOSE("next_psbt inputs:");
	for(size_t i = 0; i < next_psbt->num_inputs; i++) {
		u64 serial_id;
		if (!psbt_get_serial_id(&next_psbt->inputs[i].unknowns,
					&serial_id))
			return "interactivetx ADD_INPUT PSBT has invalid"
			       " serial_id.";
		SUPERVERBOSE("txhash: "SHA_FMT", index: %"PRIu32", serial_id: %s",
			     SHA_VALS(next_psbt->inputs[i].txhash),
			     next_psbt->inputs[i].index,
			     tal_hexstr(ctx, &serial_id, sizeof(serial_id)));
	}

	ictx->change_set = get_changes(ctx, ictx, next_psbt);