Refactor: 데이터 변환 계층을 인터페이스로 추상화

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: SimoKii

src/main/java/com/rabbittick/streamer/converter/ExchangeDataConverter.java

@@ -0,0 +1,62 @@
+package com.rabbittick.streamer.converter;
+
+import com.rabbittick.streamer.global.dto.MarketDataMessage;
+import com.rabbittick.streamer.global.dto.OrderBookPayload;
+import com.rabbittick.streamer.global.dto.TickerPayload;
+import com.rabbittick.streamer.global.dto.TradePayload;
+
+/**
+ * 거래소 WebSocket 수신 데이터를 시스템 표준 DTO로 변환하는 컨버터의 표준 계약을 정의하는 인터페이스.
+ *
+ * <p>주요 책임:
+ * <ul>
+ *   <li>거래소별 원시 JSON 메시지를 표준 {@link MarketDataMessage}로 변환</li>
+ *   <li>거래소 식별자 제공 (라우팅 키 생성에 사용)</li>
+ * </ul>
+ *
+ * <p>각 거래소 구현체는 이 인터페이스를 통해 거래소별 JSON 포맷 차이를 캡슐화한다.
+ * 변환된 {@link MarketDataMessage}는 거래소 종류에 관계없이 동일한 구조를 가지므로
+ * 하위 계층(발행, 저장)은 거래소에 대한 지식 없이 데이터를 처리할 수 있다.
+ *
+ * <p>새로운 거래소를 추가하려면 이 인터페이스를 구현하고
+ * {@code AbstractExchangeConnector}의 {@code handleMessage()} 안에서 호출한다.
+ */
+public interface ExchangeDataConverter {
+
+    /**
+     * 거래소 식별자를 반환한다.
+     *
+     * <p>반환값은 {@link com.rabbittick.streamer.global.dto.Metadata}의
+     * {@code exchange} 필드에 기록되며, RabbitMQ 라우팅 키 생성에 사용된다.
+     *
+     * @return 대문자 거래소 식별자 (예: "UPBIT", "BINANCE")
+     */
+    String getExchangeName();
+
+    /**
+     * 원시 JSON 문자열을 파싱하여 표준 ticker {@link MarketDataMessage}로 변환한다.
+     *
+     * @param rawJson 거래소 WebSocket으로부터 수신된 원시 JSON 문자열
+     * @return 표준화된 ticker MarketDataMessage
+     * @throws IllegalArgumentException JSON 파싱 실패 또는 필수 필드 누락 시
+     */
+    MarketDataMessage<TickerPayload> convertTicker(String rawJson);
+
+    /**
+     * 원시 JSON 문자열을 파싱하여 표준 trade {@link MarketDataMessage}로 변환한다.
+     *
+     * @param rawJson 거래소 WebSocket으로부터 수신된 원시 JSON 문자열
+     * @return 표준화된 trade MarketDataMessage
+     * @throws IllegalArgumentException JSON 파싱 실패 또는 필수 필드 누락 시
+     */
+    MarketDataMessage<TradePayload> convertTrade(String rawJson);
+
+    /**
+     * 원시 JSON 문자열을 파싱하여 표준 orderbook {@link MarketDataMessage}로 변환한다.
+     *
+     * @param rawJson 거래소 WebSocket으로부터 수신된 원시 JSON 문자열
+     * @return 표준화된 orderbook MarketDataMessage
+     * @throws IllegalArgumentException JSON 파싱 실패 또는 필수 필드 누락 시
+     */
+    MarketDataMessage<OrderBookPayload> convertOrderBook(String rawJson);
+}

src/main/java/com/rabbittick/streamer/converter/UpbitDataConverter.java

@@ -6,6 +6,8 @@
 
 import org.springframework.stereotype.Component;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.rabbittick.streamer.connector.dto.upbit.UpbitOrderBookDto;
 import com.rabbittick.streamer.connector.dto.upbit.UpbitTickerDto;
 import com.rabbittick.streamer.connector.dto.upbit.UpbitTradeDto;
