myRepository.js

import pool from '../db.js';

const myRepository = {
  async getCombinationsByUserId(userId) {
    const query = `
      SELECT id, name 
      FROM combinations 
      WHERE owner_id = $1
    `;
    const values = [userId];

    const { rows } = await pool.query(query, values);
    return rows;
  },

  async getPartIdsByCombinationId(combinationId) {
    const query = `
      SELECT part_id 
      FROM relations 
      WHERE combination_id = $1
    `;
    const values = [combinationId];

    const { rows } = await pool.query(query, values);
    return rows.map((row) => row.part_id);
  },

  async saveTransaction(userId, transactionId) {
    const query = `
      INSERT INTO transactions (user_id, id, created_at, updated_at)
      VALUES ($1, $2, NOW(), NOW())
    `;
    const values = [userId, transactionId];
    await pool.query(query, values);
  },

  async getCombinationIdByTransactionId(transactionId) {
    const query = `
      SELECT combination_id
      FROM Pcregister_Transection
      WHERE transection_id = $1
    `;
    const values = [transactionId];
    const { rows } = await pool.query(query, values);

    return rows.length > 0 ? rows[0].combination_id : null;
  },
};

export default myRepository;