feat: veCRV locks + FeeDistributor protocol revenue

- veCRV vote-escrow: per-user Lock (amount, unlock time) + VeCrvState
  (total locked, lock count). Validated: 68.67M CRV locked across 719 locks.
- FeeDistributor (3CRV + crvUSD): weekly FeeDistribution (CheckpointToken) +
  FeeClaim. Validated: 21 weekly distributions, 1,319 claims (first week $3.18M).

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: moose-code

config.yaml

@@ -208,6 +208,27 @@ contracts:
             - hash
       - event: UpdateLiquidityLimit(address user, uint256 original_balance, uint256 original_supply, uint256 working_balance, uint256 working_supply)
 
+  # veCRV vote-escrow + fee distribution (protocol revenue).
+  - name: VotingEscrow
+    events:
+      - event: Deposit(address indexed provider, uint256 value, uint256 indexed locktime, int128 type, uint256 ts)
+        field_selection:
+          transaction_fields:
+            - hash
+      - event: Withdraw(address indexed provider, uint256 value, uint256 ts)
+        field_selection:
+          transaction_fields:
+            - hash
+      - event: Supply(uint256 prevSupply, uint256 supply)
+
+  - name: FeeDistributor
+    events:
+      - event: CheckpointToken(uint256 time, uint256 tokens)
+      - event: Claimed(address indexed recipient, uint256 amount, uint256 claim_epoch, uint256 max_epoch)
+        field_selection:
+          transaction_fields:
+            - hash
+
   # scrvUSD savings vault (ERC4626).
   - name: ScrvUsdVault
     events:
@@ -229,6 +250,15 @@ chains:
         address:
           - 0x2F50D538606Fa9EDD2B11E2446BEb18C9D5846bB
       - name: Gauge
+      - name: VotingEscrow
+        address:
+          - 0x5f3b5DfEb7B28CDbD7FAba78963EE202a494e2A2
+        start_block: 10650387
+      - name: FeeDistributor
+        address:
+          - 0xA464e6DCda8AC41e03616F95f4BC98a13b8922Dc
+          - 0xD16d5eC345Dd86Fb63C6a9C43c517210F1027914
+        start_block: 11362396
       - name: TricryptoFactoryNG
         address:
           - 0x0c0e5f2fF0ff18a3be9b835635039256dC4B4963

schema.graphql

@@ -295,6 +295,55 @@ type GaugeVote {
   txHash: String!
 }
 
