class Message {
  constructor(text) {
    this.text = text;
    this.timestamp = Date.now();
  }

  toString() {
    return JSON.stringify({
      text: this.text,
      timestamp: this.timestamp,
    });
  }
}js

const http = require('http');

// 핵심 데이터 구조
let waitingClients = []; // 응답을 기다리는 클라이언트들의 response 객체 배열
let messageQueue = []; // 메시지 큐 (실무에서는 Redis Pub/Sub 등 사용)

// 롱 폴링 요청 핸들러
const longPoll = (req, res) => {
  const WAITING_MS = 10_000; // 최대 대기 시간 10초

  if (messageQueue.length === 0) {
    // 전달할 메시지가 없으면 클라이언트를 대기열에 추가
    waitingClients.push(res);

    // 무한정 기다릴 수 없으므로 타임아웃 설정
    res.setTimeout(WAITING_MS, () => {
      // 타임아웃 응답 방식 선택 가능(사내 선택사항):
      // 1. 408 Request Timeout (명시적 타임아웃)
      // 2. 200 OK + 빈 데이터 (정상 흐름으로 처리)
      // 3. 204 No Content (컨텐츠 없음 명시)
      res.statusCode = 204; // 여기서는 204 사용
      res.end();
    });
    return;
  }

  // 메시지가 있다면 즉시 전송
  const message = messageQueue.shift(); // 큐에서 메시지 꺼내기
  res.setHeader('Content-Type', 'application/json');
  res.end(`${message}`);
};

// 메시지 업데이트 핸들러 (새로운 채팅 메시지 전송)
const update = (req, res) => {
  let body = '';

  // POST 데이터를 청크 단위로 수신
  req.on('data', (chunk) => (body += chunk.toString()));

  req.on('end', () => {
    const { text } = JSON.parse(body);

    // 유효성 검사
    if (!text) {
      res.statusCode = 400;
      return res.end(JSON.stringify({ error: 'text 필드를 채워주세요' }));
    }

    // 새 메시지 생성 및 큐에 추가
    const message = new Message(text);
    messageQueue.push(message);

    // 중요: 대기 중인 모든 클라이언트에게 메시지 전달
    for (const client of waitingClients) {
      client.setHeader('Content-Type', 'application/json');
      client.end(`${message}`);
    }
    waitingClients = []; // 대기열 초기화

    // 업데이트 요청한 클라이언트에게도 응답
    res.setHeader('Content-Type', 'application/json');
    res.end(`${message}`);
  });
};

// 라우팅
const handler = (req, res) => {
  const { pathname } = new URL(req.url, `http://${req.headers.host}`);
  if (pathname === '/longpoll') return longPoll(req, res);
  if (pathname === '/update') return update(req, res);
  res.statusCode = 404;
  res.end('Not Found');
};

http.createServer(handler).listen(8080, () => {
  console.log('server running ::8080');
});js

curl http://localhost:8080/longpoll -vbash

< HTTP/1.1 204 No Content

curl http://localhost:8080/update \
  -H "Content-Type: application/json" \
  -d '{"text":"고구마"}' -vbash

< HTTP/1.1 200 OK
{"text":"고구마","timestamp":1756026935210}

const longPollServer = async () => {
  const response = await fetch('/longpoll');

  if (response.status === 204 || response.status === 408) {
    // 타임아웃 발생 → 즉시 재연결
    // 재귀 호출로 끊김 없는 연결 유지
    return longPollServer();
  }

  // 정상 메시지 수신
  const message = await response.json();
  render(message);

  // 핵심: 응답을 받자마자 즉시 다시 요청
  // 이렇게 해야 다음 메시지도 놓치지 않고 받을 수 있음
  longPollServer();
};

const render = (message) => {
  const div = document.createElement('div');
  div.textContent = `${message.text} (${new Date(
    message.timestamp
  ).toLocaleTimeString()})`;
  document.body.appendChild(div);
};

// 페이지 로드 시 롱 폴링 시작
document.addEventListener('DOMContentLoaded', longPollServer);js

curl http://localhost:8080/update \
  -H "Content-Type: application/json" \
  -d '{"text":"고구마"}' -vbash