migrate to new indexer

Author: thelostone-mc

.env.example

@@ -9,3 +9,4 @@
 
 DATABASE_URL="postgresql://postgres:postgres@localhost:5432/Grants?schema=public"
 GRANTS_BASE_URL="https://indexer-production.fly.dev/data"
+INDEXER_PASSWORD="your-indexer-password"

src/graphql/index.ts

@@ -6,13 +6,17 @@ export type GraphQLResponse<K> = {
 
 export const gqlRequest = async (
   document: any,
-  variable: any,
+  variable: any
 ): Promise<any> => {
   try {
     return await request(
-      `https://grants-stack-indexer-v2.gitcoin.co/graphql`,
+      `https://beta.indexer.gitcoin.co/v1/graphql`,
       document,
       variable,
+      {
+        "content-type": "application/json",
+        "x-hasura-admin-secret": process.env.INDEXER_PASSWORD || "",
+      }
     );
   } catch (error) {
     console.log(`Request failed, refreshing in 2 seconds`);
@@ -25,7 +29,7 @@ export const getRounds = async (chainId: number) => {
   return gqlRequest(
     gql`
       query getRounds($chainId: Int = 10) {
-        rounds(condition: { chainId: $chainId }) {
+        rounds(where: { chainId: { _eq: $chainId } }) {
           id
           chainId
           applicationMetadata
@@ -53,7 +57,7 @@ export const getRounds = async (chainId: number) => {
         }
       }
     `,
-    { chainId },
+    { chainId }
   );
 };
 
@@ -67,7 +71,7 @@ export const getApplications = async ({
   return gqlRequest(
     gql`
       query getApplications($roundId: String = "", $chainId: Int = 10) {
-        round(chainId: $chainId, id: $roundId) {
+        rounds(where: { chainId: { _eq: $chainId }, id: { _eq: $roundId } }) {
           applications {
             id
             projectId
@@ -85,7 +89,7 @@ export const getApplications = async ({
         }
       }
     `,
-    { chainId, roundId },
+    { chainId, roundId }
   );
 };
 
@@ -99,7 +103,7 @@ export const getVotes = async ({
   return gqlRequest(
     gql`
       query getVotes($roundId: String = "", $chainId: Int = 10) {
-        round(chainId: $chainId, id: $roundId) {
+        rounds(where: { chainId: { _eq: $chainId }, id: { _eq: $roundId } }) {
           donations {
             amount
             amountInRoundMatchToken
@@ -118,42 +122,24 @@ export const getVotes = async ({
         }
       }
     `,
-    { chainId, roundId },
+    { chainId, roundId }
   );
 };
 
-export const getTokenPrice = async ({
-  chainId,
-  tokenAddress,
-  blockNumber,
-}: {
-  chainId: number;
-  tokenAddress: string;
-  blockNumber: string;
-}) => {
+export const getTokenPrice = async ({ tokenCode }: { tokenCode: string }) => {
   return gqlRequest(
     gql`
-      query getTokenPrice(
-        $tokenAddress: String = ""
-        $chainId: Int = 10
-        $blockNumber: BigFloat = ""
-      ) {
-        prices(
+      query getTokenPrice($tokenCode: String = "") {
+        priceCache(
           orderBy: BLOCK_NUMBER_DESC
-          filter: {
-            tokenAddress: { equalTo: $tokenAddress }
-            chainId: { equalTo: $chainId }
-            blockNumber: { lessThanOrEqualTo: $blockNumber }
-          }
-          first: 1
+          filter: { tokenCode: { equalTo: $tokenCode } }
+          limit: 1
         ) {
           id
-          chainId
-          priceInUsd
-          blockNumber
+          priceUsd
         }
       }
     `,
-    { chainId, tokenAddress, blockNumber },
+    { tokenCode }
   );
 };

src/loaders/applications.ts

@@ -36,14 +36,16 @@ const manageApplications = async ({ chainId, prisma, roundId }: Props) => {
     const applicationResponse = (await getApplications({
       chainId: Number(chainId),
       roundId: round.roundId.toLowerCase(),
-    })) as GraphQLResponse<{ applications: any[] }>;
+    })) as GraphQLResponse<{ applications: any[] }[]>;
 
-    const applicationList = applicationResponse?.round?.applications || [];
+    const applicationList = applicationResponse?.round[0]?.applications || [];
 
     console.log(
       `${applicationList.length} application${
         applicationList.length !== 1 ? "s" : ""
-      } found for active application round (${rIndex + 1}/${rounds.length}) : ${round.roundId}`,
+      } found for active application round (${rIndex + 1}/${rounds.length}) : ${
+        round.roundId
+      }`
     );
 
     for (const [index, application] of applicationList.entries()) {
@@ -116,9 +118,11 @@ const manageApplications = async ({ chainId, prisma, roundId }: Props) => {
       });
 
       process.stdout.write(
-        ` => Committed ${index + 1} of ${applicationList.length} applications (${
+        ` => Committed ${index + 1} of ${
+          applicationList.length
+        } applications (${
           Math.round((currentCount / applicationList.length) * 10000) / 100
-        }%) ${isLast ? "\n" : "\r"}`,
+        }%) ${isLast ? "\n" : "\r"}`
       );
     }
 
@@ -137,7 +141,7 @@ const manageApplications = async ({ chainId, prisma, roundId }: Props) => {
       });
 
       console.log(
-        `\r\n   Round application period has ended, disabling further indexing\r\n`,
+        `\r\n   Round application period has ended, disabling further indexing\r\n`
       );
     }
   }

src/loaders/votes.ts

@@ -35,16 +35,18 @@ const manageVotes = async ({ chainId, prisma, roundId }: Props) => {
     const votesResponse = (await getVotes({
       chainId: Number(chainId),
       roundId: round.roundId.toLowerCase(),
-    })) as GraphQLResponse<{ donations: any[] }>;
+    })) as GraphQLResponse<{ donations: any[] }[]>;
 
-    const votesList = votesResponse?.round?.donations || [];
+    const votesList = votesResponse?.round[0]?.donations || [];
 
     // logger(`Committing vote: ${vote.transaction}`)
     if (votesList.length > 0) {
       process.stdout.write(`\n`);
     }
     process.stdout.write(
-      `${votesList.length} votes found for round (${rIndex + 1}/${rounds.length}): ${round.roundId} \n`,
+      `${votesList.length} votes found for round (${rIndex + 1}/${
+        rounds.length
+      }): ${round.roundId} \n`
     );
 
     for (const [index, vote] of votesList.entries()) {
@@ -98,7 +100,7 @@ const manageVotes = async ({ chainId, prisma, roundId }: Props) => {
         process.stdout.write(
           ` => Committed ${currentCount} of ${votesList.length} votes (${
             Math.round((currentCount / votesList.length) * 10000) / 100
-          }%) ${isLast ? "\n" : "\r"}`,
+          }%) ${isLast ? "\n" : "\r"}`
         );
       }
     }

src/utils/index.ts

@@ -67,11 +67,12 @@ export const grantFetch = async (path: string) => {
 
 export const initialFetch = async (chainId: string) => {
   try {
-    const block =
-      await clients[Number(chainId) as keyof typeof clients].getBlock();
+    const block = await clients[
+      Number(chainId) as keyof typeof clients
+    ].getBlock();
 
     console.log(
-      `Current block on chainId ${chainId} is ${block.number?.toString()}`,
+      `Current block on chainId ${chainId} is ${block.number?.toString()}`
     );
   } catch (error) {}
 };
@@ -144,7 +145,7 @@ export const createExtraParams = (next_page_params: NextPageParams) => {
       const prefix = acc ? "&" : "";
       return `${acc}${prefix}${curr}=${value}`;
     },
-    "",
+    ""
   );
 };
 
