Update app.py

app.py

@@ -11,33 +11,33 @@ from youtube_transcript_api import YouTubeTranscriptApi
 from youtube_transcript_api.formatters import TextFormatter
 from dotenv import load_dotenv
 
-# 환경 변수 로드
+# Load environment variables
 load_dotenv()
 
-# 로깅 설정
+# Logging configuration
 logging.basicConfig(level=logging.DEBUG, format='%(asctime)s:%(levelname)s:%(name)s:%(message)s', handlers=[logging.StreamHandler()])
 
-# 인텐트 설정
+# Intents configuration
 intents = discord.Intents.default()
 intents.message_content = True
 intents.messages = True
 intents.guilds = True
 intents.guild_messages = True
 
-# 추론 API 클라이언트 설정
+# Inference API client configuration
 hf_client = InferenceClient("CohereForAI/c4ai-command-r-plus", token=os.getenv("HF_TOKEN"))
 
-# YouTube API 설정
+# YouTube API configuration
 API_KEY = os.getenv("YOUTUBE_API_KEY")
 youtube_service = build('youtube', 'v3', developerKey=API_KEY)
 
-# 특정 채널 ID
+# Specific channel ID
 SPECIFIC_CHANNEL_ID = int(os.getenv("DISCORD_CHANNEL_ID"))
 
-# 웹훅 URL 설정
+# Webhook URL configuration
 WEBHOOK_URL = "https://connect.pabbly.com/workflow/sendwebhookdata/IjU3NjUwNTY1MDYzMjA0MzA1MjY4NTUzMDUxMzUi_pc"
 
-# 전송 실패 시 재시도 횟수
+# Maximum retries for sending data
 MAX_RETRIES = 3
 
 class MyClient(discord.Client):
@@ -49,14 +49,14 @@ class MyClient(discord.Client):
     async def on_ready(self):
         logging.info(f'{self.user}로 로그인되었습니다!')
 
-        # web.py 파일 실행
+        # Start web.py
         subprocess.Popen(["python", "web.py"])
         logging.info("Web.py 서버가 시작되었습니다.")
 
-        # aiohttp 클라이언트 세션 생성
+        # Create aiohttp client session
         self.session = aiohttp.ClientSession()
 
-        # 봇이 시작될 때 안내 메시지를 전송
+        # Send initial message when bot starts
         channel = self.get_channel(SPECIFIC_CHANNEL_ID)
         if channel:
             await channel.send("유튜브 비디오 URL을 입력하면, 자막과 댓글을 기반으로 답글을 작성합니다.")
@@ -76,7 +76,7 @@ class MyClient(discord.Client):
                 comments = await get_video_comments(video_id)
                 if comments and transcript:
                     replies = await generate_replies(comments, transcript)
-                    await create_thread_and_send_replies(message, video_id, comments, replies)
+                    await create_thread_and_send_replies(message, video_id, comments, replies, self.session)
                 else:
                     await message.channel.send("자막이나 댓글을 가져올 수 없습니다.")
             else:
@@ -90,7 +90,7 @@ class MyClient(discord.Client):
         )
 
     async def close(self):
-        # aiohttp 클라이언트 세션 종료
+        # Close aiohttp client session
         if self.session:
             await self.session.close()
         await super().close()
@@ -180,7 +180,7 @@ async def send_webhook_data(session, chunk_data, chunk_number):
 
     return False  # 재시도 횟수 초과 시 실패로 간주
 
-async def create_thread_and_send_replies(message, video_id, comments, replies):
+async def create_thread_and_send_replies(message, video_id, comments, replies, session):
     thread = await message.channel.create_thread(name=f"{message.author.name}의 댓글 답글", message=message)
     webhook_data = {"video_id": video_id, "replies": []}
 
@@ -197,7 +197,7 @@ async def create_thread_and_send_replies(message, video_id, comments, replies):
         chunk = webhook_data["replies"][i:i+chunk_size]
         chunk_data = {"video_id": video_id, "replies": chunk}
 
-        success = await send_webhook_data(self.session, chunk_data, i // chunk_size + 1)
+        success = await send_webhook_data(session, chunk_data, i // chunk_size + 1)
         if not success:
             logging.error(f"데이터 전송 실패: {i // chunk_size + 1} 번째 청크")