main.js

'use strict';

const http = require('node:http');
const pg = require('pg');
const hash = require('./hash.js');
const receiveArgs = require('./body.js');

const PORT = 8000;

const pool = new pg.Pool({
  host: '127.0.0.1',
  port: 5432,
  database: 'example',
  user: 'marcus',
  password: 'marcus',
});

const routing = {
  user: {
    async get(id) {
      if (!id) return pool.query('SELECT id, login FROM users');
      const sql = 'SELECT id, login FROM users WHERE id = $1';
      return await pool.query(sql, [id]);
    },

    async post({ login, password }) {
      const sql = 'INSERT INTO users (login, password) VALUES ($1, $2)';
      const passwordHash = await hash(password);
      return await pool.query(sql, [login, passwordHash]);
    },

    async put(id, { login, password }) {
      const sql = 'UPDATE users SET login = $1, password = $2 WHERE id = $3';
      const passwordHash = await hash(password);
      return await pool.query(sql, [login, passwordHash, id]);
    },

    async delete(id) {
      const sql = 'DELETE FROM users WHERE id = $1';
      return await pool.query(sql, [id]);
    },
  },
};

http.createServer(async (req, res) => {
  const { method, url, socket } = req;
  const [name, id] = url.substring(1).split('/');
  const entity = routing[name];
  if (!entity) return void res.end('Not found');
  const handler = entity[method.toLowerCase()];
  if (!handler) return void res.end('Not found');
  const src = handler.toString();
  const signature = src.substring(0, src.indexOf(')'));
  const args = [];
  if (signature.includes('(id')) args.push(id);
  if (signature.includes('{')) args.push(await receiveArgs(req));
  console.log(`${socket.remoteAddress} ${method} ${url}`);
  const result = await handler(...args);
  res.end(JSON.stringify(result.rows));
}).listen(PORT);

console.log(`Listen on port ${PORT}`);