dealing with corrupted history sessions

Author: igorcosta

src/session/SessionManager.ts

@@ -222,7 +222,16 @@ export class SessionManager {
     private async loadIndex(): Promise<void> {
         const indexPath = path.join(this.sessionsDir, 'index.json');
         if (await fs.pathExists(indexPath)) {
-            this.index = await fs.readJson(indexPath) as SessionIndex;
+            try {
+                this.index = await fs.readJson(indexPath) as SessionIndex;
+            } catch (error) {
+                const backupPath = `${indexPath}.corrupt-${Date.now()}`;
+                await fs.move(indexPath, backupPath, { overwrite: true });
+                const reason = error instanceof Error ? error.message : String(error);
+                console.warn(`Session index was corrupt and has been reset: ${reason}. Backup saved to ${backupPath}`);
+                this.index = { sessions: [], byProject: {} };
+                await this.saveIndex();
+            }
         } else {
             this.index = { sessions: [], byProject: {} };
         }

tests/session/SessionManager.test.ts

@@ -7,7 +7,7 @@ import { afterEach, beforeEach, describe, expect, it } from 'vitest';
 import fs from 'fs-extra';
 import path from 'node:path';
 import os from 'node:os';
-import { Session } from '../../src/session/SessionManager.js';
+import { Session, SessionManager } from '../../src/session/SessionManager.js';
 import type { SessionMetadata } from '../../src/session/types.js';
 
 describe('Session', () => {
@@ -50,3 +50,45 @@ describe('Session', () => {
     expect(session.metadata.messageCount).toBe(1);
   });
 });
+
+describe('SessionManager', () => {
+  let tmpDir: string;
+
+  beforeEach(async () => {
+    tmpDir = await fs.mkdtemp(path.join(os.tmpdir(), 'autohand-session-manager-test-'));
+  });
+
+  afterEach(async () => {
+    await fs.remove(tmpDir);
+  });
+
+  it('recovers from a corrupt session index and initializes empty', async () => {
+    const indexPath = path.join(tmpDir, 'index.json');
+    const corruptContent = '{ "sessions": [\n  { "id": "broken\x00"';
+    await fs.writeFile(indexPath, corruptContent);
+
+    const manager = new SessionManager(tmpDir);
+    await expect(manager.initialize()).resolves.toBeUndefined();
+
+    const sessions = await manager.listSessions();
+    expect(sessions).toEqual([]);
+
+    const backupFiles = (await fs.readdir(tmpDir)).filter((f) => f.startsWith('index.json.corrupt-'));
+    expect(backupFiles).toHaveLength(1);
+    expect(await fs.readFile(path.join(tmpDir, backupFiles[0]), 'utf-8')).toBe(corruptContent);
+  });
+
+  it('recovers from an empty session index file', async () => {
+    const indexPath = path.join(tmpDir, 'index.json');
+    await fs.writeFile(indexPath, '');
+
+    const manager = new SessionManager(tmpDir);
+    await expect(manager.initialize()).resolves.toBeUndefined();
+
+    const sessions = await manager.listSessions();
+    expect(sessions).toEqual([]);
+
+    const backupFiles = (await fs.readdir(tmpDir)).filter((f) => f.startsWith('index.json.corrupt-'));
+    expect(backupFiles).toHaveLength(1);
+  });
+});