비공식 SOOP 채팅 API

import com.github.getcurrentthread.soopapi.SOOPClient;
import com.github.getcurrentthread.soopapi.api.model.*;
import com.github.getcurrentthread.soopapi.client.SOOPChatClient;
import com.github.getcurrentthread.soopapi.event.ChatEvent;
import com.github.getcurrentthread.soopapi.event.model.*;

public class Example {
    public static void main(String[] args) throws Exception {
        try (SOOPClient client = new SOOPClient()) {
            // 방송 정보 조회
            LiveDetail detail = client.live().detail("streamerId").join();
            System.out.println("방송 제목: " + detail.title());

            // 채널 정보 조회
            StationInfo station = client.channel().station("streamerId").join();
            System.out.println("스테이션: " + station.stationName());

            // 글로벌 리스너 먼저 등록 — 이후 추가되는 스트림에 자동 attach됨
            client.on(ChatEvent.CHAT_MESSAGE, (String bid, ChatMessageEvent e) -> {
                System.out.println("[" + bid + "] " + e.senderNickname() + ": " + e.message());
            });

            client.on(ChatEvent.SEND_BALLOON, (String bid, SendBalloonEvent e) -> {
                System.out.println("[" + bid + "] " + e.senderNickname()
                        + "님이 풍선 " + e.count() + "개 선물!");
            });

            // add() 호출 즉시 비동기 연결이 시작됩니다 (별도 connectToChat() 불필요)
            client.add("streamerId");

            // 등록된 모든 세션이 끝날 때까지 블로킹
            client.connectAll().join();
        }
    }
}

try (SOOPClient client = new SOOPClient()) {
    // 글로벌 리스너 먼저 등록 — 이후 add()되는 스트림에도 자동 적용
    client.on(ChatEvent.CHAT_MESSAGE, (String bid, ChatMessageEvent e) -> {
        System.out.println("[" + bid + "] " + e.senderNickname() + ": " + e.message());
    });

    // 연결 실패/끊김 추적
    client.on(ChatEvent.DISCONNECTED, (String bid, DisconnectedEvent e) -> {
        if (e.causedByError()) {
            System.err.println("[" + bid + "] 연결 오류로 끊김: " + e.reason());
        }
    });

    // 등록 즉시 자동 연결됨 — 호출 순서/타이밍은 자유
    client.add("streamerA");
    client.add("streamerB");
    client.add("streamerA"); // dedup: 기존 인스턴스 반환, no-op

    // 런타임 중 추가/제거 자유
    Thread.sleep(5_000);
    client.add("streamerC");            // 자동 연결
    client.reconnect("streamerA");      // 강제 재연결 (tear-down + 새 연결)
    client.remove("streamerB");         // disconnect + 등록 해제

    // 등록된 모든 세션이 끝날 때까지 대기
    client.connectAll().join();
}

SOOPChatClient a = client.get("streamerA");        // 없으면 null
Set<String> ids = client.streamerIds();             // 등록된 bid 스냅샷
Collection<SOOPChatClient> all = client.clients();  // 등록된 클라이언트 스냅샷

import com.github.getcurrentthread.soopapi.client.SOOPChatClient;
import com.github.getcurrentthread.soopapi.config.SOOPChatConfig;
import com.github.getcurrentthread.soopapi.event.ChatEvent;
import com.github.getcurrentthread.soopapi.event.model.ChatMessageEvent;

public class DirectExample {
    public static void main(String[] args) throws Exception {
        SOOPChatConfig config = new SOOPChatConfig.Builder()
                .bid("streamerId")
                .build();

        SOOPChatClient client = new SOOPChatClient(config);

        client.on(ChatEvent.CHAT_MESSAGE, (ChatMessageEvent e) -> {
            System.out.println(e.senderNickname() + ": " + e.message());
        });

        // connectAndAwait()는 세션이 끝날 때까지 블로킹됩니다
        client.connectAndAwait();
    }
}

// 인증 없이 읽기 전용으로 연결
SOOPChatConfig config = new SOOPChatConfig.Builder()
        .bid("streamerId")
        .build();

SOOPChatClient client = new SOOPChatClient(config);

client.on(ChatEvent.CHAT_MESSAGE, (ChatMessageEvent e) -> {
    System.out.println(e.senderNickname() + ": " + e.message());
});

client.connectAndAwait(); // 채팅 수신 가능, 전송 불가

SOOPClient client = new SOOPClient();

// 1. 로그인 (실패하면 join()이 AuthenticationException을 원인으로 담은 CompletionException을 던짐)
AuthCookie cookie = client.auth().signIn("userId", "password").join();
System.out.println("로그인 성공");

