Metrics · fullstack.org.ua

fullstack.org.ua

Metrics · fullstack.org.ua

javascript

const http = require('node:http');

const metrics = {
  requestsTotal: 0,
  errorsTotal: 0,
  activeRequests: 0,
  durationsMs: [],
};

function observeDuration(durationMs) {
  metrics.durationsMs.push(durationMs);

  // Зберігаємо лише останні 1000 вимірювань.
  if (metrics.durationsMs.length > 1000) {
    metrics.durationsMs.shift();
  }
}

function percentile(values, percentileValue) {
  if (values.length === 0) {
    return 0;
  }

  const sorted = [...values].sort((a, b) => a - b);
  const index = Math.ceil((percentileValue / 100) * sorted.length) - 1;

  return sorted[Math.max(0, index)];
}

function formatMetrics() {
  const durations = metrics.durationsMs;

  return [
    '# HELP app_requests_total Загальна кількість HTTP-запитів',
    '# TYPE app_requests_total counter',
    `app_requests_total ${metrics.requestsTotal}`,

    '# HELP app_errors_total Загальна кількість помилок',
    '# TYPE app_errors_total counter',
    `app_errors_total ${metrics.errorsTotal}`,

    '# HELP app_active_requests Поточна кількість активних запитів',
    '# TYPE app_active_requests gauge',
    `app_active_requests ${metrics.activeRequests}`,

    '# HELP app_request_duration_ms_95 95-й перцентиль тривалості запитів у мілісекундах',
    '# TYPE app_request_duration_ms_95 gauge',
    `app_request_duration_ms_95 ${percentile(durations, 95).toFixed(2)}`,

    '',
  ].join('\n');
}

const server = http.createServer(async (request, response) => {
  const startedAt = process.hrtime.bigint();

  metrics.requestsTotal += 1;
  metrics.activeRequests += 1;

  try {
    if (request.url === '/metrics') {
      response.writeHead(200, {
        'Content-Type': 'text/plain; version=0.0.4',
      });
      response.end(formatMetrics());
      return;
    }

    if (request.url === '/hello') {
      await new Promise((resolve) => setTimeout(resolve, 50));

      response.writeHead(200, {
        'Content-Type': 'application/json; charset=utf-8',
      });
      response.end(JSON.stringify({ message: 'Привіт!' }));
      return;
    }

    metrics.errorsTotal += 1;
    response.writeHead(404, {
      'Content-Type': 'application/json; charset=utf-8',
    });
    response.end(JSON.stringify({ error: 'Не знайдено' }));
  } catch (error) {
    metrics.errorsTotal += 1;

    response.writeHead(500, {
      'Content-Type': 'application/json; charset=utf-8',
    });
    response.end(JSON.stringify({ error: 'Внутрішня помилка' }));
  } finally {
    const finishedAt = process.hrtime.bigint();
    const durationMs = Number(finishedAt - startedAt) / 1_000_000;

    observeDuration(durationMs);
    metrics.activeRequests -= 1;
  }
});

server.listen(3000, () => {
  console.log('Сервер запущено на http://localhost:3000');
});