@@ -16,11 +18,13 @@
 import com.rabbittick.streamer.global.dto.TickerPayload;
 import com.rabbittick.streamer.global.dto.TradePayload;
 
+import lombok.RequiredArgsConstructor;
+
 /**
- * Upbit 외부 API DTO를 시스템 표준 DTO로 변환하는 컨버터.
+ * Upbit WebSocket 수신 데이터를 시스템 표준 DTO로 변환하는 컨버터.
  *
- * <p>각 데이터 타입별로 명시적인 변환 메서드를 제공하여
- * 타입 안전성과 코드 가독성을 확보한다.
+ * <p>{@link ExchangeDataConverter}를 구현하여 원시 JSON 문자열을 직접 수신하고,
+ * Upbit 전용 DTO로 파싱한 후 거래소 독립적인 {@link MarketDataMessage}로 변환한다.
  *
  * <p>지원하는 데이터 타입:
  * <ul>
@@ -30,11 +34,70 @@
  * </ul>
  */
 @Component
-public class UpbitDataConverter {
+@RequiredArgsConstructor
+public class UpbitDataConverter implements ExchangeDataConverter {
+
+    private final ObjectMapper objectMapper;
 
 	private static final String EXCHANGE_NAME = "UPBIT";
 	private static final String VERSION = "1.0";
 
+	@Override
+	public String getExchangeName() {
+		return EXCHANGE_NAME;
+	}
+
+	/**
+	 * 원시 JSON 문자열을 {@link UpbitTickerDto}로 파싱하여 표준 ticker 메시지로 변환한다.
+	 *
+	 * @param rawJson Upbit WebSocket으로부터 수신된 원시 JSON 문자열
+	 * @return 표준화된 ticker MarketDataMessage
+	 * @throws IllegalArgumentException JSON 파싱 실패 시
+	 */
+	@Override
+	public MarketDataMessage<TickerPayload> convertTicker(String rawJson) {
+		try {
+			UpbitTickerDto dto = objectMapper.readValue(rawJson, UpbitTickerDto.class);
+			return convertTickerData(dto);
+		} catch (JsonProcessingException e) {
+			throw new IllegalArgumentException("Ticker JSON 파싱 실패: " + e.getMessage(), e);
+		}
+	}
+
+	/**
+	 * 원시 JSON 문자열을 {@link UpbitTradeDto}로 파싱하여 표준 trade 메시지로 변환한다.
+	 *
+	 * @param rawJson Upbit WebSocket으로부터 수신된 원시 JSON 문자열
+	 * @return 표준화된 trade MarketDataMessage
+	 * @throws IllegalArgumentException JSON 파싱 실패 시
+	 */
+	@Override
+	public MarketDataMessage<TradePayload> convertTrade(String rawJson) {
+		try {
+			UpbitTradeDto dto = objectMapper.readValue(rawJson, UpbitTradeDto.class);
+			return convertTradeData(dto);
+		} catch (JsonProcessingException e) {
+			throw new IllegalArgumentException("Trade JSON 파싱 실패: " + e.getMessage(), e);
+		}
+	}
+
+	/**
+	 * 원시 JSON 문자열을 {@link UpbitOrderBookDto}로 파싱하여 표준 orderbook 메시지로 변환한다.
+	 *
+	 * @param rawJson Upbit WebSocket으로부터 수신된 원시 JSON 문자열
+	 * @return 표준화된 orderbook MarketDataMessage
+	 * @throws IllegalArgumentException JSON 파싱 실패 시
+	 */
+	@Override
+	public MarketDataMessage<OrderBookPayload> convertOrderBook(String rawJson) {
+		try {
+			UpbitOrderBookDto dto = objectMapper.readValue(rawJson, UpbitOrderBookDto.class);
+			return convertOrderBookData(dto);
+		} catch (JsonProcessingException e) {
+			throw new IllegalArgumentException("OrderBook JSON 파싱 실패: " + e.getMessage(), e);
+		}
+	}
+
 	/**
 	 * UpbitTickerDto를 표준 MarketDataMessage로 변환한다.
 	 *