retryOnError

Author: masx200

retry.ts

@@ -0,0 +1,52 @@
+import {
+    RetryError,
+    RetryOptions,
+} from "https://deno.land/[email protected]/async/retry.ts";
+
+export const defaultRetryOptions = {
+    multiplier: 2,
+    maxTimeout: 60000,
+    maxAttempts: 5,
+    minTimeout: 1000,
+};
+export async function retry<T>(
+    fn: (() => Promise<T>) | (() => T),
+    opts?: RetryOptions & {
+        retryOnError?:
+            | ((error: any) => Promise<boolean>)
+            | ((error: any) => boolean);
+    },
+) {
+    const retryOnError = opts?.retryOnError ?? (() => true);
+    const options: Required<RetryOptions> = {
+        ...defaultRetryOptions,
+        ...opts,
+    };
+
+    if (options.maxTimeout >= 0 && options.minTimeout > options.maxTimeout) {
+        throw new RangeError("minTimeout is greater than maxTimeout");
+    }
+
+    let timeout = options.minTimeout;
+    let error: unknown;
+
+    for (let i = 0; i < options.maxAttempts; i++) {
+        try {
+            return await fn();
+        } catch (err) {
+            if (!retryOnError(err)) {
+                throw err;
+            }
+
+            await new Promise((r) => setTimeout(r, timeout));
+            timeout *= options.multiplier;
+            timeout = Math.max(timeout, options.minTimeout);
+            if (options.maxTimeout >= 0) {
+                timeout = Math.min(timeout, options.maxTimeout);
+            }
+            error = err;
+        }
+    }
+
+    throw new RetryError(error, options.maxAttempts);
+}

xmake.ts

@@ -5,7 +5,7 @@ import { join, resolve } from "https://deno.land/[email protected]/path/mod.ts";
 import { assertEquals } from "asserts";
 import { dirname } from "https://deno.land/x/[email protected]/mod.ts";
 import parse from "npm:@masx200/[email protected]";
-import { retry } from "https://deno.land/[email protected]/async/retry.ts";
+import { retry } from "./retry.ts";
 
 async function* findFilesRecursive(
     path: string,
@@ -40,6 +40,11 @@ async function RunXmake(file: string, toolchain: string, sdk: string) {
     await RunXmakeConfig(file, toolchain, sdk);
     await retry(RunXmakeBuild.bind(null, file), {
         maxAttempts: os === "windows" ? 10 : 1,
+        retryOnError: (e) => {
+            return Boolean(
+                e?.stdout?.match(/error:.*cannot open file:.*Unknown/g),
+            );
+        },
     });
     await RunXmakeTest(file);
 }