feat: agglayer grpc client

agglayer/grpc/agglayer_grpc_client.go

@@ -0,0 +1,25 @@
+package grpc
+
+import (
+	"github.com/agglayer/aggkit/agglayer/proto/node"
+	"github.com/agglayer/aggkit/common"
+)
+
+type AgglayerGRPCClient struct {
+	cfgService          node.AgglayerConfigurationServiceClient
+	networkStateService node.AgglayerNetworkStateServiceClient
+	submissionService   node.AgglayerCertificateSubmissionServiceClient
+}
+
+// NewAggchainProofClient initializes a new AggchainProof instance
+func NewAgglayerGRPCClient(serverAddr string) (*AgglayerGRPCClient, error) {
+	grpcClient, err := common.NewClient(serverAddr)
+	if err != nil {
+		return nil, err
+	}
+	return &AgglayerGRPCClient{
+		cfgService:          node.NewAgglayerConfigurationServiceClient(grpcClient.Conn()),
+		networkStateService: node.NewAgglayerNetworkStateServiceClient(grpcClient.Conn()),
+		submissionService:   node.NewAgglayerCertificateSubmissionServiceClient(grpcClient.Conn()),
+	}, nil
+}

aggsender/grpc/aggchain_proof_client.go

@@ -6,6 +6,7 @@ import (
 
 	agglayer "github.com/agglayer/aggkit/agglayer"
 	"github.com/agglayer/aggkit/aggsender/types"
+	aggkitCommon "github.com/agglayer/aggkit/common"
 	"github.com/agglayer/aggkit/l1infotreesync"
 	treeTypes "github.com/agglayer/aggkit/tree/types"
 	"github.com/ethereum/go-ethereum/common"
@@ -33,12 +34,12 @@ type AggchainProofClient struct {
 
 // NewAggchainProofClient initializes a new AggchainProof instance
 func NewAggchainProofClient(serverAddr string) (*AggchainProofClient, error) {
-	grpcClient, err := NewClient(serverAddr)
+	grpcClient, err := aggkitCommon.NewClient(serverAddr)
 	if err != nil {
 		return nil, err
 	}
 	return &AggchainProofClient{
-		client: types.NewAggchainProofServiceClient(grpcClient.conn),
+		client: types.NewAggchainProofServiceClient(grpcClient.Conn()),
 	}, nil
 }
 

aggsender/grpc/client.go → common/grpc_client.go

@@ -1,4 +1,4 @@
-package grpc
+package common
 
 import (
 	"google.golang.org/grpc"
@@ -23,6 +23,11 @@ func NewClient(serverAddr string) (*Client, error) {
 	return &Client{conn: conn}, nil
 }
 
+// Conn returns the gRPC connection
+func (c *Client) Conn() *grpc.ClientConn {
+	return c.conn
+}
+
 // Close closes the gRPC connection
 func (c *Client) Close() error {
 	return c.conn.Close()