// Node.js (Express 예시)
// npm install express
import express from "express";
const app = express();

// 연결된 모든 클라이언트(res 객체)를 저장
const clients = new Set();

app.get("/events", (req, res) => {
  // 1. SSE 연결을 위한 필수 헤더 설정
  res.writeHead(200, {
    "Content-Type": "text/event-stream",
    Connection: "keep-alive",
    "Cache-Control": "no-cache",
  });

  // 2. 연결된 클라이언트를 Set에 추가
  clients.add(res);
  console.log("Client connected");

  // 3. 클라이언트가 연결을 끊었을 때의 처리
  req.on("close", () => {
    clients.delete(res);
    console.log("Client disconnected");
  });
});

app.listen(3000, () => console.log("SSE server listening on port 3000"));

// Client-side (Browser JS)
async function connectSSE() {
  let response;
  try {
    response = await fetch("http://localhost:3000/events");
  } catch (error) {
    console.error("Connection failed:", error);
    return;
  }

  // 1. 응답 바디에서 ReadableStream의 리더(reader)를 가져옴
  const reader = response.body.getReader();

  // 2. 텍스트 디코더 준비 (바이너리 데이터를 UTF-8 텍스트로 변환)
  const decoder = new TextDecoder();

  // 3. 스트림이 끝날 때(done)까지 무한 루프
  while (true) {
    const { done, value } = await reader.read();

    if (done) {
      console.log("Stream finished");
      break; // 서버가 연결을 종료함
    }

    // 4. 수신된 바이너리 청크(value)를 텍스트로 디코딩
    const rawChunk = decoder.decode(value);

    // (이후 이 청크를 파싱하는 로직이 필요함)
    parseStreamChunk(rawChunk);
  }
}
// (파싱 로직은 아래 '이벤트 파싱' 섹션 참고)
connectSSE();

// Node.js (Express) - 서버 어디에서든 호출 가능

// 모든 연결된 클라이언트에게 브로드캐스트하는 함수
function broadcast(eventName, data) {
  // 1. (옵션) 'update'라는 이름의 이벤트를 지정
  const message =
    `event: ${eventName}\n` +
    // 2. (필수) 실제 데이터를 'data:' 필드에 담아 전송
    `data: ${data}\n` +
    // 3. (필수) 메시지의 끝을 알리는 개행 전송
    `\n`;

  for (const res of clients) {
    res.write(message);
  }
}

// 2초마다 모든 클라이언트에게 'update' 이벤트 전송
setInterval(() => {
  broadcast("update", `This is message number ${Date.now()}`);
}, 2000);

// 서버에서 JSON 전송 시
const payload = { user: "test", value: 123 };

// [Good ✅] JSON은 반드시 한 줄의 data 필드로 전송
broadcast("update", JSON.stringify(payload));
// (전송되는 텍스트: 'event: update\ndata: {"user":"test","value":123}\n\n')

// [Bad ❌] 아래와 같이 여러 data 라인에 걸쳐 JSON을 쪼개면
// res.write(`data: {"user": "test",\n`)
// res.write(`data: "value": 123}\n\n`)

// 클라이언트 파서는 망가진 텍스트('{"user": "test",\n"value": 123}')를 받게 되어
// JSON.parse()에서 오류가 발생함

// Client-side (Browser JS)

let buffer = ""; // 수신된 청크를 임시 저장할 버퍼

// connectSSE()의 read() 루프에서 호출되는 함수
function parseStreamChunk(rawChunk) {
  // 1. 버퍼에 새로 수신된 청크를 추가
  buffer += rawChunk;

  // 2. 버퍼에서 메시지 구분자(\n\n)를 찾음
  let boundary = buffer.indexOf("\n\n");

  // 3. 구분자가 존재하면 (즉, 메시지가 하나 이상 완성되면)
  while (boundary !== -1) {
    // 4. 완성된 메시지 한 개를 추출 (구분자 앞까지)
    const rawMessage = buffer.substring(0, boundary);

    // 5. 버퍼에서 처리된 메시지+구분자 제거
    buffer = buffer.substring(boundary + 2);

    // 6. 추출한 메시지 파싱
    parseMessage(rawMessage);

    // 7. 버퍼에 또 다른 메시지가 있는지 확인
    boundary = buffer.indexOf("\n\n");
  }
}

// 수신된 raw 메시지를 파싱하는 헬퍼 함수
function parseMessage(rawMessage) {
  const lines = rawMessage.split("\n");
  let eventType = "message"; // event: 필드가 없으면 기본값 'message'
  let eventData = "";

  for (const line of lines) {
    if (line.startsWith("event:")) {
      eventType = line.substring(6).trim();
    } else if (line.startsWith("data:")) {
      // data 필드가 여러 줄일 경우를 대비해 (JSON이 아닌 경우)
      eventData += line.substring(5).trim();
    }
  }

  if (eventData) {
    console.log(`[Event Received] Type: ${eventType}, Data: ${eventData}`);
    // 여기서 DOM을 업데이트하거나 알림을 표시하는 등 실제 작업 수행
  }
}

// Node.js (Express) - 서버 측

// 15초마다 하트비트 전송
setInterval(() => {
  // : 주석은 클라이언트의 message 이벤트로 전달되지 않음
  const heartbeatMessage = ": heartbeat\n\n";

  for (const res of clients) {
    res.write(heartbeatMessage);
  }
}, 15000);

// Node.js (Express) - /events 핸들러
app.get("/events", (req, res) => {
  // ... 헤더 설정 ...

  // (실제로는 JWT 등에서 파싱한 ID)
  res.locals.userId = "user-" + Math.floor(Math.random() * 1000);
  clients.add(res);

  req.on("close", () => {
    clients.delete(res);
  });
});

// (어드민 API 등) 특정 사용자를 종료시켜야 할 때
function kickUser(userIdToKick, reason) {
  for (const res of clients) {
    if (res.locals.userId === userIdToKick) {
      // 1. 클라이언트가 처리할 수 있는 에러 이벤트를 전송
      const message = `event: error\ndata: ${JSON.stringify({
        code: "KICKED",
        reason: reason,
      })}\n\n`;
      res.write(message);

      // 2. 스트림을 정상적으로 종료 (클라이언트의 req.on('close')가 호출됨)
      res.end();

      console.log(`Kicked user: ${userIdToKick}`);
      break;
    }
  }
}

// 예시: 5초 뒤 특정 유저 강제 종료
setTimeout(() => {
  // (실제로는 ID를 특정해야 함)
  if (clients.size > 0) {
    const userToKick = clients.values().next().value.locals.userId;
    kickUser(userToKick, "Session expired");
  }
}, 5000);