feat(canvas): experimental thread/feed/inbox tweaks

- Remove the "Create PR"/"Draft PR" ship actions from the open thread's
  agent row (the status chip still reflects PR/ship state).
- Feed task card now agrees with the thread: a settled live session
  downgrades a stale non-terminal cloud run status to "Ready" instead of
  a lingering "In progress".
- Add a placeholder "Inbox" tab to the channel tab strip with a live
  pipeline-report count badge (no destination yet; clicking is a no-op).
- Minor spacing/mention-link tweaks in the feed and mention rendering.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: adamleithp

packages/ui/src/features/canvas/components/ChannelFeedView.tsx

@@ -60,6 +60,7 @@ import { useChannelTaskData } from "@posthog/ui/features/canvas/hooks/useChannel
 import { useTaskThread } from "@posthog/ui/features/canvas/hooks/useTaskThread";
 import { useThreadPanelStore } from "@posthog/ui/features/canvas/stores/threadPanelStore";
 import { userDisplayName } from "@posthog/ui/features/canvas/utils/userDisplay";
+import { useSessionSelector } from "@posthog/ui/features/sessions/useSession";
 import {
   type SidebarPrState,
   useTaskPrStatus,
@@ -176,6 +177,20 @@ interface TaskStatusDisplay {
 // deliberate end state we should not soften with a PR.
 function useTaskStatusDisplay(task: Task): TaskStatusDisplay {
   const data = useChannelTaskData(task);
+  // A cloud run's status lingers on "in_progress" after the agent yields its
+  // turn — the same staleness the thread's "Ready to ship" sidesteps by reading
+  // the live session instead. Once the local session has produced output and
+  // settled (not generating, not blocked on a permission), trust that the agent
+  // has finished so the card and the thread agree. Gated on real activity so a
+  // not-yet-started task (empty session) isn't mislabeled "Ready".
+  const agentSettledAfterRun = useSessionSelector(
+    task.id,
+    (s) =>
+      !!s &&
+      (s.events?.length ?? 0) > 0 &&
+      !s.isPromptPending &&
+      (s.pendingPermissions?.size ?? 0) === 0,
+  );
   const { prState } = useTaskPrStatus({
     id: task.id,
     cloudPrUrl: data?.cloudPrUrl ?? null,
@@ -215,7 +230,12 @@ function useTaskStatusDisplay(task: Task): TaskStatusDisplay {
   } else if (!status) {
     base = <Badge>Draft</Badge>;
   } else if (environment === "cloud" || isTerminalStatus(status)) {
-    base = statusBadge(status);
+    // Prefer the settled live session over a stale non-terminal cloud status, so
+    // a finished run reads "Ready" instead of a lingering "In progress". Never
+    // softens a terminal status (a failed run stays failed).
+    const effective =
+      agentSettledAfterRun && !isTerminalStatus(status) ? "completed" : status;
+    base = statusBadge(effective);
   } else {
     // Local, non-terminal: the run status is unreliable (the backend row stays
     // "queued" while the agent runs on the creator's machine), so we render no
@@ -403,7 +423,7 @@ const FeedItem = memo(function FeedItem({
   onOpenThread: (task: Task) => void;
 }) {
   return (
-    <ThreadItem className="rounded-none py-1 pr-8 hover:bg-fill-hover/50">
+    <ThreadItem className="rounded-none py-1 pr-8 pl-0 hover:bg-fill-hover/50">
       <ThreadItemGutter>
         <Avatar>
           <AvatarFallback>

packages/ui/src/features/canvas/components/ChannelTabs.tsx

@@ -1,6 +1,8 @@
-import { Button, cn } from "@posthog/quill";
+import { INBOX_PIPELINE_STATUS_FILTER } from "@posthog/core/inbox/reportFiltering";
+import { Badge, Button, cn } from "@posthog/quill";
 import { CHANNEL_SECTIONS } from "@posthog/ui/features/canvas/channelSections";
 import { ChannelPinnedMenu } from "@posthog/ui/features/canvas/components/ChannelPinnedMenu";
+import { useInboxReports } from "@posthog/ui/features/inbox/hooks/useInboxReports";
 import { Link, useRouterState } from "@tanstack/react-router";
 
 const TABS = CHANNEL_SECTIONS.map((s) => ({
@@ -13,9 +15,27 @@ const TABS = CHANNEL_SECTIONS.map((s) => ({
 // codebase's convention) rather than Link's activeProps.
 export function ChannelTabs({ channelId }: { channelId: string }) {
   const pathname = useRouterState({ select: (s) => s.location.pathname });
+  // Live report count for the Inbox tab's badge — pipeline reports still needing
+  // attention (the same status set the real Inbox badges), not every report ever
+  // (which includes resolved/suppressed history). A cheap `limit: 1` count query
+  // returns the real total without pulling the list. The tab itself is a
+  // placeholder (no destination yet) — clicking is a no-op.
+  const { data: inbox } = useInboxReports({
+    status: INBOX_PIPELINE_STATUS_FILTER,
+    limit: 1,
+  });
+  const inboxCount = inbox?.count ?? 0;
 
   return (
     <nav className="flex items-center gap-px">
+      <Button type="button" variant="default" size="sm">
+        Inbox
+        {inboxCount > 0 && (
+          <Badge variant="info" className="ms-0.5">
+            {inboxCount}
+          </Badge>
+        )}
+      </Button>
       {TABS.map((tab) => {
         const href = tab.to.replace("$channelId", channelId);
         const active = pathname === href;

packages/ui/src/features/canvas/components/ChannelsList.tsx

@@ -633,7 +633,7 @@ export function ChannelsList() {
               open={starredOpen}
               onOpenChange={setStarredOpen}
             >
-              <div className="pl-2">
+              <div>
                 {starred.map((channel) => (
                   <ChannelSection key={channel.id} channel={channel} />
                 ))}

packages/ui/src/features/canvas/components/MentionText.tsx

@@ -102,7 +102,7 @@ export function MentionText({
   }, [content, markdownLinks]);
   const selfEmail = currentUserEmail?.toLowerCase();
   const router = useRouter();
-  const linkClass = "bg-info/50 px-0.5 rounded-xs";
+  const linkClass = "bg-info/50 px-0.5 rounded-xs hover:bg-info/80";
   return (
     <Text size="1" className={className}>
       {segments.map(({ segment, key }) => {

packages/ui/src/features/canvas/components/ThreadPanel.tsx

@@ -2,7 +2,6 @@ import {
   ArrowSquareOutIcon,
   CaretRightIcon,
   DotsThreeIcon,
-  GitPullRequestIcon,
   PaperPlaneRightIcon,
   RobotIcon,
   TrashIcon,
@@ -235,25 +234,17 @@ function AgentStatusChip({ status }: { status: AgentStatus }) {
 
 // One agent turn as its own thread item — a full avatar/"Agent" header row with
 // a timestamp, the turn's final message, and (on the current turn) the live
-// status chip plus ship actions. The live turn's bubble streams; settled turns
-// render static and stay put as new turns arrive below.
+// status chip. The live turn's bubble streams; settled turns render static and
+// stay put as new turns arrive below.
 function AgentTurnRow({
   message,
   status,
   streaming,
-  showActions,
-  hasPr,
-  onCreatePr,
-  onDraftPr,
 }: {
   message?: AgentMessage;
   /** The live status chip; only the current turn passes one. */
   status?: AgentStatus;
   streaming: boolean;
-  showActions: boolean;
-  hasPr: boolean;
-  onCreatePr: () => void;
-  onDraftPr: () => void;
 }) {
   return (
     <ThreadItem>
@@ -283,17 +274,6 @@ function AgentTurnRow({
             </div>
           </ThreadItemBody>
         )}
-        {showActions && !hasPr && (
-          <div className="pbs-1 flex flex-wrap items-center gap-1.5">
-            <Button variant="primary" size="sm" onClick={onCreatePr}>
-              <GitPullRequestIcon size={13} />
-              Create PR
-            </Button>
-            <Button variant="outline" size="sm" onClick={onDraftPr}>
-              Draft PR
-            </Button>
-          </div>
-        )}
       </ThreadItemContent>
     </ThreadItem>
   );
@@ -411,7 +391,7 @@ function ThreadConversation({
   useSessionConnection({ taskId, task, session, repoPath, isCloud });
   const { items } = useConversationItems(events, isPromptPending);
   const pendingPermissions = usePendingPermissionsForTask(taskId);
-  const { handleSendPrompt } = useSessionCallbacks({
+  useSessionCallbacks({
     taskId,
     task,
     session,
@@ -455,22 +435,6 @@ function ThreadConversation({
     prUrl,
   ]);
 
-  // Shipping a PR from a channel thread means asking the agent to open it — the
-  // uniform path that works for cloud and local runs alike (the agent owns the
-  // branch/commit). Re-engages the session, so the status flips back to active.
-  const askAgentToOpenPr = (draftPr: boolean) => {
-    void handleSendPrompt(
-      draftPr
-        ? "Create a draft pull request with these changes."
-        : "Create a pull request with these changes.",
-    );
-    toast.success(
-      draftPr
-        ? "Asked the agent to open a draft PR"
-        : "Asked the agent to open a PR",
-    );
-  };
-
   // User prompts, human thread messages, and agent turns woven into one
   // chronological list. Ties keep insertion order (prompts, then humans, then
   // agents); an agent turn with no timestamp yet (just started, still streaming)
@@ -661,10 +625,6 @@ function ThreadConversation({
                     row.message.id === lastAgentId &&
                     agentStatus?.phase === "active"
                   }
-                  showActions={false}
-                  hasPr={!!prUrl}
-                  onCreatePr={() => askAgentToOpenPr(false)}
-                  onDraftPr={() => askAgentToOpenPr(true)}
                 />
               ),
             )}
@@ -674,14 +634,7 @@ function ThreadConversation({
                 PR" action above it, out of view. Once a PR exists the agent's
                 "Done" message already reflects it, so the footer is dropped. */}
             {agentStatus && !(agentStatus.phase === "complete" && !!prUrl) && (
-              <AgentTurnRow
-                status={agentStatus}
-                streaming={false}
-                showActions={agentStatus.phase === "complete"}
-                hasPr={!!prUrl}
-                onCreatePr={() => askAgentToOpenPr(false)}
-                onDraftPr={() => askAgentToOpenPr(true)}
-              />
+              <AgentTurnRow status={agentStatus} streaming={false} />
             )}
           </ThreadItemGroup>
         )}