feat(eventindexer): Eventindexer and relayer a5 updates (#14597)

packages/eventindexer/abigen.sh

@@ -5,9 +5,9 @@ if [ ! -d "../protocol/out" ]; then
     exit 1
 fi
 
-paths=("TaikoL1.sol" "ProverPool.sol" "Bridge.sol")
+paths=("TaikoL1.sol" "Bridge.sol")
 
-names=("TaikoL1" "ProverPool" "Bridge")
+names=("TaikoL1" "Bridge")
 
 
 for (( i = 0; i < ${#paths[@]}; ++i ));

packages/eventindexer/cli/cli.go

@@ -142,7 +142,6 @@ func Run(
 			EthClient:           ethClient,
 			RPCClient:           rpcClient,
 			SrcTaikoAddress:     common.HexToAddress(os.Getenv("L1_TAIKO_ADDRESS")),
-			ProverPoolAddress:   common.HexToAddress(os.Getenv("PROVER_POOL_ADDRESS")),
 			SrcBridgeAddress:    common.HexToAddress(os.Getenv("BRIDGE_ADDRESS")),
 			SrcSwapAddresses:    stringsToAddresses(strings.Split(os.Getenv("SWAP_ADDRESSES"), ",")),
 			BlockBatchSize:      uint64(blockBatchSize),
@@ -283,13 +282,12 @@ func newHTTPServer(db eventindexer.DB, l1EthClient *ethclient.Client) (*http.Ser
 	}
 
 	srv, err := http.NewServer(http.NewServerOpts{
-		EventRepo:         eventRepo,
-		StatRepo:          statRepo,
-		NFTBalanceRepo:    nftBalanceRepo,
-		Echo:              echo.New(),
-		CorsOrigins:       strings.Split(os.Getenv("CORS_ORIGINS"), ","),
-		EthClient:         l1EthClient,
-		ProverPoolAddress: common.HexToAddress(os.Getenv("PROVER_POOL_ADDRESS")),
+		EventRepo:      eventRepo,
+		StatRepo:       statRepo,
+		NFTBalanceRepo: nftBalanceRepo,
+		Echo:           echo.New(),
+		CorsOrigins:    strings.Split(os.Getenv("CORS_ORIGINS"), ","),
+		EthClient:      l1EthClient,
 	})
 	if err != nil {
 		return nil, err

packages/eventindexer/event.go

@@ -15,12 +15,8 @@ var (
 	EventNameBlockProven   = "BlockProven"
 	EventNameBlockProposed = "BlockProposed"
 	EventNameBlockVerified = "BlockVerified"
-	EventNameSlashed       = "Slashed"
 	EventNameMessageSent   = "MessageSent"
 	EventNameSwap          = "Swap"
-	EventNameStaked        = "Staked"
-	EventNameExited        = "Exited"
-	EventNameWithdrawn     = "Withdrawn"
 	EventNameMint          = "Mint"
 	EventNameNFTTransfer   = "Transfer"
 )
@@ -92,7 +88,6 @@ type EventRepository interface {
 		address string,
 		event string,
 	) (paginate.Page, error)
-	GetTotalSlashedTokens(ctx context.Context) (*big.Int, error)
 	FirstByAddressAndEventName(
 		ctx context.Context,
 		address string,

packages/eventindexer/http/routes.go

@@ -9,8 +9,6 @@ func (srv *Server) configureRoutes() {
 	srv.echo.GET("/eventByAddress", srv.GetCountByAddressAndEventName)
 	srv.echo.GET("/events", srv.GetByAddressAndEventName)
 	srv.echo.GET("/stats", srv.GetStats)
-	srv.echo.GET("/posStats", srv.GetPOSStats)
-	srv.echo.GET("/currentProvers", srv.GetCurrentProvers)
 	srv.echo.GET("/assignedBlocks", srv.GetAssignedBlocksByProverAddress)
 	srv.echo.GET("/nftsByAddress", srv.GetNFTBalancesByAddessAndChainID)
 

packages/eventindexer/http/server.go

@@ -7,12 +7,10 @@ import (
 	"os"
 	"time"
 
-	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/ethclient"
 	"github.com/labstack/echo/v4/middleware"
 	"github.com/patrickmn/go-cache"
 	"github.com/taikoxyz/taiko-mono/packages/eventindexer"
-	"github.com/taikoxyz/taiko-mono/packages/eventindexer/contracts/proverpool"
 
 	echoprom "github.com/labstack/echo-contrib/prometheus"
 	echo "github.com/labstack/echo/v4"
@@ -24,17 +22,15 @@ type Server struct {
 	statRepo       eventindexer.StatRepository
 	nftBalanceRepo eventindexer.NFTBalanceRepository
 	cache          *cache.Cache
-	proverPool     *proverpool.ProverPool
 }
 
 type NewServerOpts struct {
-	Echo              *echo.Echo
-	EventRepo         eventindexer.EventRepository
-	StatRepo          eventindexer.StatRepository
-	NFTBalanceRepo    eventindexer.NFTBalanceRepository
-	ProverPoolAddress common.Address
-	EthClient         *ethclient.Client
-	CorsOrigins       []string
+	Echo           *echo.Echo
+	EventRepo      eventindexer.EventRepository
+	StatRepo       eventindexer.StatRepository
+	NFTBalanceRepo eventindexer.NFTBalanceRepository
+	EthClient      *ethclient.Client
+	CorsOrigins    []string
 }
 
 func (opts NewServerOpts) Validate() error {
@@ -58,8 +54,6 @@ func (opts NewServerOpts) Validate() error {
 		return eventindexer.ErrNoNFTBalanceRepository
 	}
 
-	// proverpooladdress is optional
-
 	return nil
 }
 
@@ -70,24 +64,12 @@ func NewServer(opts NewServerOpts) (*Server, error) {
 
 	cache := cache.New(5*time.Minute, 10*time.Minute)
 
-	var proverPool *proverpool.ProverPool
-
-	var err error
-
-	if opts.ProverPoolAddress.Hex() != "" {
-		proverPool, err = proverpool.NewProverPool(opts.ProverPoolAddress, opts.EthClient)
-		if err != nil {
-			return nil, err
-		}
-	}
-
 	srv := &Server{
 		echo:           opts.Echo,
 		eventRepo:      opts.EventRepo,
 		statRepo:       opts.StatRepo,
 		nftBalanceRepo: opts.NFTBalanceRepo,
 		cache:          cache,
-		proverPool:     proverPool,
 	}
 
 	corsOrigins := opts.CorsOrigins

packages/eventindexer/indexer/filter.go

@@ -57,7 +57,7 @@ func L1FilterFunc(
 		})
 
 		wg.Go(func() error {
-			blockVerifiedEvents, err := svc.taikol1.FilterBlockVerified(filterOpts, nil)
+			blockVerifiedEvents, err := svc.taikol1.FilterBlockVerified(filterOpts, nil, nil)
 			if err != nil {
 				return errors.Wrap(err, "svc.taikol1.FilterBlockVerified")
 			}
@@ -87,63 +87,6 @@ func L1FilterFunc(
 		})
 	}
 
-	if svc.proverPool != nil {
-		wg.Go(func() error {
-			slashedEvents, err := svc.proverPool.FilterSlashed(filterOpts, nil, nil)
-			if err != nil {
-				return errors.Wrap(err, "svc.proverPool.FilterSlashed")
-			}
-
-			err = svc.saveSlashedEvents(ctx, chainID, slashedEvents)
-			if err != nil {
-				return errors.Wrap(err, "svc.saveSlashedEvents")
-			}
-
-			return nil
-		})
-
-		wg.Go(func() error {
-			stakedEvents, err := svc.proverPool.FilterStaked(filterOpts, nil)
-			if err != nil {
-				return errors.Wrap(err, "svc.proverPool.FilterStaked")
-			}
-
-			err = svc.saveStakedEvents(ctx, chainID, stakedEvents)
-			if err != nil {
-				return errors.Wrap(err, "svc.saveStakedEvents")
-			}
-
-			return nil
-		})
-
-		wg.Go(func() error {
-			exitedEvents, err := svc.proverPool.FilterExited(filterOpts, nil)
-			if err != nil {
-				return errors.Wrap(err, "svc.proverPool.FilterExited")
-			}
-
-			err = svc.saveExitedEvents(ctx, chainID, exitedEvents)
-			if err != nil {
-				return errors.Wrap(err, "svc.saveExitedEvents")
-			}
-
-			return nil
-		})
-
-		wg.Go(func() error {
-			withdrawnEvents, err := svc.proverPool.FilterWithdrawn(filterOpts, nil)
-			if err != nil {
-				return errors.Wrap(err, "svc.proverPool.FilterWithdrawn")
-			}
-
-			err = svc.saveWithdrawnEvents(ctx, chainID, withdrawnEvents)
-			if err != nil {
-				return errors.Wrap(err, "svc.saveWithdrawnEvents")
-			}
-			return nil
-		})
-	}
-
 	if svc.indexNfts {
 		wg.Go(func() error {
 			if err := svc.indexNFTTransfers(ctx, chainID, filterOpts.Start, *filterOpts.End); err != nil {