Update app.py

app.py

@@ -48,36 +48,50 @@ class MyClient(discord.Client):
         super().__init__(*args, **kwargs)
         self.session = None
         self.last_comments = {}
+        self.processed_comments = set()
 
     async def on_ready(self):
         logging.info(f'{self.user}로 로그인되었습니다!')
         self.session = aiohttp.ClientSession()
         self.loop.create_task(self.check_for_new_comments())
+        self.loop.create_task(self.reply_to_unanswered_comments())
 
     async def check_for_new_comments(self):
         while True:
             try:
-                channel = self.get_channel(SPECIFIC_CHANNEL_ID)
-                if channel:
-                    logging.info(f"채널 {channel}에서 새로운 댓글을 확인합니다.")
-                    async for message in channel.history(limit=10):
-                        video_id = extract_video_id(message.content)
-                        if video_id:
-                            logging.info(f"비디오 ID: {video_id} - 메시지: {message.content}")
-                            new_comments = await get_video_comments(video_id)
-                            old_comments = self.last_comments.get(video_id, [])
-                            for comment in new_comments:
-                                if comment not in old_comments:
-                                    logging.info(f"새 댓글 발견: {comment[0]}")
-                                    transcript = await get_best_available_transcript(video_id)
-                                    reply = await generate_reply(comment[0], transcript)
-                                    logging.info(f"생성된 답변: {reply}")
-                                    await send_reply(message, video_id, comment, reply)
-                                    old_comments.append(comment)
-                            self.last_comments[video_id] = old_comments
+                await self.process_comments()
             except Exception as e:
                 logging.error(f"Error in check_for_new_comments: {e}")
-            await asyncio.sleep(30)  # 주기적인 체크 간격을 30초로 설정
+            await asyncio.sleep(30)
+
+    async def reply_to_unanswered_comments(self):
+        while True:
+            try:
+                await self.process_comments()
+            except Exception as e:
+                logging.error(f"Error in reply_to_unanswered_comments: {e}")
+            await asyncio.sleep(60)
+
+    async def process_comments(self):
+        channel = self.get_channel(SPECIFIC_CHANNEL_ID)
+        if channel:
+            logging.info(f"채널 {channel}에서 새로운 댓글을 확인합니다.")
+            async for message in channel.history(limit=10):
+                video_id = extract_video_id(message.content)
+                if video_id:
+                    logging.info(f"비디오 ID: {video_id} - 메시지: {message.content}")
+                    new_comments = await get_video_comments(video_id)
+                    old_comments = self.last_comments.get(video_id, [])
+                    for comment in new_comments:
+                        if comment not in old_comments:
+                            logging.info(f"새 댓글 발견: {comment[0]}")
+                            transcript = await get_best_available_transcript(video_id)
+                            reply = await generate_reply(comment[0], transcript)
+                            logging.info(f"생성된 답변: {reply}")
+                            await send_reply(message, video_id, comment, reply)
+                            old_comments.append(comment)
+                            self.processed_comments.add(comment[1])
+                    self.last_comments[video_id] = old_comments
 
     async def close(self):
         if self.session:
@@ -133,11 +147,9 @@ async def generate_reply(comment, transcript):
         response = hf_client.text_generation(prompt)
         if response:
             try:
-                # JSON 파싱 시도
                 response_json = json.loads(response)
                 return response_json.get("generated_text", "").strip()
             except json.JSONDecodeError:
-                # JSON 파싱 실패 시 로그 남기고 응답 그대로 반환
                 logging.error(f"Failed to decode JSON: {response}")
                 return response.strip()
     except Exception as e: