import { sql } from "../database/database.js";

const addTopic = async (userId, name) => {
  await sql`INSERT INTO topics (user_id, name) VALUES (${userId}, ${name})`;
};

const countTopics = async () => {
  const result = await sql`SELECT COUNT(id) FROM topics`;
  return result.rows[0].count;
};

const getAllTopics = async () => {
  await sql`SELECT * FROM topics ORDER BY name ASC`;
  return result.rows;
};

const getTopicsByUserId = async (userId) => {
  const result =
    await sql`SELECT * FROM topics WHERE user_id = ${userId} ORDER BY name ASC`;
  return result.rows;
};

const getTopicByTopicId = async (topicId) => {
  const result = await sql`SELECT * FROM topics WHERE id = ${topicId}`;
  return result.rows[0];
};

const deleteTopic = async (topicId) => {
  await sql`DELETE FROM topics WHERE id = ${topicId}`;
};

export {
  addTopic,
  countTopics,
  getAllTopics,
  getTopicsByUserId,
  getTopicByTopicId,
  deleteTopic,
};