refactor: remove legacy eims tool path

dap-was-lib/src/main/java/io/shinhanlife/dap/lib/adapter/connector/LegacyEimsConnector.java

@@ -1,151 +0,0 @@
-package io.shinhanlife.dap.lib.adapter.connector;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import io.shinhanlife.dap.lib.adapter.sender.EimsSender;
-import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
-import io.github.resilience4j.ratelimiter.RequestNotPermitted;
-import io.github.resilience4j.ratelimiter.annotation.RateLimiter;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.cache.annotation.Cacheable;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-import java.util.Map;
-import io.shinhanlife.dap.lib.adapter.util.LegacyDataTransformer;
-
-/**
- * @package io.shinhanlife.dap.lib.adapter.connector
- * @className LegacyEimsConnector
- * @description AX HUB 시스템 처리 클래스
- * @author 0986406
- * @create 2026.09.01
- * <pre>
- * ---------- 개정이력 ----------
- * 수정일      수정자    수정내용
- * ---------- -------- ---------------------------
- * 2026.09.01  0986406    최초생성
- * 
- * </pre>
- */
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class LegacyEimsConnector {
-
-    // 4가지 방식의 Sender를 모두 주입받습니다. (변수명이 아주 중요합니다!)
-    private final EimsSender httpEimsSender;      // 1~20 (EIMS API)
-    private final EimsSender tcpEimsSender;       // 21~30 (EIMS Socket)
-    private final EimsSender jspFormEimsSender;   // 31~40 (JSP Form)
-    private final EimsSender jspJsonEimsSender;   // 41~50 (JSP JSON)
-
-    private final EimsSender mciEimsSender;   // 실시간 연계 (기존 HTTP/TCP 대체, 동기식 API)
-    private final EimsSender mciStringEimsSender; // 실시간 연계 (String 전문 버전)
-    private final EimsSender eaiEimsSender;   // 비동기/대용량 연계 (배치 통신 등)
-
-    private final ObjectMapper jsonMapper;
-
-
-    //  방어막 적용: 예외가 발생하거나 차단기가 열리면 fallbackMethod를 즉시 실행합니다!
-    //  서킷 브레이커와 Rate Limiter를 동시에 적용 (둘 중 하나라도 걸리면 fallbackForEims 실행)
-    @RateLimiter(name = "eims", fallbackMethod = "fallbackForEims")
-    @CircuitBreaker(name = "eims", fallbackMethod = "fallbackForEims")
-    //  2번 업그레이드 적용: 파라미터 기반의 스마트 캐싱 (고객의 요청 데이터가 다르면 캐시도 다르게 적용)
-    @Cacheable(value = "eimsData", key = "#routingType + '-' + #interfaceId + '-' + (#data != null ? #data.hashCode() : 0)")
-    public String executeByTool(String routingType, String interfaceId, Map<String, Object> data, List<Map<String, Object>> spec) throws Exception {
-
-        // 1. 데이터 조립 (방어 로직 포함)
-        String payload = buildPayload(data, spec);
-
-        log.info("\n [Adapter -> Legacy] EIMS 통신 요청 - RoutingType: {}, Interface: {}, Payload: {}", routingType, interfaceId, payload);
-
-        // 2. 4단계 라우팅 분기 처리 (Switch Expression 활용)
-        String upperRoutingType = routingType != null ? routingType.toUpperCase() : "";
-        
-        String legacyResponse = switch (upperRoutingType) {
-            case "HTTP" -> {
-                log.info("[라우팅] EIMS API (HTTP) 통신으로 전달");
-                yield httpEimsSender.send(interfaceId, payload);
-            }
-            case "TCP" -> {
-                log.info("[라우팅] EIMS 소켓 (TCP) 통신으로 전달");
-                yield tcpEimsSender.send(interfaceId, payload);
-            }
-            case "JSP_FORM" -> {
-                log.info("[라우팅] JSP Form 통신으로 전달");
-                yield jspFormEimsSender.send(interfaceId, payload);
-            }
-            case "JSP_JSON" -> {
-                log.info("[라우팅] JSP JSON 통신으로 전달");
-                yield jspJsonEimsSender.send(interfaceId, payload);
-            }
-
-            case "MCI" -> {
-                if (isStringMci(spec)) {
-                    log.info("[라우팅] 스펙 자동 판별 (String 포맷 감지) -> MCI 연계 어댑터(String)를 통해 EIMS 전달");
-                    yield mciStringEimsSender.send(interfaceId, payload);
-                } else {
-                    log.info("[라우팅] 실시간 AI 요청 -> MCI 연계 어댑터를 통해 EIMS 전달");
-                    yield mciEimsSender.send(interfaceId, payload);
-                }
-            }
-            case "EAI" -> {
-                log.info("[라우팅] 비동기/대용량 요청 -> EAI 연계 어댑터를 통해 EIMS 전달");
-                yield eaiEimsSender.send(interfaceId, payload);
-            }
-            default -> {
-                log.error("[라우팅] 알 수 없는 라우팅 타입: {}", routingType);
-                throw new IllegalArgumentException("지원하지 않는 라우팅 타입입니다: " + routingType);
-            }
-        };
-        
-        log.info("\n [Legacy -> Adapter] EIMS 통신 응답 수신: {}", legacyResponse);
-        return legacyResponse;
-    }
-
-
-    //  비상용 응답 메서드 (차단기가 열려있거나, 타임아웃/에러가 났을 때 실행됨)
-    // 주의: 파라미터는 원본 메서드와 100% 똑같이 맞추고, 마지막에 Throwable을 받아야 합니다.
-    public String fallbackForEims(String routingType, String interfaceId, Map<String, Object> data, List<Map<String, Object>> spec, Throwable t) {
-
-        // 1. Rate Limiter에 의해 차단된 경우 (트래픽 폭주)
-        if (t instanceof RequestNotPermitted) {
-            log.warn(" [Rate Limiter 발동] 트래픽 폭주로 요청 차단! interfaceId: {}", interfaceId);
-            return String.format(
-                    "{\"status\":\"TOO_MANY_REQUESTS\", \"message\":\"순간적인 요청 폭주로 인해 일시적으로 제한되었습니다. 잠시 후 시도해 주세요.\", \"interfaceId\":\"%s\"}",
-                    interfaceId
-            );
-        }
-
-        // 2. Circuit Breaker에 의해 차단된 경우 (레거시 시스템 장애/지연)
-        log.error(" [서킷 브레이커 발동] 레거시 통신 차단! 원인: {}", t.getMessage());
-        return String.format(
-                "{\"status\":\"CIRCUIT_OPEN\", \"message\":\"신한라이프 내부 시스템 장애로 인해 일시적으로 차단되었습니다. 복구 후 재시도 부탁드립니다.\", \"interfaceId\":\"%s\"}",
-                interfaceId
-        );
-    }
-
-    private String buildPayload(Map<String, Object> data, List<Map<String, Object>> spec) {
-        //  3번 항목 적용: 원본 데이터를 스펙에 맞게 엄격히 정제(변환, 형변환, 잘라내기, 기본값 등)
-        Map<String, Object> transformedData = LegacyDataTransformer.transform(data, spec);
-
-        if (transformedData == null || transformedData.isEmpty()) return "{}";
-        
-        try {
-            return jsonMapper.writeValueAsString(transformedData);
-        } catch (Exception e) {
-            log.error(" JSON 변환 에러: {}", e.getMessage());
-            return "{}";
-        }
-    }
-
-    private boolean isStringMci(List<Map<String, Object>> spec) {
-        if (spec == null || spec.isEmpty()) return false;
-        // 스펙 내에 maxLength 등 고정길이 전문 관련 속성이 하나라도 존재하거나 명시적으로 STRING 힌트가 있으면 String 전문으로 간주
-        return spec.stream().anyMatch(field -> 
-            field.containsKey("maxLength") || 
-            field.containsKey("byteSize") ||
-            "STRING".equalsIgnoreCase(String.valueOf(field.get("mciFormat")))
-        );
-    }
-}

