fix(server): the ultracode keyword works in Claude threads

apps/mobile/src/state/use-thread-composer-state.ts

@@ -533,6 +533,7 @@ export function useThreadComposerState(input: {
     const result = await editQueuedRun({
       environmentId: thread.environmentId,
       input: {
+        creationSource: "mobile",
         threadId: thread.id,
         runId: edit.runId,
         text: restoreAttachmentOnlyBootstrapPrompt(text, payload.attachments.length > 0),

apps/server/scripts/probe-claude-fork-local-rollback-replay.ts

@@ -161,7 +161,7 @@ async function recordTurn(input: {
   readonly label: string;
   readonly pathFragments: ReadonlyArray<readonly [string, string]>;
 }): Promise<SDKAssistantMessage["uuid"]> {
-  const message = makeClaudeUserMessage({ text: input.prompt });
+  const message = makeClaudeUserMessage({ text: input.prompt, origin: { kind: "human" } });
   input.entries.push({
     type: "expect_outbound",
     label: input.label,

apps/server/src/mcp/toolkits/thread/handlers.ts

@@ -310,6 +310,7 @@ export const layer = McpToolAccess.toLayer(ThreadToolkit, {
             return yield* dispatch(input.threadId, (common) => ({
               ...common,
               type: "queued-run.edit",
+              editor: { createdBy: "agent", creationSource: "mcp" },
               runId,
               text,
             }));

apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.test.ts

@@ -52,6 +52,7 @@ import {
   ProviderTurnId,
   RunAttemptId,
   RunId,
+  ScheduledTaskId,
   ThreadId,
 } from "@t3tools/contracts";
 import { mcpAppFromToolItem } from "@t3tools/shared/toolOutput";
@@ -5294,6 +5295,61 @@ describe("ClaudeAdapterV2 background wake turns", () => {
       ),
   );
 
+  it.effect.each([
+    { name: "web", createdBy: "user", creationSource: "web", human: true },
+    { name: "mobile", createdBy: "user", creationSource: "mobile", human: true },
+    { name: "scheduled", createdBy: "user", creationSource: "web", scheduled: true, human: false },
+    { name: "server", createdBy: "user", creationSource: "server", human: false },
+    { name: "mcp", createdBy: "agent", creationSource: "mcp", human: false },
+  ] as const)(
+    "stamps $name sends and steers as human only when a user typed them",
+    ({ createdBy, creationSource, human, ...rest }) =>
+      Effect.gen(function* () {
+        const harness = yield* makeWakeHarness;
+        const input = makeClaudeTestTurnInput({
+          threadId: harness.threadId,
+          providerThread: harness.providerThread,
+          now: yield* DateTime.now,
+          attemptId: RunAttemptId.make("message-origin"),
+          text: "Watch the artifact",
+          attachments: [],
+          messageCreatedBy: createdBy,
+          messageCreationSource: creationSource,
+        });
+        const message = {
+          ...input.message,
+          ...("scheduled" in rest ? { scheduledTaskId: ScheduledTaskId.make("task-origin") } : {}),
+        };
+        yield* harness.runtime.startTurn({ ...input, message });
+        const idAllocator = yield* IdAllocator.IdAllocatorV2;
+        yield* harness.runtime.steerTurn({
+          threadId: harness.threadId,
+          runId: input.runId,
+          providerThread: harness.providerThread,
+          providerTurnId: idAllocator.derive.providerTurn({
+            driver: ClaudeAdapterV2.CLAUDE_PROVIDER,
+            nativeTurnId: `turn:${input.attemptId}`,
+          }),
+          message: { ...message, messageId: MessageId.make("message-origin-steer") },
+        });
+
+        const expected = human ? { kind: "human" } : undefined;
+        assert.deepEqual(harness.offeredMessages[0]?.origin, expected);
+        assert.equal(harness.offeredMessages[1]?.priority, "now");
+        assert.deepEqual(harness.offeredMessages[1]?.origin, expected);
+      }).pipe(
+        Effect.scoped,
+        Effect.provide(
+          Layer.mergeAll(
+            IdAllocator.layer,
+            McpProviderSessions.layer,
+            NodeServices.layer,
+            NodeCrypto.layer,
+          ),
+        ),
+      ),
+  );
+
   // regression: #29750 Claude sets a goal only from a prompt that opens with /goal
   it("keeps a /goal that mentions a skill as one native goal command", () => {
     const message = ClaudeAdapterV2.makeClaudeUserMessage({
@@ -10959,6 +11015,7 @@ describe("ClaudeAdapterV2 background wake turns", () => {
                 type: "user",
                 message: { role: "user", content: prompt },
                 parent_tool_use_id: null,
+                origin: { kind: "human" },
               },
             },
           },

apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.testkit.ts

@@ -464,6 +464,9 @@ function makeClaudeQueryOpenFrame(
   };
 }
 
+// Recorded prompts stand in for composer messages, which T3 stamps as typed by the user.
+const RECORDED_PROMPT_ORIGIN = { kind: "human" } as const;
+
 function makeClaudePromptOfferFrame(message: SDKUserMessage): ClaudePromptOfferFrame {
   return {
     type: "prompt.offer",
@@ -1619,6 +1622,7 @@ async function recordClaudeStreamingQuery(input: {
   try {
     for (const [index, prompt] of input.prompts.entries()) {
       const message = ClaudeAdapterV2.makeClaudeUserMessage({
+        origin: RECORDED_PROMPT_ORIGIN,
         text: prompt,
         uuid: await Effect.runPromise(
           SecureRandom.SecureRandom.pipe(
@@ -1693,6 +1697,7 @@ async function recordClaudeActiveSteeringQuery(input: {
   const promptQueue = new RecordingPromptQueue();
   const offerPrompt = (index: number, priority?: SDKUserMessage["priority"]) => {
     const message = ClaudeAdapterV2.makeClaudeUserMessage({
+      origin: RECORDED_PROMPT_ORIGIN,
       text: input.prompts[index]!,
       ...(priority === undefined ? {} : { priority }),
     });
@@ -1839,7 +1844,10 @@ async function recordClaudeRestartingQueries(input: {
       label: `query.open:${index + 1}`,
       frame: makeClaudeQueryOpenFrame({ options }),
     });
-    const message = ClaudeAdapterV2.makeClaudeUserMessage({ text: prompt });
+    const message = ClaudeAdapterV2.makeClaudeUserMessage({
+      origin: RECORDED_PROMPT_ORIGIN,
+      text: prompt,
+    });
     input.entries.push({
       type: "expect_outbound",
       label: `prompt.offer:${index + 1}`,
@@ -1941,7 +1949,10 @@ async function recordClaudeResumeAtCursorQuery(input: {
   try {
     const sourceCursors: Array<SDKAssistantMessage["uuid"]> = [];
     for (const [index, prompt] of input.prompts.slice(0, 2).entries()) {
-      const message = ClaudeAdapterV2.makeClaudeUserMessage({ text: prompt });
+      const message = ClaudeAdapterV2.makeClaudeUserMessage({
+        origin: RECORDED_PROMPT_ORIGIN,
+        text: prompt,
+      });
       input.entries.push({
         type: "expect_outbound",
         label: `prompt.offer:${index + 1}`,
@@ -2003,7 +2014,10 @@ async function recordClaudeResumeAtCursorQuery(input: {
       label: "query.open:resume_at_cursor",
       frame: makeClaudeQueryOpenFrame({ options: resumedOptions }),
     });
-    const resumedMessage = ClaudeAdapterV2.makeClaudeUserMessage({ text: input.prompts[2]! });
+    const resumedMessage = ClaudeAdapterV2.makeClaudeUserMessage({
+      origin: RECORDED_PROMPT_ORIGIN,
+      text: input.prompts[2]!,
+    });
     input.entries.push({
       type: "expect_outbound",
       label: "prompt.offer:3",
@@ -2123,7 +2137,10 @@ async function recordClaudeForkSessionQuery(input: {
   try {
     const sourceCursors: Array<SDKAssistantMessage["uuid"]> = [];
     for (const [index, prompt] of input.prompts.slice(0, sourcePromptCount).entries()) {
-      const message = ClaudeAdapterV2.makeClaudeUserMessage({ text: prompt });
+      const message = ClaudeAdapterV2.makeClaudeUserMessage({
+        origin: RECORDED_PROMPT_ORIGIN,
+        text: prompt,
+      });
       input.entries.push({
         type: "expect_outbound",
         label: `prompt.offer:${index + 1}`,
@@ -2225,7 +2242,10 @@ async function recordClaudeForkSessionQuery(input: {
       const targetIterator = targetRuntime[Symbol.asyncIterator]();
       for (const prompt of forkPrompts) {
         promptOrdinal += 1;
-        const targetMessage = ClaudeAdapterV2.makeClaudeUserMessage({ text: prompt });
+        const targetMessage = ClaudeAdapterV2.makeClaudeUserMessage({
+          origin: RECORDED_PROMPT_ORIGIN,
+          text: prompt,
+        });
         input.entries.push({
           type: "expect_outbound",
           label: `prompt.offer:${promptOrdinal}`,
@@ -2283,7 +2303,10 @@ async function recordClaudeForkSessionQuery(input: {
       const continuationIterator = continuationRuntime[Symbol.asyncIterator]();
       for (const prompt of input.prompts.slice(forkPromptEnd)) {
         promptOrdinal += 1;
-        const continuationMessage = ClaudeAdapterV2.makeClaudeUserMessage({ text: prompt });
+        const continuationMessage = ClaudeAdapterV2.makeClaudeUserMessage({
+          origin: RECORDED_PROMPT_ORIGIN,
+          text: prompt,
+        });
         input.entries.push({
           type: "expect_outbound",
           label: `prompt.offer:${promptOrdinal}`,
@@ -2371,7 +2394,10 @@ async function recordInterruptedClaudeQuery(input: {
     options,
   });
   const iterator = runtime[Symbol.asyncIterator]();
-  const message = ClaudeAdapterV2.makeClaudeUserMessage({ text: input.prompt });
+  const message = ClaudeAdapterV2.makeClaudeUserMessage({
+    origin: RECORDED_PROMPT_ORIGIN,
+    text: input.prompt,
+  });
   input.entries.push({
     type: "expect_outbound",
     label: input.promptOfferLabel,
@@ -2547,7 +2573,10 @@ async function recordClaudeInterruptRestartQuery(input: {
     label: "query.open:2",
     frame: makeClaudeQueryOpenFrame({ options: secondOptions }),
   });
-  const secondMessage = ClaudeAdapterV2.makeClaudeUserMessage({ text: input.prompts[1]! });
+  const secondMessage = ClaudeAdapterV2.makeClaudeUserMessage({
+    origin: RECORDED_PROMPT_ORIGIN,
+    text: input.prompts[1]!,
+  });
   input.entries.push({
     type: "expect_outbound",
     label: "prompt.offer:2",

apps/server/src/orchestration-v2/Adapters/ClaudeAdapterV2.ts

@@ -2744,9 +2744,21 @@ function isSupportedClaudeImageMimeType(
   return supportedClaudeImageMimeTypes.has(mimeType);
 }
 
+// Claude's trust gates, like artifact comment auto-replies, need typed input stamped human.
+function claudeMessageOrigin(
+  message: ProviderAdapter.ProviderAdapterV2TurnMessage,
+): SDKUserMessage["origin"] {
+  return message.createdBy === "user" &&
+    (message.creationSource === "web" || message.creationSource === "mobile") &&
+    message.scheduledTaskId === undefined
+    ? { kind: "human" }
+    : undefined;
+}
+
 export function makeClaudeUserMessage(input: {
   readonly text: string;
   readonly priority?: SDKUserMessage["priority"];
+  readonly origin?: SDKUserMessage["origin"];
   readonly skills?: ReadonlyMap<string, ClaudeSkillTarget>;
   readonly skillMentionsFrom?: number;
   readonly uuid?: SDKUserMessage["uuid"];
@@ -2776,6 +2788,7 @@ export function makeClaudeUserMessage(input: {
     },
     parent_tool_use_id: null,
     ...(input.priority === undefined ? {} : { priority: input.priority }),
+    ...(input.origin === undefined ? {} : { origin: input.origin }),
     ...(input.uuid === undefined ? {} : { uuid: input.uuid }),
   };
 }
@@ -2916,6 +2929,7 @@ const makeClaudeUserMessageWithAttachments = Effect.fnUntraced(function* (input:
   readonly text: string;
   readonly attachments: ReadonlyArray<ChatAttachment>;
   readonly priority?: SDKUserMessage["priority"];
+  readonly origin?: SDKUserMessage["origin"];
   readonly uuid?: SDKUserMessage["uuid"];
   readonly attachmentsDir: string;
   readonly fileSystem: FileSystem.FileSystem;
@@ -2931,6 +2945,7 @@ const makeClaudeUserMessageWithAttachments = Effect.fnUntraced(function* (input:
         ? {}
         : { skillMentionsFrom: input.skillMentionsFrom }),
       ...(input.priority === undefined ? {} : { priority: input.priority }),
+      ...(input.origin === undefined ? {} : { origin: input.origin }),
       ...(input.uuid === undefined ? {} : { uuid: input.uuid }),
     });
     const bytes = Buffer.byteLength(encodeClaudeJson(message.message.content));
@@ -3096,6 +3111,7 @@ const makeClaudeUserMessageWithAttachments = Effect.fnUntraced(function* (input:
     },
     parent_tool_use_id: null,
     ...(input.priority === undefined ? {} : { priority: input.priority }),
+    ...(input.origin === undefined ? {} : { origin: input.origin }),
     ...(input.uuid === undefined ? {} : { uuid: input.uuid }),
   } satisfies SDKUserMessage;
 });
@@ -12829,6 +12845,7 @@ export const makeClaudeAdapterV2 = Effect.fn("makeClaudeAdapterV2")(function* (
                       fileSystem,
                       pdfReservation,
                       ...(skills === undefined ? {} : { skills }),
+                      origin: claudeMessageOrigin(turnInput.message),
                       uuid: promptUuid,
                     }).pipe(
                       Effect.provideService(ChildProcessSpawner.ChildProcessSpawner, spawner),
@@ -13360,6 +13377,7 @@ export const makeClaudeAdapterV2 = Effect.fn("makeClaudeAdapterV2")(function* (
               ),
               attachments: turnInput.message.attachments,
               priority: "now",
+              origin: claudeMessageOrigin(turnInput.message),
               uuid: steerUuid,
               attachmentsDir,
               fileSystem,