feat(daemon): wire generated plans and continue ChangeSet

apps/daemon/src/api/body.ts

@@ -126,6 +126,25 @@ export function queryString(raw: unknown): string | undefined {
   return typeof raw === "string" ? raw : String(raw);
 }
 
+export function optionalObjectArray(
+  body: Record<string, unknown>,
+  key: string,
+): Record<string, unknown>[] | undefined {
+  if (!(key in body)) {
+    return undefined;
+  }
+  const value = body[key];
+  if (!Array.isArray(value)) {
+    throw new AppError("validation_failed", `${key} must be an array`);
+  }
+  return value.map((item, index) => {
+    if (item === null || typeof item !== "object" || Array.isArray(item)) {
+      throw new AppError("validation_failed", `${key}[${index}] must be an object`);
+    }
+    return item as Record<string, unknown>;
+  });
+}
+
 export function queryStringList(raw: unknown): string[] | undefined {
   if (raw === undefined) {
     return undefined;

apps/daemon/src/api/routes.ts

@@ -27,6 +27,7 @@ import type { SessionRegistry } from "./auth.js";
 import {
   asObject,
   optionalInt,
+  optionalObjectArray,
   optionalString,
   parseLimit,
   queryString,
@@ -610,6 +611,71 @@ export function registerRoutes(app: FastifyInstance, deps: RouteDeps): void {
     );
   }
 
+  app.post(
+    "/api/v1/authoring-sessions/:sessionId/change-sets/:changeSetId/_cmd/continue",
+    async (request, reply) => {
+      await cmd(
+        request,
+        reply,
+        {
+          canonicalOperation:
+            "POST /authoring-sessions/{sessionId}/change-sets/{changeSetId}:continue",
+          resource: (req) => `${param(req, "sessionId")}:${param(req, "changeSetId")}`,
+          requireIfMatch: true,
+        },
+        (ctx, body) => {
+          rejectUnknownFields(body, [
+            "operationId",
+            "workflowDrafts",
+            "teamDrafts",
+            "taskPatches",
+          ]);
+          const input: {
+            workflowDrafts?: Record<string, unknown>[];
+            teamDrafts?: Record<string, unknown>[];
+            taskPatches?: Record<string, unknown>[];
+          } = {};
+          const workflowDrafts = optionalObjectArray(body, "workflowDrafts");
+          const teamDrafts = optionalObjectArray(body, "teamDrafts");
+          const taskPatches = optionalObjectArray(body, "taskPatches");
+          if (workflowDrafts !== undefined) input.workflowDrafts = workflowDrafts;
+          if (teamDrafts !== undefined) input.teamDrafts = teamDrafts;
+          if (taskPatches !== undefined) input.taskPatches = taskPatches;
+          return deps.services.continueAuthoringChangeSet(
+            ctx,
+            param(request, "sessionId"),
+            param(request, "changeSetId"),
+            input,
+          );
+        },
+      );
+    },
+  );
+
+  app.post(
+    "/api/v1/authoring-sessions/:sessionId/change-sets/:changeSetId/_cmd/retry",
+    async (request, reply) => {
+      await cmd(
+        request,
+        reply,
+        {
+          canonicalOperation:
+            "POST /authoring-sessions/{sessionId}/change-sets/{changeSetId}:retry",
+          resource: (req) => `${param(req, "sessionId")}:${param(req, "changeSetId")}`,
+          requireIfMatch: true,
+        },
+        (ctx, body) => {
+          rejectUnknownFields(body, ["operationId"]);
+          return deps.services.retryAuthoringChangeSet(
+            ctx,
+            param(request, "sessionId"),
+            param(request, "changeSetId"),
+          );
+        },
+      );
+    },
+  );
+
   app.get("/api/v1/approvals", async (request) => deps.services.listApprovals(listQuery(request)));
   app.get("/api/v1/approvals/:id", async (request, reply) => {
     const approval = requireFound(