const { pool } = require("../triggerBackend.cjs");
const escapeString = require("sql-escape-string");

const getSearchHistory = async (_req, res) => {
	const conn = await pool.getConnection();
	const query =
		"SELECT * FROM trigger_database.searchHistory ORDER BY dateTimeStamp DESC;";
	conn.query(query).then((rows) => {
		res.status(200).send(rows);
	});
	conn.end();
};

const addSearchHistoryItem = async (req, res) => {
	const conn = await pool.getConnection();
	const query = `INSERT INTO trigger_database.searchHistory (prefix, provider, searchTerm) VALUES (${escapeString(req.body.prefix)}, ${escapeString(req.body.provider)}, ${escapeString(req.body.searchTerm)})`;
	conn
		.query(query)
		.then((_rows) => {
			res.status(200).send({ status: "success" });
		})
		.catch((err) => {
			res.status(500).send({ error: err });
		});
	conn.end();
};

const deleteSearchHistoryItem = async (req, res) => {
	const conn = await pool.getConnection();
	const query = `DELETE FROM trigger_database.searchHistory WHERE id = ${req.body.id}`;
	conn
		.query(query)
		.then((_rows) => {
			res.status(200).send({ status: "success" });
		})
		.catch((err) => {
			res.status(500).send({ error: err });
		});
	conn.end();
};

module.exports = {
	getSearchHistory,
	addSearchHistoryItem,
	deleteSearchHistoryItem,
};