attach metafile to background worker

Author: nicktrn

packages/cli-v3/src/dev/backgroundWorker.ts

@@ -5,6 +5,7 @@ import { indexWorkerManifest } from "../indexing/indexWorkerManifest.js";
 import { prettyError } from "../utilities/cliOutput.js";
 import { writeJSONFile } from "../utilities/fileSystem.js";
 import { logger } from "../utilities/logger.js";
+import type { Metafile } from "esbuild";
 
 export type BackgroundWorkerOptions = {
   env: Record<string, string>;
@@ -19,6 +20,7 @@ export class BackgroundWorker {
 
   constructor(
     public build: BuildManifest,
+    public metafile: Metafile,
     public params: BackgroundWorkerOptions
   ) {}
 

packages/cli-v3/src/dev/devSession.ts

@@ -116,7 +116,11 @@ export async function startDevSession({
     try {
       logger.debug("Updated bundle", { bundle, buildManifest });
 
-      await runtime.initializeWorker(buildManifest, workerDir?.remove ?? (() => {}));
+      await runtime.initializeWorker(
+        buildManifest,
+        bundle.metafile,
+        workerDir?.remove ?? (() => {})
+      );
     } catch (error) {
       if (error instanceof Error) {
         eventBus.emit("backgroundWorkerIndexingError", buildManifest, error);

packages/cli-v3/src/dev/devSupervisor.ts

@@ -12,7 +12,6 @@ import { CliApiClient } from "../apiClient.js";
 import { DevCommandOptions } from "../commands/dev.js";
 import { eventBus } from "../utilities/eventBus.js";
 import { logger } from "../utilities/logger.js";
-import { sanitizeEnvVars } from "../utilities/sanitizeEnvVars.js";
 import { resolveSourceFiles } from "../utilities/sourceFiles.js";
 import { BackgroundWorker } from "./backgroundWorker.js";
 import { WorkerRuntime } from "./workerRuntime.js";
@@ -25,6 +24,7 @@ import {
 } from "@trigger.dev/core/v3/workers";
 import pLimit from "p-limit";
 import { resolveLocalEnvVars } from "../utilities/localEnvVars.js";
+import type { Metafile } from "esbuild";
 
 export type WorkerRuntimeOptions = {
   name: string | undefined;
@@ -113,7 +113,11 @@ class DevSupervisor implements WorkerRuntime {
     }
   }
 
-  async initializeWorker(manifest: BuildManifest, stop: () => void): Promise<void> {
+  async initializeWorker(
+    manifest: BuildManifest,
+    metafile: Metafile,
+    stop: () => void
+  ): Promise<void> {
     if (this.lastManifest && this.lastManifest.contentHash === manifest.contentHash) {
       logger.debug("worker skipped", { lastManifestContentHash: this.lastManifest?.contentHash });
       eventBus.emit("workerSkipped");
@@ -123,7 +127,7 @@ class DevSupervisor implements WorkerRuntime {
 
     const env = await this.#getEnvVars();
 
-    const backgroundWorker = new BackgroundWorker(manifest, {
+    const backgroundWorker = new BackgroundWorker(manifest, metafile, {
       env,
       cwd: this.options.config.workingDir,
       stop,

packages/cli-v3/src/dev/workerRuntime.ts

@@ -2,10 +2,11 @@ import { BuildManifest } from "@trigger.dev/core/v3";
 import { ResolvedConfig } from "@trigger.dev/core/v3/build";
 import { CliApiClient } from "../apiClient.js";
 import { DevCommandOptions } from "../commands/dev.js";
+import type { Metafile } from "esbuild";
 
 export interface WorkerRuntime {
   shutdown(): Promise<void>;
-  initializeWorker(manifest: BuildManifest, stop: () => void): Promise<void>;
+  initializeWorker(manifest: BuildManifest, metafile: Metafile, stop: () => void): Promise<void>;
 }
 
 export type WorkerRuntimeOptions = {