Method GetTransactionByRef

database/transaction.go:561–607

GetTransactionByRef retrieves a transaction from the database using the provided reference. It traces the operation using OpenTelemetry and returns the transaction or an error. Parameters: - ctx: Context for managing the request and tracing. - reference: The reference of the transaction to retrieve.

(ctx context.Context, reference string)

// Returns:
// - A model.Transaction representing the transaction or an error if the retrieval fails.
func (d Datasource) GetTransactionByRef(ctx context.Context, reference string) (model.Transaction, error) {
	// Start a new tracing span for the database operation
	ctx, span := otel.Tracer("transaction.database").Start(ctx, "GetTransactionByRef")
	defer span.End()

	// Query the transaction by reference
	row := d.Conn.QueryRowContext(ctx, `
		SELECT transaction_id, source, reference, amount, precise_amount, currency, destination, description, status, created_at, meta_data, parent_transaction
		FROM ledgerforge.transactions
		WHERE reference = $1
	`, reference)

	// Initialize the transaction object and scan the query result into it
	txn := model.Transaction{}
	var metaDataJSON []byte
	var preciseAmountStr string
	err := row.Scan(&txn.TransactionID, &txn.Source, &txn.Reference, &txn.Amount, &preciseAmountStr, &txn.Currency, &txn.Destination, &txn.Description, &txn.Status, &txn.CreatedAt, &metaDataJSON, &txn.ParentTransaction)
	if err != nil {
		if err == sql.ErrNoRows {
			span.RecordError(err)
			return model.Transaction{}, apierror.NewAPIError(apierror.ErrNotFound, fmt.Sprintf("Transaction with reference '%s' not found", reference), err)
		}
		span.RecordError(err)
		return model.Transaction{}, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to retrieve transaction", err)
	}

	// Unmarshal the metadata JSON into the transaction's MetaData field
	err = json.Unmarshal(metaDataJSON, &txn.MetaData)
	if err != nil {
		span.RecordError(err)
		return model.Transaction{}, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to unmarshal metadata", err)
	}

	txn.PreciseAmount, err = parseBigInt(preciseAmountStr)
	if err != nil {
		span.RecordError(err)
		return model.Transaction{}, fmt.Errorf("failed to parse precise_amount: %w", err)
	}

	// Log the successful transaction retrieval in the tracing span
	span.AddEvent("Transaction retrieved by reference", trace.WithAttributes(
		attribute.String("transaction.id", txn.TransactionID),
		attribute.String("transaction.reference", txn.Reference),
	))

	return txn, nil
}

// UpdateTransactionStatus updates the status of a transaction in the database.
// It traces the operation using OpenTelemetry and returns an error if the update fails or if the transaction is not found.