Improve chat list

Author: ericdallo

eca-webview

@@ -174,6 +174,42 @@ export class EcaRemoteApi {
     });
   }
 
+  // ---------------------------------------------------------------------------
+  // Trust
+  // ---------------------------------------------------------------------------
+
+  /** Set the trust mode on the server. */
+  async setTrust(trust: boolean): Promise<void> {
+    return this.request('/trust', {
+      method: 'POST',
+      body: { trust },
+    });
+  }
+
+  // ---------------------------------------------------------------------------
+  // MCP operations
+  // ---------------------------------------------------------------------------
+
+  /** Start an MCP server by name. */
+  async mcpStartServer(name: string): Promise<void> {
+    return this.request(`/mcp/${encodeURIComponent(name)}/start`, { method: 'POST' });
+  }
+
+  /** Stop an MCP server by name. */
+  async mcpStopServer(name: string): Promise<void> {
+    return this.request(`/mcp/${encodeURIComponent(name)}/stop`, { method: 'POST' });
+  }
+
+  /** Connect (reconnect) an MCP server by name. */
+  async mcpConnectServer(name: string): Promise<void> {
+    return this.request(`/mcp/${encodeURIComponent(name)}/connect`, { method: 'POST' });
+  }
+
+  /** Logout an MCP server by name. */
+  async mcpLogoutServer(name: string): Promise<void> {
+    return this.request(`/mcp/${encodeURIComponent(name)}/logout`, { method: 'POST' });
+  }
+
   // ---------------------------------------------------------------------------
   // SSE
   // ---------------------------------------------------------------------------

src/bridge/api.ts

