mdemirhan · melihceyhan · Mar 16, 2026 · Mar 16, 2026 · Mar 16, 2026
diff --git a/apps/desktop/src/main/appStateStore.test.ts b/apps/desktop/src/main/appStateStore.test.ts
@@ -82,6 +82,7 @@ describe("AppStateStore", () => {
         codex: ["^<environment_context>"],
         gemini: [],
         cursor: [],
+        opencode: [],
       },
     });
     store.setWindowState({ width: 1440, height: 920, x: 48, y: 72, isMaximized: false });
@@ -113,6 +114,7 @@ describe("AppStateStore", () => {
         codex: ["^<environment_context>"],
         gemini: [],
         cursor: [],
+        opencode: [],
       },
     });
     expect(reloaded.getWindowState()).toEqual({
@@ -185,7 +187,7 @@ describe("AppStateStore", () => {
     expect(store.getPaneState()).toEqual({
       projectPaneWidth: 300,
       sessionPaneWidth: 360,
-      projectProviders: ["claude", "codex", "gemini", "cursor"],
+      projectProviders: ["claude", "codex", "gemini", "cursor", "opencode"],
       historyCategories: ["assistant"],
     });
   });

diff --git a/apps/desktop/src/main/appStateStore.ts b/apps/desktop/src/main/appStateStore.ts
@@ -428,6 +428,7 @@ function sanitizeSystemMessageRegexRules(value: unknown): Record<Provider, strin
     codex: [],
     gemini: [],
     cursor: [],
+    opencode: [],
   };
 
   for (const provider of PROVIDER_VALUES) {

diff --git a/apps/desktop/src/main/bootstrap.test.ts b/apps/desktop/src/main/bootstrap.test.ts
@@ -142,6 +142,7 @@ vi.mock("@codetrail/core", async () => {
       geminiHistoryRoot: null,
       geminiProjectsPath: null,
       cursorRoot: "/cursor/root",
+      opencodeDbPath: "/mock/.local/share/opencode/opencode.db",
     },
     initializeDatabase: mockInitializeDatabase,
     resolveSystemMessageRegexRules: mockResolveSystemMessageRegexRules,
@@ -233,6 +234,7 @@ describe("bootstrapMainProcess", () => {
       codex: ["^<environment_context>"],
       gemini: [],
       cursor: [],
+      opencode: [],
     },
   };
 
@@ -329,6 +331,7 @@ describe("bootstrapMainProcess", () => {
       geminiHistoryRoot: "/Users/test/.gemini/history",
       geminiProjectsPath: "/Users/test/.gemini/projects.json",
       cursorRoot: "/cursor/root",
+      opencodeDbPath: "/mock/.local/share/opencode/opencode.db",
     });
 
     const projectPayload = { providers: ["claude"], query: "" };
@@ -493,6 +496,7 @@ describe("bootstrapMainProcess", () => {
         codex: ["^<environment_context>"],
         gemini: [],
         cursor: [],
+        opencode: [],
       },
     });
 
@@ -529,6 +533,7 @@ describe("bootstrapMainProcess", () => {
           "/gemini/root",
           "/Users/test/.gemini/history",
           "/cursor/root",
+          "/mock/.local/share/opencode",
         ],
         backend: "kqueue",
       });
@@ -539,6 +544,7 @@ describe("bootstrapMainProcess", () => {
           "/gemini/root",
           "/Users/test/.gemini/history",
           "/cursor/root",
+          "/mock/.local/share/opencode",
         ],
         expect.any(Function),
         expect.objectContaining({
@@ -627,6 +633,7 @@ describe("bootstrapMainProcess", () => {
           "/gemini/root",
           "/Users/test/.gemini/history",
           "/cursor/root",
+          "/mock/.local/share/opencode",
         ],
         expect.any(Function),
         expect.objectContaining({
@@ -642,6 +649,7 @@ describe("bootstrapMainProcess", () => {
           "/gemini/root",
           "/Users/test/.gemini/history",
           "/cursor/root",
+          "/mock/.local/share/opencode",
         ],
         expect.any(Function),
         expect.objectContaining({

diff --git a/apps/desktop/src/main/bootstrap.ts b/apps/desktop/src/main/bootstrap.ts
@@ -24,6 +24,7 @@ import {
 } from "./fileWatcherService";
 import { WorkerIndexingRunner } from "./indexingRunner";
 import { registerIpcHandlers } from "./ipc";
+import { initializeOpenCodeReaders } from "./openCodeReaders";
 import { WatchStatsStore } from "./watchStatsStore";
 
 const MIN_ZOOM_PERCENT = 60;
@@ -65,6 +66,7 @@ export async function bootstrapMainProcess(
 
   const dbBootstrap = initializeDatabase(dbPath);
   initializeBookmarkStore(bookmarksDbPath);
+  initializeOpenCodeReaders();
   const watchStatsStore = new WatchStatsStore();
   const indexingRunner = new WorkerIndexingRunner(dbPath, {
     bookmarksDbPath,
@@ -107,6 +109,7 @@ export async function bootstrapMainProcess(
     DEFAULT_DISCOVERY_CONFIG.geminiRoot,
     geminiHistoryRoot,
     DEFAULT_DISCOVERY_CONFIG.cursorRoot,
+    dirname(DEFAULT_DISCOVERY_CONFIG.opencodeDbPath),
   ];
   registerIpcHandlers(ipcMain, {
     "app:getHealth": () => ({
@@ -128,6 +131,7 @@ export async function bootstrapMainProcess(
         geminiHistoryRoot,
         geminiProjectsPath,
         cursorRoot: DEFAULT_DISCOVERY_CONFIG.cursorRoot,
+        opencodeDbPath: DEFAULT_DISCOVERY_CONFIG.opencodeDbPath,
       },
     }),
     "db:getSchemaVersion": () => ({
@@ -404,6 +408,7 @@ function getAllowedOpenInFileManagerRoots(input: {
   addRoot(input.geminiProjectsPath);
   addRoot(dirname(input.geminiProjectsPath));
   addRoot(DEFAULT_DISCOVERY_CONFIG.cursorRoot);
+  addRoot(dirname(DEFAULT_DISCOVERY_CONFIG.opencodeDbPath));
 
   try {
     // Indexed project paths are dynamic, so fold them into the static provider/app roots cache.

diff --git a/apps/desktop/src/main/indexingRunner.test.ts b/apps/desktop/src/main/indexingRunner.test.ts
@@ -8,7 +8,7 @@ type WorkerMessage =
   | {
       type: "file-issue";
       issue: {
-        provider: "claude" | "codex" | "gemini" | "cursor";
+        provider: "claude" | "codex" | "gemini" | "cursor" | "opencode";
         sessionId: string;
         filePath: string;
         stage: "read" | "parse" | "persist";
@@ -18,7 +18,7 @@ type WorkerMessage =
   | {
       type: "notice";
       notice: {
-        provider: "claude" | "codex" | "gemini" | "cursor";
+        provider: "claude" | "codex" | "gemini" | "cursor" | "opencode";
         sessionId: string;
         filePath: string;
         stage: "read" | "parse" | "persist";
@@ -38,6 +38,7 @@ type WorkerRequest = {
     codex?: string[];
     gemini?: string[];
     cursor?: string[];
+    opencode?: string[];
   };
 };
 
@@ -219,6 +220,7 @@ describe("WorkerIndexingRunner", () => {
         codex: ["^<environment_context>"],
         gemini: [],
         cursor: [],
+        opencode: [],
       }),
     });
 
@@ -233,6 +235,7 @@ describe("WorkerIndexingRunner", () => {
           codex: ["^<environment_context>"],
           gemini: [],
           cursor: [],
+          opencode: [],
         },
       },
       {},

diff --git a/apps/desktop/src/main/indexingWorker.ts b/apps/desktop/src/main/indexingWorker.ts
@@ -8,6 +8,8 @@ import {
   runIncrementalIndexing,
 } from "@codetrail/core";
 
+import { initializeOpenCodeReaders } from "./openCodeReaders";
+
 type IncrementalRequest = {
   kind: "incremental";
   dbPath: string;
@@ -129,6 +131,8 @@ function handleRequest(request: IndexingWorkerRequest): void {
   }
 }
 
+initializeOpenCodeReaders();
+
 if (parentPort) {
   parentPort.on("message", (request: IndexingWorkerRequest) => {
     handleRequest(request);

diff --git a/apps/desktop/src/main/ipc.test.ts b/apps/desktop/src/main/ipc.test.ts
@@ -35,6 +35,7 @@ describe("registerIpcHandlers", () => {
             geminiHistoryRoot: "/Users/test/.gemini/history",
             geminiProjectsPath: "/Users/test/.gemini/projects.json",
             cursorRoot: "/Users/test/.cursor/projects",
+            opencodeDbPath: "/mock/.local/share/opencode/opencode.db",
           },
         }),
         "db:getSchemaVersion": () => ({ schemaVersion: 1 }),
@@ -188,6 +189,7 @@ describe("registerIpcHandlers", () => {
             geminiHistoryRoot: "/Users/test/.gemini/history",
             geminiProjectsPath: "/Users/test/.gemini/projects.json",
             cursorRoot: "/Users/test/.cursor/projects",
+            opencodeDbPath: "/mock/.local/share/opencode/opencode.db",
           },
         }),
         "db:getSchemaVersion": () => ({ schemaVersion: 1 }),

diff --git a/apps/desktop/src/main/openCodeReaders.ts b/apps/desktop/src/main/openCodeReaders.ts
@@ -0,0 +1,157 @@
+import { existsSync } from "node:fs";
+
+import Database from "better-sqlite3";
+
+import { setOpenCodeDbReader, setOpenCodeMessagePartReader } from "@codetrail/core";
+
+function openReadonlyDb(dbPath: string): InstanceType<typeof Database> | null {
+  if (!existsSync(dbPath)) {
+    return null;
+  }
+  try {
+    const db = new Database(dbPath, { readonly: true, fileMustExist: true });
+    db.pragma("journal_mode = WAL");
+    return db;
+  } catch {
+    return null;
+  }
+}
+
+export function initializeOpenCodeReaders(): void {
+  setOpenCodeDbReader({
+    readSessions: (dbPath) => {
+      const db = openReadonlyDb(dbPath);
+      if (!db) {
+        return [];
+      }
+      try {
+        return db
+          .prepare(
+            `SELECT id, project_id, parent_id, title, directory,
+                    time_created, time_updated
+             FROM session
+             ORDER BY time_updated DESC`,
+          )
+          .all() as Array<{
+          id: string;
+          project_id: string;
+          parent_id: string | null;
+          title: string;
+          directory: string;
+          time_created: number;
+          time_updated: number;
+        }>;
+      } finally {
+        db.close();
+      }
+    },
+    readProjects: (dbPath) => {
+      const db = openReadonlyDb(dbPath);
+      if (!db) {
+        return [];
+      }
+      try {
+        return db.prepare("SELECT id, worktree, name FROM project").all() as Array<{
+          id: string;
+          worktree: string;
+          name: string | null;
+        }>;
+      } finally {
+        db.close();
+      }
+    },
+  });
+
+  setOpenCodeMessagePartReader({
+    readSessionMessagesWithParts: (dbPath, sessionId) => {
+      const db = openReadonlyDb(dbPath);
+      if (!db) {
+        return [];
+      }
+      try {
+        const messages = db
+          .prepare(
+            `SELECT id, session_id, time_created, data
+             FROM message
+             WHERE session_id = ?
+             ORDER BY time_created ASC, id ASC`,
+          )
+          .all(sessionId) as Array<{
+          id: string;
+          session_id: string;
+          time_created: number;
+          data: string;
+        }>;
+
+        const parts = db
+          .prepare(
+            `SELECT id, message_id, data
+             FROM part
+             WHERE session_id = ?
+             ORDER BY message_id, id`,
+          )
+          .all(sessionId) as Array<{
+          id: string;
+          message_id: string;
+          data: string;
+        }>;
+
+        const partsByMessage = new Map<string, typeof parts>();
+        for (const part of parts) {
+          const existing = partsByMessage.get(part.message_id) ?? [];
+          existing.push(part);
+          partsByMessage.set(part.message_id, existing);
+        }
+
+        return messages.map((msg) => {
+          let msgData: Record<string, unknown> = {};
+          try {
+            msgData = JSON.parse(msg.data) as Record<string, unknown>;
+          } catch {
+            // ignore
+          }
+
+          const time = msgData.time as Record<string, unknown> | undefined;
+          const tokens = msgData.tokens as Record<string, unknown> | undefined;
+          const path = msgData.path as Record<string, unknown> | undefined;
+          const nestedModel = msgData.model as Record<string, unknown> | undefined;
+
+          const messageParts = partsByMessage.get(msg.id) ?? [];
+          return {
+            messageId: msg.id,
+            role: (msgData.role as string) ?? "user",
+            timeCreated: msg.time_created,
+            timeCompleted:
+              typeof time?.completed === "number" ? (time.completed as number) : null,
+            modelId:
+              (msgData.modelID as string) ??
+              (nestedModel?.modelID as string) ??
+              null,
+            providerId:
+              (msgData.providerID as string) ??
+              (nestedModel?.providerID as string) ??
+              null,
+            cwd: (path?.cwd as string) ?? null,
+            tokenInput: typeof tokens?.input === "number" ? (tokens.input as number) : null,
+            tokenOutput: typeof tokens?.output === "number" ? (tokens.output as number) : null,
+            parts: messageParts.map((p) => {
+              let partData: Record<string, unknown> = {};
+              try {
+                partData = JSON.parse(p.data) as Record<string, unknown>;
+              } catch {
+                // ignore
+              }
+              return {
+                id: p.id,
+                type: (partData.type as string) ?? "unknown",
+                data: p.data,
+              };
+            }),
+          };
+        });
+      } finally {
+        db.close();
+      }
+    },
+  });
+}
diff --git a/apps/desktop/src/renderer/app/constants.ts b/apps/desktop/src/renderer/app/constants.ts
@@ -64,6 +64,7 @@ export const EMPTY_SYSTEM_MESSAGE_REGEX_RULES: SystemMessageRegexRules = {
   codex: [],
   gemini: [],
   cursor: [],
+  opencode: [],
 };
 
 export const SHORTCUT_ITEMS = [

diff --git a/apps/desktop/src/renderer/components/SettingsView.test.tsx b/apps/desktop/src/renderer/components/SettingsView.test.tsx
@@ -35,6 +35,7 @@ const info = {
     geminiHistoryRoot: "/Users/test/.gemini/history",
     geminiProjectsPath: "/Users/test/.gemini/projects.json",
     cursorRoot: "/Users/test/.cursor/projects",
+    opencodeDbPath: "/mock/.local/share/opencode/opencode.db",
   },
 };
 
@@ -111,6 +112,7 @@ function createBaseProps() {
       codex: ["^<environment_context>"],
       gemini: [],
       cursor: [],
+      opencode: [],
     },
     onAddSystemMessageRegexRule: vi.fn(),
     onUpdateSystemMessageRegexRule: vi.fn(),