Первый HTTP-сервер: модуль node:http, заголовки, статус-коды и парсинг JSON

[ Клиент (Браузер / cURL) ]
             | HTTP/1.1 POST /api/users
             v
[ TCP Socket (node:net) ]
             |
             v
[ llhttp C++ Parser ] ---> Разбор статусной строки и Headers
             |
             +---> Создание IncomingMessage (req) & ServerResponse (res)
             |
             v
[ http.createServer((req, res) => { ... }) ]
             |
     +-------+-------+
     |               |
[ req (Readable) ]   [ res (Writable) ]
 Чанки тела запроса   res.writeHead(200, ...)
 for await (chunk)    res.end(JSON.stringify(payload))

import http from 'node:http';
import { Buffer } from 'node:buffer';

const PORT = 3000;
const MAX_BODY_SIZE = 1024 * 1024; // 1 МБ лимит на полезную нагрузку (защита от DoS)

// Функция безопасного чтения тела запроса через асинхронный итератор стрима
async function readJsonBody<T>(req: http.IncomingMessage): Promise<T> {
  const chunks: Buffer[] = [];
  let totalBytes = 0;

  for await (const chunk of req) {
    const bufferChunk = Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk);
    totalBytes += bufferChunk.byteLength;

    if (totalBytes > MAX_BODY_SIZE) {
      throw new Error('PAYLOAD_TOO_LARGE');
    }
    chunks.push(bufferChunk);
  }

  if (chunks.length === 0) {
    return {} as T;
  }

  const rawString = Buffer.concat(chunks).toString('utf-8');
  try {
    return JSON.parse(rawString) as T;
  } catch {
    throw new Error('INVALID_JSON');
  }
}

// Создание HTTP-сервера
const server = http.createServer(async (req, res) => {
  // Базовый URL для корректного разрешения относительного пути
  const protocol = 'http';
  const host = req.headers.host || 'localhost';
  const parsedUrl = new URL(req.url || '/', `${protocol}://${host}`);

  const { pathname } = parsedUrl;
  const method = req.method?.toUpperCase();

  // 1. Маршрут: GET /healthz
  if (method === 'GET' && pathname === '/healthz') {
    res.writeHead(200, {
      'Content-Type': 'application/json; charset=utf-8',
      'Cache-Control': 'no-store'
    });
    res.end(JSON.stringify({ status: 'ok', uptime: process.uptime() }));
    return;
  }

  // 2. Маршрут: POST /api/users
  if (method === 'POST' && pathname === '/api/users') {
    try {
      const body = await readJsonBody<{ username: string; email: string }>(req);

      if (!body.username || !body.email) {
        res.writeHead(400, { 'Content-Type': 'application/json; charset=utf-8' });
        res.end(JSON.stringify({ error: 'Поля username и email обязательны для заполнения' }));
        return;
      }

      // Успешный ответ со статусом 201 Created
      res.writeHead(201, {
        'Content-Type': 'application/json; charset=utf-8',
        'X-Service-Version': '1.0.0'
      });
      res.end(JSON.stringify({ id: crypto.randomUUID(), ...body, createdAt: Date.now() }));
      return;
    } catch (err: unknown) {
      const errMsg = err instanceof Error ? err.message : 'UNKNOWN_ERROR';
      if (errMsg === 'PAYLOAD_TOO_LARGE') {
        res.writeHead(413, { 'Content-Type': 'application/json; charset=utf-8' });
        res.end(JSON.stringify({ error: 'Размер тела запроса превышает допустимый лимит 1 МБ' }));
        return;
      }

      res.writeHead(400, { 'Content-Type': 'application/json; charset=utf-8' });
      res.end(JSON.stringify({ error: 'Некорректный синтаксис JSON в теле запроса' }));
      return;
    }
  }

  // 3. Fallback: 404 Not Found для всех неизвестных путей
  res.writeHead(404, { 'Content-Type': 'application/json; charset=utf-8' });
  res.end(JSON.stringify({ error: `Маршрут ${method} ${pathname} не найден` }));
});

// Запуск прослушивания сокета
server.listen(PORT, '0.0.0.0', () => {
  console.log(`HTTP Server successfully listening on http://0.0.0.0:${PORT}`);
});