database_d_sqlite.v

module main

import config
import db.sqlite
import os

type GitlyDb = sqlite.DB

fn connect_db(conf config.Config) !GitlyDb {
	path := first_env(['GITLY_SQLITE_PATH', 'GITLY_DB_PATH'], conf.sqlite.path)
	mut db := sqlite.connect(path)!
	if db.busy_timeout(10000) != 0 {
		return error('failed to configure sqlite busy timeout')
	}
	db.exec('pragma journal_mode = WAL;') or { eprintln('cannot enable sqlite WAL mode: ${err}') }
	return GitlyDb(db)
}

fn db_backend_name() string {
	return 'sqlite'
}

fn db_exec_values(db &GitlyDb, query string) ![][]string {
	rows := db.exec(query)!
	mut values := [][]string{cap: rows.len}
	for row in rows {
		values << row.vals.clone()
	}
	return values
}

fn db_last_insert_id(db &GitlyDb) int {
	rows := db.exec('select last_insert_rowid()') or { return 0 }
	if rows.len > 0 && rows[0].vals.len > 0 {
		return rows[0].vals[0].int()
	}
	return 0
}

fn db_column_exists(db &GitlyDb, table_name string, column_name string) !bool {
	rows := db_exec_values(db, 'pragma table_info(${sql_table(table_name)})')!
	for row in rows {
		if row.len > 1 && row[1] == column_name {
			return true
		}
	}
	return false
}

fn db_bool_column_type() string {
	return 'INTEGER NOT NULL DEFAULT 0'
}

fn first_env(keys []string, fallback string) string {
	for key in keys {
		value := os.getenv(key)
		if value != '' {
			return value
		}
	}
	return fallback
}