feat(code): cloud task SSE streaming

Author: tatoalo

apps/code/src/main/services/cloud-task/schemas.ts

@@ -1,11 +1,13 @@
-import type { CloudTaskUpdatePayload, TaskRun } from "@shared/types";
+import {
+  type CloudTaskUpdatePayload,
+  isTerminalStatus,
+  type TaskRunStatus,
+  TERMINAL_STATUSES,
+} from "@shared/types";
 import { z } from "zod";
 
-export type { CloudTaskUpdatePayload };
-
-// --- Terminal statuses ---
-
-export const TERMINAL_STATUSES = ["completed", "failed", "cancelled"] as const;
+export type { CloudTaskUpdatePayload, TaskRunStatus };
+export { TERMINAL_STATUSES, isTerminalStatus };
 
 // --- Events ---
 
@@ -17,16 +19,13 @@ export interface CloudTaskEvents {
   [CloudTaskEvent.Update]: CloudTaskUpdatePayload;
 }
 
-export type TaskRunStatus = TaskRun["status"];
-
 // --- tRPC Schemas ---
 
 export const watchInput = z.object({
   taskId: z.string(),
   runId: z.string(),
   apiHost: z.string(),
   teamId: z.number(),
-  viewing: z.boolean().optional(),
 });
 
 export type WatchInput = z.infer<typeof watchInput>;
@@ -36,15 +35,14 @@ export const unwatchInput = z.object({
   runId: z.string(),
 });
 
-export const onUpdateInput = z.object({
+export const retryInput = z.object({
   taskId: z.string(),
   runId: z.string(),
 });
 
-export const setViewingInput = z.object({
+export const onUpdateInput = z.object({
   taskId: z.string(),
   runId: z.string(),
-  viewing: z.boolean(),
 });
 
 export const sendCommandInput = z.object({