chore: detail comments

Author: uri-99

aggregator/pkg/server.go

@@ -59,9 +59,9 @@ func (agg *Aggregator) ProcessOperatorSignedTaskResponseV2(signedTaskResponse *t
 		agg.logger.Warn("Task not found in the internal map, might have been missed. Trying to fetch task data from Ethereum")
 		batch, err := agg.avsReader.GetPendingBatchFromMerkleRoot(signedTaskResponse.BatchMerkleRoot, agg.AggregatorConfig.Aggregator.PendingBatchFetchBlockRange)
 		if err != nil || batch == nil {
-			agg.logger.Warnf("Pending task with merkle root 0x%x not found in logs", signedTaskResponse.BatchMerkleRoot)
+			agg.logger.Warnf("Pending task with merkle root 0x%x not found in the contract", signedTaskResponse.BatchMerkleRoot)
 			*reply = 1
-			return nil
+			return nil // TODO non urgent nice to have: return an error. With it, the Operator would know that his signature corresponded to a not found task
 		}
 		agg.logger.Info("Task was found in Ethereum, adding it to the internal map")
 		agg.AddNewTask(batch.BatchMerkleRoot, batch.SenderAddress, batch.TaskCreatedBlock)

core/chainio/avs_reader.go

@@ -174,7 +174,7 @@ func (r *AvsReader) GetPendingBatchFromMerkleRoot(merkleRoot [32]byte, blockRang
 	}
 
 	if !logs.Next() {
-		return nil, nil //Not an error, but no tasks found
+		return nil, nil // Not an error, but no tasks found
 	}
 
 	batch := logs.Event
@@ -188,7 +188,7 @@ func (r *AvsReader) GetPendingBatchFromMerkleRoot(merkleRoot [32]byte, blockRang
 	}
 
 	if state.Responded {
-		return nil, nil
+		return nil, nil // Task found but already responded
 	}
 
 	return batch, nil