ditch seperate log entries, everything is an AgentEvent

Author: joshsny

apps/array/src/api/posthogClient.ts

@@ -1,5 +1,6 @@
+import type { AgentEvent } from "@posthog/agent";
 import { logger } from "@renderer/lib/logger";
-import type { LogEntry, Task, TaskRun } from "@shared/types";
+import type { Task, TaskRun } from "@shared/types";
 import { buildApiFetcher } from "./fetcher";
 import { createApiClient, type Schemas } from "./generated";
 
@@ -171,7 +172,7 @@ export class PostHogAPIClient {
     return data.results ?? data ?? [];
   }
 
-  async getTaskRun(taskId: string, runId: string) {
+  async getTaskRun(taskId: string, runId: string): Promise<TaskRun> {
     const teamId = await this.getTeamId();
     const url = new URL(
       `${this.api.baseUrl}/api/projects/${teamId}/tasks/${taskId}/runs/${runId}/`,
@@ -229,7 +230,31 @@ export class PostHogAPIClient {
     return data as unknown as TaskRun;
   }
 
-  async getTaskLogs(taskId: string): Promise<LogEntry[]> {
+  /**
+   * Append events to a task run's S3 log file
+   */
+  async appendTaskRunLog(
+    taskId: string,
+    runId: string,
+    entries: AgentEvent[],
+  ): Promise<void> {
+    const teamId = await this.getTeamId();
+    const url = `${this.api.baseUrl}/api/projects/${teamId}/tasks/${taskId}/runs/${runId}/append_log/`;
+    const response = await this.api.fetcher.fetch({
+      method: "post",
+      url: new URL(url),
+      path: url,
+      overrides: {
+        body: JSON.stringify({ entries }),
+        headers: { "Content-Type": "application/json" },
+      },
+    });
+    if (!response.ok) {
+      throw new Error(`Failed to append log: ${response.statusText}`);
+    }
+  }
+
+  async getTaskLogs(taskId: string): Promise<AgentEvent[]> {
     try {
       const task = (await this.getTask(taskId)) as unknown as Task;
       const logUrl = task?.latest_run?.log_url;
@@ -255,7 +280,7 @@ export class PostHogAPIClient {
       return content
         .trim()
         .split("\n")
-        .map((line) => JSON.parse(line) as LogEntry);
+        .map((line) => JSON.parse(line) as AgentEvent);
     } catch (err) {
       log.warn("Failed to fetch task logs from latest run", err);
       return [];

apps/array/src/main/lib/logger.ts

@@ -1,10 +1,16 @@
+import { app } from "electron";
 import log from "electron-log/main";
 
 // Initialize IPC transport to forward main process logs to renderer dev tools
 log.initialize();
 
-log.transports.file.level = "info";
-log.transports.console.level = "info";
+// Set levels - use debug in dev (check NODE_ENV since app.isPackaged may not be ready)
+const isDev = process.env.NODE_ENV === "development" || !app.isPackaged;
+const level = isDev ? "debug" : "info";
+log.transports.file.level = level;
+log.transports.console.level = level;
+// IPC transport needs level set separately
+log.transports.ipc.level = level;
 
 export const logger = {
   info: (message: string, ...args: unknown[]) => log.info(message, ...args),

apps/array/src/main/services/agent.ts

@@ -16,7 +16,7 @@ const log = logger.scope("agent");
 const onAgentLog: OnLogCallback = (level, scope, message, data) => {
   const scopedLog = logger.scope(scope);
   if (data !== undefined) {
-    scopedLog[level](message, data);
+    scopedLog[level as keyof typeof scopedLog](message, data);
   } else {
     scopedLog[level](message);
   }
@@ -88,7 +88,7 @@ export function registerAgentIpc(
         permissionMode,
         autoProgress,
         model,
-        runMode,
+        runMode: _runMode, // TODO: Add support for cloud runs
         createPR,
       }: AgentStartParams,
     ): Promise<{ taskId: string; channel: string }> => {
@@ -158,7 +158,7 @@ export function registerAgentIpc(
         posthogApiKey: apiKey,
         posthogApiUrl: apiHost,
         posthogProjectId: projectId,
-        debug: true,
+        debug: !app.isPackaged,
         onLog: onAgentLog,
       });
 
@@ -188,6 +188,12 @@ export function registerAgentIpc(
               // Store the current run ID
               controllerEntry.currentRunId = latestRun.id;
 
+              log.debug("Task progress poll", {
+                runId: latestRun.id,
+                status: latestRun.status,
+                hasLogUrl: !!latestRun.log_url,
+              });
+
               emitToRenderer({
                 type: "progress",
                 ts: Date.now(),
@@ -252,7 +258,7 @@ export function registerAgentIpc(
           await agent.runTask(posthogTaskId, taskRunId, {
             repositoryPath: repoPath,
             permissionMode: resolvedPermission,
-            isCloudMode: runMode === "cloud",
+            isCloudMode: false,
             autoProgress: autoProgress ?? true,
             createPR: createPR ?? true,
             queryOverrides: {

apps/array/src/renderer/features/logs/components/ConsoleView.tsx

@@ -0,0 +1,26 @@
+import { BaseLogEntry } from "@features/logs/components/BaseLogEntry";
+import type { AgentEvent } from "@posthog/agent";
+import { Code } from "@radix-ui/themes";
+
+interface ConsoleViewProps {
+  event: Extract<AgentEvent, { type: "console" }>;
+}
+
+const LEVEL_COLORS = {
+  debug: "gray",
+  info: "blue",
+  warn: "yellow",
+  error: "red",
+} as const;
+
+export function ConsoleView({ event }: ConsoleViewProps) {
+  const color = LEVEL_COLORS[event.level] || "gray";
+
+  return (
+    <BaseLogEntry ts={event.ts}>
+      <Code size="2" color={color} variant="ghost">
+        [{event.level}] {event.message}
+      </Code>
+    </BaseLogEntry>
+  );
+}

apps/array/src/renderer/features/logs/components/LogEventRenderer.tsx

@@ -1,5 +1,6 @@
 import { ArtifactView } from "@features/logs/components/ArtifactView";
 import { BaseLogEntry } from "@features/logs/components/BaseLogEntry";
+import { ConsoleView } from "@features/logs/components/ConsoleView";
 import { DoneView } from "@features/logs/components/DoneView";
 import { ErrorView } from "@features/logs/components/ErrorView";
 import { InitView } from "@features/logs/components/InitView";
@@ -28,6 +29,7 @@ const EVENT_COMPONENT_MAP: Record<
   artifact: ArtifactView,
   metric: MetricEventView,
   progress: ProgressView,
+  console: ConsoleView,
 };
 
 const SKIP_EVENTS = [