From 6265f7b2bd5dd205e9b65ecc82eda0563cc9d88c Mon Sep 17 00:00:00 2001
From: llunaCreixent <elesmp@protonmail.com>
Date: Fri, 17 Dec 2021 20:06:39 +0100
Subject: [PATCH] Change graph health query

---
 src/services/graph.js | 28 ++++++++++++++++++++++++----
 1 file changed, 24 insertions(+), 4 deletions(-)

diff --git a/src/services/graph.js b/src/services/graph.js
index a43b58e7..7a5e0b8f 100644
--- a/src/services/graph.js
+++ b/src/services/graph.js
@@ -31,6 +31,27 @@ async function fetchFromGraphStatus(query) {
     });
 }
 
+// This function aims to replace `fetchFromGraphStatus()` when `index-node`
+// requests don't work for thegraph.com/hosted-service
+async function fetchFromSubgraphStatus(query) {
+  const endpoint = `${process.env.GRAPH_NODE_ENDPOINT}/subgraphs/name/${process.env.SUBGRAPH_NAME}`
+  return await fetch(endpoint, {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+    },
+    body: JSON.stringify({
+      query: query.replace(/\s\s+/g, ' '),
+    }),
+  })
+    .then((response) => {
+      return response.json();
+    })
+    .then((response) => {
+      return response.data;
+    });
+}
+
 async function wait(ms) {
   return new Promise((resolve) => {
     setTimeout(resolve, ms);
@@ -97,18 +118,17 @@ export default async function fetchAllFromGraph(name, fields, extra = '') {
 }
 
 export async function waitUntilGraphIsReady() {
-  const query = `{ indexingStatusForCurrentVersion(subgraphName: "${process.env.SUBGRAPH_NAME}") { health } }`;
+  const query = `{ _meta { block { number } } }`;
   return await loop(
     async () => {
       try {
-        let data = await fetchFromGraphStatus(query);
-        return data.indexingStatusForCurrentVersion.health;
+        return await fetchFromSubgraphStatus(query);
       } catch {
         return false;
       }
     },
     (isHealthy) => {
-      return isHealthy === 'healthy';
+      return isHealthy
     },
   );
 }