feat: fetch versions with retries (#46)

This commit is contained in:
David Sherret 2023-05-30 18:18:39 -04:00 committed by GitHub
parent 61fe2df320
commit 85bf53342c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 27 additions and 3 deletions

View File

@ -48,7 +48,9 @@ function parseVersionRange(version) {
async function resolveVersion({ range, isCanary }) { async function resolveVersion({ range, isCanary }) {
if (isCanary) { if (isCanary) {
if (range === "latest") { if (range === "latest") {
const res = await fetch("https://dl.deno.land/canary-latest.txt"); const res = await fetchWithRetries(
"https://dl.deno.land/canary-latest.txt",
);
if (res.status !== 200) { if (res.status !== 200) {
throw new Error( throw new Error(
"Failed to fetch canary version info from dl.deno.land. Please try again later.", "Failed to fetch canary version info from dl.deno.land. Please try again later.",
@ -60,10 +62,10 @@ async function resolveVersion({ range, isCanary }) {
return { version: range, isCanary: true }; return { version: range, isCanary: true };
} }
const res = await fetch("https://deno.com/versions.json"); const res = await fetchWithRetries("https://deno.com/versions.json");
if (res.status !== 200) { if (res.status !== 200) {
throw new Error( throw new Error(
"Failed to fetch stable version info from raw.githubusercontent.com. Please try again later.", "Failed to fetch stable version info from deno.com/versions.json. Please try again later.",
); );
} }
const versionJson = await res.json(); const versionJson = await res.json();
@ -88,6 +90,28 @@ async function resolveVersion({ range, isCanary }) {
return { version, isCanary: false }; return { version, isCanary: false };
} }
/** @param {string} url */
async function fetchWithRetries(url, maxRetries = 5) {
let sleepMs = 250;
let iterationCount = 0;
while (true) {
iterationCount++;
try {
const res = await fetch(url);
if (res.status === 200 || iterationCount > maxRetries) {
return res;
}
} catch (err) {
if (iterationCount > maxRetries) {
throw err;
}
}
console.warn(`Failed fetching. Retrying in ${sleepMs}ms...`);
await new Promise((resolve) => setTimeout(resolve, sleepMs));
sleepMs = Math.min(sleepMs * 2, 10_000);
}
}
module.exports = { module.exports = {
parseVersionRange, parseVersionRange,
resolveVersion, resolveVersion,