import { connect } from '@tursodatabase/database';
import { access, mkdir, readFile } from 'node:fs/promises';
import { dirname, resolve } from 'node:path';
import process from 'node:process';
import { initializeDefaultUsers } from './default-users.mjs';

const databasePath = resolve(process.env.TDR_DATABASE_PATH || './data/shd-build.db');
const schemaPath = resolve('./database/schema.sql');
let databaseAlreadyExisted = true;
try {
	await access(databasePath);
} catch {
	databaseAlreadyExisted = false;
}

await mkdir(dirname(databasePath), { recursive: true });

const database = await connect(databasePath);
const schema = await readFile(schemaPath, 'utf8');

const usersTable = await (await database.prepare(
	"SELECT 1 FROM sqlite_master WHERE type='table' AND name='users'"
)).get();
if (usersTable) {
	const userColumns = await (await database.prepare("PRAGMA table_info('users')")).all();
	if (!userColumns.some((column) => column.name === 'login_username')) {
		console.log('Separating optional local login usernames from internal account identifiers.');
		await database.exec('ALTER TABLE users ADD COLUMN login_username TEXT');
		await database.exec('UPDATE users SET login_username=username WHERE password_hash IS NOT NULL');
	}
}

// The project schema deliberately avoids semicolons inside string literals.
const statements = schema
	.split(';')
	.map((statement) => statement.trim())
	.filter(Boolean);

for (const statement of statements) {
	await database.exec(statement);
}

const loginEventsDefinition = await (await database.prepare(
	"SELECT sql FROM sqlite_master WHERE type='table' AND name='login_events'"
)).get();
if (typeof loginEventsDefinition?.sql === 'string' && !loginEventsDefinition.sql.includes('magic_link')) {
	console.log('Expanding login event providers for passwordless authentication.');
	await database.exec('ALTER TABLE login_events RENAME TO login_events_legacy');
	await database.exec(`CREATE TABLE login_events (
		id TEXT PRIMARY KEY,
		user_id TEXT REFERENCES users(id) ON DELETE SET NULL,
		provider TEXT NOT NULL CHECK(provider IN ('password', 'discord', 'magic_link', 'passkey')),
		succeeded INTEGER NOT NULL CHECK(succeeded IN (0, 1)),
		created_at TEXT NOT NULL
	)`);
	await database.exec(`INSERT INTO login_events(id,user_id,provider,succeeded,created_at)
		SELECT id,user_id,provider,succeeded,created_at FROM login_events_legacy`);
	await database.exec('DROP TABLE login_events_legacy');
	await database.exec('CREATE INDEX IF NOT EXISTS login_events_user_created_idx ON login_events(user_id, created_at DESC)');
}
const loginEventColumns = await (await database.prepare("PRAGMA table_info('login_events')")).all();
for (const [name, definition] of [
	['ip_address', 'TEXT'],
	['user_agent', 'TEXT'],
	['client_name', 'TEXT'],
	['operating_system', 'TEXT'],
	['device_type', 'TEXT'],
	['location_country', 'TEXT'],
	['location_region', 'TEXT'],
	['location_city', 'TEXT'],
	['failure_reason', 'TEXT'],
	['risk_flags', 'TEXT'],
	['credential_id', 'TEXT'],
	['session_id', 'TEXT REFERENCES sessions(id) ON DELETE SET NULL'],
	['session_ended_at', 'TEXT'],
	['session_end_reason', 'TEXT'],
	['sensitive_purged_at', 'TEXT']
]) {
	if (!loginEventColumns.some((column) => column.name === name)) {
		await database.exec(`ALTER TABLE login_events ADD COLUMN ${name} ${definition}`);
	}
}

const proposalColumns = await (await database.prepare("PRAGMA table_info('data_change_proposals')")).all();
for (const [name, definition] of [
	['draft_entity_id', 'TEXT'],
	['applied_entity_id', 'TEXT']
]) {
	if (!proposalColumns.some((column) => column.name === name)) {
		await database.exec(`ALTER TABLE data_change_proposals ADD COLUMN ${name} ${definition}`);
	}
}
await database.exec("UPDATE data_change_proposals SET draft_entity_id=id WHERE draft_entity_id IS NULL AND entity_id IS NULL");
await database.exec('CREATE UNIQUE INDEX IF NOT EXISTS data_change_proposals_draft_entity_idx ON data_change_proposals(draft_entity_id) WHERE draft_entity_id IS NOT NULL');

