Add worker start test

Author: codenem

packages/cli-v3/e2e/compile.ts

@@ -1,5 +1,3 @@
-#!/usr/bin/env node
-
 import { esbuildDecorators } from "@anatine/esbuild-decorators";
 import { build } from "esbuild";
 import { readFileSync } from "node:fs";
@@ -91,8 +89,11 @@ export async function compile(options: CompileOptions) {
     target: ["node18", "es2020"],
     // outdir: "out",
     outdir: resolve(config.projectDir, "out"),
-    banner: {
-      js: `process.on("uncaughtException", function(error, origin) { if (error instanceof Error) { process.send && process.send({ type: "EVENT", message: { type: "UNCAUGHT_EXCEPTION", payload: { error: { name: error.name, message: error.message, stack: error.stack }, origin }, version: "v1" } }); } else { process.send && process.send({ type: "EVENT", message: { type: "UNCAUGHT_EXCEPTION", payload: { error: { name: "Error", message: typeof error === "string" ? error : JSON.stringify(error) }, origin }, version: "v1" } }); } });`,
+    // banner: {
+    //   js: `process.on("uncaughtException", function(error, origin) { if (error instanceof Error) { process.send && process.send({ type: "EVENT", message: { type: "UNCAUGHT_EXCEPTION", payload: { error: { name: error.name, message: error.message, stack: error.stack }, origin }, version: "v1" } }); } else { process.send && process.send({ type: "EVENT", message: { type: "UNCAUGHT_EXCEPTION", payload: { error: { name: "Error", message: typeof error === "string" ? error : JSON.stringify(error) }, origin }, version: "v1" } }); } });`,
+    // },
+    footer: {
+      js: "process.exit();",
     },
     define: {
       TRIGGER_API_URL: `"${config.triggerUrl}"`,

packages/cli-v3/e2e/index.test.ts

@@ -1,5 +1,4 @@
-import { execa } from "execa";
-import { readFileSync } from "node:fs";
+import { execa, execaNode } from "execa";
 import { mkdir, rename, rm } from "node:fs/promises";
 import { join, resolve } from "node:path";
 
@@ -12,14 +11,17 @@ import { compile } from "./compile";
 import { handleDependencies } from "./handleDependencies";
 import { createContainerFile } from "./createContainerFile";
 import { createDeployHash } from "./createDeployHash";
+import { readFileSync } from "node:fs";
 
 type TestCase = {
   name: string;
   skipTypecheck?: boolean;
   wantConfigNotFoundError?: boolean;
   wantBadConfigError?: boolean;
   wantCompilationError?: boolean;
+  wantWorkerError?: boolean;
   wantDependenciesError?: boolean;
+  wantInstallationError?: boolean;
 };
 
 const allTestCases: TestCase[] = [
@@ -71,7 +73,9 @@ if (testCases.length > 0) {
       wantConfigNotFoundError,
       wantBadConfigError,
       wantCompilationError,
+      wantWorkerError,
       wantDependenciesError,
+      wantInstallationError,
     }: TestCase) => {
       const fixtureDir = resolve(join(process.cwd(), "e2e/fixtures", name));
 
@@ -108,19 +112,25 @@ if (testCases.length > 0) {
                 console.log(
                   `Detected ${packageManager}@${version} from package.json 'engines' field`
                 );
-                const { stdout } = await execa(
+                const { stdout, stderr } = await execa(
                   "corepack",
                   ["use", `${packageManager}@${version}`],
                   {
                     cwd: fixtureDir,
                   }
                 );
                 console.log(stdout);
+                if (stderr) console.error(stderr);
               } else {
-                const { stdout } = await execa(packageManager, installArgs(packageManager), {
-                  cwd: fixtureDir,
-                });
+                const { stdout, stderr } = await execa(
+                  packageManager,
+                  installArgs(packageManager),
+                  {
+                    cwd: fixtureDir,
+                  }
+                );
                 console.log(stdout);
+                if (stderr) console.error(stderr);
               }
             })()
           ).resolves.not.toThrowError();
@@ -262,6 +272,56 @@ if (testCases.length > 0) {
                 })()
               ).resolves.not.toThrowError();
             });
+
+            describe("with Containerfile ready", () => {
+              test(
+                "installs dependencies",
+                async () => {
+                  const expectation = expect(
+                    (async () => {
+                      const { stdout, stderr } = await execa(
+                        "npm",
+                        ["ci", "--no-audit", "--no-fund"],
+                        {
+                          cwd: resolve(join(fixtureDir, ".trigger")),
+                        }
+                      );
+                      console.log(stdout);
+                      if (stderr) console.error(stderr);
+                    })()
+                  );
+
+                  if (wantInstallationError) {
+                    await expectation.rejects.toThrowError();
+                  } else {
+                    await expectation.resolves.not.toThrowError();
+                  }
+                },
+                { timeout: 60_000 }
+              );
+
+              test(
+                wantWorkerError ? "'node worker.js' fails" : "'node worker.js' succeeds",
+                async () => {
+                  const expectation = expect(
+                    (async () => {
+                      const { stdout, stderr } = await execaNode("worker.js", {
+                        cwd: resolve(join(fixtureDir, ".trigger")),
+                      });
+                      console.log(stdout);
+                      if (stderr) console.error(stderr);
+                    })()
+                  );
+
+                  if (wantWorkerError) {
+                    await expectation.rejects.toThrowError();
+                  } else {
+                    await expectation.resolves.not.toThrowError();
+                  }
+                },
+                { timeout: 60_000 }
+              );
+            });
           });
         });
       });