From e3df60c506fb2570ce5f91c40106ccc9c8f543fa Mon Sep 17 00:00:00 2001 From: Abdul Rabbani Date: Tue, 22 Mar 2022 11:52:35 -0400 Subject: [PATCH] Remove the need to pass a transaction when upserting to known_gaps Thanks Ian :D --- statediff/indexer/database/sql/writer.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/statediff/indexer/database/sql/writer.go b/statediff/indexer/database/sql/writer.go index 26305973c..b04a2b434 100644 --- a/statediff/indexer/database/sql/writer.go +++ b/statediff/indexer/database/sql/writer.go @@ -17,6 +17,7 @@ package sql import ( + "context" "fmt" "github.com/ethereum/go-ethereum/common" @@ -186,14 +187,12 @@ func (w *Writer) upsertStorageCID(tx Tx, storageCID models.StorageNodeModel) err return nil } -func (w *Writer) upsertKnownGaps(tx Tx, knownGaps models.KnownGapsModel) error { - res, err := tx.Exec(w.db.Context(), w.db.InsertKnownGapsStm(), +func (w *Writer) upsertKnownGaps(knownGaps models.KnownGapsModel) error { + _, err := w.db.Exec(context.Background(), w.db.InsertKnownGapsStm(), knownGaps.StartingBlockNumber, knownGaps.EndingBlockNumber, knownGaps.CheckedOut, knownGaps.ProcessingKey) if err != nil { return fmt.Errorf("error upserting known_gaps entry: %v", err) } - ret, _ := res.RowsAffected() - fmt.Println("Res:", ret) return nil }