Method TransactionExistsByRef

database/transaction.go:479–504

TransactionExistsByRef checks if a transaction with a given reference exists in the database. It uses OpenTelemetry to trace the operation and returns a boolean indicating whether the transaction exists. Parameters: - ctx: Context for managing the request and tracing. - reference: The reference of t

(ctx context.Context, reference string)

// Returns:
// - A boolean indicating whether the transaction exists, or an error if the check fails.
func (d Datasource) TransactionExistsByRef(ctx context.Context, reference string) (bool, error) {
	// Start a new tracing span for the database operation
	ctx, span := otel.Tracer("transaction.database").Start(ctx, "TransactionExistsByRef")
	defer span.End()

	// Variable to store whether the transaction exists
	var exists bool

	// Execute the SQL query to check if the transaction exists by reference
	err := d.Conn.QueryRowContext(ctx, `
		SELECT EXISTS(SELECT 1 FROM ledgerforge.transactions WHERE reference = $1)
	`, reference).Scan(&exists)
	// Handle errors from the query
	if err != nil {
		span.RecordError(err)
		return false, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to check if transaction exists", err)
	}

	// Log the transaction existence result in the tracing span
	span.AddEvent("Transaction existence check", trace.WithAttributes(
		attribute.String("transaction.reference", reference),
		attribute.Bool("transaction.exists", exists),
	))

	return exists, nil
}

// GetExistingTransactionReferences retrieves the subset of the provided references that already
// exist in the database. It returns an empty set when the input is empty.