chore(vendor): adopt upstream HEAD content in vendored trees (4cc6972)

Verbatim adoption of the drift ranges triaged in docs/VENDORING.md; carried patches and ledgers land next.

Author: TheGreatAxios

src/session/runtime-assembly.test.ts

@@ -1218,7 +1218,7 @@ describe("buildCompactionContinuationMessage", () => {
     expect(message.ref).toEqual({ uid: 0, mailbox: "system" });
     expect(message.headers.from).toBe("user@local");
     expect(message.headers.to).toEqual(["agent@local"]);
-    expect(message.headers.messageId.startsWith("compact-continue-")).toBe(
+    expect(message.headers.messageId?.startsWith("compact-continue-")).toBe(
       true,
     );
   });
@@ -1251,6 +1251,6 @@ describe("buildMailboxMailMessage", () => {
     expect(message.ref).toEqual({ uid: 0, mailbox: "system" });
     expect(message.headers.from).toBe("user@local");
     expect(message.headers.to).toEqual(["agent@local"]);
-    expect(message.headers.messageId.startsWith("mailbox-mail-")).toBe(true);
+    expect(message.headers.messageId?.startsWith("mailbox-mail-")).toBe(true);
   });
 });

src/tui/queued-input-chrome.test.ts

@@ -718,6 +718,8 @@ test("mid-run steer paints QUEUED INPUT until the real director reads it", async
               deliver: (text, pending, settle) => {
                 const message = userInboundMessage(text, pending);
                 const messageId = message.headers.messageId;
+                if (messageId === undefined)
+                  throw new Error("userInboundMessage set no messageId");
                 steerMessageId.current = messageId;
                 bridge.beginQueuedInputDelivery(messageId);
                 void deliverAgentMessage({

src/tui/runner/submit.ts

@@ -581,7 +581,7 @@ export function createDeliverRouting(
           () => targetAgent.deliver(message),
           (result) => {
             if (result.status === "accepted" && isOperatorMessage) {
-              state.acceptedInputObserver?.(message.headers.messageId);
+              state.acceptedInputObserver?.(messageId);
             } else if (isOperatorMessage) {
               state.discardAcceptedInputObserver?.(messageId);
             }

vendor/intx-agent/README.md

@@ -4,6 +4,14 @@ In-process agent runtime built on `createReactorAssembly` from
 `@intx/inference`. Construct an agent, `send()` it a message,
 get a reply.
 
+Workflow packages can import `defineAgent`, tool and director declarations,
+and director registries from `@intx/agent/authoring`. That entry point keeps
+the reactor and agent execution runtime out of definition loading.
+
+`@intx/agent/canonicalize` exports `canonicalizeForHash` and
+`CanonicalizationError` for deterministic serialization of deploy-hash inputs
+without loading the agent execution runtime.
+
 Use this package when you want an agent you can drive from inside
 your own program — a CLI, a worker, a test, an embedded assistant.
 If you want an agent that lives behind a mailbox instead, see

vendor/intx-agent/src/authoring.ts

@@ -0,0 +1,40 @@
+/** Agent definitions and declarations, without the agent execution runtime. */
+export {
+  defineAgent,
+  type AgentDefinition,
+  type DefineAgentConfig,
+  type EnvRequiredByAll,
+  type InferencePreference,
+} from "./definition";
+export {
+  defineTool,
+  definePlugin,
+  isAnnotatedPluginFactory,
+  toolApprovalEffect,
+  type AnnotatedPluginFactory,
+  type AnnotatedToolFactory,
+  type ToolDeclaration,
+} from "./tool";
+export {
+  defineDirector,
+  isAnnotatedDirectorFactory,
+  type DefinedDirector,
+} from "./director";
+export {
+  createDefaultDirectorRegistry,
+  createDirectorRegistry,
+  createWorkflowDirectorRegistry,
+  UnknownDirectorIdError,
+} from "./director-registry";
+export {
+  buildDefaultDirectorRef,
+  defaultDirectorFactory,
+  type DefaultDirectorConfig,
+} from "./default-director";
+export { effectiveDirectorRef } from "./env-validation";
+export type {
+  AnnotatedDirectorFactory,
+  DirectorRef,
+  DirectorRegistry,
+} from "./director-types";
+export type { BaseEnv } from "./env";

vendor/intx-agent/src/default-director.ts

@@ -18,7 +18,7 @@ import { type } from "arktype";
 import {
   createDefaultDirector,
   type DefaultDirectorPolicy,
-} from "@intx/inference";
+} from "@intx/inference/default-director";
 
 import { defineDirector } from "./director";
 

vendor/intx-agent/src/send-queue.ts

@@ -15,6 +15,9 @@
 //     queue ordered against actual reactor cycles — two send() promises
 //     cannot interleave at the reactor level.
 //
+// A `start` that throws synchronously rejects that item and pumps the
+// next, so a rejected item never occupies the active slot.
+//
 // Queue depth (active + pending) is bounded by `maxDepth`; exceeding it
 // throws `SendQueueFullError` synchronously from enqueue() so a buggy
 // caller flooding sends fails loud instead of silently buffering.
@@ -106,7 +109,13 @@ export function createSendQueue<T, R>(
         continue;
       }
       active = next;
-      opts.start(next.item);
+      try {
+        opts.start(next.item);
+      } catch (cause) {
+        active = null;
+        settle(next, "reject", cause);
+        continue;
+      }
       return;
     }
   }

vendor/intx-agent/src/source.ts

@@ -18,7 +18,7 @@ import {
   InferenceSource as InferenceSourceValidator,
   applyInferenceSourceFields,
   type InferenceSource,
-} from "@intx/types/runtime";
+} from "@intx/types/runtime-core";
 
 export class InvalidInferenceSourceError extends Error {
   constructor(message: string) {

vendor/intx-agent/src/tool.ts

@@ -18,7 +18,7 @@
 //                                            handler throws.
 //
 // `createToolRunner(tools)` builds a `ToolRunner` that dispatches by tool
-// name. Per the ToolRunner contract (packages/types/src/runtime.ts), `run`
+// name. Per the ToolRunner contract (packages/types/src/runtime-core.ts), `run`
 // must not throw -- unknown tool names and handler exceptions are surfaced
 // as `ToolResult` with `isError: true` so the model sees them and can
 // recover.