Storage Management

final class StorageManager: StorageManaging, @unchecked Sendable {
    static let shared = StorageManager()
    
    private let dbURL: URL
    private var db: DatabasePool!
    private let root: URL
    private let backupsDir: URL
    
    var recordingsRoot: URL { root }
    
    private init() {
        let appSupport = fileMgr.urls(for: .applicationSupportDirectory, in: .userDomainMask)[0]
        let baseDir = appSupport.appendingPathComponent("Dayflow", isDirectory: true)
        let recordingsDir = baseDir.appendingPathComponent("recordings", isDirectory: true)
        let backupDir = baseDir.appendingPathComponent("backups", isDirectory: true)
        
        // Ensure directories exist
        try? fileMgr.createDirectory(at: baseDir, withIntermediateDirectories: true)
        try? fileMgr.createDirectory(at: recordingsDir, withIntermediateDirectories: true)
        try? fileMgr.createDirectory(at: backupDir, withIntermediateDirectories: true)
        
        root = recordingsDir
        backupsDir = backupDir
        dbURL = baseDir.appendingPathComponent("chunks.sqlite")
    }
}

private init() {
    // ...
    
    // Run initial purge, then schedule hourly
    purgeIfNeeded()
    TimelapseStorageManager.shared.purgeIfNeeded()
    startPurgeScheduler()
    
    // Schedule WAL checkpoints every 5 minutes
    startCheckpointScheduler()
    
    // Schedule daily backups
    startBackupScheduler()
}

CREATE TABLE IF NOT EXISTS screenshots (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    captured_at INTEGER NOT NULL,
    file_path TEXT NOT NULL,
    file_size INTEGER,
    is_deleted INTEGER DEFAULT 0,
    created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);
CREATE INDEX IF NOT EXISTS idx_screenshots_captured_at ON screenshots(captured_at);

CREATE TABLE IF NOT EXISTS timeline_cards (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    batch_id INTEGER REFERENCES analysis_batches(id) ON DELETE CASCADE,
    start_ts INTEGER,
    end_ts INTEGER,
    is_deleted INTEGER NOT NULL DEFAULT 0,
    ...
);

// Safe database initialization with automatic recovery from backup
db = Self.openDatabaseSafely(
    at: dbURL,
    backupsDir: backupDir,
    config: config,
    fileManager: fileMgr
)

var config = Configuration()
config.maximumReaderCount = 5
config.prepareDatabase { db in
    if !db.configuration.readonly {
        try db.execute(sql: "PRAGMA journal_mode = WAL")
        try db.execute(sql: "PRAGMA synchronous = NORMAL")
    }
    try db.execute(sql: "PRAGMA busy_timeout = 5000")
}

private let debugSlowQueries = true
private let slowThresholdMs: Double = 100  // Log anything over 100ms

#if DEBUG
try? db.write { db in
    db.trace { event in
        if case .profile(let statement, let duration) = event, duration > 0.1 {
            print("📊 SLOW SQL (\(Int(duration * 1000))ms): \(statement)")
        }
    }
}
#endif