Update app.py

app.py

@@ -31,9 +31,6 @@ CX = "c01abc75e1b95483d"  # 사용자 커스텀 검색 엔진 ID
 # 대화 히스토리를 저장할 딕셔너리
 conversation_histories = {}
 
-# 스레드 ID를 저장할 딕셔너리
-user_threads = {}
-
 def google_search(query):
     logger.info(f"Searching for query: {query}")
     url = f"https://www.googleapis.com/customsearch/v1?key={API_KEY}&cx={CX}&q={query}&num=10"
@@ -87,37 +84,14 @@ class MyClient(commands.Bot):
         
         self.is_processing = True
         try:
-            # 스레드 생성 또는 기존 스레드 찾기
-            thread = await self.get_or_create_thread(message)
-            
-            # 스레드에서 응답 생성
-            response = await generate_response(message, thread.id)
-            await self.send_long_message(thread, response)
+            response = await generate_response(message)
+            await self.send_long_message(message.channel, response)
         finally:
             self.is_processing = False
 
     def is_message_in_specific_channel(self, message):
         return message.channel.id == SPECIFIC_CHANNEL_ID
 
-    async def get_or_create_thread(self, message):
-        if message.author.id in user_threads:
-            thread_id = user_threads[message.author.id]
-            thread = self.get_channel(thread_id)
-            if thread is None:
-                # 스레드가 삭제되었다면 새로 생성
-                thread = await self.create_thread(message)
-        else:
-            thread = await self.create_thread(message)
-        return thread
-
-    async def create_thread(self, message):
-        thread = await message.channel.create_thread(
-            name=f"대화 - {message.author.name}",
-            auto_archive_duration=60
-        )
-        user_threads[message.author.id] = thread.id
-        return thread
-
     async def send_long_message(self, channel, message):
         if len(message) <= 2000:
             await channel.send(message)
@@ -126,16 +100,16 @@ class MyClient(commands.Bot):
             for part in parts:
                 await channel.send(part)
 
-async def generate_response(message, thread_id):
+async def generate_response(message):
     global conversation_histories
     user_input = message.content
     user_mention = message.author.mention
     
-    # 스레드별 대화 히스토리 관리
-    if thread_id not in conversation_histories:
-        conversation_histories[thread_id] = []
+    # 사용자별 대화 히스토리 관리
+    if message.author.id not in conversation_histories:
+        conversation_histories[message.author.id] = []
     
-    conversation_history = conversation_histories[thread_id]
+    conversation_history = conversation_histories[message.author.id]
     
     system_message = f"{user_mention}, DISCORD에서 사용자들의 질문에 답하는 어시스턴트입니다."
     system_prefix = """
@@ -185,9 +159,9 @@ async def generate_response(message, thread_id):
         conversation_history.append({"role": "assistant", "content": full_response_text})
         
         # 대화 히스토리 길이 제한 (최근 10개 메시지만 유지)
-        conversation_histories[thread_id] = conversation_history[-10:]
+        conversation_histories[message.author.id] = conversation_history[-10:]
         
-        logging.debug(f'Conversation history updated: {conversation_histories[thread_id]}')
+        logging.debug(f'Conversation history updated: {conversation_histories[message.author.id]}')
         
         return f"{user_mention}, {full_response_text}"
     except Exception as e: