add migration for blob indexes

flashbots · Jul 26, 2024 · 4898344 · 4898344
1 parent d4a808a
commit 4898344
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 1 deletion.
diff --git a/cmd/core/data-api-backfill.go b/cmd/core/data-api-backfill.go
@@ -131,7 +131,7 @@ func (bf *backfiller) backfillPayloadsDelivered() error {
 		payloadsNew := 0
 		url := fmt.Sprintf("%s?limit=%d", baseURL, pageLimit)
 		if cursorSlot > 0 {
-			url = fmt.Sprintf("%s&cursor=%d", baseURL, cursorSlot)
+			url = fmt.Sprintf("%s&cursor=%d", url, cursorSlot)
 		}
 		_log.WithField("url: ", url).Info("Fetching payloads...")
 		var data []relaycommon.BidTraceV2JSON

diff --git a/database/migrations/003_add_blob_index.go b/database/migrations/003_add_blob_index.go
@@ -0,0 +1,19 @@
+package migrations
+
+import (
+	"github.com/flashbots/relayscan/database/vars"
+	migrate "github.com/rubenv/sql-migrate"
+)
+
+var migration003SQL = `
+	CREATE INDEX IF NOT EXISTS ` + vars.TableDataAPIPayloadDelivered + `_num_blob_txs_idx ON ` + vars.TableDataAPIPayloadDelivered + `("num_blob_txs");
+	CREATE INDEX IF NOT EXISTS ` + vars.TableDataAPIPayloadDelivered + `_num_blobs_idx ON ` + vars.TableDataAPIPayloadDelivered + `("num_blobs");
+`
+
+var Migration003AddBlobIndexes = &migrate.Migration{
+	Id: "003-add-blob-indexes",
+	Up: []string{migration003SQL},
+
+	DisableTransactionUp:   false,
+	DisableTransactionDown: true,
+}
diff --git a/database/migrations/migration.go b/database/migrations/migration.go
@@ -9,5 +9,6 @@ var Migrations = migrate.MemoryMigrationSource{
 	Migrations: []*migrate.Migration{
 		Migration001InitDatabase,
 		Migration002AddBlobCount,
+		Migration003AddBlobIndexes,
 	},
 }