@@ -159,8 +160,8 @@ export const fetchBlockTimestamp = async ({
     blockNumbers.map((blockNumber) =>
       clients[Number(chainId) as keyof typeof clients]
         .getBlock({ blockNumber: BigInt(blockNumber) })
-        .then((block) => block.timestamp),
-    ),
+        .then((block) => block.timestamp)
+    )
   );
 };
 
@@ -204,7 +205,7 @@ export const fetchRoundDistributionData = async ({
         address: roundId,
         abi: roundABI,
         functionName: "payoutStrategy",
-      }),
+      })
     ) as `0x${string}`;
 
     const contractConfig = {
@@ -263,16 +264,14 @@ export const fetchRoundDistributionData = async ({
           }
 
           const targetTokenPrice = (await getTokenPrice({
-            chainId,
-            tokenAddress: nTokenAddress,
-            blockNumber: targetBlockNumber.toString(),
-          })) as { prices: any[] };
+            tokenCode: token.code,
+          })) as { priceCache: any[] };
 
-          token.price = targetTokenPrice.prices[0].priceInUsd ?? 0;
+          token.price = targetTokenPrice.priceCache[0].priceUsd ?? 0;
         }
 
         const res = await fetch(
-          `https://d16c97c2np8a2o.cloudfront.net/ipfs/${metaPtr}`,
+          `https://d16c97c2np8a2o.cloudfront.net/ipfs/${metaPtr}`
         );
 
         const distro = await res.json();
@@ -287,7 +286,7 @@ export const fetchRoundDistributionData = async ({
     console.log(error);
 
     console.log(
-      `Error occurred while fetching round distro data for ${roundId}`,
+      `Error occurred while fetching round distro data for ${roundId}`
     );
   }
 
@@ -306,7 +305,7 @@ export const formatDistributionPrice = ({
   return Number(
     formatUnits(
       hexToBigInt(amount) * parseUnits(price.toString(), decimal),
-      decimal + 18,
-    ),
+      decimal + 18
+    )
   );
 };