feat(eko): add task continuation and file attachment management

This commit introduces major enhancements to the Eko task system:

Features:
- Add task continuation support with full chain history preservation
- Implement file attachment management system with auto-collection
- Add FileAttachmentList component with filtering and collapsing
- Support file preview in detail panel after clicking attachments

UX Improvements:
- Show spin loader during tool execution for better feedback
- Display clickable file links inline after file_write completion
- Pin attachment list above input box (collapsed by default)
- Optimize user message layout (right-aligned, 80% max width)
- Fix detail panel visibility issue in history mode

Technical Changes:
- Upgrade IndexedDB schema to version 4 with chain history field
- Add chainPlanRequest, chainPlanResult, files fields to Task model
- Enhance EkoService with context restoration and chain passing
- Add IPC handlers: navigateDetailView, ekoRestoreTask
- Improve MessageProcessor logic for better message handling
- Update dependencies: @jarvis-agent/electron to 0.1.9

Version bumped from 0.0.7 to 0.0.9

Author: lsustc

electron/main/ipc/eko-handlers.ts

@@ -93,5 +93,48 @@ export function registerEkoHandlers() {
     }
   });
 
+  // Get task context (workflow + contextParams) for restoration
+  ipcMain.handle('eko:get-task-context', async (event, taskId: string) => {
+    try {
+      console.log('IPC eko:get-task-context received:', taskId);
+      const context = windowContextManager.getContext(event.sender.id);
+      if (!context || !context.ekoService) {
+        throw new Error('EkoService not found for this window');
+      }
+      const taskContext = context.ekoService.getTaskContext(taskId);
+      return taskContext;
+    } catch (error: any) {
+      console.error('IPC eko:get-task-context error:', error);
+      throw error;
+    }
+  });
+
+  // Restore task from saved workflow and contextParams
+  ipcMain.handle('eko:restore-task', async (
+    event,
+    workflow: any,
+    contextParams?: Record<string, any>,
+    chainPlanRequest?: any,
+    chainPlanResult?: string
+  ) => {
+    try {
+      console.log('IPC eko:restore-task received:', workflow.taskId);
+      const context = windowContextManager.getContext(event.sender.id);
+      if (!context || !context.ekoService) {
+        throw new Error('EkoService not found for this window');
+      }
+      const taskId = await context.ekoService.restoreTask(
+        workflow,
+        contextParams,
+        chainPlanRequest,
+        chainPlanResult
+      );
+      return { success: true, taskId };
+    } catch (error: any) {
+      console.error('IPC eko:restore-task error:', error);
+      throw error;
+    }
+  });
+
   console.log('[IPC] Eko service handlers registered');
 }

electron/main/ipc/view-handlers.ts

@@ -54,5 +54,24 @@ export function registerViewHandlers() {
     }
   });
 
+  // Navigate detail view to specified URL
+  ipcMain.handle('navigate-detail-view', async (event, url: string) => {
+    try {
+      console.log('IPC navigate-detail-view received:', url);
+      const context = windowContextManager.getContext(event.sender.id);
+      if (!context || !context.detailView) {
+        throw new Error('DetailView not found for this window');
+      }
+
+      // Load URL in detail view
+      await context.detailView.webContents.loadURL(url);
+
+      return { success: true, url };
+    } catch (error: any) {
+      console.error('IPC navigate-detail-view error:', error);
+      throw error;
+    }
+  });
+
   console.log('[IPC] View control handlers registered');
 }

electron/main/services/eko-service.ts

@@ -390,6 +390,92 @@ export class EkoService {
     return false;
   }
 
+  /**
+   * Get task context (for restoring conversation)
+   * Returns workflow, contextParams, and chain history needed to restore the task
+   */
+  getTaskContext(taskId: string): {
+    workflow: any;
+    contextParams: Record<string, any>;
+    chainPlanRequest?: any;
+    chainPlanResult?: string;
+  } | null {
+    if (!this.eko) {
+      Log.error('Eko service not initialized');
+      return null;
+    }
+
+    const context = this.eko.getTask(taskId);
+    if (!context) {
+      Log.error(`Task ${taskId} not found in Eko`);
+      return null;
+    }
+
+    // Extract workflow and convert variables Map to plain object
+    const workflow = context.workflow;
+    const contextParams: Record<string, any> = {};
+
+    // Convert Map to plain object for serialization
+    context.variables.forEach((value, key) => {
+      contextParams[key] = value;
+    });
+
+    // Extract chain history (critical for replan to maintain conversation context)
+    const chainPlanRequest = context.chain?.planRequest;
+    const chainPlanResult = context.chain?.planResult;
+
+    Log.info('Extracted task context:', {
+      taskId,
+      hasWorkflow: !!workflow,
+      contextParamsCount: Object.keys(contextParams).length,
+      hasChainHistory: !!(chainPlanRequest && chainPlanResult)
+    });
+
+    return {
+      workflow,
+      contextParams,
+      chainPlanRequest,
+      chainPlanResult
+    };
+  }
+
+  /**
+   * Restore task from saved workflow and contextParams
+   * Used to continue conversation from history
+   */
+  async restoreTask(
+    workflow: any,
+    contextParams?: Record<string, any>,
+    chainPlanRequest?: any,
+    chainPlanResult?: string
+  ): Promise<string> {
+    if (!this.eko) {
+      throw new Error('Eko service not initialized');
+    }
+
+    try {
+      Log.info('Restoring task from workflow:', workflow.taskId);
+
+      // Use Eko's initContext to restore the task
+      const context = await this.eko.initContext(workflow, contextParams);
+
+      // Restore chain history (critical for replan to maintain conversation context)
+      if (chainPlanRequest && chainPlanResult) {
+        context.chain.planRequest = chainPlanRequest;
+        context.chain.planResult = chainPlanResult;
+        Log.info('Chain history restored successfully');
+      } else {
+        Log.warn('No chain history to restore - replan will treat as new task');
+      }
+
+      Log.info('Task restored successfully:', workflow.taskId);
+      return workflow.taskId;
+    } catch (error: any) {
+      Log.error('Failed to restore task:', error);
+      throw error;
+    }
+  }
+
   /**
    * Abort all running tasks
    */
