refactor: clean up agent package (#574)

Author: jonathanlab

apps/twig/src/api/posthogClient.ts

@@ -1,4 +1,3 @@
-import type { AgentEvent } from "@posthog/agent";
 import { logger } from "@renderer/lib/logger";
 import type { Task, TaskRun } from "@shared/types";
 import type { StoredLogEntry } from "@shared/types/session-events";
@@ -258,7 +257,7 @@ export class PostHogAPIClient {
     }
   }
 
-  async getTaskLogs(taskId: string): Promise<AgentEvent[]> {
+  async getTaskLogs(taskId: string): Promise<StoredLogEntry[]> {
     try {
       const task = (await this.getTask(taskId)) as unknown as Task;
       const logUrl = task?.latest_run?.log_url;
@@ -284,7 +283,7 @@ export class PostHogAPIClient {
       return content
         .trim()
         .split("\n")
-        .map((line) => JSON.parse(line) as AgentEvent);
+        .map((line) => JSON.parse(line) as StoredLogEntry);
     } catch (err) {
       log.warn("Failed to fetch task logs from latest run", err);
       return [];

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

@@ -341,19 +341,17 @@ export class AgentService extends TypedEventEmitter<AgentServiceEvents> {
     this.setupEnvironment(credentials, mockNodeDir);
 
     const agent = new Agent({
-      workingDirectory: repoPath,
-      posthogApiUrl: credentials.apiHost,
-      getPosthogApiKey: () => this.getToken(credentials.apiKey),
-      posthogProjectId: credentials.projectId,
+      posthog: {
+        apiUrl: credentials.apiHost,
+        getApiKey: () => this.getToken(credentials.apiKey),
+        projectId: credentials.projectId,
+      },
       debug: !app.isPackaged,
       onLog: onAgentLog,
     });
 
     try {
-      const { clientStreams } = await agent.runTaskV2(taskId, taskRunId, {
-        skipGitBranch: true,
-        isReconnect,
-      });
+      const { clientStreams } = await agent.run(taskId, taskRunId);
 
       const connection = this.createClientConnection(
         taskRunId,
@@ -534,14 +532,8 @@ export class AgentService extends TypedEventEmitter<AgentServiceEvents> {
     const session = this.sessions.get(sessionId);
     if (!session) return false;
 
-    try {
-      session.agent.cancelTask(session.taskId);
-      this.cleanupSession(sessionId);
-      return true;
-    } catch (_err) {
-      this.cleanupSession(sessionId);
-      return false;
-    }
+    this.cleanupSession(sessionId);
+    return true;
   }
 
   async cancelPrompt(
@@ -724,14 +716,7 @@ For git operations while detached:
         log.warn("Failed to send ACP cancel", { taskRunId, error: err });
       }
 
-      // Step 2: Cancel via agent (triggers AbortController)
-      try {
-        session.agent.cancelTask(session.taskId);
-      } catch (err) {
-        log.warn("Failed to cancel task", { taskRunId, error: err });
-      }
-
-      // Step 3: Cleanup agent connection (closes streams, aborts subprocess)
+      // Step 2: Cleanup agent connection (closes streams, aborts subprocess)
       try {
         await session.agent.cleanup();
       } catch (err) {

apps/twig/src/renderer/features/task-detail/utils/eventEmitter.ts

@@ -1,5 +1,6 @@
 {
   "$schema": "https://unpkg.com/knip@latest/schema.json",
+  "ignoreWorkspaces": ["apps/mobile"],
   "workspaces": {
     ".": {
       "entry": ["mprocs.yaml"]