server.js

const { app, pool, ensureAuthenticated } = require('./app');
const port = 3000;

// Подключение маршрутов
const housesRouter = require('./routes/houses')(pool, ensureAuthenticated);
app.use('/api/houses', housesRouter);

// Функция для инициализации таблиц
const initDb = async () => {
    try {
        const client = await pool.connect();
        console.log("Попытка инициализации таблиц...");

        // 1. ТАБЛИЦА USERS
        await client.query(`
            CREATE TABLE IF NOT EXISTS users (
                id SERIAL PRIMARY KEY,
                google_id VARCHAR(255) UNIQUE NOT NULL,
                email VARCHAR(255) UNIQUE NOT NULL,
                name VARCHAR(255),
                created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
            );
        `);

        // 2. ТАБЛИЦА HOUSES
        await client.query(`
            CREATE TABLE IF NOT EXISTS houses (
                id SERIAL PRIMARY KEY,
                name TEXT NOT NULL,
                zip_code TEXT,
                user_id INTEGER REFERENCES users(id) ON DELETE CASCADE NOT NULL
            );
        `);

        // 3. ТАБЛИЦА ROOMS
        await client.query(`
            CREATE TABLE IF NOT EXISTS rooms (
                id SERIAL PRIMARY KEY,
                name TEXT NOT NULL,
                house_id INTEGER REFERENCES houses(id) ON DELETE CASCADE,
                user_id INTEGER REFERENCES users(id) ON DELETE CASCADE NOT NULL
            );
        `);

        // 4. ТАБЛИЦА ITEMS
        await client.query(`
            CREATE TABLE IF NOT EXISTS items (
                id SERIAL PRIMARY KEY,
                name TEXT NOT NULL,
                description TEXT,
                type TEXT NOT NULL,
                room_id INTEGER REFERENCES rooms(id) ON DELETE CASCADE,
                parent_item_id INTEGER REFERENCES items(id) ON DELETE CASCADE,
                is_on_floor BOOLEAN DEFAULT FALSE,
                user_id INTEGER REFERENCES users(id) ON DELETE CASCADE NOT NULL
            );
        `);

        // 5. ТАБЛИЦА GHOST_LOCATIONS (уже есть)
        await client.query(`
            CREATE TABLE IF NOT EXISTS ghost_locations (
                id SERIAL PRIMARY KEY,
                item_id INTEGER REFERENCES items(id) ON DELETE CASCADE NOT NULL,
                location_name VARCHAR(255) NOT NULL,
                user_id INTEGER REFERENCES users(id) ON DELETE CASCADE NOT NULL,
                UNIQUE (item_id, location_name)
            );
        `);

        // ======= НОВОЕ: memberships / invites / notifications / owner_id =======
        await client.query(`
            CREATE TABLE IF NOT EXISTS house_memberships (
                id SERIAL PRIMARY KEY,
                house_id INTEGER NOT NULL REFERENCES houses(id) ON DELETE CASCADE,
                user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
                role TEXT NOT NULL DEFAULT 'viewer',
                created_at timestamptz DEFAULT now(),
                UNIQUE (house_id, user_id)
            );
        `);

        await client.query(`
            CREATE TABLE IF NOT EXISTS house_invites (
                id SERIAL PRIMARY KEY,
                house_id INTEGER NOT NULL REFERENCES houses(id) ON DELETE CASCADE,
                token TEXT NOT NULL UNIQUE,
                role TEXT NOT NULL DEFAULT 'viewer',
                created_by INTEGER REFERENCES users(id),
                expires_at timestamptz,
                used BOOLEAN DEFAULT false,
                created_at timestamptz DEFAULT now()
            );
        `);

        await client.query(`
            CREATE TABLE IF NOT EXISTS notifications (
                id SERIAL PRIMARY KEY,
                user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
                payload JSONB,
                message TEXT,
                seen BOOLEAN DEFAULT false,
                created_at timestamptz DEFAULT now()
            );
        `);

        // owner_id для items (если ещё нет)
        await client.query(`
            ALTER TABLE items
            ADD COLUMN IF NOT EXISTS owner_id INTEGER REFERENCES users(id);
        `);

        // дополнительные индексы (при необходимости)
        await client.query(`CREATE INDEX IF NOT EXISTS idx_house_invites_token ON house_invites(token);`);
        await client.query(`CREATE INDEX IF NOT EXISTS idx_house_memberships_house_id ON house_memberships(house_id);`);
        await client.query(`CREATE INDEX IF NOT EXISTS idx_notifications_user_id ON notifications(user_id);`);
        // ======= конец нового блока =======

        client.release();
        console.log("Таблицы успешно инициализированы или уже существуют.");
    } catch (err) {
        console.error('Ошибка инициализации базы данных:', err.stack);
        // Не вызываем throw, чтобы сервер мог запуститься, но это плохая практика
    }
};

const startServer = async () => {
    await initDb();
    app.listen(port, () => {
        console.log(`Server running at http://localhost:${port}`);
    });
};

startServer();