queries.js

const pool = require('./pool');
const loadScheema = require('./scheema');

loadScheema(pool);

const getAllUsers = (request, response) => {
  pool.query('SELECT * FROM users ORDER BY id ASC', (error, result) => {
    if (error) {
      response.status(500);
      throw error;
    }

    response.status(200).json(result.rows);
  });
};

const getUserById = (request, response) => {
  const id = parseInt(request.params.id);

  pool.query('SELECT * FROM users WHERE id = $1', [id], (error, result) => {
    if (error) {
      response.status(500);
    }

    response.status(200).json(result.rows);
  });
};

const createUser = (request, response) => {
  const { name, email } = request.body;

  pool.query(
    'INSERT INTO users (name, email) VALUES ($1, $2) RETURNING id',
    [name, email],
    (error, result) => {
      if (error) {
        response.status(500);
      }

      response.status(201).send(`User's created with id: ${result.rows[0].id}`);
    }
  );
};

const updateUserById = (request, response) => {
  const id = parseInt(request.params.id);
  const { name, email } = request.body;

  pool.query(
    'UPDATE users SET name = $1, email = $2 WHERE id = $3',
    [name, email, id],
    (error, result) => {
      if (error) {
        response.status(500);
      }

      response.status(200).send(`Updated user with id ${id}`);
    }
  );
};

const deleteUserById = (request, response) => {
  const id = parseInt(request.params.id);

  pool.query('DELETE FROM users WHERE id = $1', [id], (error, result) => {
    if (error) {
      response.status(500);
    }

    response.status(200).send(`Deleted user with id ${id}`);
  });
};

module.exports = {
  getAllUsers,
  getUserById,
  createUser,
  updateUserById,
  deleteUserById,
};