@@ -57,25 +57,22 @@ public class ChatBotService {
5757 @ Transactional
5858 public Flux <ChatResponse > sendMessage (Long memberId , ChatRequest chatRequestDto , Long roomId ) {
5959
60- // 벡터 검색 (판례, 법령) (블로킹)
60+ // 벡터 검색 (판례, 법령)
6161 List <Document > similarCaseDocuments = qdrantService .searchDocument (chatRequestDto .getMessage (), "type" , "판례" );
6262 List <Document > similarLawDocuments = qdrantService .searchDocument (chatRequestDto .getMessage (), "type" , "법령" );
6363
6464 String caseContext = formatting (similarCaseDocuments );
6565 String lawContext = formatting (similarLawDocuments );
6666
67- // 채팅방 조회 또는 생성 (블로킹)
67+ // 채팅방 조회 또는 생성
6868 History history = getOrCreateRoom (memberId , roomId );
6969
70- // 메시지 기억 관리 (User 메시지 추가)
70+ // 메시지 기억 관리
7171 ChatMemory chatMemory = saveChatMemory (chatRequestDto , history );
7272
7373 // 프롬프트 생성
7474 Prompt prompt = getPrompt (caseContext , lawContext , chatMemory , history );
7575
76- // 준비된 데이터를 담은 컨텍스트 객체 반환
77- //return new PreparedChatContext(prompt, history, similarCaseDocuments, similarLawDocuments);
78-
7976 return chatClient .prompt (prompt )
8077 .stream ()
8178 .content ()
@@ -176,23 +173,4 @@ private ChatResponse handleError(History history) {
176173 .build ();
177174 }
178175
179- /**
180- * 블로킹 작업에서 준비된 데이터를 담는 컨텍스트 클래스
181- * 리액티브 체인에서 데이터를 전달하기 위한 내부 클래스
182- */
183- private static class PreparedChatContext {
184- final Prompt prompt ;
185- final History history ;
186- final List <Document > similarCaseDocuments ;
187- final List <Document > similarLawDocuments ;
188-
189- PreparedChatContext (Prompt prompt , History history ,
190- List <Document > similarCaseDocuments ,
191- List <Document > similarLawDocuments ) {
192- this .prompt = prompt ;
193- this .history = history ;
194- this .similarCaseDocuments = similarCaseDocuments ;
195- this .similarLawDocuments = similarLawDocuments ;
196- }
197- }
198176}
0 commit comments