1 files changed, 72 insertions, 0 deletions

diff --git a/dist/main/db/sessions.js b/dist/main/db/sessions.js
new file mode 100644
index 0000000..b554898
--- /dev/null
+++ b/dist/main/db/sessions.js
@@ -0,0 +1,72 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.listSessions = listSessions;
+exports.getSession = getSession;
+exports.createSession = createSession;
+exports.updateSession = updateSession;
+exports.deleteSession = deleteSession;
+exports.listMessages = listMessages;
+exports.addMessage = addMessage;
+const index_1 = require("./index");
+const uuid_1 = require("uuid");
+function listSessions(projectId) {
+    return (0, index_1.getDb)()
+        .prepare("SELECT * FROM sessions WHERE project_id = ? ORDER BY updated_at DESC")
+        .all(projectId);
+}
+function getSession(id) {
+    return (0, index_1.getDb)()
+        .prepare("SELECT * FROM sessions WHERE id = ?")
+        .get(id);
+}
+function createSession(projectId, name) {
+    const db = (0, index_1.getDb)();
+    const id = (0, uuid_1.v4)();
+    const now = Math.floor(Date.now() / 1000);
+    db.prepare(`INSERT INTO sessions (id, project_id, name, phase, permission_mode, created_at, updated_at)
+     VALUES (?, ?, ?, 'research', 'acceptEdits', ?, ?)`).run(id, projectId, name, now, now);
+    return {
+        id,
+        project_id: projectId,
+        name,
+        phase: "research",
+        claude_session_id: null,
+        permission_mode: "acceptEdits",
+        created_at: now,
+        updated_at: now,
+    };
+}
+function updateSession(id, updates) {
+    const db = (0, index_1.getDb)();
+    const sets = [];
+    const values = [];
+    for (const [key, value] of Object.entries(updates)) {
+        if (value !== undefined) {
+            sets.push(`${key} = ?`);
+            values.push(value);
+        }
+    }
+    if (sets.length > 0) {
+        sets.push("updated_at = ?");
+        values.push(Math.floor(Date.now() / 1000));
+        values.push(id);
+        db.prepare(`UPDATE sessions SET ${sets.join(", ")} WHERE id = ?`).run(...values);
+    }
+}
+function deleteSession(id) {
+    (0, index_1.getDb)().prepare("DELETE FROM sessions WHERE id = ?").run(id);
+}
+// Messages
+function listMessages(sessionId) {
+    return (0, index_1.getDb)()
+        .prepare("SELECT * FROM messages WHERE session_id = ? ORDER BY created_at ASC")
+        .all(sessionId);
+}
+function addMessage(sessionId, role, content) {
+    const db = (0, index_1.getDb)();
+    const id = (0, uuid_1.v4)();
+    const now = Math.floor(Date.now() / 1000);
+    db.prepare("INSERT INTO messages (id, session_id, role, content, created_at) VALUES (?, ?, ?, ?, ?)").run(id, sessionId, role, content, now);
+    db.prepare("UPDATE sessions SET updated_at = ? WHERE id = ?").run(now, sessionId);
+    return { id, session_id: sessionId, role, content, created_at: now };
+}