fix(eventindexer): add indexes for struggling queries (#15483)

packages/eventindexer/.l2.env

@@ -7,8 +7,9 @@ DATABASE_HOST=localhost:3306
 DATABASE_MAX_IDLE_CONNS=50
 DATABASE_MAX_OPEN_CONNS=3000
 DATABASE_CONN_MAX_LIFETIME_IN_MS=100000
-RPC_URL=wss://ws.internal.taiko.xyz
+RPC_URL=wss://ws.katla.taiko.xyz
 CORS_ORIGINS=*
-BLOCK_BATCH_SIZE=100
+BLOCK_BATCH_SIZE=50
 CACHE_INTERVAL_IN_SECONDS=60
 LAYER=l2
+INDEX_NFTS=true

packages/eventindexer/generator/generator.go

@@ -196,7 +196,7 @@ func (g *Generator) queryByTask(task string, date time.Time) error {
 	case tasks.TotalTransitionProvedByTier:
 		var tiers []uint16 = make([]uint16, 0)
 
-		query := "SELECT DISTINCT tier FROM events WHERE name = ? AND tier IS NOT NULL;"
+		query := "SELECT DISTINCT tier FROM events WHERE event = ? AND tier IS NOT NULL;"
 
 		err = g.db.GormDB().
 			Raw(query, eventindexer.EventNameTransitionProved).
@@ -252,7 +252,7 @@ func (g *Generator) queryByTask(task string, date time.Time) error {
 	case tasks.TransitionProvedByTierPerDay:
 		var tiers []uint16 = make([]uint16, 0)
 
-		query := "SELECT DISTINCT tier FROM events WHERE name = ? AND tier IS NOT NULL;"
+		query := "SELECT DISTINCT tier FROM events WHERE event = ? AND tier IS NOT NULL;"
 
 		err = g.db.GormDB().
 			Raw(query, eventindexer.EventNameTransitionProved).
@@ -301,7 +301,7 @@ func (g *Generator) queryByTask(task string, date time.Time) error {
 	case tasks.TransitionContestedByTierPerDay:
 		var tiers []uint16 = make([]uint16, 0)
 
-		query := "SELECT DISTINCT tier FROM events WHERE name = ? AND tier IS NOT NULL;"
+		query := "SELECT DISTINCT tier FROM events WHERE event = ? AND tier IS NOT NULL;"
 
 		err = g.db.GormDB().
 			Raw(query, eventindexer.EventNameTransitionContested).
@@ -350,7 +350,7 @@ func (g *Generator) queryByTask(task string, date time.Time) error {
 	case tasks.TotalTransitionContestedByTier:
 		var tiers []uint16 = make([]uint16, 0)
 
-		query := "SELECT DISTINCT tier FROM events WHERE name = ? AND tier IS NOT NULL;"
+		query := "SELECT DISTINCT tier FROM events WHERE event = ? AND tier IS NOT NULL;"
 
 		err = g.db.GormDB().
 			Raw(query, eventindexer.EventNameTransitionContested).

packages/eventindexer/migrations/20250906208839_alter_transactions_table_add_indexes.sql

@@ -0,0 +1,11 @@
+-- +goose Up
+-- +goose StatementBegin
+ALTER TABLE `transactions` ADD INDEX transacted_at_index(`transacted_at`), 
+ADD INDEX transacted_at_contract_address_index(`transacted_at`, `contract_address`);
+
+-- +goose StatementEnd
+-- +goose Down
+-- +goose StatementBegin
+DROP INDEX transacted_at_index on transactions;
+DROP INDEX transacted_at_contract_address_index on transactions;
+-- +goose StatementEnd

packages/eventindexer/migrations/20260906208839_alter_events_table_add_indexes.sql

@@ -0,0 +1,15 @@
+-- +goose Up
+-- +goose StatementBegin
+ALTER TABLE `events` ADD INDEX `event_transacted_at_tier_index` (`transacted_at`, `event`, `tier`), 
+ADD INDEX `event_transacted_at_index` (`transacted_at`, `event`),
+ADD INDEX `event_block_id_index` (`event`, `block_id`), 
+ADD INDEX `event_tier_index` (`event`, `tier`);
+
+-- +goose StatementEnd
+-- +goose Down
+-- +goose StatementBegin
+DROP INDEX event_transacted_at_tier_index on events,
+event_transacted_at_index on events,
+event_block_id_index on events,
+event_tier_index on events;
+-- +goose StatementEnd

packages/eventindexer/migrations/20270906208839_alter_accounts_table_add_indexes.sql

@@ -0,0 +1,9 @@
+-- +goose Up
+-- +goose StatementBegin
+ALTER TABLE `accounts` ADD INDEX `transacted_at_index` (`transacted_at`);
+
+-- +goose StatementEnd
+-- +goose Down
+-- +goose StatementBegin
+DROP INDEX transacted_at_index on accounts;
+-- +goose StatementEnd

packages/eventindexer/migrations/20280906208839_alter_blocks_table_add_indexes.sql

@@ -0,0 +1,9 @@
+-- +goose Up
+-- +goose StatementBegin
+ALTER TABLE `blocks` ADD INDEX `transacted_at_index` (`transacted_at`);
+
+-- +goose StatementEnd
+-- +goose Down
+-- +goose StatementBegin
+DROP INDEX transacted_at_index on blocks;
+-- +goose StatementEnd