server.js

const express = require('express');
const { pool, initializeDatabase } = require('./db');

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

app.use(express.json());
app.use(express.static('public'));

/* =========================================================
   GET ALL ISSUES
========================================================= */

app.get('/api/issues', async (req, res) => {
  try {
    const result = await pool.query(
      'SELECT * FROM issues ORDER BY id DESC'
    );

    res.json(result.rows);
  } catch (error) {
    console.error('GET /api/issues error:', error);
    res.status(500).json({
      error: 'Failed to fetch issues'
    });
  }
});


/* =========================================================
   CREATE ISSUE
========================================================= */

app.post('/api/issues', async (req, res) => {
  try {
    const { title, description, category } = req.body;

    if (!title || title.trim().length < 5) {
      return res.status(400).json({
        error: 'Title must be at least 5 characters'
      });
    }

    if (!category || category.trim() === '') {
      return res.status(400).json({
        error: 'Category is required'
      });
    }

    const result = await pool.query(
      `
      INSERT INTO issues
        (title, description, category)
      VALUES
        ($1, $2, $3)
      RETURNING *
      `,
      [
        title.trim(),
        description || '',
        category.trim()
      ]
    );

    res.status(201).json(result.rows[0]);

  } catch (error) {
    console.error('POST /api/issues error:', error);

    res.status(500).json({
      error: 'Failed to create issue'
    });
  }
});


/* =========================================================
   UPDATE ISSUE
========================================================= */

app.put('/api/issues/:id', async (req, res) => {
  try {
    const id = parseInt(req.params.id, 10);

    if (Number.isNaN(id)) {
      return res.status(400).json({
        error: 'Invalid issue ID'
      });
    }

    // Check that the issue exists
    const existingResult = await pool.query(
      'SELECT * FROM issues WHERE id = $1',
      [id]
    );

    if (existingResult.rows.length === 0) {
      return res.status(404).json({
        error: 'Issue not found'
      });
    }

    const existing = existingResult.rows[0];

    const {
      title,
      description,
      category,
      status
    } = req.body;


    // Validate title
    if (
      title !== undefined &&
      (!title || title.trim() === '')
    ) {
      return res.status(400).json({
        error: 'Title cannot be empty'
      });
    }


    // Accept both UI labels and database values
    const statusMap = {
      open: 'open',
      'Open': 'open',

      'in-progress': 'in-progress',
      'In Progress': 'in-progress',

      resolved: 'resolved',
      'Resolved': 'resolved'
    };

    let normalizedStatus = existing.status;

    if (status !== undefined) {
      normalizedStatus = statusMap[status];

      if (!normalizedStatus) {
        return res.status(400).json({
          error: 'Invalid status value'
        });
      }
    }


    const result = await pool.query(
      `
      UPDATE issues
      SET
        title = $1,
        description = $2,
        category = $3,
        status = $4
      WHERE id = $5
      RETURNING *
      `,
      [
        title !== undefined
          ? title.trim()
          : existing.title,

        description !== undefined
          ? description
          : existing.description,

        category !== undefined
          ? category
          : existing.category,

        normalizedStatus,

        id
      ]
    );

    res.json(result.rows[0]);

  } catch (error) {
    console.error('PUT /api/issues/:id error:', error);

    res.status(500).json({
      error: 'Failed to update issue'
    });
  }
});


/* =========================================================
   DELETE ISSUE
========================================================= */

app.delete('/api/issues/:id', async (req, res) => {
  try {
    const id = parseInt(req.params.id, 10);

    if (Number.isNaN(id)) {
      return res.status(400).json({
        error: 'Invalid issue ID'
      });
    }

    const result = await pool.query(
      'DELETE FROM issues WHERE id = $1 RETURNING *',
      [id]
    );

    if (result.rows.length === 0) {
      return res.status(404).json({
        error: 'Issue not found'
      });
    }

    res.status(204).send();

  } catch (error) {
    console.error('DELETE /api/issues/:id error:', error);

    res.status(500).json({
      error: 'Failed to delete issue'
    });
  }
});


/* =========================================================
   START SERVER
========================================================= */

async function startServer() {
  try {
    await initializeDatabase();

    app.listen(PORT, '0.0.0.0', () => {
      console.log(`Server running on port ${PORT}`);
    });

  } catch (error) {
    console.error(
      'Failed to initialize database:',
      error
    );

    process.exit(1);
  }
}

startServer();