Method GetTotalCommittedTransactions

database/transaction.go:745–786

GetTotalCommittedTransactions calculates the total committed transaction amounts for a given parent transaction. It uses OpenTelemetry for tracing and returns the total or an error if the retrieval fails. Parameters: - ctx: Context for managing the request and tracing. - parentID: The ID of the pare

(ctx context.Context, parentID string)

// Returns:
// - The total committed amount as *big.Int, or 0 if no transactions are found, along with an error if the retrieval fails.
func (d Datasource) GetTotalCommittedTransactions(ctx context.Context, parentID string) (*big.Int, error) {
	// Start a new tracing span for the operation
	ctx, span := otel.Tracer("transaction.database").Start(ctx, "GetTotalCommittedTransactions")
	defer span.End()

	// SQL query to calculate the total precise amount for the given parent transaction
	query := `
		SELECT SUM(precise_amount) AS total_amount
		FROM ledgerforge.transactions
		WHERE parent_transaction = $1 AND status = 'APPLIED'
		GROUP BY parent_transaction;
	`

	// Initialize the variable to store the total amount
	var totalAmountStr string

	// Execute the query and scan the result into totalAmount
	err := d.Conn.QueryRowContext(ctx, query, parentID).Scan(&totalAmountStr)
	if err != nil {
		// If no rows are found, return 0 without error
		if errors.Is(err, sql.ErrNoRows) {
			return new(big.Int), nil
		}
		// Record the error in the tracing span and return the error
		span.RecordError(err)
		return big.NewInt(0), apierror.NewAPIError(apierror.ErrInternalServer, "Failed to get total committed transactions", err)
	}

	total, ok := new(big.Int).SetString(totalAmountStr, 10)
	if !ok {
		return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to parse precise amount", nil)
	}

	// Log the successful retrieval of the total amount
	span.AddEvent("Total committed transactions retrieved", trace.WithAttributes(
		attribute.String("parent_transaction.id", parentID),
		attribute.String("total_amount", total.String()),
	))

	// Return the total amount
	return total, nil
}

// GetTransactionsPaginated retrieves a batch of transactions from the database with pagination support and caches the result.
// If the data is found in cache, it is returned from there; otherwise, it is fetched from the database and then cached.