cleaned up spot subgraph

aalavandhan · aalavandhan · commit 72e64d0027d7 · 2025-06-30T14:15:10.000-04:00
diff --git a/spot-subgraph/schema.graphql b/spot-subgraph/schema.graphql
@@ -232,18 +232,6 @@ type PerpetualTrancheDailyStat @entity {
   " the timestamp of the given day "
   timestamp: BigInt!
 
-  " the total perp tokens minted on the given day  "
-  totalMints: BigDecimal!
-
-  " the total perp tokens redeemed on the given day  "
-  totalRedemptions: BigDecimal!
-
-  " the total value of perp tokens minted on the given day  "
-  totalMintValue: BigDecimal!
-
-  " the total value of perp tokens redeemed on the given day  "
-  totalRedemptionValue: BigDecimal!
-
   " the tvl on the given day "
   tvl: BigDecimal!
 
@@ -253,9 +241,6 @@ type PerpetualTrancheDailyStat @entity {
   " the perp token supply on the given day "
   totalSupply: BigDecimal!
 
-  " the total amount of perp tokens paid as fees "
-  totalPerpFeeAmt: BigDecimal!
-
   " the total underlying value of fees "
   totalUnderlyingFeeValue: BigDecimal!
 }
@@ -279,12 +264,6 @@ type RolloverVault @entity {
   " addresses of assets currently in the reserve "
   activeReserves: [RolloverVaultAsset!]!
 
-  " the total fixed mc share of underlying tokens deposited into the system "
-  totalScaledUnderlyingDeposited: BigDecimal!
-
-  " the total fixed mc share of underlying tokens deposited by each user "
-  scaledUnderlyingBalances: [ScaledUnderlyingVaultDepositorBalance!]! @derivedFrom(field: "vault")
-
   " the current tvl based on the active reserves "
   tvl: BigDecimal!
 
@@ -304,13 +283,6 @@ type RolloverVault @entity {
   dailyStats: [RolloverVaultDailyStat!]! @derivedFrom(field: "vault")
 }
 
-type ScaledUnderlyingVaultDepositorBalance @entity {
-  id: ID!
-  vault: RolloverVault!
-  account: Bytes!
-  value: BigDecimal!
-}
-
 type RolloverVaultAsset @entity {
   " Equals to: <vaultTokenAddress>-<assetTokenAddress>"
   id: ID!
@@ -341,18 +313,6 @@ type RolloverVaultDailyStat @entity {
   " the timestamp of the given day "
   timestamp: BigInt!
 
-  " the total vault notes minted on the given day  "
-  totalMints: BigDecimal!
-
-  " the total vault notes redeemed on the given day  "
-  totalRedemptions: BigDecimal!
-
-  " the total value of vault notes minted on the given day  "
-  totalMintValue: BigDecimal!
-
-  " the total value of vault notes redeemed on the given day  "
-  totalRedemptionValue: BigDecimal!
-
   " the tvl on the given day "
   tvl: BigDecimal!
 
@@ -365,15 +325,6 @@ type RolloverVaultDailyStat @entity {
   " the vault note supply on the given day "
   totalSupply: BigDecimal!
 
-  " 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!
-
   " the system deviation ratio "
   deviationRatio: BigDecimal!
 
diff --git a/spot-subgraph/scripts/deploy.sh b/spot-subgraph/scripts/deploy.sh
@@ -7,6 +7,10 @@ yarn codegen
 
 yarn build
 
+echo "NOTE: graph deploy to Alchemy fails when you redeploy with the same IPFS hash"
+
+# yarn graph auth $THE_GRAPH_API_KEY
+# yarn graph deploy $2
 yarn graph deploy $2 \
   --node https://subgraphs.alchemy.com/api/subgraphs/deploy \
-  --deploy-key $GRAPH_AUTH
+  --deploy-key $GRAPH_AUTH
diff --git a/spot-subgraph/scripts/generate-ipfs-cid.sh b/spot-subgraph/scripts/generate-ipfs-cid.sh
@@ -0,0 +1,30 @@
+#!/bin/bash
+
+# generate-ipfs-cid.sh
+# Computes IPFS CID of a given directory using IPFS in Docker without uploading
+
+set -e
+
+TARGET_PATH=${1:-build}
+
+if [ ! -d "$TARGET_PATH" ]; then
+  echo "❌ Error: Directory '$TARGET_PATH' does not exist."
+  echo "Usage: $0 [path-to-directory]"
+  exit 1
+fi
+
+echo "📦 Computing IPFS CID for '$TARGET_PATH'..."
+
+CID=$(docker run --rm \
+  -v "$(pwd):/data" \
+  -e IPFS_PATH=/tmp/ipfs \
+  --entrypoint sh \
+  ipfs/kubo \
+  -c "ipfs init >/dev/null && ipfs add -r --only-hash --quiet /data/$TARGET_PATH" | tail -n 1)
+
+if [ -z "$CID" ]; then
+  echo "❌ Failed to generate IPFS CID."
+  exit 1
+fi
+
+echo "✅ IPFS CID: $CID"
diff --git a/spot-subgraph/src/data/perpetualTranche.ts b/spot-subgraph/src/data/perpetualTranche.ts
@@ -172,14 +172,9 @@ export function fetchPerpetualTrancheDailyStat(
     dailyStat = new PerpetualTrancheDailyStat(id)
     dailyStat.perp = perp.id
     dailyStat.timestamp = timestamp
-    dailyStat.totalMints = BIGDECIMAL_ZERO
-    dailyStat.totalRedemptions = BIGDECIMAL_ZERO
-    dailyStat.totalMintValue = BIGDECIMAL_ZERO
-    dailyStat.totalRedemptionValue = BIGDECIMAL_ZERO
     dailyStat.tvl = BIGDECIMAL_ZERO
     dailyStat.price = BIGDECIMAL_ZERO
     dailyStat.totalSupply = BIGDECIMAL_ZERO
-    dailyStat.totalPerpFeeAmt = BIGDECIMAL_ZERO
     dailyStat.totalUnderlyingFeeValue = BIGDECIMAL_ZERO
   }
   return dailyStat as PerpetualTrancheDailyStat
diff --git a/spot-subgraph/src/data/rolloverVault.ts b/spot-subgraph/src/data/rolloverVault.ts
@@ -2,7 +2,6 @@ import { log, BigDecimal, BigInt, Address, DataSourceContext } from '@graphproto
 import {
   RolloverVault,
   RolloverVaultAsset,
-  ScaledUnderlyingVaultDepositorBalance,
   RolloverVaultDailyStat,
   Tranche,
 } from '../../generated/schema'
@@ -173,7 +172,6 @@ export function fetchRolloverVault(address: Address): RolloverVault {
     vaultToken.save()
     vault = new RolloverVault(id)
     vault.token = vaultToken.id
-    vault.totalScaledUnderlyingDeposited = BIGDECIMAL_ZERO
     vault.activeReserves = []
     vault.tvl = BIGDECIMAL_ZERO
     vault.rebaseMultiplier = BIGDECIMAL_ONE
@@ -219,21 +217,6 @@ export function fetchRolloverVaultAsset(
   return assetToken as RolloverVaultAsset
 }
 
-export function fetchScaledUnderlyingVaultDepositorBalance(
-  vault: RolloverVault,
-  account: Address,
-): ScaledUnderlyingVaultDepositorBalance {
-  let id = vault.id.concat('-').concat(account.toHexString())
-  let balance = ScaledUnderlyingVaultDepositorBalance.load(id)
-  if (balance == null) {
-    balance = new ScaledUnderlyingVaultDepositorBalance(id)
-    balance.vault = vault.id
-    balance.account = account
-    balance.value = BIGDECIMAL_ZERO
-  }
-  return balance as ScaledUnderlyingVaultDepositorBalance
-}
-
 export function fetchRolloverVaultDailyStat(
   vault: RolloverVault,
   timestamp: BigInt,
@@ -244,17 +227,10 @@ export function fetchRolloverVaultDailyStat(
     dailyStat = new RolloverVaultDailyStat(id)
     dailyStat.vault = vault.id
     dailyStat.timestamp = timestamp
-    dailyStat.totalMints = BIGDECIMAL_ZERO
-    dailyStat.totalRedemptions = BIGDECIMAL_ZERO
-    dailyStat.totalMintValue = BIGDECIMAL_ZERO
-    dailyStat.totalRedemptionValue = BIGDECIMAL_ZERO
     dailyStat.tvl = BIGDECIMAL_ZERO
     dailyStat.rebaseMultiplier = BIGDECIMAL_ONE
     dailyStat.price = BIGDECIMAL_ZERO
     dailyStat.totalSupply = BIGDECIMAL_ZERO
-    dailyStat.totalSwapValue = BIGDECIMAL_ZERO
-    dailyStat.totalUnderlyingToPerpSwapValue = BIGDECIMAL_ZERO
-    dailyStat.totalPerpToUnderlyingSwapValue = BIGDECIMAL_ZERO
     dailyStat.deviationRatio = BIGDECIMAL_ZERO
     dailyStat.totalUnderlyingFeeValue = BIGDECIMAL_ZERO
   }
@@ -276,13 +252,13 @@ function fetchTargetSystemRatio(vaultAddress: Address): BigDecimal {
   let vaultContract = RolloverVaultABI.bind(vaultAddress)
   let r1 = vaultContract.try_feePolicy()
   if (r1.reverted) {
-    log.debug('fee policy not set', [])
+    log.error('fee policy not set', [])
     return SYSTEM_RATIO_START
   }
   let feePolicyContract = FeePolicyABI.bind(r1.value)
   let r2 = feePolicyContract.try_targetSystemRatio()
   if (r2.reverted) {
-    log.debug('fee policy version incorrect', [])
+    log.error('fee policy version incorrect', [])
     return SYSTEM_RATIO_START
   }
   return formatBalance(r2.value, BigInt.fromI32(feePolicyContract.decimals()))
@@ -307,7 +283,7 @@ export function computeFeePerc(
   let vaultContract = RolloverVaultABI.bind(vaultAddress)
   let r1 = vaultContract.try_feePolicy()
   if (r1.reverted) {
-    log.debug('fee policy not set', [])
+    log.error('fee policy not set', [])
     return BIGDECIMAL_ZERO
   }
   let feePolicyContract = FeePolicyABI.bind(r1.value)
@@ -322,7 +298,7 @@ export function computeFeePerc(
   )
   let r2 = feePolicyContract.try_computeFeePerc(drPre, drPost)
   if (r2.reverted) {
-    log.debug('fee policy version incorrect', [])
+    log.error('fee policy version incorrect', [])
     return BIGDECIMAL_ZERO
   }
   return formatBalance(r2.value, feePolicyDecimals)
diff --git a/spot-subgraph/src/mappings/perpetualTranche.ts b/spot-subgraph/src/mappings/perpetualTranche.ts
@@ -63,44 +63,28 @@ export function handleTransfer(event: Transfer): void {
     log.debug('triggered mint', [])
     let perpToken = fetchToken(event.address)
     refreshSupply(perpToken)
-
     let perp = fetchPerpetualTranche(event.address)
     refreshPerpetualTrancheTVL(perp)
+  }
 
-    let perpAmtMinted = formatBalance(event.params.value, perpToken.decimals)
-    let dailyStat = fetchPerpetualTrancheDailyStat(perp, dayTimestamp(event.block.timestamp))
-    dailyStat.totalMints = dailyStat.totalMints.plus(perpAmtMinted)
-    dailyStat.totalMintValue = dailyStat.totalMintValue.plus(perpAmtMinted.times(perp.price))
-    dailyStat.save()
+  if (to == ADDRESS_ZERO) {
+    log.debug('triggered burn', [])
+    let perpToken = fetchToken(event.address)
+    refreshSupply(perpToken)
+    let perp = fetchPerpetualTranche(event.address)
+    refreshPerpetualTrancheTVL(perp)
   }
 
   // Mint and burn fees are handled by sending perp tokens to the perp contract
   if (to == event.address) {
+    log.debug('perp fees paid', [])
     let perpToken = fetchToken(event.address)
     let perp = fetchPerpetualTranche(event.address)
     let perpFeeAmt = formatBalance(event.params.value, perpToken.decimals)
     let dailyStat = fetchPerpetualTrancheDailyStat(perp, dayTimestamp(event.block.timestamp))
-    dailyStat.totalPerpFeeAmt = dailyStat.totalPerpFeeAmt.plus(perpFeeAmt)
     dailyStat.totalUnderlyingFeeValue = dailyStat.totalUnderlyingFeeValue.plus(
       perpFeeAmt.times(perp.price),
     )
     dailyStat.save()
   }
 }
-
-export function handleRedeem(call: RedeemCall): void {
-  log.debug('triggered redeem', [])
-  let perpToken = fetchToken(call.to)
-  refreshSupply(perpToken)
-
-  let perp = fetchPerpetualTranche(call.to)
-  refreshPerpetualTrancheTVL(perp)
-
-  let perpAmtBurnt = formatBalance(call.inputs.perpAmtBurnt, perpToken.decimals)
-  let dailyStat = fetchPerpetualTrancheDailyStat(perp, dayTimestamp(call.block.timestamp))
-  dailyStat.totalRedemptions = dailyStat.totalRedemptions.plus(perpAmtBurnt)
-  dailyStat.totalRedemptionValue = dailyStat.totalRedemptionValue.plus(
-    perpAmtBurnt.times(perp.price),
-  )
-  dailyStat.save()
-}
diff --git a/spot-subgraph/src/mappings/rolloverVault.ts b/spot-subgraph/src/mappings/rolloverVault.ts
diff --git a/spot-subgraph/subgraph.template.yaml b/spot-subgraph/subgraph.template.yaml
