feat: add logs to bridgesync creation

0xPolygon · Nov 27, 2024 · 144cfee · 144cfee
1 parent 521b968
commit 144cfee
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 6 deletions.
diff --git a/bridgesync/bridgesync.go b/bridgesync/bridgesync.go
@@ -5,6 +5,7 @@ import (
 	"time"
 
 	"github.com/0xPolygon/cdk/etherman"
+	"github.com/0xPolygon/cdk/log"
 	"github.com/0xPolygon/cdk/sync"
 	tree "github.com/0xPolygon/cdk/tree/types"
 	"github.com/ethereum/go-ethereum/common"
@@ -111,7 +112,8 @@ func newBridgeSync(
 	originNetwork uint32,
 	syncFullClaims bool,
 ) (*BridgeSync, error) {
-	processor, err := newProcessor(dbPath, l1OrL2ID)
+	logger := log.WithFields("bridge-syncer", l1OrL2ID)
+	processor, err := newProcessor(dbPath, logger)
 	if err != nil {
 		return nil, err
 	}
@@ -156,6 +158,13 @@ func newBridgeSync(
 	if err != nil {
 		return nil, err
 	}
+	logger.Infof("BridgeSyncer [%s] created: dbPath: %s initialBlock:%d bridgeAddr: %s, syncFullClaims: %d,"+
+		" maxRetryAttemptsAfterError:%d RetryAfterErrorPeriod:%s"+
+		"syncBlockChunkSize: %d, blockFinalityType: %s waitForNewBlocksPeriod: %s",
+		l1OrL2ID,
+		dbPath, initialBlock, bridge.String(), syncFullClaims,
+		maxRetryAttemptsAfterError, retryAfterErrorPeriod.String(),
+		syncBlockChunkSize, blockFinalityType, waitForNewBlocksPeriod.String())
 
 	return &BridgeSync{
 		processor:     processor,

diff --git a/bridgesync/processor.go b/bridgesync/processor.go
@@ -109,7 +109,7 @@ type processor struct {
 	bridgeContract BridgeContractor
 }
 
-func newProcessor(dbPath, loggerPrefix string) (*processor, error) {
+func newProcessor(dbPath string, logger *log.Logger) (*processor, error) {
 	err := migrations.RunMigrations(dbPath)
 	if err != nil {
 		return nil, err
@@ -118,7 +118,7 @@ func newProcessor(dbPath, loggerPrefix string) (*processor, error) {
 	if err != nil {
 		return nil, err
 	}
-	logger := log.WithFields("bridge-syncer", loggerPrefix)
+
 	exitTree := tree.NewAppendOnlyTree(db, "")
 	return &processor{
 		db:       db,

diff --git a/bridgesync/processor_test.go b/bridgesync/processor_test.go
@@ -82,7 +82,8 @@ func TestProceessor(t *testing.T) {
 	log.Debugf("sqlite path: %s", path)
 	err := migrationsBridge.RunMigrations(path)
 	require.NoError(t, err)
-	p, err := newProcessor(path, "foo")
+	logger := log.WithFields("bridge-syncer", "foo")
+	p, err := newProcessor(path, logger)
 	require.NoError(t, err)
 	actions := []processAction{
 		// processed: ~
@@ -735,7 +736,8 @@ func TestInsertAndGetClaim(t *testing.T) {
 	log.Debugf("sqlite path: %s", path)
 	err := migrationsBridge.RunMigrations(path)
 	require.NoError(t, err)
-	p, err := newProcessor(path, "foo")
+	logger := log.WithFields("bridge-syncer", "foo")
+	p, err := newProcessor(path, logger)
 	require.NoError(t, err)
 
 	tx, err := p.db.BeginTx(context.Background(), nil)
@@ -828,7 +830,8 @@ func TestGetBridgesPublished(t *testing.T) {
 
 			path := path.Join(t.TempDir(), "file::memory:?cache=shared")
 			require.NoError(t, migrationsBridge.RunMigrations(path))
-			p, err := newProcessor(path, "foo")
+			logger := log.WithFields("bridge-syncer", "foo")
+			p, err := newProcessor(path, logger)
 			require.NoError(t, err)
 
 			tx, err := p.db.BeginTx(context.Background(), nil)