capture total locked value and keep it up to date with pool updates.

oceanprotocol · Jan 14, 2021 · 083dfe6 · 083dfe6
1 parent ecb9e8b
commit 083dfe6
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/schema.graphql b/schema.graphql
@@ -1,6 +1,7 @@
 type PoolFactory @entity {
     id: ID!
 
+    totalLockedValue: BigDecimal                        # total value from all pools expressed in OCEAN
     totalLiquidity: BigDecimal!                         # All the pools liquidity value in Ocean
     totalSwapVolume: BigDecimal!                        # All the swap volume in Ocean
     totalSwapFee: BigDecimal!                           # All the swap fee in Ocean
@@ -28,6 +29,7 @@ type Pool @entity {
     totalSwapVolume: BigDecimal!                        # Total swap volume in OCEAN
     totalSwapFee: BigDecimal!                           # Total swap fee in OCEAN
 
+    lockedValue: BigDecimal!                            # locked value expressed in OCEAN (captures both Ocean and Datatoken)
     datatokenReserve: BigDecimal!                       # Total pool reserve of Datatoken
     oceanReserve: BigDecimal!                           # Total pool reserve of OCEAN
     spotPrice: BigDecimal!

diff --git a/src/helpers.ts b/src/helpers.ts
@@ -303,10 +303,15 @@ export function createPoolTransaction(
 
   pool.consumePrice = poolTx.consumePrice
   pool.spotPrice = poolTx.spotPrice
+  const lockedValue = pool.lockedValue
+  pool.lockedValue = pool.oceanReserve + (pool.datatokenReserve * pool.spotPrice)
+  let factory = PoolFactory.load('1')
+  factory.totalLockedValue = factory.totalLockedValue - lockedValue + pool.lockedValue
 
   pool.transactionCount = pool.transactionCount.plus(BigInt.fromI32(1))
 
   pool.save()
+  factory.save()
 
   debuglog(
     'updated pool reserves (source, dtBalance, ocnBalance, dtReserve, ocnReserve): ',

diff --git a/src/mappings/factory.ts b/src/mappings/factory.ts
@@ -12,6 +12,7 @@ export function handleNewPool(event: BPoolRegistered): void {
     factory.totalLiquidity = ZERO_BD
     factory.totalSwapVolume = ZERO_BD
     factory.totalSwapFee = ZERO_BD
+    factory.totalLockedValue = ZERO_BD
 
     factory.poolCount = 0
     factory.finalizedPoolCount = 0
@@ -36,6 +37,7 @@ export function handleNewPool(event: BPoolRegistered): void {
   pool.totalShares = ZERO_BD
   pool.totalSwapVolume = ZERO_BD
   pool.totalSwapFee = ZERO_BD
+  pool.lockedValue = ZERO_BD
 
   pool.datatokenReserve = ZERO_BD
   pool.oceanReserve = ZERO_BD