Function sendGraphqlQuery

libs/definitions/src/utils/subgraph.utils.ts:131–169

(
  endpoint: string,
  query: string,
  headers: Record<string, any> = {},
  retries = 1,
  waitMillis = 300,
)

}

export async function sendGraphqlQuery(
  endpoint: string,
  query: string,
  headers: Record<string, any> = {},
  retries = 1,
  waitMillis = 300,
): Promise<any> {
  try {
    const res = await axios({
      method: 'POST',
      url: endpoint,
      headers: {
        'Content-Type': 'application/json',
        Accept: 'application/json',
        ...headers,
      },
      data: {
        query: compress(query),
      },
    })

    // retry 5xx errors
    if (res.status >= 500 && retries) {
      await wait(waitMillis)
      return sendGraphqlQuery(endpoint, query, headers, retries - 1)
    }

    return res.data
  } catch (e) {
    if (e.response?.status >= 500 && retries) {
      await wait(waitMillis)
      return sendGraphqlQuery(endpoint, query, headers, retries - 1)
    }
    if (e.response?.data?.errors?.[0]?.message) {
      throw new Error(e.response.data.errors[0].message)
    }
    throw e
  }
}

export async function runSubgraphOperation(
  endpoints: Endpoints,