WebSocket 완전 정복 9편 — 재연결 전략: 지수 백오프와 지터, seq 기반 상태 복구

class ReconnectingSocket {
  private ws?: WebSocket;
  private attempt = 0;
  private lastSeq = 0;
  private closedByUser = false;
 
  constructor(private url: string, private onEvent: (msg: any) => void) {
    this.connect();
  }
 
  private connect() {
    this.ws = new WebSocket(this.url);
 
    this.ws.onopen = () => {
      this.attempt = 0;
      // 상태 복구: 마지막 seq 이후를 요청
      this.ws!.send(JSON.stringify({ type: "resume", since: this.lastSeq }));
    };
 
    this.ws.onmessage = (e) => {
      const msg = JSON.parse(e.data);
      if (typeof msg.seq === "number") {
        if (msg.seq <= this.lastSeq) return; // 중복 무시
        this.lastSeq = msg.seq;
      }
      this.onEvent(msg);
    };
 
    this.ws.onclose = (e) => {
      if (this.closedByUser) return;
      if (e.code >= 4000 && e.code < 4100) return; // 예: 인증 실패 → 재연결 금지
      const base = Math.min(30_000, 500 * 2 ** this.attempt++);
      const delay = Math.random() * base; // full jitter
      setTimeout(() => this.connect(), delay);
    };
  }
 
  close() { this.closedByUser = true; this.ws?.close(1000); }
}