const proposalDefinition = await (await database.prepare(
	"SELECT sql FROM sqlite_master WHERE type='table' AND name='data_change_proposals'"
)).get();
if (typeof proposalDefinition?.sql === 'string' && !proposalDefinition.sql.includes("'attributes'")) {
	console.log('Renaming the moderated Stats module to Attributes.');
	await database.exec('PRAGMA foreign_keys=OFF');
	await database.exec(`CREATE TABLE data_change_proposals_expanded (
		id TEXT PRIMARY KEY,
		module TEXT NOT NULL CHECK(module IN ('attributes','talents','brands','gear','weapons','protocols','skillchips')),
		action TEXT NOT NULL,
		entity_id TEXT,
		draft_entity_id TEXT,
		applied_entity_id TEXT,
		summary TEXT NOT NULL,
		payload_json TEXT NOT NULL,
		status TEXT NOT NULL DEFAULT 'pending' CHECK(status IN ('pending','approved','rejected','failed')),
		proposed_by TEXT NOT NULL REFERENCES users(id),
		reviewed_by TEXT REFERENCES users(id),
		review_note TEXT,
		created_at TEXT NOT NULL,
		reviewed_at TEXT,
		applied_at TEXT
	)`);
	await database.exec(`INSERT INTO data_change_proposals_expanded
		SELECT id,CASE module WHEN 'stats' THEN 'attributes' ELSE module END,action,entity_id,draft_entity_id,applied_entity_id,summary,payload_json,status,proposed_by,reviewed_by,review_note,created_at,reviewed_at,applied_at
		FROM data_change_proposals`);
	await database.exec('DROP TABLE data_change_proposals');
	await database.exec('ALTER TABLE data_change_proposals_expanded RENAME TO data_change_proposals');
	await database.exec('PRAGMA foreign_keys=ON');
}
await database.exec('CREATE INDEX IF NOT EXISTS data_change_proposals_status_created_idx ON data_change_proposals(status,created_at DESC)');
await database.exec('CREATE INDEX IF NOT EXISTS data_change_proposals_module_status_idx ON data_change_proposals(module,status)');
await database.exec('CREATE UNIQUE INDEX IF NOT EXISTS data_change_proposals_draft_entity_idx ON data_change_proposals(draft_entity_id) WHERE draft_entity_id IS NOT NULL');

const iconDefinition = await (await database.prepare(
	"SELECT sql FROM sqlite_master WHERE type='table' AND name='game_data_icons'"
)).get();
if (typeof iconDefinition?.sql === 'string' && !iconDefinition.sql.includes("'skill_chip'")) {
	console.log('Adding Skill Chip icon storage support.');
	await database.exec(`CREATE TABLE game_data_icons_expanded (
		entity_type TEXT NOT NULL CHECK(entity_type IN ('talent', 'brand_set', 'os_protocol', 'skill_chip')),
		entity_id TEXT NOT NULL,
		storage_key TEXT NOT NULL UNIQUE,
		byte_size INTEGER NOT NULL CHECK(byte_size > 0),
		updated_at TEXT NOT NULL,
		PRIMARY KEY(entity_type, entity_id)
	)`);
	await database.exec(`INSERT INTO game_data_icons_expanded SELECT entity_type,entity_id,storage_key,byte_size,updated_at FROM game_data_icons`);
	await database.exec('DROP TABLE game_data_icons');
	await database.exec('ALTER TABLE game_data_icons_expanded RENAME TO game_data_icons');
}

console.log(`Applied ${statements.length} schema statements to ${databasePath}`);

if (!databaseAlreadyExisted) {
	console.log('New database detected; creating default users.');
	await initializeDefaultUsers(database);
}