script to serve and test

Author: maparent

.github/workflows/test-database.yaml

@@ -30,6 +30,4 @@ jobs:
         run: pnpm run setup
       - name: Serve and run tests
         working-directory: ./packages/database
-        run: |
-          pnpm run serve &
-          wait 2 ; pnpm run test
+        run: pnpm run test:withserve

packages/database/package.json

@@ -33,6 +33,7 @@
     "lint:fix": "eslint --fix . && tsx scripts/lintSchemas.ts -f && tsx scripts/lintFunctions.ts",
     "migrate": "tsx scripts/migrate.ts",
     "test": "pnpm run build && cucumber-js",
+    "test:withserve": "pnpm run build && tsx/serve_and_test.ts",
     "genenv": "tsx scripts/createEnv.mts",
     "gentypes": "tsx scripts/genTypes.ts",
     "dbdiff": "supabase stop && supabase db diff --use-pg-schema",

packages/database/scripts/serve_and_test.ts

@@ -0,0 +1,52 @@
+import { spawn, execSync } from "node:child_process";
+import { join, dirname } from "path";
+
+const __dirname = dirname(__filename);
+const projectRoot = join(__dirname, "..");
+
+if (process.env.GITHUB_TEST !== "test") {
+}
+
+const serve = spawn("supabase", ["functions", "serve"], {
+  cwd: projectRoot,
+  detached: true,
+});
+
+let resolveCallback: ((v: unknown) => void) | undefined = undefined;
+let rejectCallback: ((v: unknown) => void) | undefined = undefined;
+
+const servingReady = new Promise((rsc, rjc) => {
+  resolveCallback = rsc;
+  rejectCallback = rjc;
+});
+
+serve.stdout.on("data", (data: string) => {
+  console.log(`stdout: ${data}`);
+  if (data.includes("Serving functions ")) {
+    console.log("Found serving functions");
+    if (resolveCallback === undefined) throw new Error("did not get callback");
+    resolveCallback(null);
+  }
+});
+
+const doTest = async () => {
+  await servingReady;
+  try {
+    execSync("cucumber-js", {
+      cwd: projectRoot,
+      stdio: "inherit",
+    });
+    // will throw on failure
+  } finally {
+    if (serve.pid) process.kill(-serve.pid);
+  }
+};
+
+doTest()
+  .then(() => {
+    console.log("success");
+  })
+  .catch((err) => {
+    console.error(err);
+    process.exit(-1);
+  });