fix: calculate cavalue locally for tvl

Author: harsh-98

debts/engine.go

@@ -209,6 +209,22 @@ func (eng *DebtEngine) CalculateDebt() {
 				log.Fatalf("CM(%s):pool is missing stats at %d, so cumulative index of pool is unknown", cmAddr, blockNum)
 			}
 		}
+		for _, session := range sessions {
+			if (session.ClosedAt != 0 && session.ClosedAt <= blockNum) || session.Since > blockNum {
+				continue
+			}
+			pool := eng.priceHandler.GetPoolFromCM(session.CreditManager)
+			adapter := eng.repo.GetAdapter(pool)
+			state := adapter.GetUnderlyingState()
+			if state == nil {
+				log.Fatal("State for pool not found for address: ", pool)
+			}
+			//
+			market := state.(*schemas.PoolState).Market
+			if debt := eng.lastDebts[session.ID]; debt != nil {
+				marketToTvl.add(market, 0, 0, 0, debt.TotalValueInUSD)
+			}
+		}
 		//
 		eng.createTvlSnapshots(blockNum, marketToTvl)
 		if len(sessionsUpdated) > 0 {
@@ -260,6 +276,7 @@ func (eng *DebtEngine) createTvlSnapshots(blockNum int64, marketToTvl MarketToTv
 			AvailableLiquidity: details.totalAvailableLiquidity,
 			CATotalValue:       details.caTotalValue,
 			ExpectedLiq:        details.expectedLiq,
+			CATotalValueCalc:   details.caTotalValueCalculated,
 			Market:             market,
 		}
 		addedMarket = append(addedMarket, market)

debts/tvl_snapshots.go

@@ -4,20 +4,27 @@ type caValueAndAvailLiquidity struct {
 	caTotalValue            float64
 	totalAvailableLiquidity float64
 	expectedLiq             float64
+	caTotalValueCalculated  float64
 }
 
 type MarketToTvl map[string]*caValueAndAvailLiquidity
 
-func (ds *MarketToTvl) add(pool string, caValue float64, availLiq float64, expectedLiq float64) {
+func (ds *MarketToTvl) add(pool string, caValue float64, availLiq float64, expectedLiq float64, caValueCalculated ...float64) {
 	if x := (*ds)[pool]; x != nil {
 		x.caTotalValue += caValue
 		x.totalAvailableLiquidity += availLiq
 		x.expectedLiq += expectedLiq
+		if len(caValueCalculated) > 0 {
+			x.caTotalValueCalculated += caValueCalculated[0]
+		}
 	} else {
 		(*ds)[pool] = &caValueAndAvailLiquidity{
 			caTotalValue:            caValue,
 			totalAvailableLiquidity: availLiq,
 			expectedLiq:             expectedLiq,
 		}
+		if len(caValueCalculated) > 0 {
+			(*ds)[pool].caTotalValueCalculated = caValueCalculated[0]
+		}
 	}
 }

go.mod

@@ -5,7 +5,7 @@ go 1.23
 // toolchain go1.23.2
 
 require (
-	github.com/Gearbox-protocol/sdk-go v0.0.0-20250929104426-c8299bf40701
+	github.com/Gearbox-protocol/sdk-go v0.0.0-20251003023307-36e24214f260
 	github.com/ethereum/go-ethereum v1.13.14
 	github.com/go-playground/validator/v10 v10.4.1
 	github.com/google/go-cmp v0.6.0

go.sum

@@ -6,10 +6,8 @@ github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/DataDog/zstd v1.4.5 h1:EndNeuB0l9syBZhut0wns3gV1hL8zX8LIu6ZiVHWLIQ=
 github.com/DataDog/zstd v1.4.5/go.mod h1:1jcaCB/ufaK+sKp1NBhlGmpz41jOoPQ35bpF36t7BBo=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250929102435-cb0c6080818c h1:QIP4D/YtOiBMXBv59I/GbgPvrwqOTU/lAv0kQaxAAP4=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250929102435-cb0c6080818c/go.mod h1:MZsiiSAwDdnHY6GEILYtHEqhb9wmbUUE34UBQgNlUyM=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250929104426-c8299bf40701 h1:jekIAAiAui7J95/VFtfIxVtCcadW0/wDcbPWJOub/JU=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250929104426-c8299bf40701/go.mod h1:MZsiiSAwDdnHY6GEILYtHEqhb9wmbUUE34UBQgNlUyM=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20251003023307-36e24214f260 h1:kUM2YOxHE5ybdGQ7OoPvKJ4La0QRWALkTWfYQoNLIW0=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20251003023307-36e24214f260/go.mod h1:MZsiiSAwDdnHY6GEILYtHEqhb9wmbUUE34UBQgNlUyM=
 github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
 github.com/Microsoft/go-winio v0.6.1/go.mod h1:LRdKpFKfdobln8UmuiYcKPot9D2v6svN5+sAH+4kjUM=
 github.com/OffchainLabs/go-ethereum v1.13.4-0.20240313010929-e5d8587e7227 h1:+/3TrD+q+BP36jGj2Bycdmrc/joKLNbc5ImePQzKRLM=

migrations/000057_tvl_calc_ca.up.sql

@@ -0,0 +1 @@
+alter table tvl_snapshots add ca_total_value_calc double precision default 0;