lint

PatStiles · PatStiles · commit 9bd182df7f36 · 2024-11-27T11:29:39.000-03:00
diff --git a/operator/pkg/operator.go b/operator/pkg/operator.go
@@ -334,7 +334,10 @@ func (o *Operator) handleNewBatchLogV2(newBatchLog *servicemanager.ContractAlign
 		hex.EncodeToString(signedTaskResponse.SenderAddress[:]),
 	)
 
-	o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)
+	_, err = o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)
+	if err != nil {
+		o.Logger.Infof("Failed to send signed task response %x to Aggregator. Err: %v", signedTaskResponse.BatchMerkleRoot, err)
+	}
 }
 func (o *Operator) ProcessNewBatchLogV2(newBatchLog *servicemanager.ContractAlignedLayerServiceManagerNewBatchV2) error {
 
@@ -415,7 +418,10 @@ func (o *Operator) handleNewBatchLogV3(newBatchLog *servicemanager.ContractAlign
 		hex.EncodeToString(signedTaskResponse.SenderAddress[:]),
 	)
 
-	o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)
+	_, err = o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)
+	if err != nil {
+		o.Logger.Infof("Failed to send signed task response %x to Aggregator. Err: %v", signedTaskResponse.BatchMerkleRoot, err)
+	}
 }
 func (o *Operator) ProcessNewBatchLogV3(newBatchLog *servicemanager.ContractAlignedLayerServiceManagerNewBatchV3) error {
 

Original file line number	Diff line number	Diff line change
`@@ -334,7 +334,10 @@ func (o Operator) handleNewBatchLogV2(newBatchLog servicemanager.ContractAlign`
`334`	`334`	`hex.EncodeToString(signedTaskResponse.SenderAddress[:]),`
`335`	`335`	`)`
`336`	`336`
`337`		`- o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)`
	`337`	`+ _, err = o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)`
	`338`	`+ if err != nil {`
	`339`	`+ o.Logger.Infof("Failed to send signed task response %x to Aggregator. Err: %v", signedTaskResponse.BatchMerkleRoot, err)`
	`340`	`+ }`
`338`	`341`	`}`
`339`	`342`	`func (o Operator) ProcessNewBatchLogV2(newBatchLog servicemanager.ContractAlignedLayerServiceManagerNewBatchV2) error {`
`340`	`343`
`@@ -415,7 +418,10 @@ func (o Operator) handleNewBatchLogV3(newBatchLog servicemanager.ContractAlign`
`415`	`418`	`hex.EncodeToString(signedTaskResponse.SenderAddress[:]),`
`416`	`419`	`)`
`417`	`420`
`418`		`- o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)`
	`421`	`+ _, err = o.aggRpcClient.SendSignedTaskResponseToAggregatorRetryable(&signedTaskResponse)`
	`422`	`+ if err != nil {`
	`423`	`+ o.Logger.Infof("Failed to send signed task response %x to Aggregator. Err: %v", signedTaskResponse.BatchMerkleRoot, err)`
	`424`	`+ }`
`419`	`425`	`}`
`420`	`426`	`func (o Operator) ProcessNewBatchLogV3(newBatchLog servicemanager.ContractAlignedLayerServiceManagerNewBatchV3) error {`
`421`	`427`