huangruiteng · Oct 16, 2026 · Oct 16, 2026 · Oct 16, 2026 · Oct 16, 2026 · Oct 16, 2026
@@ -54,6 +54,12 @@
 .attached-conversation-messages summary > time {margin-left: 8px;}
 .attached-tool-metadata {font-size: var(--text-caption); margin-top: 8px;}
 .attached-conversation-messages .attached-tool-source {font-size: var(--text-caption);}
+.attached-conversation-messages strong:has(> .attached-activity-mark) {display: inline-flex; align-items: center; gap: 8px;}
+.attached-activity-mark {position: relative; display: inline-block; flex: 0 0 12px; width: 12px; height: 12px; border: 1px solid var(--pw-muted); border-radius: 50%; color: var(--pw-blue-ink);}
+.attached-activity-mark[data-active] {border-color: color-mix(in srgb, currentColor 28%, transparent);}
+.attached-activity-mark[data-active]::before {content: ""; position: absolute; inset: 3px; border-radius: 50%; background: currentColor;}
+.attached-activity-mark[data-active]::after {content: ""; position: absolute; inset: -1px; border: 1px solid transparent; border-top-color: currentColor; border-radius: 50%; animation: pw-spin 1s linear infinite;}
+@media (prefers-reduced-motion: reduce) {.attached-activity-mark[data-active]::after {animation: none;}}
 @media (max-width: 640px) {
   .goal-agent-work-page form {flex-wrap: wrap;}
   .goal-agent-work-page form label {flex-basis: 100%;}

@@ -6,6 +6,9 @@ type Binding = {agent_id: string; thread_id: string; binding_ref: string};
 type Message = ConversationRecord;
 type Snapshot = {messages?: Message[]; before?: number | null; after?: number; has_more?: boolean; reset?: boolean; source_ref?: string; history_size?: number; revision: string; unchanged?: boolean; connected?: boolean; can_reply?: boolean; activity: {state: string}};
 type Submission = {operation_id: string; text: string; status?: string};
+type LiveRecords = {identity: string; records: Message[]};
+type LiveObservation = {kind: "records"; revision: number; records: Message[]} |
+  {kind: "unavailable"; retry: boolean};
 
 class ConversationRequestError extends Error {
   constructor(message: string, readonly unsubmittedOperation?: string, readonly httpStatus?: number) {super(message);}
@@ -95,6 +98,9 @@ export function AttachedAgentConversations({goalId, zh, targetAgentId}: {
   const [refresh, setRefresh] = useState(0);
   const [readingHistory, setReadingHistory] = useState(false);
   const [unread, setUnread] = useState(false);
+  const [liveView, setLiveView] = useState<LiveRecords>({identity: "", records: []});
+  const [liveUnavailable, setLiveUnavailable] = useState(false);
+  const latestLive = useRef<LiveRecords>({identity: "", records: []});
   const following = useRef(true);
   const after = useRef<number | null>(null);
   const historyEpoch = useRef(0);
@@ -108,8 +114,41 @@ export function AttachedAgentConversations({goalId, zh, targetAgentId}: {
   const binding = agents.find(agent => agent.agent_id === selected);
   const awaitingReceipt = Boolean(submission?.status && submission.status !== "delivered");
   const cacheKey = binding ? `loopx-attached-input:${goalId}:${binding.binding_ref}` : "";
+  const liveEnabled = Boolean(snapshot?.connected && snapshot.activity.state !== "idle");
+  const liveIdentity = `${goalId}:${targetAgentId ?? ""}:${binding?.agent_id ?? ""}:${binding?.binding_ref ?? ""}`;
+  const liveRecords = liveView.identity === liveIdentity ? liveView.records : [];
+  // Frozen history is still readable, but must not look like current work.
+  // Connection/registration alone is never an activity observation.
+  const liveActive = liveEnabled && !liveUnavailable && !readingHistory;
   const query = binding ? new URLSearchParams({goal_id: goalId, agent_id: binding.agent_id, binding_ref: binding.binding_ref}) : null;
 
+  useEffect(() => {
+    let active = true;
+    latestLive.current = {identity: "", records: []}; setLiveView(latestLive.current); setLiveUnavailable(false);
+    if (!binding || !liveEnabled) return;
+    const source = new EventSource(`/api/chat/codex-attached/live?${query}`);
+    const unavailable = () => {latestLive.current = {identity: "", records: []}; setLiveView(latestLive.current); setLiveUnavailable(true);};
+    source.addEventListener("observation", event => {
+      if (!active) return;
+      try {
+        const value = JSON.parse((event as MessageEvent<string>).data) as LiveObservation;
+        if (value.kind === "records" && Array.isArray(value.records)) {
+          latestLive.current = {identity: liveIdentity, records: value.records}; setLiveUnavailable(false);
+          if (following.current) {
+            const follow = !transcript.current || transcript.current.scrollHeight - transcript.current.scrollTop - transcript.current.clientHeight < 64;
+            setLiveView(latestLive.current);
+            if (follow) requestAnimationFrame(() => {if (active && following.current) transcript.current?.scrollTo({top: transcript.current.scrollHeight});});
+          } else setUnread(true);
+        } else if (value.kind === "unavailable") {
+          unavailable();
+          if (!value.retry) source.close();
+        } else {source.close(); unavailable();}
+      } catch {source.close(); unavailable();}
+    });
+    source.onerror = () => {if (active) unavailable();};
+    return () => {active = false; source.close();};
+  }, [liveIdentity, liveEnabled]);
+
   useEffect(() => {
     let active = true;
     let timer: ReturnType<typeof setTimeout>;
@@ -173,7 +212,7 @@ export function AttachedAgentConversations({goalId, zh, targetAgentId}: {
               if (combined.length > 300) setBefore(Number(combined[combined.length - 300].id));
               return combined.slice(-300);
             });
-            if (reset) {setBefore(next.before ?? null); following.current = true; setReadingHistory(false); setUnread(false);}
+            if (reset) {setBefore(next.before ?? null); resumeFollowing();}
           } else setUnread(true);
         }
         setSnapshot(previous => ({...previous, ...next})); setError("");
@@ -223,17 +262,24 @@ export function AttachedAgentConversations({goalId, zh, targetAgentId}: {
           return retained;
         });
         if (!newer) requestAnimationFrame(() => {if (transcript.current) transcript.current.scrollTop += transcript.current.scrollHeight - previousHeight;});
-        if (newer && !next.has_more) {following.current = true; setReadingHistory(false); setUnread(false);}
+        if (newer && !next.has_more) resumeFollowing();
         setError("");
       }
     } catch (failure) {if (current === generation.current) setError(String(failure));}
     finally {if (current === generation.current) setLoadingOlder(false);}
   }
 
+  // Every path that returns to the live tail publishes the buffered projection.
+  // Resuming while keeping the frozen draft would show stale work as current.
+  function resumeFollowing() {
+    following.current = true; setReadingHistory(false); setUnread(false);
+    setLiveView(latestLive.current);
+  }
   function pauseHistory() {following.current = false; setReadingHistory(true);}
   function latest() {
     historyEpoch.current++; after.current = null; history.current = null; revision.current = "";
-    following.current = true; setReadingHistory(false); setUnread(false); setMessages([]); setBefore(null);
+    setMessages([]); setBefore(null);
+    resumeFollowing();
   }
   async function loadContent(record: Message, offset: number): Promise<ContentPage> {
     const params = new URLSearchParams(query!);
@@ -307,16 +353,20 @@ export function AttachedAgentConversations({goalId, zh, targetAgentId}: {
       {error ? <p role="alert">{error} <button type="button" onClick={() => setRefresh(value => value + 1)}>{zh ? "重新连接" : "Reconnect"}</button></p> : null}
       {sendNotice ? <p role="status">{sendNotice}</p> : null}
       {binding ? <>
-        <div className="attached-connection-status"><div><p className="attached-conversation-source">{zh ? "Codex App · 已保存消息与工具记录自动更新" : "Codex App · saved messages and tools update automatically"}</p><p role="status">{!snapshot ? (zh ? "正在连接或连接不可用" : "Connecting or unavailable") : snapshot.can_reply ? (zh ? "原会话可回复" : "Original conversation accepts replies") : snapshot.activity.state === "turn_open" ? (zh ? "原会话有未结束执行；可在原 App 中追加输入" : "The original conversation has an unfinished turn; add input in the original App") : (zh ? "历史可读；回复连接或执行状态尚未确认" : "History available; reply connection or execution state unconfirmed")}</p></div>
+        <div className="attached-connection-status"><div><p className="attached-conversation-source" title={zh ? "已保存消息与工具记录自动更新；实时内容来自原宿主。" : "Saved messages and tools update automatically; live content comes from the original host."}>Codex App</p><p role="status">{!snapshot ? (zh ? "正在连接或连接不可用" : "Connecting or unavailable") : snapshot.can_reply ? (zh ? "原会话可回复" : "Original conversation accepts replies") : snapshot.activity.state === "turn_open" ? (zh ? "原会话有未结束执行；可在原 App 中追加输入" : "The original conversation has an unfinished turn; add input in the original App") : (zh ? "历史可读；回复连接或执行状态尚未确认" : "History available; reply connection or execution state unconfirmed")}</p></div>
         <button type="button" className="attached-conversation-open" aria-disabled={opening} aria-busy={opening} onClick={() => void openOriginal()}>{zh ? "在 Codex App 中打开" : "Open in Codex App"}</button></div>
         {openRequested ? <p role="status">{zh ? "已请求打开原会话，请在 Codex App 中查看。" : "Requested opening the original conversation; check Codex App."}</p> : null}
         {openError ? <p role="alert">{openError}</p> : null}
         {before !== null ? <button type="button" disabled={loadingOlder} onClick={() => void older()}>{zh ? "读取更早的消息" : "Read earlier messages"}</button> : null}
         {readingHistory ? <div className="attached-history-navigation"><span>{zh ? "正在回看历史" : "Reading history"}{unread ? (zh ? " · 有新活动" : " · new activity") : ""}</span><button type="button" disabled={loadingOlder} onClick={() => void older(true)}>{zh ? "较新记录" : "Newer records"}</button><button type="button" onClick={latest}>{zh ? "回到最新" : "Back to latest"}</button></div> : null}
         <div className="attached-conversation-messages" ref={transcript} onWheel={event => {if (event.deltaY < 0) pauseHistory();}} onTouchMove={pauseHistory} onClick={pauseHistory} onKeyDown={event => {if (["ArrowUp", "PageUp", "Home"].includes(event.key)) pauseHistory();}} aria-label={zh ? "原会话消息" : "Original conversation messages"}>
           {messages.map(message => <AttachedConversationRecord key={`${history.current?.source}:${message.id}:${message.content_ref ?? ""}`} record={message} agent={binding.agent_id} zh={zh} load={loadContent}/>)}
-          {!messages.length && snapshot ? <p>{zh ? "当前有界历史窗口内没有可显示的消息，可读取更早记录。" : "No displayable messages in this bounded window; read earlier records."}</p> : null}
+          {liveRecords.length ? <div aria-label={zh ? "原宿主实时记录" : "Original host live records"}>
+            {liveRecords.map(record => <AttachedConversationRecord key={record.id} record={record} agent={binding.agent_id} zh={zh} load={loadContent} live active={liveActive}/>)}
+          </div> : null}
+          {!messages.length && !liveRecords.length && snapshot ? <p>{zh ? "当前有界历史窗口内没有可显示的消息，可读取更早记录。" : "No displayable messages in this bounded window; read earlier records."}</p> : null}
         </div>
+        {liveUnavailable ? <p role="status">{zh ? "实时观察暂不可用，已保存的消息与工具记录仍会自动更新。" : "Live observation is unavailable; saved messages and tools still update automatically."}</p> : null}
         {submission?.status ? <p role="status">{submission.status === "delivered" ? (zh ? "已由原 App 接纳；等待 Agent 结果。" : "Accepted by the original App; awaiting the Agent result.") : (zh ? "投递尚未确认，请先在原 App 核对，不会自动重发。" : "Delivery unconfirmed; check the original App. No automatic resend.")} {submission.status === "pending" ? <button type="button" disabled={sending} onClick={() => void readReceipt()}>{zh ? "重读投递回执" : "Recheck delivery receipt"}</button> : null}{awaitingReceipt ? <button type="button" disabled={sending} onClick={nextReply}>{zh ? "已核对，写下一条" : "Checked; write another"}</button> : null}</p> : null}
         {!awaitingReceipt ? <form onSubmit={event => {event.preventDefault(); void send();}}><label>{zh ? `回复 ${binding.agent_id}` : `Reply to ${binding.agent_id}`}<textarea value={draft} maxLength={24000} disabled={sending} onChange={event => editDraft(event.target.value)}/></label><button type="submit" disabled={sending || Boolean(error || recoveryError) || !snapshot?.can_reply || !draft.trim()}>{sending ? (zh ? "正在交给原 App…" : "Sending to original App…") : (zh ? "发送到原会话" : "Send to original conversation")}</button></form> : null}
       </> : null}

@@ -30,11 +30,14 @@ function ToolContent({text, complete, zh}: {text: string; complete: boolean; zh:
   return <pre>{text}</pre>;
 }
 
-export function AttachedConversationRecord({record, agent, zh, load}: {
+export function AttachedConversationRecord({record, agent, zh, load, live = false, active = false}: {
   record: ConversationRecord; agent: string; zh: boolean;
   load: (record: ConversationRecord, offset: number) => Promise<ContentPage>;
+  live?: boolean;
+  active?: boolean;
 }) {
-  const [text, setText] = useState(record.text);
+  const [storedText, setText] = useState(record.text);
+  const text = live ? record.text : storedText;
   const [more, setMore] = useState(record.truncated);
   const [loading, setLoading] = useState(false);
   const [error, setError] = useState("");
@@ -48,7 +51,8 @@ export function AttachedConversationRecord({record, agent, zh, load}: {
     function_call: "Tool call", custom_tool_call: "Tool call",
     function_call_output: "Tool result", custom_tool_call_output: "Tool result",
   };
-  const title = record.role === "user" ? (zh ? "你" : "You") : record.role === "assistant" ? agent :
+  const title = live && record.role === "tool" ? record.label :
+    record.role === "user" ? (zh ? "你" : "You") : record.role === "assistant" ? agent :
     `${labels[record.kind] ?? (zh ? "记录暂不可读" : "Record unavailable")}${record.label && record.label !== record.kind ? ` · ${record.label}` : ""}`;
   async function continueReading() {
     if (loading) return;
@@ -64,7 +68,8 @@ export function AttachedConversationRecord({record, agent, zh, load}: {
     {more ? <button type="button" disabled={loading} onClick={() => void continueReading()}>{loading ? (zh ? "正在读取…" : "Loading…") : (zh ? "继续读取完整内容" : "Read more of this record")}</button> : null}
     {error ? <p role="alert">{error}</p> : null}
   </>;
-  const heading = <><strong>{title}</strong>{record.timestamp ? <time>{new Date(record.timestamp).toLocaleString()}</time> : null}</>;
+  const activityLabel = active ? (zh ? "原宿主执行中" : "Work observed in the original host") : (zh ? "回看的原宿主记录" : "Previously observed host record");
+  const heading = <><strong>{live && record.role !== "activity" ? <span className="attached-activity-mark" data-active={active || undefined} role="img" aria-label={activityLabel} title={activityLabel}/> : null}{title}</strong>{record.timestamp ? <time>{new Date(record.timestamp).toLocaleString()}</time> : null}</>;
   return <article data-role={record.role} data-record-id={record.id}>
     {record.role !== "tool" ? <header>{heading}</header> : null}
     {record.unavailable ? <p>{zh ? "源记录无法安全读取；此处保留缺口，未将其当作完成。" : "This source record could not be read safely. The gap is retained, not treated as completion."}</p> :

@@ -1040,8 +1040,14 @@ and Back/Forward and showing unbound or unsupported hosts explicitly. The
 ordinary Goal composer/executor is absent in this view. This first provider does
 not establish other-provider coverage or complete native activity/stream parity.
 See the [provider boundary and operation](../../integrations/session-runtime-control-plane-adapter.md#experimental-owner-local-codex-app-conversations).
+A bounded live-observation companion now follows the original Desktop owner's
+versioned snapshot/patch stream while the host is not observed idle. Supported
+unfinished visible messages/tools update in the same Agent reader, with paused
+history insertion and saved-record fallback. Exact owner/binding, revisions,
+private-content exclusion and bounded data remain enforced; no executor or
+approval authority is added. See the same provider operation guide for limits.
 This is an experimental provider proposal, not full Slice B acceptance:
-token deltas, busy-turn steering/queueing, approval callbacks, native live-send
+complete native event/token parity, busy-turn steering/queueing, approval callbacks, native live-send
 qualification, Windows transport and installed adoption remain separate gaps.
 Its bounded user task is following up with a specific Agent while reviewing
 Goal work. Confirmed input leaves the composer ready without a redundant