updated spot subgraph to keep track of vault swap volume

ampleforth · Nov 6, 2024 · d6e9cf5 · d6e9cf5
1 parent a8ae0ae
commit d6e9cf5
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 3 deletions.
diff --git a/spot-subgraph/schema.graphql b/spot-subgraph/schema.graphql
@@ -355,4 +355,10 @@ type RolloverVaultDailyStat @entity {
 
   " the total value of swaps on the given day "
   totalSwapValue: BigDecimal!
+
+  " the total value of underlying to perp swaps on the given day "
+  totalUnderlyingToPerpSwapValue: BigDecimal!
+
+  " the total value of perp to underlying swaps on the given day "
+  totalPerpToUnderlyingSwapValue: BigDecimal!
 }
diff --git a/spot-subgraph/src/data/rolloverVault.ts b/spot-subgraph/src/data/rolloverVault.ts
@@ -4,7 +4,7 @@ import {
   RolloverVaultAsset,
   ScaledUnderlyingVaultDepositorBalance,
   RolloverVaultDailyStat,
-  Tranche
+  Tranche,
 } from '../../generated/schema'
 import { RolloverVault as RolloverVaultABI } from '../../generated/RolloverVault/RolloverVault'
 import { ERC20 as ERC20ABI } from '../../generated/BondFactory/ERC20'
@@ -144,10 +144,10 @@ export function refreshRolloverVaultRebaseMultiplier(vault: RolloverVault): void
     .plus(vaultPerpBalance)
     .plus(vaultZBalance)
     .plus(vaultUnderlyingBalance)
-  if(denominator.gt(BIGDECIMAL_ZERO)){
+  if (denominator.gt(BIGDECIMAL_ZERO)) {
     vault.rebaseMultiplier = numerator.div(denominator)
   }
-  vault.save()  
+  vault.save()
 }
 
 export function refreshRolloverVaultDailyStat(dailyStat: RolloverVaultDailyStat): void {
@@ -246,6 +246,8 @@ export function fetchRolloverVaultDailyStat(
     dailyStat.price = BIGDECIMAL_ZERO
     dailyStat.totalSupply = BIGDECIMAL_ZERO
     dailyStat.totalSwapValue = BIGDECIMAL_ZERO
+    dailyStat.totalUnderlyingToPerpSwapValue = BIGDECIMAL_ZERO
+    dailyStat.totalPerpToUnderlyingSwapValue = BIGDECIMAL_ZERO
   }
   return dailyStat as RolloverVaultDailyStat
 }
diff --git a/spot-subgraph/src/mappings/rolloverVault.ts b/spot-subgraph/src/mappings/rolloverVault.ts
@@ -135,6 +135,9 @@ export function handleUnderlyingToPerpSwap(call: SwapUnderlyingForPerpsCall): vo
 
   let dailyStat = fetchRolloverVaultDailyStat(vault, dayTimestamp(call.block.timestamp))
   dailyStat.totalSwapValue = dailyStat.totalSwapValue.plus(underlyingAmtIn)
+  dailyStat.totalUnderlyingToPerpSwapValue = dailyStat.totalUnderlyingToPerpSwapValue.plus(
+    underlyingAmtIn,
+  )
   dailyStat.save()
 }
 
@@ -153,5 +156,8 @@ export function handlePerpToUnderlyingSwap(call: SwapPerpsForUnderlyingCall): vo
 
   let dailyStat = fetchRolloverVaultDailyStat(vault, dayTimestamp(call.block.timestamp))
   dailyStat.totalSwapValue = dailyStat.totalSwapValue.plus(perpAmtIn.times(perp.price))
+  dailyStat.totalPerpToUnderlyingSwapValue = dailyStat.totalPerpToUnderlyingSwapValue.plus(
+    perpAmtIn.times(perp.price),
+  )
   dailyStat.save()
 }