@@ -110,6 +110,10 @@ export async function handleOutbound(
         dispatch('editor/saveClipboardImage', { requestId: data.requestId, path: null });
         break;
 
+      case 'editor/toggleSidebar':
+        window.dispatchEvent(new CustomEvent('eca-toggle-sidebar'));
+        break;
+
       // --- Query operations (not available via REST — return empty) ---
       case 'chat/queryContext':
         dispatch('chat/queryContext', { chatId: data.chatId, contexts: [] });
@@ -123,16 +127,31 @@ export async function handleOutbound(
         dispatch('chat/queryFiles', { chatId: data.chatId, files: [] });
         break;
 
-      // --- MCP operations (not available in web) ---
+      // --- Trust mode ---
+      case 'server/setTrust':
+        await api.setTrust(data);
+        break;
+
+      // --- MCP operations ---
       case 'mcp/startServer':
+        await api.mcpStartServer(data.name);
+        break;
+
       case 'mcp/stopServer':
+        await api.mcpStopServer(data.name);
+        break;
+
       case 'mcp/connectServer':
+        await api.mcpConnectServer(data.name);
+        break;
+
       case 'mcp/logoutServer':
-        console.log(`[outbound] MCP operation not available in web: ${type}`);
+        await api.mcpLogoutServer(data.name);
         break;
 
       case 'mcp/updateServer':
         // Respond immediately to prevent webviewSendAndGet from hanging
+        // (no REST endpoint for updating MCP server config in web context)
         console.log(`[outbound] MCP update not available in web`);
         if (data.requestId) {
           dispatch('editor/readInput', { requestId: data.requestId, value: null });

src/bridge/outbound-handler.ts

@@ -22,13 +22,16 @@ import { chatToRestoreEvents } from './chat-restore';
 import { handleOutbound, type OutboundContext } from './outbound-handler';
 import { SSEClient, type SSEEvent } from './sse';
 import type {
+  ChatEntry,
+  ChatListChangeCallback,
   MCPServerUpdatedParams,
   RemoteChat,
   SessionConfig,
   SessionState,
   SSEChatStatusPayload,
   SSESessionConnectedPayload,
   SSESessionMessagePayload,
+  SSETrustUpdatedPayload,
 } from './types';
 
 /** Timeout for the initial SSE handshake (session:connected). */
@@ -43,6 +46,15 @@ export class WebBridge {
   private outboundListener: ((e: Event) => void) | null = null;
   private mcpServers: MCPServerUpdatedParams[] = [];
 
+  /**
+   * Lightweight chat index exposed to the React shell for the sidebar.
+   * Kept in sync as chat events flow through the bridge.
+   */
+  private chatEntries: ChatEntry[] = [];
+
+  /** Callback invoked whenever the chat list or selection changes. */
+  private onChatListChange: ChatListChangeCallback | null = null;
+
   /**
    * True after `disconnect()` has been called. Checked after every async
    * boundary in `connect()` so that orphaned bridges (e.g. from React
@@ -101,6 +113,48 @@ export class WebBridge {
     return this.connected;
   }
 
+  // ---------------------------------------------------------------------------
+  // Chat list API (for the sidebar)
+  // ---------------------------------------------------------------------------
+
+  /** Register a listener for chat list changes (used by the sidebar). */
+  onChatListChanged(cb: ChatListChangeCallback): void {
+    this.onChatListChange = cb;
+    // Immediately fire with current state
+    cb([...this.chatEntries], this.currentChatId);
+  }
+
+  /** Get the current chat entries snapshot. */
+  getChatEntries(): ChatEntry[] {
+    return [...this.chatEntries];
+  }
+
+  /** Get the currently selected chat ID. */
+  getSelectedChatId(): string | null {
+    return this.currentChatId;
+  }
+
+  /** Select a chat by ID — dispatches to the webview and updates tracking. */
+  selectChat(chatId: string): void {
+    this.currentChatId = chatId;
+    this.dispatch('chat/selectChat', chatId);
+    this.notifyChatListChange();
+  }
+
+  /** Create a new chat — dispatches to the webview. */
+  newChat(): void {
+    this.dispatch('chat/createNewChat', undefined);
+  }
+
+  /** Delete a chat by ID — calls the REST API. */
+  async deleteChatFromSidebar(chatId: string): Promise<void> {
+    try {
+      await this.api.deleteChat(chatId);
+    } catch (err) {
+      console.error('[Bridge] Failed to delete chat:', err);
+    }
+  }
+
   // ---------------------------------------------------------------------------
   // SSE connection
   // ---------------------------------------------------------------------------
@@ -165,6 +219,7 @@ export class WebBridge {
         mcpServers: data.mcpServers,
         chats: data.chats,
         config: this.buildSessionConfig(data),
+        trust: data.trust ?? false,
       };
     } catch (err) {
       console.error('[Bridge] Failed to parse session:connected', err);
@@ -185,6 +240,14 @@ export class WebBridge {
       switch (event.event) {
         case 'chat:content-received':
           this.dispatch('chat/contentReceived', data);
+          // Track new chats and title updates for the sidebar
+          if (data.chatId) {
+            this.upsertChatEntry(data.chatId, {});
+            if (data.content?.type === 'metadata' && data.content?.title) {
+              this.upsertChatEntry(data.chatId, { title: data.content.title });
+            }
+            this.notifyChatListChange();
+          }
           break;
 
         case 'chat:cleared':
@@ -193,10 +256,14 @@ export class WebBridge {
 
         case 'chat:deleted':
           this.dispatch('chat/deleted', data.chatId);
+          this.removeChatEntry(data.chatId);
+          this.notifyChatListChange();
           break;
 
         case 'chat:status-changed': {
           const status = data as SSEChatStatusPayload;
+          this.upsertChatEntry(status.chatId, { status: status.status });
+          this.notifyChatListChange();
           if (status.status === 'idle') {
             this.dispatch('chat/contentReceived', {
               chatId: status.chatId,
@@ -227,6 +294,12 @@ export class WebBridge {
           break;
         }
 
+        case 'trust:updated': {
+          const trustData = data as SSETrustUpdatedPayload;
+          this.dispatch('server/setTrust', trustData.trust);
+          break;
+        }
+
         case 'session:disconnecting':
           console.warn('[Bridge] Server shutting down:', data.reason);
           this.dispatch('server/statusChanged', 'Stopped');
@@ -262,6 +335,9 @@ export class WebBridge {
         this.dispatch('tool/serversUpdated', this.mcpServers);
       }
 
+      // Sync trust mode from server state
+      this.dispatch('server/setTrust', this.sessionState.trust ?? false);
+
       await this.restoreChats();
     } finally {
       this.restoring = false;
@@ -314,11 +390,18 @@ export class WebBridge {
       if (!chat?.id) continue;
       this.currentChatId = chat.id;
 
+      // Track in sidebar
+      this.upsertChatEntry(chat.id, {
+        title: chat.title ?? `Chat`,
+        status: chat.status ?? 'idle',
+      });
+
       const events = chatToRestoreEvents(chat);
       for (const event of events) {
         this.dispatch('chat/contentReceived', event);
       }
     }
+    this.notifyChatListChange();
   }
 
   // ---------------------------------------------------------------------------
@@ -392,4 +475,35 @@ export class WebBridge {
   private dispatch(type: string, data: unknown): void {
     window.postMessage({ type, data }, '*');
   }
+
+  // ---------------------------------------------------------------------------
+  // Chat entry tracking (for sidebar)
+  // ---------------------------------------------------------------------------
+
+  /** Notify the sidebar callback of chat list changes. */
+  private notifyChatListChange(): void {
+    this.onChatListChange?.([...this.chatEntries], this.currentChatId);
+  }
+
+  /** Upsert a chat entry by ID (creates if missing, updates if present). */
+  private upsertChatEntry(id: string, partial: Partial<Omit<ChatEntry, 'id'>>): void {
+    const idx = this.chatEntries.findIndex((e) => e.id === id);
+    if (idx >= 0) {
+      this.chatEntries = [
+        ...this.chatEntries.slice(0, idx),
+        { ...this.chatEntries[idx], ...partial },
+        ...this.chatEntries.slice(idx + 1),
+      ];
+    } else {
+      this.chatEntries = [
+        ...this.chatEntries,
+        { id, title: partial.title ?? `Chat`, status: partial.status ?? 'idle' },
+      ];
+    }
+  }
+
+  /** Remove a chat entry by ID. */
+  private removeChatEntry(id: string): void {
+    this.chatEntries = this.chatEntries.filter((e) => e.id !== id);
+  }
 }

src/bridge/transport.ts

@@ -161,7 +161,8 @@ export type SSEEventType =
   | 'chat:deleted'
   | 'chat:status-changed'
   | 'config:updated'
-  | 'tool:server-updated';
+  | 'tool:server-updated'
+  | 'trust:updated';
 
 export interface SSESessionConnectedPayload {
   workspaceFolders?: WorkspaceFolder[];
@@ -174,6 +175,11 @@ export interface SSESessionConnectedPayload {
   selectAgent?: string;
   variants?: string[];
   selectedVariant?: string | null;
+  trust?: boolean;
+}
+
+export interface SSETrustUpdatedPayload {
+  trust: boolean;
 }
 
 export interface SSEChatStatusPayload {
@@ -197,6 +203,7 @@ export interface SessionState {
   mcpServers?: MCPServerUpdatedParams[];
   chats?: RemoteChat[];
   config?: SessionConfig;
+  trust?: boolean;
 }
 
 export interface SessionConfig {
@@ -246,7 +253,8 @@ export type OutboundMessage =
   | { type: 'mcp/stopServer'; data: { name: string } }
   | { type: 'mcp/connectServer'; data: { name: string } }
   | { type: 'mcp/logoutServer'; data: { name: string } }
-  | { type: 'mcp/updateServer'; data: { requestId?: string } };
+  | { type: 'mcp/updateServer'; data: { requestId?: string } }
+  | { type: 'server/setTrust'; data: boolean };
 
 export interface UserPromptData {
   chatId?: string;
@@ -258,6 +266,20 @@ export interface UserPromptData {
   contexts?: ChatContext[];
 }
 
+// ---------------------------------------------------------------------------
+// Chat sidebar types (shell-level chat list for the sidebar)
+// ---------------------------------------------------------------------------
+
+/** Lightweight chat entry exposed to the React shell for the sidebar. */
+export interface ChatEntry {
+  id: string;
+  title: string;
+  status: 'idle' | 'running';
+}
+
+/** Callback signature for chat list change notifications. */
+export type ChatListChangeCallback = (chats: ChatEntry[], selectedChatId: string | null) => void;
+
 // ---------------------------------------------------------------------------
 // Webview dispatch types (bridge → webview via postMessage)
 // ---------------------------------------------------------------------------
@@ -269,6 +291,7 @@ export interface UserPromptData {
 export type DispatchType =
   | 'server/statusChanged'
   | 'server/setWorkspaceFolders'
+  | 'server/setTrust'
   | 'config/updated'
   | 'tool/serversUpdated'
   | 'chat/contentReceived'