init.ts at the root of the trigger dir is now automatically loaded

Author: ericallam

packages/cli-v3/src/build/bundle.ts

@@ -236,6 +236,18 @@ export async function getBundleResultFromBuild(
     ? relative(resolvedConfig.workingDir, resolvedConfig.configFile)
     : "trigger.config.ts";
 
+  // Check if the entry point is an init.ts file at the root of a trigger directory
+  function isInitEntryPoint(entryPoint: string): boolean {
+    const normalizedEntryPoint = entryPoint.replace(/\\/g, "/"); // Normalize path separators
+    const initFileName = "init.ts";
+
+    // Check if it's directly in one of the trigger directories
+    return resolvedConfig.dirs.some((dir) => {
+      const normalizedDir = dir.replace(/\\/g, "/");
+      return normalizedEntryPoint === `${normalizedDir}/${initFileName}`;
+    });
+  }
+
   for (const [outputPath, outputMeta] of Object.entries(result.metafile.outputs)) {
     if (outputPath.endsWith(".mjs")) {
       const $outputPath = resolve(workingDir, outputPath);
@@ -256,7 +268,7 @@ export async function getBundleResultFromBuild(
         indexControllerEntryPoint = $outputPath;
       } else if (isIndexWorkerForTarget(outputMeta.entryPoint, target)) {
         indexWorkerEntryPoint = $outputPath;
-      } else if (outputMeta.entryPoint.endsWith("init.ts")) {
+      } else if (isInitEntryPoint(outputMeta.entryPoint)) {
         initEntryPoint = $outputPath;
       } else {
         if (
@@ -362,6 +374,7 @@ export async function createBuildManifestFromBundle({
     runControllerEntryPoint: bundle.runControllerEntryPoint ?? getRunControllerForTarget(target),
     runWorkerEntryPoint: bundle.runWorkerEntryPoint ?? getRunWorkerForTarget(target),
     loaderEntryPoint: bundle.loaderEntryPoint,
+    initEntryPoint: bundle.initEntryPoint,
     configPath: bundle.configPath,
     customConditions: resolvedConfig.build.conditions ?? [],
     deploy: {

packages/cli-v3/src/entryPoints/dev-index-worker.ts

@@ -141,6 +141,7 @@ await sendMessageInCatalog(
       controllerEntryPoint: buildManifest.runControllerEntryPoint,
       loaderEntryPoint: buildManifest.loaderEntryPoint,
       customConditions: buildManifest.customConditions,
+      initEntryPoint: buildManifest.initEntryPoint,
     },
     importErrors,
   },

packages/cli-v3/src/entryPoints/managed-index-worker.ts

@@ -141,6 +141,7 @@ await sendMessageInCatalog(
       controllerEntryPoint: buildManifest.runControllerEntryPoint,
       loaderEntryPoint: buildManifest.loaderEntryPoint,
       customConditions: buildManifest.customConditions,
+      initEntryPoint: buildManifest.initEntryPoint,
     },
     importErrors,
   },

references/hello-world/src/trigger/example.ts

@@ -1,38 +1,6 @@
-import { batch, logger, task, timeout, wait, tasks } from "@trigger.dev/sdk";
+import { batch, logger, task, timeout, wait } from "@trigger.dev/sdk";
 import { setTimeout } from "timers/promises";
 
-tasks.onInit("logging", ({ ctx, payload, task }) => {
-  logger.info("Hello, world from the init", { ctx, payload, task });
-});
-
-// tasks.onSuccess(({ ctx, payload, output }) => {
-//   logger.info("Hello, world from the success", { ctx, payload });
-// });
-
-// tasks.onComplete(({ ctx, payload, output, error }) => {
-//   logger.info("Hello, world from the success", { ctx, payload });
-// });
-
-// tasks.handleError(({ ctx, payload, error, retry, retryAt, retryDelayInMs }) => {
-//   logger.info("Hello, world from the success", { ctx, payload });
-// });
-
-// tasks.onFailure(({ ctx, payload }) => {
-//   logger.info("Hello, world from the failure", { ctx, payload });
-// });
-
-// tasks.onStart(({ ctx, payload }) => {
-//   logger.info("Hello, world from the start", { ctx, payload });
-// });
-
-// tasks.onWait(({ ctx, payload }) => {
-//   logger.info("Hello, world from the start", { ctx, payload });
-// });
-
-// tasks.onResume(({ ctx, payload }) => {
-//   logger.info("Hello, world from the start", { ctx, payload });
-// });
-
 export const helloWorldTask = task({
   id: "hello-world",
   run: async (payload: any, { ctx }) => {

references/hello-world/src/trigger/init.ts

@@ -0,0 +1,33 @@
+import { logger, tasks } from "@trigger.dev/sdk";
+
+// tasks.onSuccess(({ ctx, payload, output }) => {
+//   logger.info("Hello, world from the success", { ctx, payload });
+// });
+
+// tasks.onComplete(({ ctx, payload, output, error }) => {
+//   logger.info("Hello, world from the success", { ctx, payload });
+// });
+
+// tasks.handleError(({ ctx, payload, error, retry, retryAt, retryDelayInMs }) => {
+//   logger.info("Hello, world from the success", { ctx, payload });
+// });
+
+// tasks.onFailure(({ ctx, payload }) => {
+//   logger.info("Hello, world from the failure", { ctx, payload });
+// });
+
+// tasks.onStart(({ ctx, payload }) => {
+//   logger.info("Hello, world from the start", { ctx, payload });
+// });
+
+// tasks.onWait(({ ctx, payload }) => {
+//   logger.info("Hello, world from the start", { ctx, payload });
+// });
+
+// tasks.onResume(({ ctx, payload }) => {
+//   logger.info("Hello, world from the start", { ctx, payload });
+// });
+
+tasks.onInit("logging", ({ ctx, payload, task }) => {
+  logger.info("Hello, world from the init", { ctx, payload, task });
+});