@@ -422,7 +508,7 @@ export class EkoService {
       type: 'human_interaction',
       requestId,
       taskId: agentContext?.context?.taskId,
-      agentName: agentContext?.agent?.name,
+      agentName: agentContext?.agent?.Name,
       timestamp: new Date(),
       ...payload
     };

electron/preload/index.ts

@@ -43,6 +43,11 @@ const api = {
   // Human interaction APIs
   sendHumanResponse: (response: any) => ipcRenderer.invoke('eko:human-response', response),
 
+  // Task restoration APIs (for continuing conversation from history)
+  ekoGetTaskContext: (taskId: string) => ipcRenderer.invoke('eko:get-task-context', taskId),
+  ekoRestoreTask: (workflow: any, contextParams?: Record<string, any>, chainPlanRequest?: any, chainPlanResult?: string) =>
+    ipcRenderer.invoke('eko:restore-task', workflow, contextParams, chainPlanRequest, chainPlanResult),
+
   // Model configuration APIs
   getUserModelConfigs: () => ipcRenderer.invoke('config:get-user-configs'),
   saveUserModelConfigs: (configs: any) => ipcRenderer.invoke('config:save-user-configs', configs),
@@ -60,10 +65,11 @@ const api = {
 
   // Detail view control APIs
   setDetailViewVisible: (visible: boolean) => ipcRenderer.invoke('set-detail-view-visible', visible),
+  navigateDetailView: (url: string) => ipcRenderer.invoke('navigate-detail-view', url),
   // URL retrieval and monitoring APIs
   getCurrentUrl: () => ipcRenderer.invoke('get-current-url'),
   onUrlChange: (callback: (url: string) => void) => {
-    ipcRenderer.on('url-changed', (event, url) => callback(url));
+    ipcRenderer.on('url-changed', (_event, url) => callback(url));
   },
   // Screenshot related APIs
   getMainViewScreenshot: () => ipcRenderer.invoke('get-main-view-screenshot'),

electron/preload/view.ts

@@ -109,6 +109,9 @@ const api = {
   captureWindowSync: (winNo: number, scale = 1) => ipcRenderer.sendSync('native:captureWindow:sync', winNo, scale),
   requestCapturePermission: () => ipcRenderer.invoke('native:requestCapturePermission'),
   onFileUpdated: (callback: (status: string, content: string) => void) => ipcRenderer.on('file-updated', (_, status, content) => callback(status, content)),
+
+  // Generic invoke method (for config and other features)
+  invoke: (channel: string, ...args: any[]) => ipcRenderer.invoke(channel, ...args),
 };
 
 // Use `contextBridge` APIs to expose Electron APIs to
@@ -128,7 +131,7 @@ if (process.contextIsolated) {
   window.api = api;
 }
 
-ipcRenderer.on("call-view-func", async (event, { payload, replyChannel }) => {
+ipcRenderer.on("call-view-func", async (_event, { payload, replyChannel }) => {
   let func;
   try {
     // @ts-ignore (define in dts) Use eval to maintain execution context

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ai-browser",
-  "version": "0.0.7",
+  "version": "0.0.9",
   "description": "DeepFundAI Browser - AI-Powered Intelligent Browser",
   "author": "Shuai Liu <lsustc@mail.ustc.edu.cn>",
   "private": true,
@@ -30,7 +30,7 @@
     "@ant-design/cssinjs": "^1.23.0",
     "@ant-design/icons": "5.x",
     "@jarvis-agent/core": "^0.1.4",
-    "@jarvis-agent/electron": "^0.1.8",
+    "@jarvis-agent/electron": "^0.1.9",
     "@jest/globals": "^30.1.2",
     "@react-spring/web": "^10.0.1",
     "antd": "^5.26.5",