import {pool} from '../lib/database.js';

export const createNewOffer = async (req, res) => {
    try {
        const { nombre, descripcion, precio, id_usuario } = req.body;
        let imagePath = null;
        if (req.processedFilename) {
            imagePath = `/uploads/${req.processedFilename}`;
        }
        const query = await pool.query(
            `INSERT INTO oferta (nombre, descripcion, precio, imagen, fecha_publicacion, id_usuario) 
             VALUES ($1, $2, $3, $4, NOW(), $5)
                RETURNING *`,
            [nombre, descripcion, precio, imagePath, id_usuario]
        );
        res.status(201).json(query.rows[0]);
    } catch (err) {
        console.error('Error creating offer:', err);
        res.status(500).json({
            error: 'Error al crear la oferta: ' + err.message
        });
    }
}

export const getOfferById = async (req, res) => {
    try {
        const { id_oferta } = req.params;
        const query = await pool.query(
            `SELECT usuarios.nombre, usuarios.apellido_pa, usuarios.apellido_ma, oferta.*
             FROM oferta
                JOIN usuarios ON oferta.id_usuario = usuarios.id_usuario
                WHERE id_oferta = $1`,
            [id_oferta]
        );
        res.json(query.rows[0]);
    } catch (err) {
        console.error(err);
        res.status(500).json({ error: err.message });
        throw err;
    }
}
export const getAllOffers = async (req, res) => {
    try {
        const query = await pool.query(
            `SELECT usuarios.nombre, usuarios.apellido_pa, usuarios.apellido_ma, oferta.*
                FROM oferta
                JOIN usuarios ON oferta.id_usuario = usuarios.id_usuario
                ORDER BY oferta.fecha_publicacion DESC`
        );
        res.json(query.rows);
    } catch (err) {
        console.error(err);
        res.status(500).json({ error: err.message });
        throw err;
    }
}

export const editOffer = async (req, res) => {
    try {
        const { id_oferta } = req.params;
        const { nombre, descripcion, precio } = req.body;
        const query = await pool.query(
            'UPDATE oferta SET nombre = $1, descripcion = $2, precio = $3 WHERE id_oferta = $4 RETURNING *',
            [nombre, descripcion, precio, id_oferta]
        );
        res.json(query.rows[0]);
    } catch (err) {
        console.error(err);
        res.status(500).json({ error: err.message });
        throw err;
    }
}

export const deleteOffer = async (req, res) => {
    try {
        const { id_oferta } = req.params;
        const query = await pool.query(
            'DELETE FROM oferta WHERE id_oferta = $1 RETURNING *',
            [id_oferta]
        );
        res.json(query.rows[0]);
    } catch (err) {
        console.error(err);
        res.status(500).json({ error: err.message });
        throw err;
    }
}

export const getOffersByUserId = async (req, res) => {
    try {
        const { id_usuario } = req.params;
        const query = await pool.query(
            `SELECT usuarios.nombre, usuarios.apellido_pa, usuarios.apellido_ma, oferta.*
             FROM oferta
                JOIN usuarios ON oferta.id_usuario = usuarios.id_usuario
                WHERE usuarios.id_usuario = $1
                ORDER BY oferta.fecha_publicacion DESC`,
            [id_usuario]
        );
        res.json(query.rows);
    }
    catch (err) {
        console.error(err);
        res.status(500).json({ error: err.message });
        throw err;
    }
}