rm cmts

Author: PatStiles

aggregator/pkg/aggregator.go

@@ -392,7 +392,6 @@ func (agg *Aggregator) AddNewTask(batchMerkleRoot [32]byte, senderAddress [20]by
 
 // |---RETRYABLE---|
 
-// TODO: Add Retryable Label
 /*
 InitializeNewTask
 Initialize a new task in the BLS Aggregation service

aggregator/pkg/server.go

@@ -53,7 +53,6 @@ func (agg *Aggregator) ProcessOperatorSignedTaskResponseV2(signedTaskResponse *t
 		"operatorId", hex.EncodeToString(signedTaskResponse.OperatorId[:]))
 	taskIndex := uint32(0)
 
-	// TODO: Add Retryable
 	taskIndex, err := agg.GetTaskIndexRetryable(signedTaskResponse.BatchIdentifierHash)
 
 	if err != nil {

core/chainio/avs_subscriber.go

@@ -68,14 +68,12 @@ func (s *AvsSubscriber) SubscribeToNewTasksV2(newTaskCreatedChan chan *servicema
 	// Subscribe to new tasks
 	sub, err := SubscribeToNewTasksV2Retryable(&bind.WatchOpts{}, s.AvsContractBindings.ServiceManager, internalChannel, nil)
 	if err != nil {
-		//TODO: Confirm these are accurate
 		s.logger.Error("Primary failed to subscribe to new AlignedLayer V2 tasks after %d retries", retry.DefaultNumRetries, "err", err)
 		return nil, err
 	}
 
 	subFallback, err := SubscribeToNewTasksV2Retryable(&bind.WatchOpts{}, s.AvsContractBindings.ServiceManagerFallback, internalChannel, nil)
 	if err != nil {
-		//TODO: Confirm these are accurate
 		s.logger.Error("Fallback failed to subscribe to new AlignedLayer V2 tasks after %d retries", retry.DefaultNumRetries, "err", err)
 		return nil, err
 	}

core/retry.go

@@ -123,7 +123,6 @@ request     retry_interval (12 sec)    randomized_interval (0.5)		randomized_int
 Reference: https://github.com/cenkalti/backoff/blob/v4/exponential.go#L9
 */
 
-// TODO: Make config optional by using default but passing nil.
 // Same as Retry only that the functionToRetry can return a value upon correct execution
 func RetryWithData[T any](functionToRetry func() (T, error), config *RetryConfig) (T, error) {
 	//func RetryWithData[T any](functionToRetry func() (T, error), minDelay time.Duration, factor float64, maxTries uint64, maxInterval time.Duration, maxElapsedTime time.Duration) (T, error) {