From 9a0e26f9ad40777347e8271bedba71e226dc6200 Mon Sep 17 00:00:00 2001
From: Artem <aopoltorzhicky@gmail.com>
Date: Sun, 8 Oct 2023 19:14:26 +0200
Subject: [PATCH] Create contract indexes

---
 cmd/indexer/indexer/indices.go  |  9 ---------
 internal/postgres/core/index.go | 24 ++++++++++++++++++++++++
 2 files changed, 24 insertions(+), 9 deletions(-)

diff --git a/cmd/indexer/indexer/indices.go b/cmd/indexer/indexer/indices.go
index a28df0a13..01d5373c4 100644
--- a/cmd/indexer/indexer/indices.go
+++ b/cmd/indexer/indexer/indices.go
@@ -44,15 +44,6 @@ func (bi *BlockchainIndexer) createIndices(ctx context.Context) error {
 	if err := bi.Storage.CreateIndex(ctx, "contracts_level_idx", "level", contractModel); err != nil {
 		return err
 	}
-	if err := bi.Storage.CreateIndex(ctx, "contracts_alpha_id_idx", "alpha_id", contractModel); err != nil {
-		return err
-	}
-	if err := bi.Storage.CreateIndex(ctx, "contracts_babylon_id_idx", "babylon_id", contractModel); err != nil {
-		return err
-	}
-	if err := bi.Storage.CreateIndex(ctx, "contracts_jakarta_id_idx", "jakarta_id", contractModel); err != nil {
-		return err
-	}
 
 	// Global constants
 	globalConstant := (*contract.GlobalConstant)(nil)
diff --git a/internal/postgres/core/index.go b/internal/postgres/core/index.go
index d16331ccc..4030a25c5 100644
--- a/internal/postgres/core/index.go
+++ b/internal/postgres/core/index.go
@@ -85,6 +85,30 @@ func createBaseIndices(ctx context.Context, db bun.IDB) error {
 			Exec(ctx); err != nil {
 			return err
 		}
+		if _, err := db.NewCreateIndex().
+			Model((*contract.Contract)(nil)).
+			IfNotExists().
+			Index("contracts_alpha_id_idx").
+			Column("alpha_id").
+			Exec(ctx); err != nil {
+			return err
+		}
+		if _, err := db.NewCreateIndex().
+			Model((*contract.Contract)(nil)).
+			IfNotExists().
+			Index("contracts_babylon_id_idx").
+			Column("babylon_id").
+			Exec(ctx); err != nil {
+			return err
+		}
+		if _, err := db.NewCreateIndex().
+			Model((*contract.Contract)(nil)).
+			IfNotExists().
+			Index("contracts_jakarta_id_idx").
+			Column("jakarta_id").
+			Exec(ctx); err != nil {
+			return err
+		}
 
 		// Scripts
 		if _, err := db.NewCreateIndex().