import pg from "pg";
import { config } from "./config/index.js";

const { Pool } = pg;

export const db = new Pool({
  connectionString: config.DATABASE_URL,
});

await db.query(`
  CREATE TABLE IF NOT EXISTS users (
    id         TEXT PRIMARY KEY,
    naam       TEXT NOT NULL,
    email      TEXT UNIQUE NOT NULL,
    wachtwoord TEXT NOT NULL,
    rol        TEXT NOT NULL DEFAULT 'Viewer',
    actief     BOOLEAN NOT NULL DEFAULT true,
    aangemaakt TIMESTAMPTZ NOT NULL DEFAULT NOW()
  );

  CREATE TABLE IF NOT EXISTS user_data (
    user_id TEXT PRIMARY KEY,
    data    TEXT NOT NULL
  );
`);

await db.query(`
  ALTER TABLE users ADD COLUMN IF NOT EXISTS aangemaakt TIMESTAMPTZ NOT NULL DEFAULT NOW();
`);

await db.query(`
  ALTER TABLE users ADD COLUMN IF NOT EXISTS avatar TEXT;
`);