feat: add Slack draft approvals

src/api/app-helpers.ts

@@ -190,7 +190,15 @@ export function createAppHelpers(deps: AppDeps, app: App) {
     const claimed = await deps.runs.claimById(runId, "inline", deps.leaseTtlMs);
     if (claimed) {
       return withAdminLink(
-        await processRun({ runs: deps.runs, orchestrator: deps.orchestrator, leaseTtlMs: deps.leaseTtlMs }, claimed),
+        await processRun(
+          {
+            runs: deps.runs,
+            orchestrator: deps.orchestrator,
+            leaseTtlMs: deps.leaseTtlMs,
+            ...(deps.messageApprovals ? { messageApprovals: deps.messageApprovals } : {}),
+          },
+          claimed,
+        ),
       );
     }
     const finished = await deps.runs.waitFor(runId, deps.runWaitMs);

src/api/app-turn.ts

@@ -270,6 +270,9 @@ export function createTurnMethods(
         ...(typeof req.intakePreambleMs === "number" ? { intakePreambleMs: req.intakePreambleMs } : {}),
         ...(typeof req.clientSentAt === "number" ? { clientSentAt: req.clientSentAt } : {}),
         ...(req.approval ? { approval: req.approval } : {}),
+        ...(req.messageApprovalContinuation
+          ? { messageApprovalContinuation: structuredClone(req.messageApprovalContinuation) }
+          : {}),
         ...(sessionParticipantIds ? { sessionParticipantIds } : {}),
         ...(projectVersion ? { scopeVersion: projectVersion } : {}),
       };
@@ -437,7 +440,7 @@ export function createTurnMethods(
         deps.runs.enqueue({
           sessionId: conversation.threadRef,
           request,
-          maxAttempts: deps.maxAttempts,
+          maxAttempts: request.messageApprovalContinuation ? 1 : deps.maxAttempts,
           ...(dedupKey ? { dedupKey } : {}),
         });
       const enqueued = await withCurrentProjectRoster(enqueue);

src/api/app-types.ts

@@ -19,6 +19,7 @@ import type { ProcessRegistry } from "../processes/process-registry.ts";
 import type { MonitorStore } from "../monitors/monitor-store.ts";
 import type { EngagedRegistry } from "../wake/engaged-registry.ts";
 import type { Orchestrator } from "../core/orchestrator.ts";
+import type { MessageApprovalService } from "../core/message-approval.ts";
 import type { Run, RunDeliveryState, RunStore } from "../runs/run-store.ts";
 import type { TurnStream } from "../runs/turn-stream.ts";
 import type { SessionStateBus, SessionStateEvent } from "../runs/session-state-bus.ts";
@@ -510,6 +511,7 @@ export interface AppDeps {
   publicWebUrl?: string;
   sessions: SessionStore;
   orchestrator: Orchestrator;
+  messageApprovals?: Pick<MessageApprovalService, "reconcileContinuation">;
   runs: RunStore;
   leaseTtlMs: number;
   maxAttempts: number;

src/api/routes/turns.ts

@@ -38,8 +38,9 @@ async function postTurn(ctx: ApiCtx): Promise<void> {
     ownerKeychainUnion: _ownerKeychainUnion,
     spawned: _spawned,
     unattendedGrants: _unattendedGrants,
+    messageApprovalContinuation: _messageApprovalContinuation,
     ...safeBody
-  } = body;
+  } = body as TurnRequest & { messageApprovalContinuation?: unknown };
   const resolvedOrigin = publicTurnOrigin(safeBody);
   if (resolvedOrigin.error) return sendJson(res, 400, { error: "bad_request", message: resolvedOrigin.error });
   const origin = resolvedOrigin.origin;

src/api/slack-core-client.ts

@@ -40,6 +40,12 @@ interface StoredApprovalView {
   reason?: string;
   purpose?: string;
   summary?: string;
+  summaryDetail?: string;
+  matched?: string;
+  approvalKey?: string;
+  grantModes?: { session: boolean; always: boolean };
+  blocksInput?: boolean;
+  kind?: "approval" | "input";
   request?: Record<string, unknown>;
 }
 
@@ -302,8 +308,14 @@ export function createSlackCoreClient(deps: SlackCoreClientDeps): SlackCoreClien
         requestId: record.requestId,
         command: record.command,
         ...(record.reason !== undefined ? { reason: record.reason } : {}),
+        ...(record.matched !== undefined ? { matched: record.matched } : {}),
         ...(record.purpose !== undefined ? { purpose: record.purpose } : {}),
         ...(record.summary !== undefined ? { summary: record.summary } : {}),
+        ...(record.summaryDetail !== undefined ? { summaryDetail: record.summaryDetail } : {}),
+        ...(record.approvalKey !== undefined ? { approvalKey: record.approvalKey } : {}),
+        ...(record.grantModes !== undefined ? { grantModes: structuredClone(record.grantModes) } : {}),
+        ...(record.blocksInput !== undefined ? { blocksInput: record.blocksInput } : {}),
+        ...(record.kind !== undefined ? { kind: record.kind } : {}),
         ...(record.request !== undefined ? { request: record.request as unknown as Record<string, unknown> } : {}),
       };
     },