import { cassandra } from "@lib/cassandra";

async function createTable() {
	const client = cassandra.getClient();

	await client.execute(`
		CREATE TABLE IF NOT EXISTS channels (
			id TEXT PRIMARY KEY,
			guild_id TEXT,
			name TEXT,
			type TEXT,
			topic TEXT,
			position INT,
			category_id TEXT,
			created_at TIMESTAMP,
			updated_at TIMESTAMP
		);
	`);

	await client.execute(`
		CREATE INDEX IF NOT EXISTS channels_guild_id_idx ON channels (guild_id);
	`);

	await client.execute(`
		CREATE INDEX IF NOT EXISTS channels_category_id_idx ON channels (category_id);
	`);
}

async function dropTable() {
	const client = cassandra.getClient();

	await client.execute("DROP TABLE IF EXISTS channels;");
	await client.execute("DROP INDEX IF EXISTS channels_guild_id_idx;");
	await client.execute("DROP INDEX IF EXISTS channels_category_id_idx;");
}

export { createTable, dropTable };