uWebSockets.js

import { App } from 'uWebSockets.js';

App()
  // Route-параметри через :param
  .get('/api/users/:id', (res, req) => {
    const id = req.getParameter(0);  // перший :param
    res.end(`User ID: ${id}`);
  })

  // Кілька параметрів у маршруті
  .get('/api/:version/items/:itemId', (res, req) => {
    const version = req.getParameter(0); // "v1"
    const itemId  = req.getParameter(1); // "42"
    res.end(`${version} → item ${itemId}`);
  })

  // Query-параметри — парсимо вручну
  .get('/search', (res, req) => {
    const query = req.getQuery();       // "q=hello&page=2"
    const params = new URLSearchParams(query);
    const q    = params.get('q');      // "hello"
    const page = params.get('page');   // "2"
    res.end(`Search: ${q}, page ${page}`);
  })

  .listen(3000, (token) => {
    if (token) console.log('Server on :3000');
  });

App().get('/api/data', (res, req) => {

  // ✅ cork() — групує всі записи в один syscall
  // Без нього кожен writeHeader/write — окремий виклик
  res.cork(() => {
    res.writeStatus('200 OK');
    res.writeHeader('Content-Type', 'application/json');
    res.writeHeader('X-Custom', 'value');
    res.end(JSON.stringify({ ok: true }));
  });

  // ❌ ПОМИЛКА — end() вже викликано вище!
  // res.end('second call'); // → CRASH / UB

  // ❌ ПОМИЛКА — writeHeader після end()
  // res.writeHeader('X-Late', 'too late');
});

// ⚠️ Async + cork — правильний патерн
App().get('/api/async', (res, req) => {
  // Зберігаємо дані з req ДО async
  const url = req.getUrl();
  let aborted = false;
  res.onAborted(() => { aborted = true; });

  fetchData(url).then(data => {
    if (aborted) return;
    res.cork(() => {
      res.writeHeader('Content-Type', 'application/json');
      res.end(JSON.stringify(data));
    });
  });
});

import { App } from 'uWebSockets.js';

App().ws('/*', {
  maxPayloadLength: 16 * 1024,
  idleTimeout: 120,

  open: (ws) => {
    // Підписуємо клієнта на канал
    ws.subscribe('chat/general');
    console.log('Connected & subscribed');
  },

  message: (ws, message, isBinary) => {
    // Pub: розсилаємо всім підписникам
    ws.publish('chat/general', message, isBinary);
  },

  drain: (ws) => {
    // Backpressure: буфер звільнився
    console.log('Buffered: ' + ws.getBufferedAmount());
  },

  close: (ws, code, msg) => {
    // Відписка від каналів — автоматична
    console.log('Disconnected');
  }
}).listen(9001, (token) => {
  if (token) console.log('WS on :9001');
});