+# =========================================================================
+# veCRV vote-escrow (locks) + fee distribution (protocol revenue to lockers).
+# =========================================================================
+
+type Lock {
+  id: ID!
+  chainId: Int!
+  user: String! @index
+  lockedAmount: BigInt!
+  unlockTime: BigInt!
+  isActive: Boolean!
+  createdBlock: Int!
+  createdTimestamp: BigInt!
+  lastUpdatedBlock: Int!
+  lastUpdatedTimestamp: BigInt!
+}
+
+type VeCrvState {
+  id: ID!
+  chainId: Int!
+  totalLocked: BigInt!
+  lockCount: Int!
+  lastUpdatedBlock: Int!
+  lastUpdatedTimestamp: BigInt!
+}
+
+type FeeDistribution {
+  id: ID!
+  chainId: Int!
+  distributor: String! @index
+  token: String!
+  weekTime: BigInt!
+  tokens: BigInt!
+  blockNumber: Int!
+  timestamp: BigInt! @index
+}
+
+type FeeClaim {
+  id: ID!
+  chainId: Int!
+  distributor: String! @index
+  recipient: String! @index
+  amount: BigInt!
+  epoch: BigInt!
+  blockNumber: Int!
+  timestamp: BigInt! @index
+  txHash: String!
+}
+
 type Loan {
   id: ID!
   chainId: Int!

src/handlers/VeCrvFees.ts

@@ -0,0 +1,140 @@
+import { indexer } from "envio";
+
+// veCRV vote-escrow locks + FeeDistributor protocol revenue (the fees paid out
+// to veCRV lockers each week — 3CRV historically, crvUSD since 2024).
+
+const FEE_TOKEN: Record<string, string> = {
+  "0xa464e6dcda8ac41e03616f95f4bc98a13b8922dc": "3CRV",
+  "0xd16d5ec345dd86fb63c6a9c43c517210f1027914": "crvUSD",
+};
+
+async function ensureVeCrvState(
+  context: any,
+  chainId: number,
+  block: { number: number; timestamp: number },
+): Promise<any> {
+  const id = `${chainId}`;
+  const existing = await context.VeCrvState.get(id);
+  if (existing) return existing;
+  const created = {
+    id,
+    chainId,
+    totalLocked: 0n,
+    lockCount: 0,
+    lastUpdatedBlock: block.number,
+    lastUpdatedTimestamp: BigInt(block.timestamp),
+  };
+  context.VeCrvState.set(created);
+  return created;
+}
+
+indexer.onEvent(
+  { contract: "VotingEscrow", event: "Deposit" },
+  async ({ event, context }) => {
+    const chainId = event.chainId;
+    const user = event.params.provider.toLowerCase();
+    const id = `${chainId}_${user}`;
+    const existing = await context.Lock.get(id);
+    const isNew = !existing || !existing.isActive;
+    const prevUnlock = existing?.unlockTime ?? 0n;
+    context.Lock.set({
+      id,
+      chainId,
+      user,
+      lockedAmount: (existing?.lockedAmount ?? 0n) + event.params.value,
+      unlockTime:
+        event.params.locktime > prevUnlock ? event.params.locktime : prevUnlock,
+      isActive: true,
+      createdBlock: existing?.createdBlock ?? event.block.number,
+      createdTimestamp: existing?.createdTimestamp ?? BigInt(event.block.timestamp),
+      lastUpdatedBlock: event.block.number,
+      lastUpdatedTimestamp: BigInt(event.block.timestamp),
+    });
+    if (isNew) {
+      const s = await ensureVeCrvState(context, chainId, event.block);
+      context.VeCrvState.set({
+        ...s,
+        lockCount: s.lockCount + 1,
+        lastUpdatedBlock: event.block.number,
+        lastUpdatedTimestamp: BigInt(event.block.timestamp),
+      });
+    }
+  },
+);
+
+indexer.onEvent(
+  { contract: "VotingEscrow", event: "Withdraw" },
+  async ({ event, context }) => {
+    const chainId = event.chainId;
+    const user = event.params.provider.toLowerCase();
+    const id = `${chainId}_${user}`;
+    const existing = await context.Lock.get(id);
+    if (!existing) return;
+    context.Lock.set({
+      ...existing,
+      lockedAmount: 0n,
+      isActive: false,
+      lastUpdatedBlock: event.block.number,
+      lastUpdatedTimestamp: BigInt(event.block.timestamp),
+    });
+    if (existing.isActive) {
+      const s = await ensureVeCrvState(context, chainId, event.block);
+      context.VeCrvState.set({
+        ...s,
+        lockCount: s.lockCount > 0 ? s.lockCount - 1 : 0,
+        lastUpdatedBlock: event.block.number,
+        lastUpdatedTimestamp: BigInt(event.block.timestamp),
+      });
+    }
+  },
+);
+
+indexer.onEvent(
+  { contract: "VotingEscrow", event: "Supply" },
+  async ({ event, context }) => {
+    const s = await ensureVeCrvState(context, event.chainId, event.block);
+    context.VeCrvState.set({
+      ...s,
+      totalLocked: event.params.supply,
+      lastUpdatedBlock: event.block.number,
+      lastUpdatedTimestamp: BigInt(event.block.timestamp),
+    });
+  },
+);
+
+indexer.onEvent(
+  { contract: "FeeDistributor", event: "CheckpointToken" },
+  async ({ event, context }) => {
+    const chainId = event.chainId;
+    const dist = event.srcAddress.toLowerCase();
+    context.FeeDistribution.set({
+      id: `${chainId}_${event.block.number}_${event.logIndex}`,
+      chainId,
+      distributor: dist,
+      token: FEE_TOKEN[dist] ?? "?",
+      weekTime: event.params.time,
+      tokens: event.params.tokens,
+      blockNumber: event.block.number,
+      timestamp: BigInt(event.block.timestamp),
+    });
+  },
+);
+
+indexer.onEvent(
+  { contract: "FeeDistributor", event: "Claimed" },
+  async ({ event, context }) => {
+    const chainId = event.chainId;
+    const dist = event.srcAddress.toLowerCase();
+    context.FeeClaim.set({
+      id: `${chainId}_${event.block.number}_${event.logIndex}`,
+      chainId,
+      distributor: dist,
+      recipient: event.params.recipient.toLowerCase(),
+      amount: event.params.amount,
+      epoch: event.params.claim_epoch,
+      blockNumber: event.block.number,
+      timestamp: BigInt(event.block.timestamp),
+      txHash: event.transaction.hash,
+    });
+  },
+);