From 8e320b289fc103e6fefb385676badeefbc47c9e0 Mon Sep 17 00:00:00 2001 From: Alonso Date: Wed, 24 Jan 2024 11:15:05 +0100 Subject: [PATCH] fix + minor refactor --- etherman/etherman.go | 12 ++++++++---- synchronizer/synchronizer.go | 15 ++------------- 2 files changed, 10 insertions(+), 17 deletions(-) diff --git a/etherman/etherman.go b/etherman/etherman.go index cc1d0a7f..3fe0a52b 100644 --- a/etherman/etherman.go +++ b/etherman/etherman.go @@ -169,7 +169,7 @@ func NewClient(cfg Config, polygonBridgeAddr, polygonZkEVMGlobalExitRootAddress, } // NewL2Client creates a new etherman for L2. -func NewL2Client(url string, bridgeAddr common.Address) (*Client, error) { +func NewL2Client(url string, polygonBridgeAddr common.Address) (*Client, error) { // Connect to ethereum node ethClient, err := ethclient.Dial(url) if err != nil { @@ -177,13 +177,17 @@ func NewL2Client(url string, bridgeAddr common.Address) (*Client, error) { return nil, err } // Create smc clients - bridge, err := polygonzkevmbridge.NewPolygonzkevmbridge(bridgeAddr, ethClient) + bridge, err := polygonzkevmbridge.NewPolygonzkevmbridge(polygonBridgeAddr, ethClient) if err != nil { return nil, err } - scAddresses := []common.Address{bridgeAddr} + oldpolygonBridge, err := oldpolygonzkevmbridge.NewOldpolygonzkevmbridge(polygonBridgeAddr, ethClient) + if err != nil { + return nil, err + } + scAddresses := []common.Address{polygonBridgeAddr} - return &Client{EtherClient: ethClient, PolygonBridge: bridge, SCAddresses: scAddresses}, nil + return &Client{EtherClient: ethClient, PolygonBridge: bridge, OldPolygonBridge: oldpolygonBridge, SCAddresses: scAddresses}, nil } // GetRollupInfoByBlockRange function retrieves the Rollup information that are included in all this ethereum blocks diff --git a/synchronizer/synchronizer.go b/synchronizer/synchronizer.go index c152bc4c..57b63f2a 100644 --- a/synchronizer/synchronizer.go +++ b/synchronizer/synchronizer.go @@ -34,7 +34,6 @@ type ClientSynchronizer struct { chSynced chan uint zkEVMClient zkEVMClientInterface synced bool - isLxLyEtrog bool l1RollupExitRoot common.Hash } @@ -73,7 +72,6 @@ func NewSynchronizer( } if networkID == 0 { return &ClientSynchronizer{ - isLxLyEtrog: isActivated, bridgeCtrl: bridge, storage: storage.(storageInterface), etherMan: ethMan, @@ -89,7 +87,6 @@ func NewSynchronizer( }, nil } return &ClientSynchronizer{ - isLxLyEtrog: isActivated, bridgeCtrl: bridge, storage: storage.(storageInterface), etherMan: ethMan, @@ -367,10 +364,8 @@ func (s *ClientSynchronizer) processBlockRange(blocks []etherman.Block, order ma return err } case etherman.ActivateEtrogOrder: - s.activateLxLyEtrog() - if err != nil { - return err - } + // this is activated when the bridge detects the CreateNewRollup or the AddExistingRollup event from the rollupManager + log.Info("Event received. Activating LxLyEtrog...") } } err = s.storage.Commit(s.ctx, dbTx) @@ -670,9 +665,3 @@ func (s *ClientSynchronizer) processTokenWrapped(tokenWrapped etherman.TokenWrap } return nil } - -func (s *ClientSynchronizer) activateLxLyEtrog() { - // this is activated when the bridge detects the CreateNewRollup or the AddExistingRollup event from the rollupManager - log.Info("Event received. Activating LxLyEtrog...") - s.isLxLyEtrog = true -}