SSH journalctl 대신 어드민 페이지에서 실시간 로그 — Server-Sent Events 인증/재연결 + JVM/HTTP/DB 메트릭 — POP-SPOT v2.10 (+v2.10.1)

// v2.10 — 메트릭 제공자 계약 설계. 새 메트릭은 구현체 주입만 추가 — 컨트롤러 변경 없음
public interface MetricSnapshotProvider {
    Map<String, Object> snapshot();
    //                  ^^^^^^^^^^   메트릭 스냅샷 반환. 키-값 쌍으로 자유롭게 구성
    //                                해설: Map<String, Object> 는 JSON 직렬화 시 자연스럽게 키-값 객체로 변환됨
}

// v2.10 — 새 메트릭 추가 예시: DB 풀 상태
@Component
//^^^^^^^   Spring 이 자동 등록. ApplicationContext 에 빈으로 올라가 List<MetricSnapshotProvider> 탐색 시 자동 포함
class DbPoolMetricProvider implements MetricSnapshotProvider {
    @Override public Map<String, Object> snapshot() {
        return Map.of("db.active", dataSource.getActiveCount(),
        //            ^^^^^^^^^^   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
        //            키 이름    현재 사용 중인 커넥션 수 (HikariCP 메트릭)
                      "db.idle",   dataSource.getIdleCount());
                      //           ^^^^^^^^^^^^^^^^^^^^^^^^^   대기 중인 커넥션 (풀에서 잘고 있는 상태)
    }
}

// v2.10 — 컨트롤러는 모든 구현체를 리스트로 주입받고 합치
@GetMapping("/api/admin/metrics")
Map<String, Object> all() {
    return providers.stream()
    //     ^^^^^^^^^         등록된 모든 MetricSnapshotProvider 구현체. Spring 이 생성자 자동 주입
        .map(MetricSnapshotProvider::snapshot)
        //   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^   메서드 레퍼런스 — 각 구현체의 snapshot() 실행
        //                                       결과: Stream<Map<String, Object>>
        .reduce(new HashMap<>(), (a, b) -> { a.putAll(b); return a; });
        //      ^^^^^^^^^^^^^^^   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
        //      |                 |
        //      |                 +-- 누적기에 (a) 다음 맵(b) 을 합침. 동일 키 있으면 덮어쓰기
        //      +-- 초기값: 빈 HashMap
        //          (Map.of 가 아닌 HashMap 인 이유 — putAll 여분적 수정 필요)
}

// v2.10 — SSE 로그 스트림 엔드포인트
@GetMapping(value = "/api/admin/logs/stream",
            produces = MediaType.TEXT_EVENT_STREAM_VALUE)
//          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^   text/event-stream MIME. SSE 표준
//                                                          그냥 JSON 이 아닌 이거로 설정해야 브라우저가 스트림 열어둔
chunked
public SseEmitter stream(@RequestParam String token) {
//                       ^^^^^^^^^^^^^^^^^^^^^^^^^^   ?token=xxx 쿼리 파라미터 —
//                                                     EventSource 는 Authorization 헤더 못 보냄 — 우회로 쿼리로
    if (!adminTokenService.isValid(token)) throw new AccessDenied();
    //                     ^^^^^^^                            토큰 검증 — 유효하지 않으면 연결 거절 (403)
    //                                              ^^^^^^^^^^^^^^^^   권한 부족 시 표준 Spring Security 예외 타입
    var emitter = new SseEmitter(0L);
    //                            ^^   타임아웃 0 = 무한. 긴 스트림에는 0 이 표준
    logBroadcaster.register(emitter);
    //             ^^^^^^^^         로그 메시지가 나올 때 이 emitter 로 푸시해주도록 등록
    return emitter;
}

// v2.10 — useSseStream.ts. 자동 재연결 + 지수 backoff 구현
export function useSseStream(url: string, token: string) {
  const [lines, setLines] = useState<string[]>([]);
  // 위: 수신한 로그 한 줄씩 는적해 담는 상태 배열

  useEffect(() => {
    let es: EventSource | null = null;
    // 위: 클로저 변수 (커넥션 인스턴스)
    let retry = 1000;
    // 위: 재시도 지연 초기값 1초 (1000ms)

    const connect = () => {
      es = new EventSource(`${url}?token=${token}`);
      // 위: ?token=xxx 로 서버에 접속. 서버가 토큰 검증 후 스트림 시작
      //      EventSource 는 내장 재연결이 있으나 우리는 수동 관리 택함 (backoff 조절 용이)
      es.onmessage = e => setLines(prev => [...prev, e.data]);
      // 위: 서버가 보낸 이벤트마다 lines 배열에 그대로 추가
      es.onerror = () => {
        es?.close();
        // 위: 끚어진 커넥션 닫음 — 좀비 세션 방지
        setTimeout(connect, retry);
        // 위: retry 밀리초 후 재연결 시도
        retry = Math.min(retry * 2, 4000);
        // 위: 지수 backoff — 1→2→4초 (4초에서 상한)
        //      서버 도움 머림짓 시 다수 클라이언트가 동시에 채움 방지
      };
      es.onopen = () => { retry = 1000; };
      // 위: 재연결 성공 시 retry 를 1초로 리셋 — 다음 재연결도 1초부터 시작
    };
    connect();
    // 위: 최초 연결 시작
    return () => es?.close();
    // 위: 언마운트 — 연결 정리. useEffect 클린업에서 호출됨
  }, [url, token]);
  return lines;
}