// 2. 인증된 설정으로 채팅 클라이언트 생성
SOOPChatConfig config = new SOOPChatConfig.Builder()
        .bid("streamerId")
        .authCookie(cookie)
        .build();

SOOPChatClient chat = new SOOPChatClient(config);

chat.on(ChatEvent.CHAT_MESSAGE, (ChatMessageEvent e) -> {
    System.out.println(e.senderNickname() + ": " + e.message());
});

// 3. 연결 시작. 반환된 future는 세션이 끝날 때 완료되므로 여기서 기다리지 않습니다
chat.connectToChat();

// 4. 채널에 입장하면(ready) 전송합니다
chat.ready().thenRun(() -> {
    chat.sendChat("Hello!")
            .exceptionally(ex -> { System.err.println("전송 실패: " + ex); return null; });

    // 특정 사용자에게 귓말 전송 ("targetUser" = 받는 사람 로그인 ID, 닉네임/(n) 형태 아님)
    chat.sendWhisper("targetUser", "안녕하세요");
}).exceptionally(ex -> { System.err.println("채널 입장 전에 세션이 끝남: " + ex); return null; });

import com.github.getcurrentthread.soopapi.event.model.*;

// 세션 종료 감지 (세션마다 정확히 한 번)
client.on(ChatEvent.DISCONNECTED, (DisconnectedEvent e) -> {
    System.out.println("연결 해제: code=" + e.statusCode()
            + ", reason=" + e.reason()
            + ", error=" + e.causedByError());
});

// 직접 끝낸 경우가 아니면 5초 뒤 새 세션 시작 (첫 연결 실패도 포함되므로 방송이 꺼져 있으면 5초마다 다시 시도)
client.on(ChatEvent.DISCONNECTED, (DisconnectedEvent e) -> {
    if (e.isClientInitiated()) {
        return; // disconnect()/close()로 직접 끝낸 경우
    }
    CompletableFuture.runAsync(
            client::connectToChat, CompletableFuture.delayedExecutor(5, TimeUnit.SECONDS));
});

// 재연결 시도 감지
client.on(ChatEvent.RECONNECTING, (ReconnectingEvent e) -> {
    System.out.println("재연결 시도 " + e.attemptNumber()
            + "/" + e.maxAttempts()
            + " (" + e.delayMs() + "ms 후)");
});

// 재연결 완료 감지
client.on(ChatEvent.RECONNECTED, (ReconnectedEvent e) -> {
    System.out.println("재연결 완료 (총 " + e.totalAttempts() + "회 시도)");
});

import com.github.getcurrentthread.soopapi.exception.EventEmitterException;

client.getEventEmitter().setErrorHandler((EventEmitterException ex) -> {
    System.err.println("이벤트 처리 중 오류: " + ex.getChatEvent());
    ex.printStackTrace();
});

SOOPChatConfig config = new SOOPChatConfig.Builder()
        .bid("streamerId")
        .bno("12345")                                  // 방송 번호 (생략 시 자동 해석)
        .connectionTimeout(Duration.ofSeconds(15))     // 연결·송신 타임아웃, 0보다 커야 함 (기본: 30초)
        .maxRetryAttempts(3)                           // 자동 재연결 최대 재시도 횟수 (기본: 5)
        .pingIntervalSeconds(30)                       // 핑 전송 간격 (기본: 60초)
        .authCookie(cookie)                            // 인증 쿠키 (생략 시 읽기 전용)
        .build();

chat.on(ChatEvent.NONE_TYPE, (UnknownEvent e) -> {
    System.out.println("알 수 없는 코드 " + e.code() + ": " + e.raw());
});

client.on(ChatEvent.CHAT_MESSAGE, (String bid, ChatMessageEvent e) -> {
    UserLevel level = e.senderLevel();          // "81952|32768" → 파싱
    if (level.has(UserFlag.BJ)) { /* 방송인 */ }
    if (level.has(UserFlag2.TOPCLAN)) { /* 보조 그룹 플래그 */ }
});

client.on(ChatEvent.QUIT_CHANNEL, (String bid, QuitChannelEvent e) -> {
    if (e.quitStatus() == ChatQuitStatus.ADMKICK) { /* 운영자 강제 퇴장 */ }
});

client.on(ChatEvent.ICE_MODE, (String bid, IceModeEvent e) -> {
    if (e.isIceFlagMode()) {
        Set<ChatIceType.Flag> flags = e.iceFlags();   // v2 비트 플래그
    } else {
        ChatIceType type = e.iceType();               // 레거시 0~4
    }
});