package database import ( "database/sql" "log" _ "github.com/mattn/go-sqlite3" "github.com/HoHD/PR-Helper/models" ) type DB struct { conn *sql.DB } func New(dbPath string) (*DB, error) { conn, err := sql.Open("sqlite3", dbPath+"?_journal_mode=WAL&_busy_timeout=5000") if err != nil { return nil, err } db := &DB{conn: conn} if err := db.migrate(); err != nil { return nil, err } if err := db.seedDefaults(); err != nil { return nil, err } return db, nil } func (db *DB) Close() error { return db.conn.Close() } func (db *DB) Conn() *sql.DB { return db.conn } func (db *DB) migrate() error { stmts := []string{ `CREATE TABLE IF NOT EXISTS settings ( key TEXT PRIMARY KEY, value TEXT NOT NULL )`, `CREATE TABLE IF NOT EXISTS repositories ( id INTEGER PRIMARY KEY AUTOINCREMENT, url TEXT NOT NULL UNIQUE, local_path TEXT NOT NULL, size_bytes INTEGER DEFAULT 0, cloned_at DATETIME DEFAULT CURRENT_TIMESTAMP, last_used DATETIME DEFAULT CURRENT_TIMESTAMP )`, `CREATE TABLE IF NOT EXISTS analyses ( id INTEGER PRIMARY KEY AUTOINCREMENT, repo_id INTEGER REFERENCES repositories(id), type TEXT NOT NULL, base_ref TEXT NOT NULL, head_ref TEXT NOT NULL, result TEXT, created_at DATETIME DEFAULT CURRENT_TIMESTAMP )`, `CREATE TABLE IF NOT EXISTS review_notes ( id INTEGER PRIMARY KEY AUTOINCREMENT, analysis_id INTEGER REFERENCES analyses(id), scope TEXT NOT NULL, scope_key TEXT NOT NULL, content TEXT NOT NULL, created_at DATETIME DEFAULT CURRENT_TIMESTAMP, updated_at DATETIME DEFAULT CURRENT_TIMESTAMP )`, } for _, s := range stmts { if _, err := db.conn.Exec(s); err != nil { return err } } return nil } func (db *DB) seedDefaults() error { for key, val := range models.DefaultSettings { _, err := db.conn.Exec( `INSERT OR IGNORE INTO settings (key, value) VALUES (?, ?)`, key, val, ) if err != nil { log.Printf("warning: failed to seed setting %s: %v", key, err) } } return nil }