feat: fix number format

Author: harsh-98

debts/debt_db.go

@@ -25,7 +25,7 @@ func (eng *DebtEngine) liquidationCheck(debt *schemas.Debt, cmAddr, borrower str
 				(debt.BlockNumber-eng.liquidableBlockTracker[debt.SessionId].BlockNum) >= sendMsgAfterXBlocks {
 				eng.repo.RecentMsgf(log.RiskHeader{
 					BlockNumber: debt.BlockNumber,
-					EventCode:   "AMQP",
+					EventCode:   "WARN",
 				}, `HealthFactor safe again: 
 				SessionId:%s
 				HF: %s@(block:%d) -> %s@(block:%d)`,
@@ -48,7 +48,7 @@ func (eng *DebtEngine) liquidationCheck(debt *schemas.Debt, cmAddr, borrower str
 		eng.notifiedIfLiquidable(debt.SessionId, true)
 		eng.repo.RecentMsgf(log.RiskHeader{
 			BlockNumber: debt.BlockNumber,
-			EventCode:   "INV-LOW-HF-NOT-LIQUIDATED",
+			EventCode:   "WARN",
 		}, `After %d blocks:
 				Session: %s
 				HF: %s

models/credit_manager/cm_v1/on_change.go

@@ -14,7 +14,7 @@ func OnDirectTokenTransfer(repo ds.RepositoryI, tx *schemas.TokenTransfer, sessi
 	}
 	repo.RecentMsgf(log.RiskHeader{
 		BlockNumber: tx.BlockNum,
-		EventCode:   "AMQP",
+		EventCode:   "WARN",
 	}, "Deposit: %s", cm_common.DirecTokenTransferString(repo, tx))
 	amount := tx.Amount.Convert()
 	repo.AddAccountOperation(&schemas.AccountOperation{

models/pool/pool_common/utils.go

@@ -22,6 +22,6 @@ func CheckIfAmountMoreThan1Mil(client core.ClientI, repo ds.RepositoryI, state *
 		repo.RecentMsgf(log.RiskHeader{
 			BlockNumber: blockNum,
 			EventCode:   "AMQP",
-		}, "Pool %s in %s is more than 1Million USD, calculated value is %f", operation, urls.ExplorerHashUrl(txHash), value)
+		}, "Pool %s in %s is more than 1Million USD, calculated value is %.2f", operation, urls.ExplorerHashUrl(txHash), value/1_000_000)
 	}
 }

models/pool/pool_v2/on_log.go

@@ -1,6 +1,7 @@
 package pool_v2
 
 import (
+	"fmt"
 	"math/big"
 
 	"github.com/Gearbox-protocol/sdk-go/core"
@@ -48,7 +49,8 @@ func (mdl *Poolv2) OnLog(txLog types.Log) {
 			AmountBI: (*core.BigInt)(addLiquidityEvent.Amount),
 			Amount:   utils.GetFloat64Decimal(addLiquidityEvent.Amount, mdl.Repo.GetToken(mdl.State.UnderlyingToken).Decimals),
 		})
-		pool_common.CheckIfAmountMoreThan1Mil(mdl.Client, mdl.Repo, mdl.State, addLiquidityEvent.Amount, blockNum, txLog.TxHash.Hex(), "deposit")
+		pool_common.CheckIfAmountMoreThan1Mil(mdl.Client, mdl.Repo, mdl.State, addLiquidityEvent.Amount, blockNum, txLog.TxHash.Hex(),
+			fmt.Sprintf("%s deposit", mdl.Repo.GetToken(mdl.State.UnderlyingToken).Symbol))
 		mdl.updateBorrowRate(blockNum)
 	case core.Topic("RemoveLiquidity(address,address,uint256)"):
 		removeLiquidityEvent, err := mdl.contractETH.ParseRemoveLiquidity(txLog)
@@ -67,7 +69,8 @@ func (mdl *Poolv2) OnLog(txLog types.Log) {
 			Receiver:    removeLiquidityEvent.To.Hex(),
 			AmountBI:    (*core.BigInt)(removeLiquidityEvent.Amount),
 		})
-		pool_common.CheckIfAmountMoreThan1Mil(mdl.Client, mdl.Repo, mdl.State, removeLiquidityEvent.Amount, blockNum, txLog.TxHash.Hex(), "withdrawn")
+		pool_common.CheckIfAmountMoreThan1Mil(mdl.Client, mdl.Repo, mdl.State, removeLiquidityEvent.Amount, blockNum, txLog.TxHash.Hex(),
+			fmt.Sprintf("%s withdrawal", mdl.Repo.GetToken(mdl.State.UnderlyingToken).Symbol))
 
 		mdl.updateBorrowRate(blockNum)
 	case core.Topic("Borrow(address,address,uint256)"):
@@ -175,19 +178,3 @@ func (mdl *Poolv2) OnLog(txLog types.Log) {
 		mdl.gatewayHandler.CheckWithdrawETH(txLog.TxHash.Hex(), blockNum, int64(ind), mdl.Address, to)
 	}
 }
-
-func (mdl Poolv2) checkIfAmountMoreThan1Mil(amount *big.Int, blockNum int64, txHash string, operation string) {
-	token := mdl.State.UnderlyingToken
-	priceInUSD := mdl.Repo.GetPrice(token)
-	if priceInUSD == nil {
-		return
-	}
-	value := utils.GetFloat64Decimal(new(big.Int).Mul(priceInUSD, amount), mdl.Repo.GetToken(token).Decimals+8)
-	if value > 1_000_000 {
-		urls := log.NetworkUIUrl(core.GetChainId(mdl.Client))
-		mdl.Repo.RecentMsgf(log.RiskHeader{
-			BlockNumber: blockNum,
-			EventCode:   "AMQP",
-		}, "Pool %s in %s is more than 1Million USD, calculated value is %f", operation, urls.ExplorerHashUrl(txHash), value)
-	}
-}

models/pool/pool_v3/on_log.go

@@ -1,6 +1,7 @@
 package pool_v3
 
 import (
+	"fmt"
 	"math/big"
 
 	"github.com/Gearbox-protocol/sdk-go/core"
@@ -69,7 +70,8 @@ func (mdl *Poolv3) OnLog(txLog types.Log) {
 		} else {
 			mdl.Repo.AddPoolLedger(event)
 		}
-		pool_common.CheckIfAmountMoreThan1Mil(mdl.Client, mdl.Repo, mdl.State, deposit.Assets, blockNum, txLog.TxHash.Hex(), "deposit")
+		pool_common.CheckIfAmountMoreThan1Mil(mdl.Client, mdl.Repo, mdl.State, deposit.Assets, blockNum, txLog.TxHash.Hex(),
+			fmt.Sprintf("%s deposit", mdl.Repo.GetToken(mdl.State.UnderlyingToken).Symbol))
 		mdl.updateBorrowRate(blockNum)
 		// while processing withdrawal event, add to receiver and sub from User
 	case core.Topic("Withdraw(address,address,address,uint256,uint256)"):
@@ -97,7 +99,8 @@ func (mdl *Poolv3) OnLog(txLog types.Log) {
 			mdl.Repo.AddPoolLedger(event)
 		}
 		//
-		pool_common.CheckIfAmountMoreThan1Mil(mdl.Client, mdl.Repo, mdl.State, withdrawal.Assets, blockNum, txLog.TxHash.Hex(), "withdraw")
+		pool_common.CheckIfAmountMoreThan1Mil(mdl.Client, mdl.Repo, mdl.State, withdrawal.Assets, blockNum, txLog.TxHash.Hex(),
+			fmt.Sprintf("%s withdrawal", mdl.Repo.GetToken(mdl.State.UnderlyingToken).Symbol))
 		mdl.updateBorrowRate(blockNum)
 	case core.Topic("Borrow(address,address,uint256)"):
 		mdl.updateBorrowRate(blockNum)

repository/handlers/blocks.go

@@ -2,7 +2,6 @@ package handlers
 
 import (
 	"context"
-	"fmt"
 	"math/big"
 	"strings"
 	"time"
@@ -184,11 +183,8 @@ func (repo *BlocksRepo) RecentMsgf(header log.RiskHeader, msg string, args ...in
 	}
 	if header.EventCode == "AMQP" {
 		log.AMQPMsgf(msg, args...)
-	} else {
-		log.SendRiskAlert(log.RiskAlert{
-			Msg:        fmt.Sprintf(msg, args...),
-			RiskHeader: header,
-		})
+	} else if header.EventCode == "WARN" {
+		log.Warnf(msg, args...)
 	}
 }
 

repository/index.go

@@ -168,7 +168,7 @@ func (repo *Repository) AfterSync(syncTill int64) {
 		for _, tx := range txs {
 			repo.RecentMsgf(log.RiskHeader{
 				BlockNumber: tx.BlockNum,
-				EventCode:   "AMQP",
+				EventCode:   "WARN",
 			}, "No session account token transfer: %v", tx)
 			repo.SetAndGetBlock(tx.BlockNum).AddNoSessionTx(tx)
 		}