Add YouTube API service for video details, comments, and posting functionality

app/routes/commend/gemini_service.py

@@ -0,0 +1,166 @@
+"""
+Gemini AI Service for Crown Commend
+Generates contextual YouTube comments using Google's Gemini API.
+"""
+
+from __future__ import annotations
+
+import os
+from typing import Optional, Tuple, List, Dict, Any
+
+import google.generativeai as genai
+
+from ...services.logging_config import get_logger
+
+logger = get_logger(__name__)
+
+# Gemini model configuration
+_model = None
+
+
+def _get_model():
+    """Lazy-load Gemini model."""
+    global _model
+
+    if _model is not None:
+        return _model
+
+    api_key = os.getenv('COMMEND_GEMINI_API_KEY')
+    if not api_key:
+        raise ValueError("COMMEND_GEMINI_API_KEY environment variable is required")
+
+    try:
+        genai.configure(api_key=api_key)
+        _model = genai.GenerativeModel('gemini-1.5-flash')
+        logger.info("Gemini model initialized successfully")
+        return _model
+    except Exception as e:
+        logger.error(f"Failed to initialize Gemini: {e}")
+        raise ValueError(f"Gemini initialization failed: {e}")
+
+
+def summarize_transcript(transcript_text: str, language: str) -> Tuple[Optional[str], Optional[str]]:
+    """Video transcript'ini özetler."""
+    try:
+        model = _get_model()
+
+        if not transcript_text or len(transcript_text.strip()) < 50:
+            return None, "Insufficient transcript data"
+
+        prompt = f"""
+Bu video transcript'ini {language} dilinde 2-3 cümlelik kısa bir özet haline getir:
+
+{transcript_text}
+
+ONEMLI: Sadece özetin kendisini yaz, başka açıklama yapma.
+"""
+
+        response = model.generate_content(prompt)
+        return response.text.strip(), None
+
+    except Exception as e:
+        logger.error(f"Transcript summarization error: {e}")
+        return None, "Failed to summarize transcript"
+
+
+def generate_comment(
+    video_details: Dict[str, Any],
+    comment_style: str,
+    language: str,
+    existing_comments: Optional[List[Dict[str, str]]] = None,
+    transcript_summary: Optional[str] = None
+) -> Tuple[Optional[str], Optional[str]]:
+    """
+    AI-powered comment generation using Gemini.
+
+    Args:
+        video_details: Video metadata (title, channel, stats, etc.)
+        comment_style: Style preference (supportive, analytical, humorous, etc.)
+        language: Target language for the comment
+        existing_comments: Sample comments from the video
+        transcript_summary: Optional transcript summary
+
+    Returns:
+        (generated_comment, error_message)
+    """
+    try:
+        model = _get_model()
+
+        # Format existing comments
+        comment_section = "No comments available to analyze."
+        if existing_comments:
+            comment_section = "\n".join(
+                [f"- '{c['text'][:150]}' (by {c['author']})" for c in existing_comments[:5]]
+            )
+
+        # Build the prompt
+        prompt = f"""
+### GOREV ###
+Sen Crown Commend AI'sin - YouTube videolarına özgün, yaratıcı ve değerli yorumlar üreten bir yapay zeka.
+Yorum dili: **{language}**
+
+### VIDEO ANALIZI ###
+
+**Mevcut Yorumlar (ONCELIKLI):**
+{comment_section}
+
+**Video Icerigi:**
+{f"- Ozet: {transcript_summary}" if transcript_summary else "- Icerik ozeti mevcut degil"}
+
+**Video Bilgileri:**
+- Baslik: {video_details.get('title', 'Bilinmiyor')}
+- Kanal: {video_details.get('channelName', 'Bilinmiyor')}
+- Aciklama: {video_details.get('description', '')[:300]}
+
+**Istatistikler:**
+- Izlenme: {video_details.get('viewCount', 0):,}
+- Begeni: {video_details.get('likeCount', 0):,}
+- Sure: {video_details.get('duration', 0) // 60} dakika
+
+### YORUM STRATEJISI ###
+**{comment_style}** stilinde yorum yaz:
+
+1. **Gercekcilik:** Normal bir izleyici gibi yaz, abartma.
+2. **Emoji Siniri:** Hic emoji kullanma veya en fazla 1 adet kullan.
+3. **Dogallik:** Samimi ama sade bir dil kullan.
+4. **Video Odak:** Videonun icerigini ve mevcut yorumlari on planda tut.
+5. **Kisalik:** Uzun yorumlardan kacin, net ve oz ol.
+
+### YORUM KURALLARI ###
+- **Dil:** Tamamen **{language}** dilinde yaz (disclaimer dahil)
+- **Uzunluk:** 1-3 cumle arasi, kisa ve etkili
+- **Ton:** Video konusuna uygun (ciddi/eglenceli/destekleyici)
+- **Ozgunluk:** Klise ifadelerden kacin
+- **Disclaimer:** Yorumun sonuna yeni satirda disclaimer ekle:
+  - Turkish: "Not: Bu yorum AI tarafindan uretilmistir."
+  - English: "Note: This comment was generated by AI."
+  - Russian: "Primechanie: Etot kommentariy sozdan II."
+  - Chinese: "Zhu: Ci pinglun you AI shengcheng."
+  - Japanese: "Chu: Kono komento wa AI ni yotte seisei saremashita."
+
+### ORNEKLER ###
+Kotu: "Harika video! Cok begendim!"
+Iyi: "3:45'teki o detay gercekten onemli bir noktaydi, bu konuya hic bu acidan bakmamistim."
+
+**Yorumun:**
+"""
+
+        response = model.generate_content(prompt)
+        generated_text = response.text.strip()
+
+        # Clean up the response if needed
+        if generated_text.startswith('"') and generated_text.endswith('"'):
+            generated_text = generated_text[1:-1]
+
+        return generated_text, None
+
+    except Exception as e:
+        logger.error(f"Comment generation error: {e}")
+        error_str = str(e).lower()
+
+        if "api key" in error_str:
+            return None, "Invalid API key configuration"
+        elif "quota" in error_str or "limit" in error_str:
+            return None, "API quota exceeded, please try again later"
+        else:
+            return None, f"Failed to generate comment: {str(e)}"

