게임 제재

@RestController
@RequestMapping("/stove")
public class StoveKickController {

    private final UserKickService kickService;

    public StoveKickController(UserKickService kickService) {
        this.kickService = kickService;
    }

    /** STOVE Event Broker가 호출하는 Kick 이벤트 수신 엔드포인트 */
    @PostMapping(value = "/kick", consumes = MediaType.APPLICATION_JSON_VALUE)
    public ResponseEntity<Map<String, Object>> onKickEvent(@RequestBody KickEvent event) {
        if (!"GAME_RESTRICT".equals(event.getEventReason())) {
            // 알 수 없는 이벤트는 200으로 응답해 재전송 루프를 막아요.
            return ResponseEntity.ok(Map.of("code", 0, "message", "IGNORED"));
        }

        kickService.kickAll(event.getTargetUsers(), event.getEventMessage(), event.getEventTime());

        // 정상 수신 → 200 OK 반환 (200 외 응답 시 STOVE Event Broker가 최대 3회 재전송)
        return ResponseEntity.ok(Map.of("code", 0, "message", "SUCCESS"));
    }

    @Getter @Setter
    public static class KickEvent {
        @JsonProperty("event_reason")  private String eventReason;
        @JsonProperty("event_message") private String eventMessage;
        @JsonProperty("event_time")    private Long eventTime;
        @JsonProperty("target_users")  private List<Long> targetUsers;
    }
}

@Component
public class StoveBanInfoClient {

    private static final String HOST_LIVE    = "https://api.onstove.com";
    private static final String HOST_SANDBOX = "https://api.gate8.com";

    private final RestClient restClient;

    @Value("${stove.api.access-token}") private String apiAccessToken;
    @Value("${stove.caller-id}")        private String callerId;
    @Value("${stove.profile:live}")     private String profile;

    public StoveBanInfoClient(RestClient.Builder builder) {
        this.restClient = builder.build();
    }

    /** 제재 상태 조회. 정상 사용자면 Optional.empty() 반환. */
    public Optional<BanInfo> getBanInfo(String guid, String gameId) {
        String host = "sandbox".equalsIgnoreCase(profile) ? HOST_SANDBOX : HOST_LIVE;
        String url  = host + "/mmember/v1.0/signin/game/status/" + guid + "/" + gameId + "?guid_yn=Y";

        BanResponse res = restClient.get()
                .uri(url)
                .header(HttpHeaders.AUTHORIZATION, "Bearer " + apiAccessToken)
                .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
                .header("caller-id", callerId)
                .retrieve()
                .body(BanResponse.class);

        if (res == null) return Optional.empty();

        switch (res.responseCode) {
            case 0:                                       // 정상
                return res.value != null ? Optional.ofNullable(res.value.RESTRICT) : Optional.empty();
            case 10003:                                   // 제재 정보 없음
                return Optional.empty();
            case 10122:                                   // 제재된 사용자
                return res.value != null ? Optional.ofNullable(res.value.RESTRICT) : Optional.empty();
            case 90001:                                   // 토큰 검증 실패
                throw new IllegalStateException("STOVE accessToken / caller-id / path 불일치 — 설정 점검");
            default:
                throw new IllegalStateException("Unexpected response_code: " + res.responseCode);
        }
    }

    @Getter @Setter
    public static class BanResponse {
        @JsonProperty("response_code")    public int responseCode;
        @JsonProperty("response_message") public String responseMessage;
        public ValueBlock value;
    }

    @Getter @Setter
    public static class ValueBlock { public BanInfo RESTRICT; }

    @Getter @Setter
    public static class BanInfo {
        public Long memberNo;
        public String nickname;
        public int banDay;
        public String banCd;
        public Long banStartDt;
        public Long banEndDt;
    }
}

public class GameEntryService {
    private final StoveBanInfoClient banClient;
    private final GameSessionService sessionService;

    public void onPlayerEnter(String guid, String gameId) {
        banClient.getBanInfo(guid, gameId).ifPresentOrElse(
            ban -> sessionService.kick(ban.memberNo, ban.banCd, ban.banEndDt),
            ()  -> sessionService.allow(guid)
        );
    }
}