Method RecordMatches

database/reconciliation.go:180–207

RecordMatches batches the saving of match records associated with a specific reconciliation ID. It uses a database transaction to ensure atomicity and consistency of the batch insert operation. Parameters: - ctx: Context for managing request and tracing. - reconciliationID: The ID of the reconciliat

(ctx context.Context, reconciliationID string, matches []model.Match)

// Returns:
// - An error if the operation fails, wrapped in an APIError for consistency.
func (d Datasource) RecordMatches(ctx context.Context, reconciliationID string, matches []model.Match) error {
	ctx, span := otel.Tracer("reconciliation.database").Start(ctx, "Batch saving matches to db")
	defer span.End()

	txn, err := d.Conn.BeginTx(ctx, nil)
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to start transaction", err)
	}
	defer func() {
		if err := txn.Rollback(); err != nil && err != sql.ErrTxDone {
			span.RecordError(fmt.Errorf("error rolling back transaction: %w", err))
		}
	}()

	for _, match := range matches {
		match.ReconciliationID = reconciliationID
		err := d.recordMatchInTransaction(ctx, txn, &match)
		if err != nil {
			return err // The error is already wrapped in an APIError by recordMatchInTransaction
		}
	}

	if err := txn.Commit(); err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to commit transaction", err)
	}

	return nil
}

// RecordUnmatched batches the saving of unmatched external transactions related to a specific reconciliation.
// It uses a database transaction to ensure atomicity and consistency of the batch insert operation.