feat: warning on agglayer rate limit (#122)

* feat: retry on agglayer rate limit exceeded

aggregator/agglayer/agglayer_client.go

@@ -13,6 +13,10 @@ import (
 	"github.com/ethereum/go-ethereum/common"
 )
 
+const errCodeAgglayerRateLimitExceeded int = -10007
+
+var ErrAgglayerRateLimitExceeded = fmt.Errorf("agglayer rate limit exceeded")
+
 // AgglayerClientInterface is the interface that defines the methods that the AggLayerClient will implement
 type AgglayerClientInterface interface {
 	SendTx(signedTx SignedTx) (common.Hash, error)
@@ -39,6 +43,9 @@ func (c *AggLayerClient) SendTx(signedTx SignedTx) (common.Hash, error) {
 	}
 
 	if response.Error != nil {
+		if response.Error.Code == errCodeAgglayerRateLimitExceeded {
+			return common.Hash{}, ErrAgglayerRateLimitExceeded
+		}
 		return common.Hash{}, fmt.Errorf("%v %v", response.Error.Code, response.Error.Message)
 	}
 

aggregator/aggregator.go

@@ -945,9 +945,12 @@ func (a *Aggregator) settleWithAggLayer(
 	a.logger.Debug("final proof signedTx: ", signedTx.Tx.ZKP.Proof.Hex())
 	txHash, err := a.aggLayerClient.SendTx(*signedTx)
 	if err != nil {
-		a.logger.Errorf("failed to send tx to the agglayer: %v", err)
+		if errors.Is(err, agglayer.ErrAgglayerRateLimitExceeded) {
+			a.logger.Errorf("%s. Config param VerifyProofInterval should match the agglayer configured rate limit.", err)
+		} else {
+			a.logger.Errorf("failed to send tx to the agglayer: %v", err)
+		}
 		a.handleFailureToAddVerifyBatchToBeMonitored(ctx, proof)
-
 		return false
 	}