feat: add aggsender to run cmd

0xPolygon · Aug 23, 2024 · 778fb96 · 778fb96
1 parent f121e17
commit 778fb96
Show file tree

Hide file tree

Showing 4 changed files with 28 additions and 3 deletions.
diff --git a/agglayer/client.go b/agglayer/client.go
@@ -17,6 +17,7 @@ import (
 type AgglayerClientInterface interface {
 	SendTx(signedTx SignedTx) (common.Hash, error)
 	WaitTxToBeMined(hash common.Hash, ctx context.Context) error
+	SendCertificate(certificate *Certificate) error
 }
 
 // AggLayerClient is the client that will be used to interact with the AggLayer

diff --git a/aggsender/aggsender.go b/aggsender/aggsender.go
@@ -102,7 +102,7 @@ type AggSender struct {
 	l1Client bridgesync.EthClienter
 
 	db             kv.RwDB
-	aggLayerClient agglayer.AggLayerClient
+	aggLayerClient agglayer.AgglayerClientInterface
 
 	sendInterval types.Duration
 
@@ -113,7 +113,7 @@ type AggSender struct {
 func New(
 	ctx context.Context,
 	cfg Config,
-	aggLayerClient agglayer.AggLayerClient,
+	aggLayerClient agglayer.AgglayerClientInterface,
 	l1Syncer *bridgesync.BridgeSync,
 	l2Syncer *bridgesync.BridgeSync,
 	l1Client bridgesync.EthClienter,

diff --git a/cmd/main.go b/cmd/main.go
@@ -20,6 +20,8 @@ const (
 	AGGORACLE = "aggoracle"
 	// RPC name to identify the rpc component
 	RPC = "rpc"
+	// AGGSENDER name to identify the aggsender component
+	AGGSENDER = "aggsender"
 )
 
 const (
@@ -51,7 +53,7 @@ var (
 		Aliases:  []string{"co"},
 		Usage:    "List of components to run",
 		Required: false,
-		Value:    cli.NewStringSlice(SEQUENCE_SENDER, AGGREGATOR, AGGORACLE, RPC),
+		Value:    cli.NewStringSlice(SEQUENCE_SENDER, AGGREGATOR, AGGORACLE, RPC, AGGSENDER),
 	}
 )
 

diff --git a/cmd/run.go b/cmd/run.go
@@ -12,10 +12,12 @@ import (
 	zkevm "github.com/0xPolygon/cdk"
 	dataCommitteeClient "github.com/0xPolygon/cdk-data-availability/client"
 	jRPC "github.com/0xPolygon/cdk-rpc/rpc"
+	"github.com/0xPolygon/cdk/agglayer"
 	"github.com/0xPolygon/cdk/aggoracle"
 	"github.com/0xPolygon/cdk/aggoracle/chaingersender"
 	"github.com/0xPolygon/cdk/aggregator"
 	"github.com/0xPolygon/cdk/aggregator/db"
+	"github.com/0xPolygon/cdk/aggsender"
 	"github.com/0xPolygon/cdk/bridgesync"
 	"github.com/0xPolygon/cdk/claimsponsor"
 	"github.com/0xPolygon/cdk/config"
@@ -106,6 +108,13 @@ func start(cliCtx *cli.Context) error {
 					log.Fatal(err)
 				}
 			}()
+		case AGGSENDER:
+			aggsender, err := createAggSender(cliCtx.Context, c.AggSender, l1BridgeSync, l2BridgeSync, l1Client, l2Client)
+			if err != nil {
+				log.Fatal(err)
+			}
+
+			go aggsender.Start(cliCtx.Context)
 		}
 	}
 
@@ -114,6 +123,19 @@ func start(cliCtx *cli.Context) error {
 	return nil
 }
 
+func createAggSender(
+	ctx context.Context,
+	cfg aggsender.Config,
+	l1Syncer *bridgesync.BridgeSync,
+	l2Syncer *bridgesync.BridgeSync,
+	l1Client bridgesync.EthClienter,
+	l2Client bridgesync.EthClienter,
+) (*aggsender.AggSender, error) {
+	agglayerClient := agglayer.NewAggLayerClient(cfg.AggLayerUrl)
+
+	return aggsender.New(ctx, cfg, agglayerClient, l1Syncer, l2Syncer, l1Client, l2Client)
+}
+
 func createAggregator(ctx context.Context, c config.Config, runMigrations bool) *aggregator.Aggregator {
 	// Migrations
 	if runMigrations {