const express = require('express');
const path = require('path');
const pool = require('./db');
require('dotenv').config();

const app = express();
const PORT = process.env.PORT || 3000;

app.use(express.json());
app.use(express.static(path.join(__dirname, 'public')));

// Get all watchlist items
app.get('/api/watchlist', async (req, res) => {
  try {
    const [rows] = await pool.query('SELECT * FROM watchlist ORDER BY created_at DESC');
    res.json(rows);
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Database error' });
  }
});

// Add a new watchlist item (now accepts poster)
app.post('/api/watchlist', async (req, res) => {
  try {
    const { title, type = 'movie', notes = '', poster = null } = req.body;
    if (!title || !title.trim()) return res.status(400).json({ error: 'Title required' });
    const [result] = await pool.query(
      'INSERT INTO watchlist (title, type, notes, poster) VALUES (?, ?, ?, ?)',
      [title.trim(), type, notes, poster]
    );
    const [rows] = await pool.query('SELECT * FROM watchlist WHERE id = ?', [result.insertId]);
    res.status(201).json(rows[0]);
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Database error' });
  }
});

// Delete an item
app.delete('/api/watchlist/:id', async (req, res) => {
  try {
    const { id } = req.params;
    await pool.query('DELETE FROM watchlist WHERE id = ?', [id]);
    res.json({ success: true });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Database error' });
  }
});

// Toggle watched state
app.put('/api/watchlist/:id/toggle', async (req, res) => {
  try {
    const { id } = req.params;
    const [rows] = await pool.query('SELECT watched FROM watchlist WHERE id = ?', [id]);
    if (!rows.length) return res.status(404).json({ error: 'Not found' });
    const newState = rows[0].watched ? 0 : 1;
    await pool.query('UPDATE watchlist SET watched = ? WHERE id = ?', [newState, id]);
    res.json({ id: Number(id), watched: !!newState });
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Database error' });
  }
});

// Suggest a random unwatched (or any) item
app.get('/api/suggest', async (req, res) => {
  try {
    const onlyUnwatched = req.query.unwatched === '1' || req.query.unwatched === 'true';
    let rows;
    if (onlyUnwatched) {
      [rows] = await pool.query('SELECT * FROM watchlist WHERE watched = 0');
    } else {
      [rows] = await pool.query('SELECT * FROM watchlist');
    }
    if (!rows.length) return res.json({ message: 'No items available' });
    const choice = rows[Math.floor(Math.random() * rows.length)];
    res.json(choice);
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'Database error' });
  }
});

const tmdb = require('./tmdb');

app.get('/api/search', async (req, res) => {
  try {
    const q = req.query.q || req.query.query;
    const type = req.query.type; // optional: movie or tv
    if (!q || !q.trim()) return res.status(400).json({ error: 'query required' });
    const results = await tmdb.search(q.trim(), type);
    res.json(results);
  } catch (err) {
    console.error('TMDb search error:', err?.response?.data || err.message || err);
    res.status(500).json({ error: 'search failed', details: err.message });
  }
});

app.listen(PORT, () => {
  console.log(`Server running on http://localhost:${PORT}`);
});