fix: db error duplicate rows with not unique constrained value

Author: harsh-98

cmd/main.go

@@ -8,6 +8,9 @@ package main
 
 import (
 	"context"
+	_ "net/http/pprof"
+	"time"
+
 	"github.com/Gearbox-protocol/sdk-go/log"
 	"github.com/Gearbox-protocol/third-eye/config"
 	"github.com/Gearbox-protocol/third-eye/debts"
@@ -18,9 +21,14 @@ import (
 	"github.com/Gearbox-protocol/third-eye/services"
 	_ "github.com/heroku/x/hmetrics/onload"
 	"go.uber.org/fx"
-	"time"
 )
 
+// func init() {
+// 	go func() {
+// 		http.ListenAndServe(":8080", nil)
+// 	}()
+// }
+
 func StartServer(lc fx.Lifecycle, engine ds.EngineI, config *config.Config) {
 	log.NewAMQPService(config.ChainId, config.AMPQEnable, config.AMPQUrl, "Third-eye")
 	// Starting server

models/credit_manager/credit_session_state.go

@@ -49,6 +49,7 @@ func (mdl *CreditManager) closeSession(sessionId string, blockNum int64, closeDe
 		amountToPool = data.LiquidationAmount
 	}
 	// pool repay
+	// check for avoiding db errors
 	mdl.PoolRepay(blockNum,
 		closeDetails.LogId,
 		closeDetails.TxHash,

models/credit_manager/v1operation.go

@@ -89,6 +89,7 @@ func (mdl *CreditManager) onCloseCreditAccount(txLog *types.Log, owner, to strin
 	}
 	mdl.AddAccountOperation(accountOperation)
 	mdl.ClosedSessions[sessionId] = &SessionCloseDetails{
+		LogId:          txLog.Index,
 		RemainingFunds: remainingFunds,
 		Status:         schemas.Closed,
 		TxHash:         txLog.TxHash.Hex(),
@@ -122,6 +123,7 @@ func (mdl *CreditManager) onLiquidateCreditAccount(txLog *types.Log, owner, liqu
 	}
 	mdl.AddAccountOperation(accountOperation)
 	mdl.ClosedSessions[sessionId] = &SessionCloseDetails{
+		LogId:          txLog.Index,
 		RemainingFunds: remainingFunds,
 		Status:         schemas.Liquidated,
 		TxHash:         txLog.TxHash.Hex(),

models/credit_manager/v2operation.go

@@ -199,6 +199,7 @@ func (mdl *CreditManager) onCloseCreditAccountV2(txLog *types.Log, owner, to str
 		mdl.GetUnderlyingToken(), mdl.GetUnderlyingDecimal(), prices))
 	session.RemainingFunds = (*core.BigInt)(remainingFunds)
 	mdl.ClosedSessions[sessionId] = &SessionCloseDetails{
+		LogId:          txLog.Index,
 		RemainingFunds: remainingFunds,
 		Status:         schemas.Closed,
 		TxHash:         txLog.TxHash.Hex(),
@@ -251,6 +252,7 @@ func (mdl *CreditManager) onLiquidateCreditAccountV2(txLog *types.Log, owner, li
 	// process multicalls
 	mdl.multiCallHandler(accountOperation)
 	mdl.ClosedSessions[sessionId] = &SessionCloseDetails{
+		LogId:          txLog.Index,
 		RemainingFunds: remainingFunds,
 		Status:         schemas.Liquidated,
 		TxHash:         txLog.TxHash.Hex(),

repository/handlers/blocks.go

@@ -53,6 +53,9 @@ func (repo *BlocksRepo) Save(tx *gorm.DB) {
 	defer utils.Elapsed("blocks sql statements")()
 	blocksToSync := make([]*schemas.Block, 0, len(repo.GetBlocks()))
 	for _, block := range repo.GetBlocks() {
+		if len(block.PoolLedgers) > 0 {
+			log.Info(utils.ToJson(block.PoolLedgers))
+		}
 		blocksToSync = append(blocksToSync, block)
 	}
 	// clauses not needed here