Add server-side session search and UI improvements

gricha · claude · gricha · commit 3fef069f8fdd · 2026-01-07T06:46:39.000Z
- Implement full-text search using ripgrep across all session files - Move search bar into sessions navbar (no extra vertical space) - Add optimistic updates for instant deletion feedback - Fix e2e test for stop button (now in settings tab) 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
diff --git a/src/agent/router.ts b/src/agent/router.ts
@@ -22,6 +22,7 @@ import {
   getSessionMessages,
   findSessionMessages,
   deleteSession as deleteSessionFromProvider,
+  searchSessions as searchSessionsInContainer,
 } from '../sessions/agents';
 import type { SessionsCacheManager } from '../sessions/cache';
 import type { ModelCacheManager } from '../models/cache';
@@ -769,6 +770,120 @@ export function createRouter(ctx: RouterContext) {
       return { success: true };
     });
 
+  const searchSessions = os
+    .input(
+      z.object({
+        workspaceName: z.string(),
+        query: z.string().min(1).max(500),
+      })
+    )
+    .handler(async ({ input }) => {
+      const isHost = input.workspaceName === HOST_WORKSPACE_NAME;
+
+      if (isHost) {
+        const config = ctx.config.get();
+        if (!config.allowHostAccess) {
+          throw new ORPCError('PRECONDITION_FAILED', { message: 'Host access is disabled' });
+        }
+
+        const results = await searchHostSessions(input.query);
+        return { results };
+      }
+
+      const workspace = await ctx.workspaces.get(input.workspaceName);
+      if (!workspace) {
+        throw new ORPCError('NOT_FOUND', { message: 'Workspace not found' });
+      }
+      if (workspace.status !== 'running') {
+        throw new ORPCError('PRECONDITION_FAILED', { message: 'Workspace is not running' });
+      }
+
+      const containerName = `workspace-${input.workspaceName}`;
+      const results = await searchSessionsInContainer(containerName, input.query, execInContainer);
+
+      return { results };
+    });
+
+  async function searchHostSessions(query: string): Promise<
+    Array<{
+      sessionId: string;
+      agentType: 'claude-code' | 'opencode' | 'codex';
+      matchCount: number;
+    }>
+  > {
+    const homeDir = os_module.homedir();
+    const safeQuery = query.replace(/['"\\]/g, '\\$&');
+    const searchPaths = [
+      path.join(homeDir, '.claude', 'projects'),
+      path.join(homeDir, '.local', 'share', 'opencode', 'storage'),
+      path.join(homeDir, '.codex', 'sessions'),
+    ].filter((p) => {
+      try {
+        require('fs').accessSync(p);
+        return true;
+      } catch {
+        return false;
+      }
+    });
+
+    if (searchPaths.length === 0) {
+      return [];
+    }
+
+    const { execSync } = await import('child_process');
+    try {
+      const output = execSync(
+        `rg -l -i --no-messages "${safeQuery}" ${searchPaths.join(' ')} 2>/dev/null | head -100`,
+        {
+          encoding: 'utf-8',
+          timeout: 30000,
+        }
+      );
+
+      const files = output.trim().split('\n').filter(Boolean);
+      const results: Array<{
+        sessionId: string;
+        agentType: 'claude-code' | 'opencode' | 'codex';
+        matchCount: number;
+      }> = [];
+
+      for (const file of files) {
+        let sessionId: string | null = null;
+        let agentType: 'claude-code' | 'opencode' | 'codex' | null = null;
+
+        if (file.includes('/.claude/projects/')) {
+          const match = file.match(/\/([^/]+)\.jsonl$/);
+          if (match && !match[1].startsWith('agent-')) {
+            sessionId = match[1];
+            agentType = 'claude-code';
+          }
+        } else if (file.includes('/.local/share/opencode/storage/')) {
+          if (file.includes('/session/') && file.endsWith('.json')) {
+            const match = file.match(/\/(ses_[^/]+)\.json$/);
+            if (match) {
+              sessionId = match[1];
+              agentType = 'opencode';
+            }
+          }
+        } else if (file.includes('/.codex/sessions/')) {
+          const match = file.match(/\/([^/]+)\.jsonl$/);
+          if (match) {
+            sessionId = match[1];
+            agentType = 'codex';
+          }
+        }
+
+        if (sessionId && agentType) {
+          results.push({ sessionId, agentType, matchCount: 1 });
+        }
+      }
+
+      return results;
+    } catch {
+      return [];
+    }
+  }
+
   async function deleteHostSession(
     sessionId: string,
     agentType: 'claude-code' | 'opencode' | 'codex'
@@ -941,6 +1056,7 @@ export function createRouter(ctx: RouterContext) {
       getRecent: getRecentSessions,
       recordAccess: recordSessionAccess,
       delete: deleteSession,
+      search: searchSessions,
     },
     models: {
       list: listModels,
diff --git a/src/sessions/agents/index.ts b/src/sessions/agents/index.ts
@@ -78,3 +78,77 @@ export async function deleteSession(
   }
   return provider.deleteSession(containerName, sessionId, exec);
 }
+
+export interface SearchResult {
+  sessionId: string;
+  agentType: AgentType;
+  filePath: string;
+  matchCount: number;
+}
+
+export async function searchSessions(
+  containerName: string,
+  query: string,
+  exec: ExecInContainer
+): Promise<SearchResult[]> {
+  const safeQuery = query.replace(/['"\\]/g, '\\$&');
+
+  const searchPaths = [
+    '/home/workspace/.claude/projects',
+    '/home/workspace/.local/share/opencode/storage',
+    '/home/workspace/.codex/sessions',
+  ];
+
+  const rgCommand = `rg -l -i --no-messages "${safeQuery}" ${searchPaths.join(' ')} 2>/dev/null | head -100`;
+
+  const result = await exec(containerName, ['bash', '-c', rgCommand], {
+    user: 'workspace',
+  });
+
+  if (result.exitCode !== 0 || !result.stdout.trim()) {
+    return [];
+  }
+
+  const files = result.stdout.trim().split('\n').filter(Boolean);
+  const results: SearchResult[] = [];
+
+  for (const file of files) {
+    let sessionId: string | null = null;
+    let agentType: AgentType | null = null;
+
+    if (file.includes('/.claude/projects/')) {
+      const match = file.match(/\/([^/]+)\.jsonl$/);
+      if (match && !match[1].startsWith('agent-')) {
+        sessionId = match[1];
+        agentType = 'claude-code';
+      }
+    } else if (file.includes('/.local/share/opencode/storage/')) {
+      if (file.includes('/session/') && file.endsWith('.json')) {
+        const match = file.match(/\/(ses_[^/]+)\.json$/);
+        if (match) {
+          sessionId = match[1];
+          agentType = 'opencode';
+        }
+      } else if (file.includes('/part/') || file.includes('/message/')) {
+        continue;
+      }
+    } else if (file.includes('/.codex/sessions/')) {
+      const match = file.match(/\/([^/]+)\.jsonl$/);
+      if (match) {
+        sessionId = match[1];
+        agentType = 'codex';
+      }
+    }
+
+    if (sessionId && agentType) {
+      results.push({
+        sessionId,
+        agentType,
+        filePath: file,
+        matchCount: 1,
+      });
+    }
+  }
+
+  return results;
+}
diff --git a/test/web/workspace.spec.ts b/test/web/workspace.spec.ts
@@ -63,10 +63,10 @@ test.describe('Web UI - Workspace Operations', () => {
     await agent.api.createWorkspace({ name: workspaceName });
 
     try {
-      await page.goto(`http://127.0.0.1:${agent.port}/workspaces/${workspaceName}`);
+      await page.goto(`http://127.0.0.1:${agent.port}/workspaces/${workspaceName}?tab=settings`);
       await expect(page.getByText(workspaceName).first()).toBeVisible({ timeout: 30000 });
 
-      const stopButton = page.getByRole('button', { name: /stop/i });
+      const stopButton = page.getByRole('button', { name: /^stop$/i });
       await stopButton.click();
 
       await expect(page.getByText('stopped').first()).toBeVisible({ timeout: 30000 });
diff --git a/web/src/lib/api.ts b/web/src/lib/api.ts
@@ -73,6 +73,7 @@ const client = createORPCClient<{
     getRecent: (input: { limit?: number }) => Promise<{ sessions: RecentSession[] }>
     recordAccess: (input: { workspaceName: string; sessionId: string; agentType: AgentType }) => Promise<{ success: boolean }>
     delete: (input: { workspaceName: string; sessionId: string; agentType: AgentType }) => Promise<{ success: boolean }>
+    search: (input: { workspaceName: string; query: string }) => Promise<{ results: Array<{ sessionId: string; agentType: AgentType; matchCount: number }> }>
   }
   models: {
     list: (input: { agentType: 'claude-code' | 'opencode'; workspaceName?: string }) => Promise<{ models: ModelInfo[] }>
@@ -128,6 +129,8 @@ export const api = {
     client.sessions.clearName({ workspaceName, sessionId }),
   deleteSession: (workspaceName: string, sessionId: string, agentType: AgentType) =>
     client.sessions.delete({ workspaceName, sessionId, agentType }),
+  searchSessions: (workspaceName: string, query: string) =>
+    client.sessions.search({ workspaceName, query }),
   getInfo: () => client.info(),
   getCredentials: () => client.config.credentials.get(),
   updateCredentials: (data: Credentials) => client.config.credentials.update(data),
diff --git a/web/src/pages/WorkspaceDetail.tsx b/web/src/pages/WorkspaceDetail.tsx
