Merge pull request #314 from solidity-io/update/backfill-pair

Add token price queries based on the protocol

Author: mschead

indexer/API.md

@@ -61,6 +61,95 @@ query GetTokenInfo {
 }
 ```
 
+### Get Token Price
+
+```graphql
+query GetTokenPrice($tokenAddress: String!, $protocolAddress: String) {
+  tokenPrice(tokenAddress: $tokenAddress, protocolAddress: $protocolAddress) {
+    id
+    token {
+      id
+      name
+      chainId
+      address
+    }
+    priceInKda
+    priceInUsd
+    protocolAddress
+    updatedAt
+  }
+}
+```
+
+**Input Parameters:**
+
+- `tokenAddress`: Address of the token (required, String!)
+- `protocolAddress`: Protocol address (optional, String)
+
+**Output Data:**
+
+```typescript
+{
+  tokenPrice: {
+    id: string;              // Price ID
+    token: {
+      id: string;           // Token ID
+      name: string;         // Token name
+      chainId: string;      // Chain ID
+      address: string;      // Token address
+    },
+    priceInKda: number;     // Price in KDA
+    priceInUsd: number;     // Price in USD
+    protocolAddress: string;// Protocol address
+    updatedAt: DateTime;    // Last update timestamp
+  }
+}
+```
+
+### Get All Token Prices
+
+```graphql
+query GetTokenPrices($protocolAddress: String) {
+  tokenPrices(protocolAddress: $protocolAddress) {
+    id
+    token {
+      id
+      name
+      chainId
+      address
+    }
+    priceInKda
+    priceInUsd
+    protocolAddress
+    updatedAt
+  }
+}
+```
+
+**Input Parameters:**
+
+- `protocolAddress`: Protocol address (optional, String)
+
+**Output Data:**
+
+```typescript
+{
+  tokenPrices: Array<{
+    id: string; // Price ID
+    token: {
+      id: string; // Token ID
+      name: string; // Token name
+      chainId: string; // Chain ID
+      address: string; // Token address
+    };
+    priceInKda: number; // Price in KDA
+    priceInUsd: number; // Price in USD
+    protocolAddress: string; // Protocol address
+    updatedAt: DateTime; // Last update timestamp
+  }>;
+}
+```
+
 ### Get Token Price and Exchange Rate
 
 ```graphql
@@ -318,64 +407,76 @@ query GetPools($first: Int, $orderBy: PoolOrderBy = TVL_USD_DESC, $after: String
 ### Get Pool by ID with Charts
 
 ```graphql
-query GetPoolDetails($poolId: ID!, $timeFrame: TimeFrame = DAY, $first: Int = 10) {
+query getPoolDetails($poolId: ID!, $timeFrame: TimeFrame!) {
   pool(id: $poolId) {
-    id
     address
-    token0 {
-      id
-      name
-    }
-    token1 {
-      id
-      name
-    }
+    apr24h
+    createdAt
+    fees24hUsd
+    feesChange24h
+    id
+    key
     reserve0
     reserve1
     totalSupply
-    tvlUsd
+    transactionCount24h
+    transactionCountChange24h
     tvlChange24h
+    tvlUsd
+    updatedAt
     volume24hUsd
-    volumeChange24h
     volume7dUsd
-    fees24hUsd
-    feesChange24h
-    transactionCount24h
-    transactionCountChange24h
-    apr24h
+    volumeChange24h
     charts(timeFrame: $timeFrame) {
-      volume {
-        timestamp
+      fees {
         value
+        timestamp
       }
       tvl {
-        timestamp
         value
-      }
-      fees {
         timestamp
+      }
+      volume {
         value
+        timestamp
       }
     }
-    transactions(first: $first) {
+    token0 {
+      name
+      id
+      chainId
+      address
+    }
+    token1 {
+      name
+      id
+      chainId
+      address
+    }
+    transactions {
+      totalCount
+      pageInfo {
+        endCursor
+        hasNextPage
+        startCursor
+        hasPreviousPage
+      }
       edges {
+        cursor
         node {
-          id
-          maker
           amount0In
-          amount1In
           amount0Out
+          amount1In
           amount1Out
-          amountUsd
-          timestamp
           transactionType
+          transactionId
+          timestamp
+          requestkey
+          maker
+          id
+          amountUsd
         }
       }
-      pageInfo {
-        hasNextPage
-        endCursor
-      }
-      totalCount
     }
   }
 }

indexer/migrations/20250610124420-update-pool-stats-timestamp.js

@@ -0,0 +1,55 @@
+'use strict';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    // First, convert existing timestamps to date-only format
+    await queryInterface.sequelize.query(`
+      UPDATE "PoolStats"
+      SET timestamp = DATE(timestamp)
+      WHERE timestamp IS NOT NULL;
+    `);
+
+    // Remove duplicate entries keeping the latest one for each pairId and timestamp
+    await queryInterface.sequelize.query(`
+      DELETE FROM "PoolStats" a
+      USING (
+        SELECT "pairId", timestamp, MAX(id) as max_id
+        FROM "PoolStats"
+        GROUP BY "pairId", timestamp
+        HAVING COUNT(*) > 1
+      ) b
+      WHERE a."pairId" = b."pairId" 
+      AND a.timestamp = b.timestamp 
+      AND a.id < b.max_id;
+    `);
+
+    // Then change the column type to DATE
+    await queryInterface.changeColumn('PoolStats', 'timestamp', {
+      type: Sequelize.DATEONLY,
+      allowNull: false,
+    });
+
+    // Create unique index
+    await queryInterface.addIndex('PoolStats', ['pairId', 'timestamp'], {
+      unique: true,
+      name: 'pool_stats_pairid_timestamp_idx',
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    // Remove unique index
+    await queryInterface.removeIndex('PoolStats', 'pool_stats_pairid_timestamp_idx');
+
+    // Convert back to TIMESTAMP WITH TIME ZONE
+    await queryInterface.changeColumn('PoolStats', 'timestamp', {
+      type: Sequelize.DATE,
+      allowNull: false,
+    });
+
+    // Recreate original non-unique index
+    await queryInterface.addIndex('PoolStats', ['pairId', 'timestamp'], {
+      name: 'pool_stats_pairid_timestamp_idx',
+    });
+  },
+};