Share the ask_director wake prefix across leftover ingest and sent-message skip

Leftover ingest skip and sent-message skip both matched the wake prefix as a string literal. Export ASK_DIRECTOR_WAKE_PREFIX from fleet-report (the wake text source) and use it in queued-delivery and submit.

Author: TheGreatAxios

src/subagent/fleet-report.ts

@@ -154,14 +154,16 @@ export function pendingAskSnapshot(
   return asks;
 }
 
+export const ASK_DIRECTOR_WAKE_PREFIX = "ask_director wake";
+
 /**
  * The wake turn text. It must read as the worker's question reaching the
  * parent, not as the operator being asked — the parent answers via
  * send_input itself and only escalates when it genuinely cannot.
  */
 export function pendingAskWakeText(wake: PendingAskWake): string {
   return [
-    `ask_director wake — worker ${wake.agentId} (${wake.description}) parked question ${wake.questionId} while this session was not collecting:`,
+    `${ASK_DIRECTOR_WAKE_PREFIX} — worker ${wake.agentId} (${wake.description}) parked question ${wake.questionId} while this session was not collecting:`,
     "",
     wake.question,
     "",

src/tui/queued-delivery.ts

@@ -10,6 +10,7 @@
 
 import type { PendingImageAttachment } from "./image-attachments.js";
 import type { ProductHostDeliver } from "./product-host.js";
+import { ASK_DIRECTOR_WAKE_PREFIX } from "../subagent/fleet-report.js";
 
 export interface RouteQueuedDeliveryArgs {
   send: (text: string, attachments?: readonly PendingImageAttachment[]) => void;
@@ -131,7 +132,7 @@ export function createLeftoverSend(
     ...args,
     hop: args.send,
     ingest: async (text, pending) =>
-      text.startsWith("ask_director wake")
+      text.startsWith(ASK_DIRECTOR_WAKE_PREFIX)
         ? { text, attachments: pending }
         : args.ingest(text, pending),
   });

src/tui/runner/submit.ts

@@ -37,6 +37,7 @@ import type { InferenceAttemptIdentity } from "./state.js";
 import { tuiSendFailureMessage } from "./send-failure-message.js";
 import type { ProviderFailureAttempt } from "../provider/failure-attempt.js";
 import type { Agent } from "@intx/agent";
+import { ASK_DIRECTOR_WAKE_PREFIX } from "../../subagent/fleet-report.js";
 import { hostOf, type RunnerServices, type RunnerState } from "./state.js";
 import { LOG_NAMESPACE_ROOT } from "../../branding.js";
 
@@ -351,7 +352,7 @@ export function createDeliverRouting(
       },
       recordSent: (text) => {
         if (text.trim().length === 0) return;
-        if (text.startsWith("ask_director wake")) return;
+        if (text.startsWith(ASK_DIRECTOR_WAKE_PREFIX)) return;
         void appendSentMessage(state.config.cwd, state.sessionId, text).catch((err: unknown) => {
           tuiLogger.debug("sent-message append failed: {error}", {
             error: err instanceof Error ? err.message : String(err),