Method recordMatchInTransaction

database/reconciliation.go:257–270

recordMatchInTransaction inserts a match into the database within a transaction context. It is used to save matches during a reconciliation process, ensuring atomicity in batch operations. Parameters: - ctx: Context for managing request and tracing. - tx: The current database transaction in which th

(ctx context.Context, tx *sql.Tx, match *model.Match)

// Returns:
// - An error if the operation fails, wrapped in an APIError for consistency.
func (d Datasource) recordMatchInTransaction(ctx context.Context, tx *sql.Tx, match *model.Match) error {
	_, err := tx.ExecContext(ctx,
		`INSERT INTO ledgerforge.matches(
			external_transaction_id, internal_transaction_id, reconciliation_id, amount, date
		) VALUES ($1, $2, $3, $4, $5)`,
		match.ExternalTransactionID, match.InternalTransactionID, match.ReconciliationID, match.Amount, match.Date,
	)
	if err != nil {
		// For other errors, return the original error
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to record match", err)
	}

	return nil
}

// RecordMatch inserts a single match into the database.
// It is used to record the match between external and internal transactions during reconciliation.