dap-was-lib/src/main/java/io/shinhanlife/dap/lib/adapter/support/ToolExecutionService.java

@@ -1,90 +0,0 @@
-package io.shinhanlife.dap.lib.adapter.support;
-
-import io.shinhanlife.dap.lib.adapter.connector.LegacyEimsConnector;
-import io.shinhanlife.dap.lib.adapter.dto.ErrorDetail;
-import io.shinhanlife.dap.lib.adapter.dto.JsonRpcRequest;
-import io.shinhanlife.dap.lib.adapter.dto.JsonRpcResponse;
-import io.shinhanlife.dap.lib.adapter.dto.Params;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * @package io.shinhanlife.dap.lib.adapter.support
- * @className ToolExecutionService
- * @description AX HUB 시스템 처리 클래스
- * @author 0986406
- * @create 2026.09.01
- * <pre>
- * ---------- 개정이력 ----------
- * 수정일      수정자    수정내용
- * ---------- -------- ---------------------------
- * 2026.09.01  0986406    최초생성
- * 
- * </pre>
- */
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class ToolExecutionService {
-
-    //  방어막(서킷/캐시)이 적용된 커넥터 주입
-    private final LegacyEimsConnector legacyEimsConnector;
-
-    /**
-     * AI Agent가 호출한 툴을 실제 레거시 커넥터로 전달합니다.
-     */
-    public JsonRpcResponse executeTool(JsonRpcRequest request) {
-        Params params = request.getParams();
-
-        // 1. 필수 파라미터 검증
-        if (params == null || params.getName() == null) {
-            return createErrorResponse(request.getId(), -32602, "Invalid params: 'name' is required");
-        }
-
-        try {
-            // 2. Connector의 executeByTool 메서드 호출
-            // [참고] connector에 선언된 파라미터 구조에 맞게 매핑합니다.
-            String result = legacyEimsConnector.executeByTool(
-                    params.getRoutingType(),
-                    params.getInterfaceId(),
-                    params.getData(),
-                    params.getSpec()
-            );
-
-            // 3. 성공 응답 생성 (result가 JSON 문자열일 경우, 실제 DTO로 변환하여 반환하면 더 좋습니다)
-            return createSuccessResponse(request.getId(), result);
-
-        } catch (Exception e) {
-            log.error(" [ToolExecution] 커넥터 호출 실패: RoutingType={}, Error={}", params.getRoutingType(), e.getMessage());
-            return createErrorResponse(request.getId(), -32000, "Connector error: " + e.getMessage());
-        }
-    }
-
-    /**
-     * AI Agent를 위한 툴 목록 스키마 반환
-     */
-    public JsonRpcResponse getToolList(String requestId) {
-        // 기존에 정의한 Tool 스키마 리스트 반환 로직...
-        Map<String, Object> result = new HashMap<>();
-        // ... (Tool 명세 내용)
-        return createSuccessResponse(requestId, result);
-    }
-
-    private JsonRpcResponse createSuccessResponse(String id, Object result) {
-        JsonRpcResponse response = new JsonRpcResponse();
-        response.setId(id);
-        response.setResult(result);
-        return response;
-    }
-
-    private JsonRpcResponse createErrorResponse(String id, int code, String message) {
-        JsonRpcResponse response = new JsonRpcResponse();
-        response.setId(id);
-        response.setError(new ErrorDetail(code, message));
-        return response;
-    }
-}

