feat: integrate examples as deno tests for ci

.github/workflows/test.yml

@@ -18,4 +18,4 @@ jobs:
       - run: deno lint
       - run: deno task codegen
       - run: deno task star
-      - run: deno task test
+      - run: deno task test:ci

deno.jsonc

@@ -36,6 +36,7 @@
     "star": "deno task run _tasks/star.ts && deno cache --check target/star.ts",
     "codegen": "deno task run cache.ts examples/mod.ts",
     "test": "deno task run test_util/ctx.ts -- deno test -A -L=info --ignore=target --parallel",
+    "test:ci": "ENV_TYPE_CI=1 deno task test",
     "test:update": "deno task test -- -- --update",
     "bench": "deno bench -A",
     "moderate": "deno task run https://deno.land/x/[email protected]/mod.ts && dprint fmt"

deps/run_with_limit.ts

@@ -0,0 +1 @@
+export * from "https://deno.land/x/[email protected]/mod.ts"

deps/std/io.ts

@@ -0,0 +1 @@
+export * from "https://deno.land/[email protected]/io/mod.ts"

deps/std/streams.ts

@@ -0,0 +1 @@
+export * from "https://deno.land/[email protected]/streams/mod.ts"

examples/.ignore

@@ -2,3 +2,4 @@ mod.ts
 multisig_transfer.ts
 smart_contract.ts
 xcm_teleport_assets.ts
+examples.test.ts

examples/examples.test.ts

@@ -0,0 +1,61 @@
+import * as path from "http://localhost:5646/@local/deps/std/path.ts"
+import { makeRunWithLimit } from "../deps/run_with_limit.ts"
+import { Buffer, readLines } from "../deps/std/io.ts"
+import { writeAll } from "../deps/std/streams.ts"
+import { assert } from "../deps/std/testing/asserts.ts"
+
+const IS_CI = Deno.env.get("ENV_TYPE_CI") ? true : false
+
+const { runWithLimit } = makeRunWithLimit<void>(navigator.hardwareConcurrency)
+
+function getModuleDir(importMeta: ImportMeta): string {
+  return path.resolve(path.dirname(path.fromFileUrl(importMeta.url)))
+}
+
+async function pipeThrough(
+  reader: Deno.Reader,
+  writer: Deno.Writer,
+) {
+  const encoder = new TextEncoder()
+  for await (const line of readLines(reader)) {
+    await writeAll(writer, encoder.encode(`${line}\n`))
+  }
+}
+
+const ignoreFile = await Deno.readTextFile(path.join(getModuleDir(import.meta), ".ignore"))
+const ignoredFiles = new Set(ignoreFile.split("\n"))
+
+const exampleFileNames = Array.from(Deno.readDirSync(getModuleDir(import.meta)))
+  .filter((e) => e.name.match(/^.*\.ts$/g) && e.isFile && !ignoredFiles.has(e.name))
+  .map((f) => f.name)
+
+const exampleTasks = IS_CI
+  ? exampleFileNames.map((fileName) =>
+    runWithLimit(async () => {
+      const t = Deno.run({
+        cmd: ["deno", "task", "run", `${getModuleDir(import.meta)}/${fileName}`],
+        stdout: "piped",
+        stderr: "piped",
+      })
+
+      const out = new Buffer()
+      pipeThrough(t.stdout, out)
+      pipeThrough(t.stderr, out)
+
+      const status = await t.status()
+
+      t.close()
+
+      return Deno.test({
+        name: fileName,
+        async fn() {
+          await pipeThrough(out, Deno.stdout)
+          assert(status.code === 0, `task failed with status code: ${status.code}`)
+          assert(status.success, `unsuccessful`)
+        },
+      })
+    })
+  )
+  : []
+
+await Promise.all(exampleTasks)