Update app.py

app.py

@@ -4,6 +4,7 @@ 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
@@ -33,6 +34,9 @@ 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"
+
 class MyClient(discord.Client):
     def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
@@ -43,7 +47,7 @@ class MyClient(discord.Client):
 
         # web.py 파일 실행
         subprocess.Popen(["python", "web.py"])
-        logging.info("Web.py server has been started.")
+        logging.info("Web.py 서버가 시작되었습니다.")
 
         # 봇이 시작될 때 안내 메시지를 전송
         channel = self.get_channel(SPECIFIC_CHANNEL_ID)
@@ -88,28 +92,28 @@ def extract_video_id(url):
     match = re.match(youtube_regex, url)
     if match:
         video_id = match.group(6)
-    logging.debug(f'Extracted video ID: {video_id}')
+    logging.debug(f'추출된 비디오 ID: {video_id}')
     return video_id
 
 async def get_best_available_transcript(video_id):
     try:
         transcript = YouTubeTranscriptApi.get_transcript(video_id, languages=['ko'])
     except Exception as e:
-        logging.warning(f'Error fetching Korean transcript: {e}')
+        logging.warning(f'한국어 자막 가져오기 오류: {e}')
         try:
             transcript = YouTubeTranscriptApi.get_transcript(video_id, languages=['en'])
         except Exception as e:
-            logging.warning(f'Error fetching English transcript: {e}')
+            logging.warning(f'영어 자막 가져오기 오류: {e}')
             try:
                 transcripts = YouTubeTranscriptApi.list_transcripts(video_id)
                 transcript = transcripts.find_manually_created_transcript().fetch()
             except Exception as e:
-                logging.error(f'Error fetching alternative transcript: {e}')
+                logging.error(f'대체 자막 가져오기 오류: {e}')
                 return None
 
     formatter = TextFormatter()
     transcript_text = formatter.format_transcript(transcript)
-    logging.debug(f'Fetched transcript: {transcript_text}')
+    logging.debug(f'가져온 자막: {transcript_text}')
     return transcript_text
 
 async def get_video_comments(video_id):
@@ -125,7 +129,7 @@ async def get_video_comments(video_id):
         comment_id = item['snippet']['topLevelComment']['id']
         comments.append((comment, comment_id))
     
-    logging.debug(f'Fetched comments: {comments}')
+    logging.debug(f'가져온 댓글: {comments}')
     return comments
 
 async def generate_replies(comments, transcript):
@@ -145,15 +149,28 @@ async def generate_replies(comments, transcript):
             reply = "답글을 생성할 수 없습니다."
         replies.append(reply)
     
-    logging.debug(f'Generated replies: {replies}')
+    logging.debug(f'생성된 답글: {replies}')
     return replies
 
 async def create_thread_and_send_replies(message, video_id, comments, replies):
     thread = await message.channel.create_thread(name=f"{message.author.name}의 댓글 답글", message=message)
+    webhook_data = {"video_id": video_id, "replies": []}
+
     for (comment, _), reply in zip(comments, replies):
         embed = discord.Embed(description=f"**댓글**: {comment}\n**답글**: {reply}")
         await thread.send(embed=embed)
 
+        # 웹훅 데이터 준비
+        webhook_data["replies"].append({"comment": comment, "reply": reply})
+
+    # 웹훅으로 데이터 전송
+    async with aiohttp.ClientSession() as session:
+        async with session.post(WEBHOOK_URL, json=webhook_data) as resp:
+            if resp.status == 200:
+                logging.info("웹훅으로 데이터 전송 성공")
+            else:
+                logging.error(f"웹훅으로 데이터 전송 실패: {resp.status}")
+
 if __name__ == "__main__":
     discord_client = MyClient(intents=intents)
     discord_client.run(os.getenv('DISCORD_TOKEN'))