dap-was-lib/src/main/java/io/shinhanlife/dap/lib/util/ToolScaffolder.java

@@ -150,6 +150,9 @@ public class ToolScaffolder {
         String bizPackage = BASE_PACKAGE + ".biz." + group.toLowerCase();
         boolean isMci = "MCI".equalsIgnoreCase(routingType);
         boolean isHttp = "HTTP".equalsIgnoreCase(routingType);
+        if (!isMci && !isHttp) {
+            throw new IllegalArgumentException("Unsupported routing type: " + routingType + ". Only MCI and HTTP are supported.");
+        }
         String mciGroupPath = "infra/itrf/mci/" + group.toLowerCase();
         String clientPrefixCap = "";
         Path mciClientDir = null;
@@ -425,7 +428,6 @@ public class ToolScaffolder {
                 import %s.dto.%sRequest;
                 import %s.dto.%sResponse;
                 import %s.usecase.%sUseCase;
-                import io.shinhanlife.dap.mcc.usecase.AbstractMcpToolUseCase;
                 import %s.converter.%sConverter;
                 import org.springframework.stereotype.Service;
                 import lombok.RequiredArgsConstructor;
@@ -448,14 +450,14 @@ public class ToolScaffolder {
                 @Slf4j
                 @Service
                 @RequiredArgsConstructor
-                public class %sUseCaseImpl extends AbstractMcpToolUseCase implements %sUseCase {
+                public class %sUseCaseImpl implements %sUseCase {
 
                     private final %sConverter converter;
 
                     @Override
                     public %sResponse execute(%sRequest req) {
                         // %sLegacyRequest legacyRequest = converter.toLegacyRequest(req);
-                        Object legacyResponse = executeLegacy("%s", "%s", req); // Or pass legacyRequest
+                        Object legacyResponse = null;
                         if (legacyResponse instanceof %sResponse response) {
                             return response;
                         }

dap-was-lib/src/main/java/io/shinhanlife/dap/mcc/usecase/AbstractMcpToolUseCase.java

@@ -1,95 +0,0 @@
-package io.shinhanlife.dap.mcc.usecase;
-
-import io.shinhanlife.dap.lib.adapter.connector.LegacyEimsConnector;
-import io.shinhanlife.dap.lib.adapter.util.PiiMaskingUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.core.type.TypeReference;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.List;
-
-import lombok.extern.slf4j.Slf4j;
-
-/**
- * @package io.shinhanlife.dap.mcc.service
- * @className AbstractMcpToolUseCase
- * @description AX HUB 시스템 처리 클래스
- * @author 0986406
- * @create 2026.09.01
- * <pre>
- * ---------- 개정이력 ----------
- * 수정일      수정자    수정내용
- * ---------- -------- ---------------------------
- * 2026.09.01  0986406    최초생성
- * 
- * </pre>
- */
-@Slf4j
-public abstract class AbstractMcpToolUseCase {
-
-    @Autowired
-    protected LegacyEimsConnector legacyEimsConnector;
-
-    @Autowired
-    protected ObjectMapper objectMapper;
-
-    protected Map<String, Object> executeLegacy(String routingType, String interfaceId, Object inputData) {
-        return executeLegacy(routingType, interfaceId, inputData, null);
-    }
-
-    /**
-     * 레거시 시스템을 호출하고 공통 처리(PII 마스킹 등)를 수행합니다. (스펙 지정 가능)
-     */
-    protected Map<String, Object> executeLegacy(String routingType, String interfaceId, Object inputData, List<Map<String, Object>> spec) {
-        Map<String, Object> inputMap;
-        if (inputData == null) {
-            inputMap = new HashMap<>();
-        } else if (inputData instanceof Map) {
-            @SuppressWarnings("unchecked")
-            Map<String, Object> map = (Map<String, Object>) inputData;
-            inputMap = map;
-        } else {
-            inputMap = objectMapper.convertValue(inputData, new TypeReference<Map<String, Object>>() {});
-        }
-
-        try {
-            log.info("\n=======================================================");
-            log.info(" [Tool -> Legacy] 레거시 시스템 통신 시작");
-            log.info(" - Routing Type: {}", routingType);
-            log.info(" - Interface ID: {}", interfaceId);
-            log.info(" - 호출 파라미터 (Request): \n{}", objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(inputMap));
-            log.info("=======================================================\n");
-
-            // 1. Adapter 공통 모듈 직접 호출
-            String executionResult = legacyEimsConnector.executeByTool(routingType, interfaceId, inputMap, spec);
-
-            log.info("\n=======================================================");
-            log.info(" [Legacy -> Tool] 레거시 시스템 통신 완료");
-            log.info(" - 응답 파라미터 (Response, 마스킹 전): \n{}", executionResult);
-            log.info("=======================================================\n");
-            
-            // 2. PII 마스킹 처리
-            String maskedResult = PiiMaskingUtils.mask(executionResult);
-
-            if (executionResult != null && (executionResult.contains("\"status\":\"CIRCUIT_OPEN\"") || executionResult.contains("\"status\":\"TOO_MANY_REQUESTS\""))) {
-                try {
-                    return objectMapper.readValue(executionResult, new TypeReference<Map<String, Object>>() {});
-                } catch (Exception e) {
-                    log.error("Fallback JSON 파싱 에러: {}", e.getMessage());
-                }
-            }
-
-            Map<String, Object> result = new HashMap<>();
-            result.put("status", "SUCCESS");
-            result.put("legacy_response", maskedResult);
-            return result;
-        } catch (Exception e) {
-            Map<String, Object> error = new HashMap<>();
-            error.put("status", "ERROR");
-            error.put("message", e.getMessage());
-            return error;
-        }
-    }
-}