const pool = require("../db/pool");


exports.getUnboughtItems = async () => {
  const result = await pool.query(
    "SELECT * FROM grocery_list WHERE bought = FALSE ORDER BY id ASC"
  );
  return result.rows;
};

exports.getItemByName = async (itemName) => {
  const result = await pool.query(
    "SELECT * FROM grocery_list WHERE item_name ILIKE $1",
    [itemName]
  );

  return result.rows[0] || null;
};


exports.addOrUpdateItem = async (itemName, quantity) => {
  const result = await pool.query(
    "SELECT id, bought FROM grocery_list WHERE item_name ILIKE $1",
    [itemName]
  );

  if (result.rowCount > 0) {
    await pool.query(
      `UPDATE grocery_list 
      SET quantity = $1, 
        bought = FALSE 
      WHERE id = $2`,
      [quantity, result.rows[0].id]
    );
    return result.rows[0].id;
  } else {
    const insert = await pool.query(
      `INSERT INTO grocery_list 
      (item_name, quantity) 
      VALUES ($1, $2) RETURNING id`,
      [itemName, quantity]
    );
    return insert.rows[0].id;
  }
};


exports.setBought = async (id) => {
  await pool.query("UPDATE grocery_list SET bought = TRUE WHERE id = $1", [id]);
};


exports.addHistoryRecord = async (itemId, quantity) => {
  await pool.query(
    `INSERT INTO grocery_history (list_item_id, quantity, added_on)
     VALUES ($1, $2, NOW())`,
    [itemId, quantity]
  );
};


exports.getSuggestions = async (query) => {
  const result = await pool.query(
    `SELECT DISTINCT item_name 
       FROM grocery_list 
       WHERE item_name ILIKE $1
       LIMIT 10`,
    [`%${query}%`]
  );
  res = result.rows;
  return result.rows;
};