app/routes/commend/youtube_service.py

@@ -0,0 +1,247 @@
+"""
+YouTube API Service for Crown Commend
+Handles video details, comments, and posting functionality.
+"""
+
+from __future__ import annotations
+
+import os
+import re
+import json
+import tempfile
+from typing import Optional, Tuple, List, Dict, Any
+
+from google.oauth2.credentials import Credentials
+from google.auth.transport.requests import Request
+from googleapiclient.discovery import build
+import isodate
+
+from ...services.logging_config import get_logger
+
+logger = get_logger(__name__)
+
+
+def _get_authenticated_service():
+    """
+    OAuth 2.0 ile YouTube API kimlik doğrulaması yapar.
+    Environment variables üzerinden credentials okur.
+    """
+    SCOPES = ['https://www.googleapis.com/auth/youtube.force-ssl']
+
+    # Production: TOKEN_JSON environment variable
+    token_json = os.getenv('COMMEND_TOKEN_JSON')
+    if token_json:
+        try:
+            token_data = json.loads(token_json)
+            creds = Credentials.from_authorized_user_info(token_data, SCOPES)
+
+            # Token expire olmuşsa refresh et
+            if creds.expired and creds.refresh_token:
+                creds.refresh(Request())
+
+            return build('youtube', 'v3', credentials=creds)
+        except Exception as e:
+            logger.error(f"TOKEN_JSON parse error: {e}")
+            raise ValueError("YouTube API authentication failed")
+
+    raise ValueError("COMMEND_TOKEN_JSON environment variable is required")
+
+
+def extract_video_id(video_url: str) -> Optional[str]:
+    """YouTube URL'sinden video ID'sini çıkarır."""
+    patterns = [
+        r"(?<=v=)[^&#]+",
+        r"(?<=be/)[^&#]+",
+        r"(?<=embed/)[^&#]+",
+        r"(?<=shorts/)[^&#]+"
+    ]
+
+    for pattern in patterns:
+        match = re.search(pattern, video_url)
+        if match:
+            return match.group(0)
+
+    return None
+
+
+def get_video_details(video_url: str) -> Tuple[Optional[Dict[str, Any]], Optional[str]]:
+    """
+    YouTube video detaylarını çeker.
+    Returns: (details_dict, error_message)
+    """
+    try:
+        video_id = extract_video_id(video_url)
+        if not video_id:
+            return None, "Invalid YouTube URL"
+
+        youtube = _get_authenticated_service()
+
+        request = youtube.videos().list(
+            part="snippet,statistics,contentDetails",
+            id=video_id
+        )
+        response = request.execute()
+
+        if not response.get('items'):
+            return None, "Video not found"
+
+        item = response['items'][0]
+        snippet = item['snippet']
+        stats = item.get('statistics', {})
+        content = item.get('contentDetails', {})
+
+        # Duration parsing
+        duration_iso = content.get('duration', 'PT0S')
+        duration_seconds = isodate.parse_duration(duration_iso).total_seconds()
+
+        details = {
+            'videoId': video_id,
+            'title': snippet.get('title'),
+            'channelName': snippet.get('channelTitle'),
+            'channelId': snippet.get('channelId'),
+            'description': snippet.get('description', '')[:500],
+            'thumbnailUrl': snippet.get('thumbnails', {}).get('high', {}).get('url'),
+            'viewCount': int(stats.get('viewCount', 0)),
+            'likeCount': int(stats.get('likeCount', 0)),
+            'commentCount': int(stats.get('commentCount', 0)),
+            'duration': int(duration_seconds),
+            'publishedAt': snippet.get('publishedAt')
+        }
+
+        return details, None
+
+    except ValueError as e:
+        return None, str(e)
+    except Exception as e:
+        logger.error(f"Error fetching video details: {e}")
+        return None, "Failed to fetch video details"
+
+
+def get_channel_details(channel_id: str) -> Tuple[Optional[Dict[str, Any]], Optional[str]]:
+    """Kanal istatistiklerini çeker."""
+    try:
+        youtube = _get_authenticated_service()
+
+        request = youtube.channels().list(
+            part="statistics,snippet",
+            id=channel_id
+        )
+        response = request.execute()
+
+        if not response.get('items'):
+            return None, "Channel not found"
+
+        item = response['items'][0]
+        stats = item.get('statistics', {})
+        snippet = item.get('snippet', {})
+
+        return {
+            'subscriberCount': int(stats.get('subscriberCount', 0)),
+            'videoCount': int(stats.get('videoCount', 0)),
+            'channelDescription': snippet.get('description', '')[:200]
+        }, None
+
+    except Exception as e:
+        logger.error(f"Error fetching channel details: {e}")
+        return None, "Failed to fetch channel details"
+
+
+def get_video_comments(video_id: str, max_results: int = 10) -> Tuple[List[Dict[str, str]], Optional[str]]:
+    """Video yorumlarını çeker."""
+    try:
+        youtube = _get_authenticated_service()
+
+        request = youtube.commentThreads().list(
+            part="snippet",
+            videoId=video_id,
+            maxResults=max_results,
+            order="relevance"
+        )
+        response = request.execute()
+
+        comments = []
+        for item in response.get('items', []):
+            top_comment = item['snippet']['topLevelComment']['snippet']
+            comments.append({
+                'author': top_comment.get('authorDisplayName'),
+                'text': top_comment.get('textDisplay'),
+                'likeCount': top_comment.get('likeCount', 0)
+            })
+
+        return comments, None
+
+    except Exception as e:
+        logger.error(f"Error fetching comments: {e}")
+        return [], "Failed to fetch comments"
+
+
+def get_video_transcript(video_id: str) -> Tuple[Optional[str], Optional[str]]:
+    """Video transcript/altyazısını çeker."""
+    try:
+        from youtube_transcript_api import YouTubeTranscriptApi
+
+        transcript_list = YouTubeTranscriptApi.list_transcripts(video_id)
+
+        # Dil önceliği: tr -> en -> auto
+        for lang in ['tr', 'en']:
+            try:
+                transcript = transcript_list.find_transcript([lang])
+                break
+            except:
+                continue
+        else:
+            try:
+                transcript = transcript_list.find_generated_transcript(['tr', 'en'])
+            except:
+                return None, "No transcript available"
+
+        transcript_data = transcript.fetch()
+        full_text = ' '.join([entry['text'] for entry in transcript_data])
+
+        # Token limiti için kısalt
+        if len(full_text) > 8000:
+            full_text = full_text[:8000] + "..."
+
+        return full_text, None
+
+    except Exception as e:
+        logger.warning(f"Transcript fetch failed: {e}")
+        return None, "Transcript not available"
+
+
+def post_youtube_comment(video_id: str, comment_text: str) -> Tuple[Optional[Dict[str, Any]], Optional[str]]:
+    """YouTube'a yorum gönderir."""
+    try:
+        youtube = _get_authenticated_service()
+
+        request_body = {
+            "snippet": {
+                "videoId": video_id,
+                "topLevelComment": {
+                    "snippet": {
+                        "textOriginal": comment_text
+                    }
+                }
+            }
+        }
+
+        response = youtube.commentThreads().insert(
+            part="snippet",
+            body=request_body
+        ).execute()
+
+        return {
+            'commentId': response.get('id'),
+            'postedAt': response.get('snippet', {}).get('topLevelComment', {}).get('snippet', {}).get('publishedAt')
+        }, None
+
+    except Exception as e:
+        logger.error(f"Error posting comment: {e}")
+        error_str = str(e).lower()
+
+        if "forbidden" in error_str or "permission" in error_str:
+            return None, "Comment posting is disabled for this video"
+        elif "quota" in error_str:
+            return None, "API quota exceeded, please try again later"
+        else:
+            return None, "Failed to post comment"