remove more unused ipc schemas

Author: nicktrn

packages/cli-v3/src/executions/taskRunProcess.ts

@@ -33,20 +33,6 @@ import {
   SuspendedProcessError,
 } from "@trigger.dev/core/v3/errors";
 
-export type OnWaitForDurationMessage = InferSocketMessageSchema<
-  typeof ExecutorToWorkerMessageCatalog,
-  "WAIT_FOR_DURATION"
->;
-export type OnWaitForTaskMessage = InferSocketMessageSchema<
-  typeof ExecutorToWorkerMessageCatalog,
-  "WAIT_FOR_TASK"
->;
-export type OnWaitForBatchMessage = InferSocketMessageSchema<
-  typeof ExecutorToWorkerMessageCatalog,
-  "WAIT_FOR_BATCH"
->;
-export type OnWaitMessage = InferSocketMessageSchema<typeof ExecutorToWorkerMessageCatalog, "WAIT">;
-
 export type TaskRunProcessOptions = {
   workerManifest: WorkerManifest;
   serverWorker: ServerBackgroundWorker;
@@ -82,11 +68,6 @@ export class TaskRunProcess {
   public onExit: Evt<{ code: number | null; signal: NodeJS.Signals | null; pid?: number }> =
     new Evt();
   public onIsBeingKilled: Evt<TaskRunProcess> = new Evt();
-  public onReadyToDispose: Evt<TaskRunProcess> = new Evt();
-
-  public onWaitForTask: Evt<OnWaitForTaskMessage> = new Evt();
-  public onWaitForBatch: Evt<OnWaitForBatchMessage> = new Evt();
-  public onWait: Evt<OnWaitMessage> = new Evt();
 
   private _isPreparedForNextRun: boolean = false;
   private _isPreparedForNextAttempt: boolean = false;
@@ -191,20 +172,9 @@ export class TaskRunProcess {
 
           resolver(result);
         },
-        READY_TO_DISPOSE: async () => {
-          logger.debug(`task run process is ready to dispose`);
-
-          this.onReadyToDispose.post(this);
-        },
         TASK_HEARTBEAT: async (message) => {
           this.onTaskRunHeartbeat.post(message.id);
         },
-        WAIT_FOR_TASK: async (message) => {
-          this.onWaitForTask.post(message);
-        },
-        WAIT_FOR_BATCH: async (message) => {
-          this.onWaitForBatch.post(message);
-        },
         UNCAUGHT_EXCEPTION: async (message) => {
           logger.debug("uncaught exception in task run process", { ...message });
         },

packages/core/src/v3/schemas/messages.ts

@@ -13,7 +13,6 @@ import {
   ProdTaskRunExecution,
   ProdTaskRunExecutionPayload,
   RunEngineVersionSchema,
-  RuntimeWait,
   TaskRunExecutionLazyAttemptPayload,
   TaskRunExecutionMetrics,
   WaitReason,
@@ -172,39 +171,9 @@ export const ExecutorToWorkerMessageCatalog = {
       id: z.string(),
     }),
   },
-  READY_TO_DISPOSE: {
-    message: z.undefined(),
-  },
-  WAIT_FOR_DURATION: {
-    message: z.object({
-      version: z.literal("v1").default("v1"),
-      ms: z.number(),
-      now: z.number(),
-      waitThresholdInMs: z.number(),
-    }),
-  },
-  WAIT_FOR_TASK: {
-    message: z.object({
-      version: z.literal("v1").default("v1"),
-      friendlyId: z.string(),
-    }),
-  },
-  WAIT_FOR_BATCH: {
-    message: z.object({
-      version: z.literal("v1").default("v1"),
-      batchFriendlyId: z.string(),
-      runFriendlyIds: z.string().array(),
-    }),
-  },
   UNCAUGHT_EXCEPTION: {
     message: UncaughtExceptionMessage,
   },
-  WAIT: {
-    message: z.object({
-      version: z.literal("v1").default("v1"),
-      wait: RuntimeWait,
-    }),
-  },
 };
 
 export const WorkerToExecutorMessageCatalog = {

packages/core/src/v3/schemas/schemas.ts

@@ -275,20 +275,6 @@ export const TaskRunExecutionLazyAttemptPayload = z.object({
 
 export type TaskRunExecutionLazyAttemptPayload = z.infer<typeof TaskRunExecutionLazyAttemptPayload>;
 
-export const RuntimeWait = z.discriminatedUnion("type", [
-  z.object({
-    type: z.literal("DATETIME"),
-    id: z.string(),
-    date: z.coerce.date(),
-  }),
-  z.object({
-    type: z.literal("MANUAL"),
-    id: z.string(),
-  }),
-]);
-
-export type RuntimeWait = z.infer<typeof RuntimeWait>;
-
 export const ManualCheckpointMetadata = z.object({
   /** NOT a friendly ID */
   attemptId: z.string(),