Update app.py

app.py

@@ -40,6 +40,71 @@ WEBHOOK_URL = "https://connect.pabbly.com/workflow/sendwebhookdata/IjU3NjUwNTY1M
 # 전송 실패 시 재시도 횟수
 MAX_RETRIES = 3
 
+class MyClient(discord.Client):
+    def __init__(self, *args, **kwargs):
+        super().__init__(*args, **kwargs)
+        self.is_processing = False
+        self.session = None
+
+    async def on_ready(self):
+        logging.info(f'{self.user}로 로그인되었습니다!')
+
+        # web.py 파일 실행
+        subprocess.Popen(["python", "web.py"])
+        logging.info("Web.py 서버가 시작되었습니다.")
+
+        # aiohttp 클라이언트 세션 생성
+        self.session = aiohttp.ClientSession()
+
+        # 봇이 시작될 때 안내 메시지를 전송
+        channel = self.get_channel(SPECIFIC_CHANNEL_ID)
+        if channel:
+            await channel.send("유튜브 비디오 URL을 입력하면, 자막과 댓글을 기반으로 답글을 작성합니다.")
+
+    async def on_message(self, message):
+        if message.author == self.user:
+            returnimport discord
+import logging
+import os
+import re
+import asyncio
+import subprocess
+import aiohttp
+from huggingface_hub import InferenceClient
+from googleapiclient.discovery import build
+from youtube_transcript_api import YouTubeTranscriptApi
+from youtube_transcript_api.formatters import TextFormatter
+from dotenv import load_dotenv
+
+# 환경 변수 로드
+load_dotenv()
+
+# 로깅 설정
+logging.basicConfig(level=logging.DEBUG, format='%(asctime)s:%(levelname)s:%(name)s:%(message)s', handlers=[logging.StreamHandler()])
+
+# 인텐트 설정
+intents = discord.Intents.default()
+intents.message_content = True
+intents.messages = True
+intents.guilds = True
+intents.guild_messages = True
+
+# 추론 API 클라이언트 설정
+hf_client = InferenceClient("CohereForAI/c4ai-command-r-plus", token=os.getenv("HF_TOKEN"))
+
+# YouTube API 설정
+API_KEY = os.getenv("YOUTUBE_API_KEY")
+youtube_service = build('youtube', 'v3', developerKey=API_KEY)
+
+# 특정 채널 ID
+SPECIFIC_CHANNEL_ID = int(os.getenv("DISCORD_CHANNEL_ID"))
+
+# 웹훅 URL 설정
+WEBHOOK_URL = "https://connect.pabbly.com/workflow/sendwebhookdata/IjU3NjUwNTY1MDYzMjA0MzA1MjY4NTUzMDUxMzUi_pc"
+
+# 전송 실패 시 재시도 횟수
+MAX_RETRIES = 3
+
 class MyClient(discord.Client):
     def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
@@ -192,7 +257,7 @@ async def create_thread_and_send_replies(message, video_id, comments, replies, s
         webhook_data["replies"].append({"comment": comment, "reply": reply, "comment_id": comment_id})
 
     # 데이터를 여러 번 나누어 전송
-    chunk_size = 10  # 전송할 데이터의 개수
+    chunk_size = 1  # 전송할 데이터의 개수를 1로 설정하여 각 데이터를 별도로 전송
     for i in range(0, len(webhook_data["replies"]), chunk_size):
         chunk = webhook_data["replies"][i:i+chunk_size]
         chunk_data = {"video_id": video_id, "replies": chunk}