feat: add validate ger functions to service and client

Author: goran-ethernal

aggsender/aggsender_validator.go

@@ -11,6 +11,7 @@ import (
 	aggkitcommon "github.com/agglayer/aggkit/common"
 	"github.com/agglayer/aggkit/grpc"
 	signertypes "github.com/agglayer/go_signer/signer/types"
+	"github.com/ethereum/go-ethereum/common"
 )
 
 var (
@@ -63,3 +64,8 @@ func (a *AggsenderValidator) Start(ctx context.Context) {
 func (a *AggsenderValidator) ValidateCertificate(ctx context.Context, params types.VerifyIncomingRequest) error {
 	return a.validator.ValidateCertificate(ctx, params)
 }
+
+// ValidateGER validates the GlobalExitRoot that needs to be injected.
+func (a *AggsenderValidator) ValidateGER(ctx context.Context, ger common.Hash) error {
+	return a.validator.ValidateGER(ctx, ger)
+}

aggsender/mocks/mock_certificate_validate_and_signer.go

@@ -257,6 +257,7 @@ func (h *HealthCheckResponse) String() string {
 
 type CertificateValidator interface {
 	ValidateCertificate(ctx context.Context, params VerifyIncomingRequest) error
+	ValidateGER(ctx context.Context, ger common.Hash) error
 }
 
 // CertificateValidateAndSigner is an interface to attach a certificate validator and signer
@@ -270,10 +271,19 @@ type CertificateValidateAndSigner interface {
 		certificate *agglayertypes.Certificate,
 		lastL2BlockInCert uint64,
 	) ([]byte, error)
+	// URL returns the URL of the validator service
 	URL() string
+	// String returns a string representation of the validator service
 	String() string
+	// Address returns the Ethereum address of the validator
 	Address() common.Address
+	// Index returns the index of the validator in the signers list
 	Index() uint32
+	// ValidateAndSignGER validates the GlobalExitRoot that needs to be injected and signs it if valid.
+	ValidateAndSignGER(
+		ctx context.Context,
+		ger common.Hash,
+	) ([]byte, error)
 }
 
 // ValidatorClient is an interface defining functions that a ValidatorClient should implement
@@ -285,6 +295,10 @@ type ValidatorClient interface {
 		certificate *agglayertypes.Certificate,
 		lastL2BlockInCert uint64,
 	) ([]byte, error)
+	ValidateGER(
+		ctx context.Context,
+		ger common.Hash,
+	) ([]byte, error)
 }
 
 // LocalExitRootQuery is an interface defining functions that a LocalExitRootQuery should implement

aggsender/mocks/mock_certificate_validator.go

@@ -99,6 +99,26 @@ func (a *LocalValidator) ValidateAndSignCertificate(
 	return aggkitcommon.EmptySignature, nil
 }
 
+// ValidateAndSignGER validates the GlobalExitRoot that needs to be injected.
+// LocalValidator does not sign the GER, it just validates it.
+func (a *LocalValidator) ValidateAndSignGER(
+	ctx context.Context,
+	ger common.Hash,
+) ([]byte, error) {
+	a.log.Infof("GER validation: %s ....", ger.Hex())
+
+	err := a.validator.ValidateGER(ctx, ger)
+	if err != nil {
+		a.log.Errorf("GER %s validation failed: %s", ger.Hex(), err.Error())
+		return nil, fmt.Errorf("GER %s validation failed: %w", ger.Hex(), err)
+	}
+
+	a.log.Infof("GER %s validation passed", ger.Hex())
+
+	// local validator does not sign the GER, it just validates it
+	return aggkitcommon.EmptySignature, nil
+}
+
 // getPreviousCertificate retrieves the previous certificate based on the new certificate's height.
 func getPreviousCertificate(
 	storage db.AggSenderStorage,