const express = require("express");
const router = express.Router();
const { getConnection, sql } = require("./db");

// Obtener todas las pastelerías
router.get("/pastelerias", async (req, res) => {
  const pool = await getConnection();
  const result = await pool.request().query("SELECT * FROM Pastelerias");
  res.json(result.recordset);
});

// Obtener productos por pastelería
router.get("/productos/:id", async (req, res) => {
  const { id } = req.params;
  const pool = await getConnection();
  const result = await pool.request()
    .input("id", sql.Int, id)
    .query("SELECT * FROM Productos WHERE pasteleria_id = @id");
  res.json(result.recordset);
});

// Agregar nuevo producto
router.post("/productos", async (req, res) => {
  const { nombre, precio, imagen, pasteleria_id } = req.body;
  const pool = await getConnection();
  await pool.request()
    .input("nombre", sql.NVarChar, nombre)
    .input("precio", sql.Decimal(10, 2), precio)
    .input("imagen", sql.NVarChar, imagen)
    .input("pasteleria_id", sql.Int, pasteleria_id)
    .query("INSERT INTO Productos (nombre, precio, imagen, pasteleria_id) VALUES (@nombre, @precio, @imagen, @pasteleria_id)");
  res.send({ message: "Producto agregado correctamente" });
});

module.exports = router;
