graphql-request-with-retry.ts

import { GraphQLClient, RequestDocument, Variables } from "graphql-request";

export function delay(ms) {
	return new Promise((resolve) => setTimeout(resolve, ms));
}

export async function gqlRequest({
	url,
	document,
	variables,
	additionalHeaders = {},
	retries = 5,
}: {
	url: string;
	document: RequestDocument;
	variables?: Variables;
	additionalHeaders?: Record<string, any>;
	retries?: number;
}) {
	const gqlClient = new GraphQLClient(url, {
		headers: {
			"Content-Type": "application/json",
			Accept: "application/json",
			...additionalHeaders,
		},
		cache: "no-cache",
		method: "POST",
	});
	return await gqlRetrify(gqlClient.request(document, variables), {
		retries,
	});
}

async function gqlRetrify(
	requestPromise: Promise<any>,
	{ retries = 3, everyMs = 1_000 },
	retriesCount = 0,
) {
	try {
		return await requestPromise;
	} catch (err) {
		if (retriesCount >= retries) {
			throw err;
		}
		await delay(everyMs);
		return await gqlRetrify(
			requestPromise,
			{ retries, everyMs },
			retriesCount + 1,
		);
	}
}