import { hashPassword } from "../src/worker/lib/password";

async function readPassword() {
	if (!process.stdin.isTTY) {
		return (await new Response(Bun.stdin.stream()).text()).trimEnd();
	}

	process.stdout.write("Password: ");
	process.stdin.setRawMode(true);
	process.stdin.resume();
	process.stdin.setEncoding("utf8");

	return new Promise<string>((resolve, reject) => {
		let password = "";
		const cleanup = () => {
			process.stdin.setRawMode(false);
			process.stdin.pause();
			process.stdout.write("\n");
		};

		process.stdin.on("data", (key: string) => {
			if (key === "\u0003") {
				cleanup();
				reject(new Error("Cancelled"));
				return;
			}
			if (key === "\r" || key === "\n") {
				cleanup();
				resolve(password);
				return;
			}
			if (key === "\u007f" || key === "\b") {
				password = password.slice(0, -1);
				return;
			}
			password += key;
		});
	});
}

function sqlValue(value: string) {
	return `'${value.replaceAll("'", "''")}'`;
}

function shellDoubleQuoted(value: string) {
	return value.replace(/[\\"$`]/g, "\\$&");
}

const password = await readPassword();
if (password.length < 8) {
	console.error("Password must contain at least 8 characters.");
	process.exit(1);
}

const now = Date.now();
const statement = [
	"INSERT OR REPLACE INTO admin_credentials",
	"(id, password_hash, created_at, updated_at)",
	`VALUES (1, ${sqlValue(await hashPassword(password))}, ${now}, ${now});`,
].join(" ");

console.log("\nLocal database:");
console.log(`bunx wrangler d1 execute uptime --local --command "${shellDoubleQuoted(statement)}"`);
console.log("\nRemote database:");
console.log(`bunx wrangler d1 execute uptime --remote --command "${shellDoubleQuoted(statement)}"`);