feat(cloud): cloud task rendering

chore: better pagination slurp

chore: log writer flush

chore: cleaner

chore: cleaner

Author: tatoalo

apps/twig/src/api/posthogClient.ts

@@ -354,7 +354,7 @@ export class PostHogAPIClient {
           task_id: taskId,
           id: runId,
         },
-        body: updates,
+        body: updates as Record<string, unknown>,
       },
     );
     return data as unknown as TaskRun;
@@ -383,6 +383,40 @@ export class PostHogAPIClient {
     }
   }
 
+  async getTaskRunSessionLogs(
+    taskId: string,
+    runId: string,
+    options?: { limit?: number; after?: string },
+  ): Promise<StoredLogEntry[]> {
+    try {
+      const teamId = await this.getTeamId();
+      const url = new URL(
+        `${this.api.baseUrl}/api/projects/${teamId}/tasks/${taskId}/runs/${runId}/session_logs/`,
+      );
+      url.searchParams.set("limit", String(options?.limit ?? 5000));
+      if (options?.after) {
+        url.searchParams.set("after", options.after);
+      }
+      const response = await this.api.fetcher.fetch({
+        method: "get",
+        url,
+        path: `/api/projects/${teamId}/tasks/${taskId}/runs/${runId}/session_logs/`,
+      });
+
+      if (!response.ok) {
+        log.warn(
+          `Failed to fetch session logs: ${response.status} ${response.statusText}`,
+        );
+        return [];
+      }
+
+      return (await response.json()) as StoredLogEntry[];
+    } catch (err) {
+      log.warn("Failed to fetch task run session logs", err);
+      return [];
+    }
+  }
+
   async getTaskLogs(taskId: string): Promise<StoredLogEntry[]> {
     try {
       const task = (await this.getTask(taskId)) as unknown as Task;

apps/twig/src/main/services/git/schemas.ts

@@ -282,6 +282,12 @@ export type GetCommitConventionsOutput = z.infer<
   typeof getCommitConventionsOutput
 >;
 
+// getPrChangedFiles schemas
+export const getPrChangedFilesInput = z.object({
+  prUrl: z.string(),
+});
+export const getPrChangedFilesOutput = z.array(changedFileSchema);
+
 export const generateCommitMessageInput = z.object({
   directoryPath: z.string(),
   credentials: z.object({

apps/twig/src/main/services/git/service.test.ts

@@ -0,0 +1,127 @@
+import { beforeEach, describe, expect, it, vi } from "vitest";
+
+const mockExecGh = vi.hoisted(() => vi.fn());
+
+vi.mock("@twig/git/gh", () => ({
+  execGh: mockExecGh,
+}));
+
+vi.mock("../../lib/logger.js", () => ({
+  logger: {
+    scope: () => ({
+      info: vi.fn(),
+      warn: vi.fn(),
+      error: vi.fn(),
+      debug: vi.fn(),
+    }),
+  },
+}));
+
+import type { LlmGatewayService } from "../llm-gateway/service.js";
+import { GitService } from "./service.js";
+
+describe("GitService.getPrChangedFiles", () => {
+  let service: GitService;
+
+  beforeEach(() => {
+    vi.clearAllMocks();
+    service = new GitService({} as LlmGatewayService);
+  });
+
+  it("flattens paginated GH API results and maps file statuses", async () => {
+    mockExecGh.mockResolvedValue({
+      exitCode: 0,
+      stdout: JSON.stringify([
+        [
+          {
+            filename: "src/new.ts",
+            status: "added",
+            additions: 10,
+            deletions: 0,
+          },
+          {
+            filename: "src/old.ts",
+            status: "removed",
+            additions: 0,
+            deletions: 3,
+          },
+        ],
+        [
+          {
+            filename: "src/renamed-new.ts",
+            status: "renamed",
+            previous_filename: "src/renamed-old.ts",
+            additions: 1,
+            deletions: 1,
+          },
+          {
+            filename: "src/changed.ts",
+            status: "changed",
+            additions: 4,
+            deletions: 2,
+          },
+        ],
+      ]),
+    });
+
+    const result = await service.getPrChangedFiles(
+      "https://github.com/posthog/twig/pull/123",
+    );
+
+    expect(mockExecGh).toHaveBeenCalledWith([
+      "api",
+      "repos/posthog/twig/pulls/123/files",
+      "--paginate",
+      "--slurp",
+    ]);
+
+    expect(result).toEqual([
+      {
+        path: "src/new.ts",
+        status: "added",
+        originalPath: undefined,
+        linesAdded: 10,
+        linesRemoved: 0,
+      },
+      {
+        path: "src/old.ts",
+        status: "deleted",
+        originalPath: undefined,
+        linesAdded: 0,
+        linesRemoved: 3,
+      },
+      {
+        path: "src/renamed-new.ts",
+        status: "renamed",
+        originalPath: "src/renamed-old.ts",
+        linesAdded: 1,
+        linesRemoved: 1,
+      },
+      {
+        path: "src/changed.ts",
+        status: "modified",
+        originalPath: undefined,
+        linesAdded: 4,
+        linesRemoved: 2,
+      },
+    ]);
+  });
+
+  it("returns empty array for non-GitHub PR URL", async () => {
+    const result = await service.getPrChangedFiles(
+      "https://example.com/pull/1",
+    );
+    expect(result).toEqual([]);
+    expect(mockExecGh).not.toHaveBeenCalled();
+  });
+
+  it("returns empty array when gh command fails", async () => {
+    mockExecGh.mockResolvedValue({ exitCode: 1, stdout: "" });
+
+    const result = await service.getPrChangedFiles(
+      "https://github.com/posthog/twig/pull/123",
+    );
+
+    expect(result).toEqual([]);
+  });
+});

apps/twig/src/main/services/git/service.ts

@@ -667,6 +667,64 @@ export class GitService extends TypedEventEmitter<GitServiceEvents> {
     return { success: !!prUrl, message: prUrl ? "OK" : "No PR found", prUrl };
   }
 
+  public async getPrChangedFiles(prUrl: string): Promise<ChangedFile[]> {
+    const match = prUrl.match(/github\.com\/([^/]+)\/([^/]+)\/pull\/(\d+)/);
+    if (!match) return [];
+
+    const [, owner, repo, number] = match;
+
+    try {
+      const result = await execGh([
+        "api",
+        `repos/${owner}/${repo}/pulls/${number}/files`,
+        "--paginate",
+        "--slurp",
+      ]);
+
+      if (result.exitCode !== 0) return [];
+
+      const pages = JSON.parse(result.stdout) as Array<
+        Array<{
+          filename: string;
+          status: string;
+          previous_filename?: string;
+          additions: number;
+          deletions: number;
+        }>
+      >;
+      const files = pages.flat();
+
+      return files.map((f) => {
+        let status: ChangedFile["status"];
+        switch (f.status) {
+          case "added":
+            status = "added";
+            break;
+          case "removed":
+            status = "deleted";
+            break;
+          case "renamed":
+            status = "renamed";
+            break;
+          default:
+            status = "modified";
+            break;
+        }
+
+        return {
+          path: f.filename,
+          status,
+          originalPath: f.previous_filename,
+          linesAdded: f.additions,
+          linesRemoved: f.deletions,
+        };
+      });
+    } catch (error) {
+      log.warn("Failed to fetch PR changed files", { prUrl, error });
+      return [];
+    }
+  }
+
   public async generateCommitMessage(
     directoryPath: string,
     credentials: LlmCredentials,

apps/twig/src/main/trpc/routers/git.ts

@@ -36,6 +36,8 @@ import {
   getGitSyncStatusOutput,
   getLatestCommitInput,
   getLatestCommitOutput,
+  getPrChangedFilesInput,
+  getPrChangedFilesOutput,
   getPrTemplateInput,
   getPrTemplateOutput,
   ghStatusOutput,
@@ -254,6 +256,11 @@ export const gitRouter = router({
       getService().getCommitConventions(input.directoryPath, input.sampleSize),
     ),
 
+  getPrChangedFiles: publicProcedure
+    .input(getPrChangedFilesInput)
+    .output(getPrChangedFilesOutput)
+    .query(({ input }) => getService().getPrChangedFiles(input.prUrl)),
+
   generateCommitMessage: publicProcedure
     .input(generateCommitMessageInput)
     .output(generateCommitMessageOutput)

apps/twig/src/renderer/components/HeaderRow.tsx

@@ -3,6 +3,7 @@ import { RightSidebarTrigger } from "@features/right-sidebar/components/RightSid
 import { useRightSidebarStore } from "@features/right-sidebar/stores/rightSidebarStore";
 import { SidebarTrigger } from "@features/sidebar/components/SidebarTrigger";
 import { useSidebarStore } from "@features/sidebar/stores/sidebarStore";
+import { useWorkspaceStore } from "@features/workspace/stores/workspaceStore";
 import { Box, Flex } from "@radix-ui/themes";
 import { useHeaderStore } from "@stores/headerStore";
 import { useNavigationStore } from "@stores/navigationStore";
@@ -28,6 +29,11 @@ export function HeaderRow() {
     (state) => state.setIsResizing,
   );
 
+  const activeTaskId = view.type === "task-detail" ? view.data?.id : undefined;
+  const activeWorkspace = useWorkspaceStore((s) =>
+    activeTaskId ? s.workspaces[activeTaskId] : undefined,
+  );
+  const isCloudTask = activeWorkspace?.mode === "cloud";
   const showRightSidebarSection = view.type === "task-detail";
 
   const handleLeftSidebarMouseDown = (e: React.MouseEvent) => {
@@ -119,7 +125,7 @@ export function HeaderRow() {
           }}
         >
           <RightSidebarTrigger />
-          <GitInteractionHeader taskId={view.data.id} />
+          {!isCloudTask && <GitInteractionHeader taskId={view.data.id} />}
           {rightSidebarOpen && (
             <Box
               onMouseDown={handleRightSidebarMouseDown}

apps/twig/src/renderer/features/git-interaction/hooks/useGitQueries.ts

@@ -1,4 +1,5 @@
 import { trpcVanilla } from "@renderer/trpc";
+import type { ChangedFile } from "@shared/types";
 import { useQuery } from "@tanstack/react-query";
 
 const EMPTY_DIFF_STATS = { filesChanged: 0, linesAdded: 0, linesRemoved: 0 };
@@ -121,3 +122,16 @@ export function useGitQueries(repoPath?: string) {
     isLoading: isRepoLoading || changesLoading || syncLoading,
   };
 }
+
+const EMPTY_FILES: ChangedFile[] = [];
+
+export function useCloudPrChangedFiles(prUrl: string | null) {
+  return useQuery({
+    queryKey: ["pr-changed-files", prUrl],
+    queryFn: () =>
+      trpcVanilla.git.getPrChangedFiles.query({ prUrl: prUrl as string }),
+    enabled: !!prUrl,
+    staleTime: 5 * 60_000,
+    placeholderData: EMPTY_FILES,
+  });
+}

apps/twig/src/renderer/features/panels/components/LeafNodeRenderer.tsx

@@ -1,5 +1,9 @@
+import { Cloud as CloudIcon } from "@phosphor-icons/react";
+import { Flex, Text } from "@radix-ui/themes";
 import type { Task } from "@shared/types";
 import type React from "react";
+import { useMemo } from "react";
+import { useWorkspaceStore } from "@/renderer/features/workspace/stores/workspaceStore";
 import { useTabInjection } from "../hooks/usePanelLayoutHooks";
 import type { SplitDirection } from "../store/panelLayoutStore";
 import type { LeafPanel } from "../store/panelTypes";
@@ -44,6 +48,29 @@ export const LeafNodeRenderer: React.FC<LeafNodeRendererProps> = ({
     closeTab,
   );
 
+  const workspace = useWorkspaceStore((s) => s.workspaces[taskId]);
+  const isCloud = workspace?.mode === "cloud";
+
+  const cloudEmptyState = useMemo(
+    () =>
+      isCloud ? (
+        <Flex
+          align="center"
+          justify="center"
+          height="100%"
+          style={{ backgroundColor: "var(--gray-2)" }}
+        >
+          <Flex direction="column" align="center" gap="2">
+            <CloudIcon size={24} className="text-gray-10" />
+            <Text size="2" color="gray">
+              Cloud runs are read-only
+            </Text>
+          </Flex>
+        </Flex>
+      ) : undefined,
+    [isCloud],
+  );
+
   const contentWithComponents = {
     ...node.content,
     tabs,
@@ -62,6 +89,7 @@ export const LeafNodeRenderer: React.FC<LeafNodeRendererProps> = ({
       draggingTabPanelId={draggingTabPanelId}
       onAddTerminal={() => onAddTerminal(node.id)}
       onSplitPanel={(direction) => onSplitPanel(node.id, direction)}
+      emptyState={cloudEmptyState}
     />
   );
 };