feat(code): Signals inbox improvements and priority badges

Author: Twixes

apps/code/src/renderer/api/posthogClient.ts

@@ -37,6 +37,8 @@ export interface ExternalDataSourceSchema {
   id: string;
   name: string;
   should_sync: boolean;
+  /** e.g. `full_refresh` (full table replication), `incremental`, `append` */
+  sync_type?: string | null;
 }
 
 export interface ExternalDataSource {
@@ -327,7 +329,7 @@ export class PostHogAPIClient {
   async updateExternalDataSchema(
     projectId: number,
     schemaId: string,
-    updates: { should_sync: boolean },
+    updates: { should_sync: boolean; sync_type?: string },
   ): Promise<void> {
     const urlPath = `/api/projects/${projectId}/external_data_schemas/${schemaId}/`;
     const url = new URL(`${this.api.baseUrl}${urlPath}`);

apps/code/src/renderer/features/inbox/components/DataSourceSetup.tsx

@@ -14,11 +14,14 @@ const REQUIRED_SCHEMAS: Record<DataSourceType, string[]> = {
   zendesk: ["tickets"],
 };
 
+/** PostHog DWH: full table replication (non-incremental); API enum value `full_refresh`. */
+const FULL_TABLE_REPLICATION = "full_refresh" as const;
+
 function schemasPayload(source: DataSourceType) {
   return REQUIRED_SCHEMAS[source].map((name) => ({
     name,
     should_sync: true,
-    sync_type: "full_refresh" as const,
+    sync_type: FULL_TABLE_REPLICATION,
   }));
 }
 
@@ -64,13 +67,20 @@ function GitHubSetup({ onComplete, onCancel }: SetupFormProps) {
   }, [repo, repositories]);
 
   const handleSubmit = useCallback(async () => {
-    if (!projectId || !client || !repo) return;
+    if (!projectId || !client || !repo || !githubIntegration) return;
 
     setLoading(true);
     try {
       await client.createExternalDataSource(projectId, {
         source_type: "Github",
-        payload: { repository: repo, schemas: schemasPayload("github") },
+        payload: {
+          repository: repo,
+          auth_method: {
+            selection: "oauth",
+            github_integration_id: githubIntegration.id,
+          },
+          schemas: schemasPayload("github"),
+        },
       });
       toast.success("GitHub data source created");
       onComplete();
@@ -81,7 +91,7 @@ function GitHubSetup({ onComplete, onCancel }: SetupFormProps) {
     } finally {
       setLoading(false);
     }
-  }, [projectId, client, repo, onComplete]);
+  }, [projectId, client, repo, githubIntegration, onComplete]);
 
   if (!githubIntegration) {
     return (

apps/code/src/renderer/features/inbox/components/InboxLiveRail.tsx

@@ -0,0 +1,30 @@
+interface InboxLiveRailProps {
+  active: boolean;
+}
+
+/**
+ * Thin “instrument” scan line while live polling is active — industrial / lab aesthetic.
+ */
+export function InboxLiveRail({ active }: InboxLiveRailProps) {
+  if (!active) {
+    return null;
+  }
+
+  return (
+    <div
+      className="relative mb-0 h-px w-full overflow-hidden"
+      style={{ background: "var(--gray-5)" }}
+      aria-hidden
+    >
+      <div
+        className="absolute inset-y-0 w-[28%] opacity-95"
+        style={{
+          background:
+            "linear-gradient(90deg, transparent, var(--amber-9), var(--orange-9), transparent)",
+          animation:
+            "inboxLiveRailSweep 2.1s cubic-bezier(0.45, 0, 0.55, 1) infinite",
+        }}
+      />
+    </div>
+  );
+}

apps/code/src/renderer/features/inbox/components/InboxSignalsTab.tsx

@@ -1,5 +1,6 @@
 import { ResizableSidebar } from "@components/ResizableSidebar";
 import { useAuthStore } from "@features/auth/stores/authStore";
+import { InboxLiveRail } from "@features/inbox/components/InboxLiveRail";
 import {
   useInboxReportArtefacts,
   useInboxReportSignals,
@@ -9,10 +10,15 @@ import { useInboxCloudTaskStore } from "@features/inbox/stores/inboxCloudTaskSto
 import { useInboxSignalsFilterStore } from "@features/inbox/stores/inboxSignalsFilterStore";
 import { useInboxSignalsSidebarStore } from "@features/inbox/stores/inboxSignalsSidebarStore";
 import { buildSignalTaskPrompt } from "@features/inbox/utils/buildSignalTaskPrompt";
+import { filterReportsBySearch } from "@features/inbox/utils/filterReports";
 import {
-  buildOrdering,
-  filterReportsBySearch,
-} from "@features/inbox/utils/filterReports";
+  INBOX_PIPELINE_STATUS_FILTER,
+  INBOX_REFETCH_INTERVAL_MS,
+} from "@features/inbox/utils/inboxConstants";
+import {
+  isReportActionable,
+  sortInboxPipelineReports,
+} from "@features/inbox/utils/inboxSort";
 import { useDraftStore } from "@features/message-editor/stores/draftStore";
 import { useCreateTask } from "@features/tasks/hooks/useTasks";
 import { useFeatureFlag } from "@hooks/useFeatureFlag";
@@ -21,7 +27,6 @@ import {
   ArrowSquareOutIcon,
   ClockIcon,
   Cloud as CloudIcon,
-  SparkleIcon,
   XIcon,
 } from "@phosphor-icons/react";
 import {
@@ -40,13 +45,22 @@ import type {
   SignalReportsQueryParams,
 } from "@shared/types";
 import { useNavigationStore } from "@stores/navigationStore";
+import { useRendererWindowFocusStore } from "@stores/rendererWindowFocusStore";
 import { useCallback, useEffect, useMemo, useRef, useState } from "react";
 import { toast } from "sonner";
 import { SignalsErrorState, SignalsLoadingState } from "./InboxEmptyStates";
+import { InboxWarmingUpState } from "./InboxWarmingUpState";
 import { ReportCard } from "./ReportCard";
 import { SignalCard } from "./SignalCard";
+import { SignalReportPriorityBadge } from "./SignalReportPriorityBadge";
+import { SignalReportSummaryMarkdown } from "./SignalReportSummaryMarkdown";
 import { SignalsToolbar } from "./SignalsToolbar";
 
+const INBOX_QUERY_PARAMS: SignalReportsQueryParams = {
+  status: INBOX_PIPELINE_STATUS_FILTER,
+  ordering: "-updated_at",
+};
+
 function getArtefactsUnavailableMessage(
   reason: SignalReportArtefactsResponse["unavailableReason"],
 ): string {
@@ -109,13 +123,9 @@ export function InboxSignalsTab() {
   const sortDirection = useInboxSignalsFilterStore((s) => s.sortDirection);
   const searchQuery = useInboxSignalsFilterStore((s) => s.searchQuery);
 
-  const queryParams = useMemo<SignalReportsQueryParams>(
-    () => ({
-      status: "ready",
-      ordering: buildOrdering(sortField, sortDirection),
-    }),
-    [sortField, sortDirection],
-  );
+  const windowFocused = useRendererWindowFocusStore((s) => s.focused);
+  const isInboxView = useNavigationStore((s) => s.view.type === "inbox");
+  const inboxPollingActive = windowFocused && isInboxView;
 
   const {
     allReports,
@@ -127,10 +137,23 @@ export function InboxSignalsTab() {
     hasNextPage,
     isFetchingNextPage,
     fetchNextPage,
-  } = useInboxReportsInfinite(queryParams);
-  const reports = useMemo(
-    () => filterReportsBySearch(allReports, searchQuery),
-    [allReports, searchQuery],
+  } = useInboxReportsInfinite(INBOX_QUERY_PARAMS, {
+    refetchInterval: inboxPollingActive ? INBOX_REFETCH_INTERVAL_MS : false,
+    refetchIntervalInBackground: false,
+    staleTime: inboxPollingActive ? INBOX_REFETCH_INTERVAL_MS : 12_000,
+  });
+  const reports = useMemo(() => {
+    const searched = filterReportsBySearch(allReports, searchQuery);
+    return sortInboxPipelineReports(searched, sortField, sortDirection);
+  }, [allReports, searchQuery, sortField, sortDirection]);
+
+  const readyCount = useMemo(
+    () => allReports.filter((r) => r.status === "ready").length,
+    [allReports],
+  );
+  const processingCount = useMemo(
+    () => allReports.filter((r) => r.status !== "ready").length,
+    [allReports],
   );
   const [selectedReportId, setSelectedReportId] = useState<string | null>(null);
   const sidebarOpen = useInboxSignalsSidebarStore((state) => state.open);
@@ -185,6 +208,9 @@ export function InboxSignalsTab() {
   });
   const signals = signalsQuery.data?.signals ?? [];
 
+  const canActOnReport =
+    !!selectedReport && isReportActionable(selectedReport.status);
+
   const cloudRegion = useAuthStore((state) => state.cloudRegion);
   const projectId = useAuthStore((state) => state.projectId);
   const replayBaseUrl =
@@ -217,6 +243,9 @@ export function InboxSignalsTab() {
   }, [selectedReport, visibleArtefacts, signals, replayBaseUrl]);
 
   const handleCreateTask = () => {
+    if (!selectedReport || !isReportActionable(selectedReport.status)) {
+      return;
+    }
     const prompt = buildPrompt();
     if (!prompt) return;
 
@@ -230,14 +259,21 @@ export function InboxSignalsTab() {
     openCloudConfirm(repositories[0] ?? null);
   }, [repositories, openCloudConfirm]);
 
+  const selectedReportRef = useRef(selectedReport);
+  selectedReportRef.current = selectedReport;
+
   const handleRunCloudTask = useCallback(async () => {
+    const report = selectedReportRef.current;
+    if (!report || !isReportActionable(report.status)) {
+      return;
+    }
     const prompt = buildPrompt();
     if (!prompt) return;
 
     const result = await runCloudTask({
       prompt,
       githubIntegrationId: githubIntegration?.id,
-      reportId: selectedReport?.id,
+      reportId: report.id,
     });
 
     if (result.success && result.task) {
@@ -251,7 +287,6 @@ export function InboxSignalsTab() {
     runCloudTask,
     invalidateTasks,
     navigateToTask,
-    selectedReport?.id,
     githubIntegration?.id,
   ]);
 
@@ -271,29 +306,7 @@ export function InboxSignalsTab() {
   }
 
   if (allReports.length === 0) {
-    return (
-      <Flex
-        direction="column"
-        align="center"
-        justify="center"
-        gap="3"
-        height="100%"
-        className="text-center"
-      >
-        <SparkleIcon size={24} className="text-gray-8" />
-        <Text size="2" weight="medium" className="font-mono text-[12px]">
-          No signals yet
-        </Text>
-        <Text
-          size="1"
-          color="gray"
-          className="font-mono text-[11px]"
-          style={{ maxWidth: 520 }}
-        >
-          Signals are processing. Check back soon as fresh events arrive.
-        </Text>
-      </Flex>
-    );
+    return <InboxWarmingUpState />;
   }
 
   return (
@@ -305,10 +318,14 @@ export function InboxSignalsTab() {
           style={{ height: "100%" }}
         >
           <Flex direction="column">
+            <InboxLiveRail active={inboxPollingActive} />
             <SignalsToolbar
               totalCount={totalCount}
               filteredCount={reports.length}
               isSearchActive={!!searchQuery.trim()}
+              livePolling={inboxPollingActive}
+              readyCount={readyCount}
+              processingCount={processingCount}
             />
             {reports.length === 0 && searchQuery.trim() ? (
               <Flex
@@ -323,9 +340,10 @@ export function InboxSignalsTab() {
                 </Text>
               </Flex>
             ) : null}
-            {reports.map((report) => (
+            {reports.map((report, index) => (
               <ReportCard
                 key={report.id}
+                index={index}
                 report={report}
                 isSelected={selectedReport?.id === report.id}
                 onClick={() => {
@@ -379,11 +397,12 @@ export function InboxSignalsTab() {
                   <XIcon size={14} />
                 </button>
               </Flex>
-              <Flex align="center" gap="1">
+              <Flex align="center" gap="1" wrap="wrap">
                 <Button
                   size="1"
                   variant="soft"
                   onClick={handleCreateTask}
+                  disabled={!canActOnReport}
                   className="font-mono text-[11px]"
                 >
                   Create task
@@ -393,14 +412,29 @@ export function InboxSignalsTab() {
                     size="1"
                     variant="solid"
                     onClick={handleOpenCloudConfirm}
-                    disabled={isRunningCloudTask || repositories.length === 0}
+                    disabled={
+                      !canActOnReport ||
+                      isRunningCloudTask ||
+                      repositories.length === 0
+                    }
                     className="font-mono text-[11px]"
                   >
                     <CloudIcon size={12} />
                     {isRunningCloudTask ? "Running..." : "Run cloud"}
                   </Button>
                 )}
               </Flex>
+              {!canActOnReport && selectedReport ? (
+                <Text
+                  size="1"
+                  color="gray"
+                  className="font-mono text-[10px] leading-snug"
+                >
+                  {selectedReport.status === "pending_input"
+                    ? "This report needs input in PostHog before an agent can act on it."
+                    : "Research is still running — you can read context below, then create a task when status is Ready."}
+                </Text>
+              ) : null}
             </Flex>
             <ScrollArea
               type="auto"
@@ -409,14 +443,13 @@ export function InboxSignalsTab() {
               style={{ height: "calc(100% - 41px)" }}
             >
               <Flex direction="column" gap="2" p="2" className="min-w-0">
-                <Text
-                  size="1"
-                  color="gray"
-                  className="whitespace-pre-wrap text-pretty break-words font-mono text-[11px]"
-                >
-                  {selectedReport.summary ?? "No summary available."}
-                </Text>
+                <SignalReportSummaryMarkdown
+                  content={selectedReport.summary}
+                  fallback="No summary available."
+                  variant="detail"
+                />
                 <Flex align="center" gap="2" wrap="wrap">
+                  <SignalReportPriorityBadge priority={selectedReport.priority} />
                   <Badge variant="soft" color="gray" size="1">
                     {selectedReport.signal_count} occurrences
                   </Badge>