kimhyungsik/ax_hub_mcp_tool
0
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: Add explicit logging for Tool-Adapter-Legacy communication pipeline

Browse Source
This commit is contained in:
jade
2026-07-04 01:35:01 +09:00
parent 1316b393ff
commit bd67bdd013
2 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/io/shinhanlife/axhub/biz/mcp/adapter/connector/LegacyEimsConnector.java
View File

@@ -42,35 +42,39 @@ public class LegacyEimsConnector {
// 1. 데이터 조립 (방어 로직 포함) // 1. 데이터 조립 (방어 로직 포함)
String payload = buildPayload(data, spec); String payload = buildPayload(data, spec);
log.info(" MCP 요청 접수 - RoutingType: {}, Interface: {}", routingType, interfaceId); log.info("\n [Adapter -> Legacy] EIMS 통신 요청 - RoutingType: {}, Interface: {}, Payload: {}", routingType, interfaceId, payload);
// 2. 4단계 라우팅 분기 처리 // 2. 4단계 라우팅 분기 처리
String legacyResponse = null;
if ("HTTP".equalsIgnoreCase(routingType)) { if ("HTTP".equalsIgnoreCase(routingType)) {
log.info("[라우팅] EIMS API (HTTP) 통신으로 전달"); log.info("[라우팅] EIMS API (HTTP) 통신으로 전달");
return httpEimsSender.send(interfaceId, payload); legacyResponse = httpEimsSender.send(interfaceId, payload);
} }
else if ("TCP".equalsIgnoreCase(routingType)) { else if ("TCP".equalsIgnoreCase(routingType)) {
log.info("[라우팅] EIMS 소켓 (TCP) 통신으로 전달"); log.info("[라우팅] EIMS 소켓 (TCP) 통신으로 전달");
return tcpEimsSender.send(interfaceId, payload); legacyResponse = tcpEimsSender.send(interfaceId, payload);
} }
else if ("JSP_FORM".equalsIgnoreCase(routingType)) { else if ("JSP_FORM".equalsIgnoreCase(routingType)) {
log.info("[라우팅] JSP Form 통신으로 전달"); log.info("[라우팅] JSP Form 통신으로 전달");
return jspFormEimsSender.send(interfaceId, payload); legacyResponse = jspFormEimsSender.send(interfaceId, payload);
} }
else if ("JSP_JSON".equalsIgnoreCase(routingType)) { else if ("JSP_JSON".equalsIgnoreCase(routingType)) {
log.info("[라우팅] JSP JSON 통신으로 전달"); log.info("[라우팅] JSP JSON 통신으로 전달");
return jspJsonEimsSender.send(interfaceId, payload); legacyResponse = jspJsonEimsSender.send(interfaceId, payload);
} }
else { else {
// 3. 아키텍처 규격에 맞춘 라우팅 (실시간 vs 비동기) // 3. 아키텍처 규격에 맞춘 라우팅 (실시간 vs 비동기)
if (isMciRouting(routingType, interfaceId)) { if (isMciRouting(routingType, interfaceId)) {
log.info("[라우팅] 실시간 AI 요청 -> MCI 연계 어댑터를 통해 EIMS 전달"); log.info("[라우팅] 실시간 AI 요청 -> MCI 연계 어댑터를 통해 EIMS 전달");
return mciEimsSender.send(interfaceId, payload); legacyResponse = mciEimsSender.send(interfaceId, payload);
} else { } else {
log.info("[라우팅] 비동기/대용량 요청 -> EAI 연계 어댑터를 통해 EIMS 전달"); log.info("[라우팅] 비동기/대용량 요청 -> EAI 연계 어댑터를 통해 EIMS 전달");
return eaiEimsSender.send(interfaceId, payload); legacyResponse = eaiEimsSender.send(interfaceId, payload);
} }
} }
log.info("\n [Legacy -> Adapter] EIMS 통신 응답 수신: {}", legacyResponse);
return legacyResponse;
} }
// 라우팅 조건을 판단하는 내부 메서드 (관리를 위해 분리) // 라우팅 조건을 판단하는 내부 메서드 (관리를 위해 분리)

2
src/main/java/io/shinhanlife/axhub/biz/mcp/tool/service/AbstractMcpToolService.java
View File

@@ -33,8 +33,10 @@ public abstract class AbstractMcpToolService {
} }
try { try {
log.info("\n [Tool -> Adapter] 레거시 실행 요청 - RoutingType: {}, Interface: {}, Data: {}", routingType, interfaceId, inputMap);
// 1. Adapter 공통 모듈 직접 호출 // 1. Adapter 공통 모듈 직접 호출
String executionResult = legacyEimsConnector.executeByTool(routingType, interfaceId, inputMap, null); String executionResult = legacyEimsConnector.executeByTool(routingType, interfaceId, inputMap, null);
log.info("\n [Adapter -> Tool] 레거시 실행 응답 수신: {}", executionResult);
// 2. PII 마스킹 처리 // 2. PII 마스킹 처리
String maskedResult = PiiMaskingUtils.mask(executionResult); String maskedResult = PiiMaskingUtils.mask(executionResult);