Clean up LightningFS on failed clone and eviction

- Wipe partial git objects on clone failure so retries
  start clean instead of reading corrupt pack data
- Delete LightningFS IndexedDB databases when repos are
  deleted, evicted, or cleared from the results cache
- Extract shared repoToFsName helper in url.ts

Author: vdavid

src/lib/cache.ts

@@ -1,5 +1,6 @@
 import { openDB, type IDBPDatabase } from 'idb'
 import type { AnalysisResult } from './types'
+import { repoUrlToFsName } from './url'
 
 const dbName = 'git-strata'
 const dbVersion = 2
@@ -57,6 +58,15 @@ const notifyCacheChange = () => {
     }
 }
 
+/** Delete the LightningFS IndexedDB database for a repo. Fire-and-forget. */
+const deleteLfsDatabase = (repoUrl: string): void => {
+    try {
+        indexedDB.deleteDatabase(repoUrlToFsName(repoUrl))
+    } catch {
+        // Invalid URL or indexedDB unavailable — nothing to clean up
+    }
+}
+
 const estimateSize = (value: unknown): number => {
     try {
         return new Blob([JSON.stringify(value)]).size
@@ -144,15 +154,19 @@ export const deleteRepo = async (repoUrl: string): Promise<void> => {
     tx.objectStore(storeName).delete(repoUrl)
     tx.objectStore(metaStoreName).delete(repoUrl)
     await tx.done
+    deleteLfsDatabase(repoUrl)
     notifyCacheChange()
 }
 
 export const clearAll = async (): Promise<void> => {
     const db = await getDb()
+    // Read all repo URLs before clearing so we can delete their LightningFS databases
+    const metas = (await db.getAll(metaStoreName)) as CachedRepoInfo[]
     const tx = db.transaction([storeName, metaStoreName], 'readwrite')
     tx.objectStore(storeName).clear()
     tx.objectStore(metaStoreName).clear()
     await tx.done
+    for (const meta of metas) deleteLfsDatabase(meta.repoUrl)
     notifyCacheChange()
 }
 
@@ -187,5 +201,6 @@ const evictIfNeeded = async (db: IDBPDatabase, neededBytes: number, excludeUrl:
             tx.objectStore(metaStoreName).delete(url)
         }
         await tx.done
+        for (const url of toDelete) deleteLfsDatabase(url)
     }
 }

src/lib/url.ts

@@ -69,3 +69,13 @@ export const parseRepoUrl = (input: string): ParsedRepo => {
 export const repoToDir = (parsed: ParsedRepo): string => {
     return `/${parsed.host}/${parsed.owner}/${parsed.repo}`
 }
+
+/** LightningFS IndexedDB database name for a parsed repo. */
+export const repoToFsName = (parsed: ParsedRepo): string => {
+    return `git-strata-${parsed.host}-${parsed.owner}-${parsed.repo}`
+}
+
+/** LightningFS IndexedDB database name from a normalized repo URL (like https://github.com/owner/repo). */
+export const repoUrlToFsName = (repoUrl: string): string => {
+    return repoToFsName(parseRepoUrl(repoUrl))
+}

src/lib/worker/analyzer.worker.ts

@@ -11,7 +11,7 @@ import { cloneRepo, detectDefaultBranch, fetchRepo, waitForBodyCleanups } from '
 import { fillDateGaps, getCommitsByDate, type DailyCommit } from '../git/history'
 import { countLinesForCommit, countLinesForCommitIncremental, LruMap } from '../git/count'
 import type { FileState } from '../git/count'
-import { parseRepoUrl, repoToDir } from '../url'
+import { parseRepoUrl, repoToDir, repoToFsName } from '../url'
 
 // Configure LogTape for the worker context
 configureSync({
@@ -47,7 +47,7 @@ const classifyError = (error: unknown): { message: string; kind: ErrorKind } =>
     ) {
         if (lower.includes('network') || lower.includes('offline') || lower.includes('lost'))
             return {
-                message: 'Network connection lost. Your partial download is saved — reconnect and try again.',
+                message: 'Network connection lost. Reconnect and try again.',
                 kind: 'network-lost',
             }
         return {
@@ -191,7 +191,7 @@ const analyzerApi = {
         const dir = repoToDir(parsed)
 
         // Initialize lightning-fs with a unique name for persistence
-        const fsName = `git-strata-${parsed.host}-${parsed.owner}-${parsed.repo}`
+        const fsName = repoToFsName(parsed)
         const fs = new LightningFS(fsName)
 
         try {
@@ -216,15 +216,24 @@ const analyzerApi = {
                 url: parsed.url,
                 branch: defaultBranch,
             })
-            await cloneRepo({
-                fs,
-                dir,
-                url: parsed.url,
-                corsProxy,
-                defaultBranch,
-                onProgress,
-                signal,
-            })
+            try {
+                await cloneRepo({
+                    fs,
+                    dir,
+                    url: parsed.url,
+                    corsProxy,
+                    defaultBranch,
+                    onProgress,
+                    signal,
+                })
+            } catch (cloneError) {
+                // Wipe partially-written git objects so the next retry starts clean.
+                // Without this, a failed clone leaves corrupt data in IndexedDB and
+                // subsequent attempts read half-written pack files.
+                logger.warning('Clone failed, wiping LightningFS database "{fsName}"', { fsName })
+                new LightningFS(fsName, { wipe: true })
+                throw cloneError
+            }
             logger.info('Clone complete')
 
             if (signal.aborted) {
@@ -329,7 +338,7 @@ const analyzerApi = {
         const signal = abortController.signal
         const parsed = parseRepoUrl(repoInput)
         const dir = repoToDir(parsed)
-        const fsName = `git-strata-${parsed.host}-${parsed.owner}-${parsed.repo}`
+        const fsName = repoToFsName(parsed)
         const fs = new LightningFS(fsName)
         const defaultBranch = cachedResult.defaultBranch