Add Crown Commend API routes for YouTube comment generation and posting

app/routes/commend/router.py

@@ -0,0 +1,281 @@
+"""
+Crown Commend API Routes
+AI-powered YouTube comment generation and posting.
+"""
+
+from __future__ import annotations
+
+import os
+import time
+from typing import Literal, Optional, Dict, Any, List
+
+from fastapi import APIRouter, HTTPException, status
+from pydantic import BaseModel, Field, field_validator
+
+from .youtube_service import (
+    extract_video_id,
+    get_video_details,
+    get_channel_details,
+    get_video_comments,
+    get_video_transcript,
+    post_youtube_comment
+)
+from .gemini_service import generate_comment, summarize_transcript
+from ...services.logging_config import get_logger
+
+logger = get_logger(__name__)
+router = APIRouter(prefix="/api/commend", tags=["commend"])
+
+
+# --- Pydantic Models ---
+
+class GenerateCommentRequest(BaseModel):
+    """Request model for comment generation."""
+    videoUrl: str = Field(..., min_length=10, description="YouTube video URL")
+    language: Literal['Turkish', 'English', 'Russian', 'Chinese', 'Japanese'] = Field(
+        default='Turkish',
+        description="Target language for the comment"
+    )
+    commentStyle: str = Field(
+        default='supportive',
+        description="Comment style (supportive, analytical, humorous, etc.)"
+    )
+
+    @field_validator('videoUrl')
+    @classmethod
+    def validate_youtube_url(cls, v: str) -> str:
+        if not extract_video_id(v):
+            raise ValueError('Invalid YouTube URL format')
+        return v
+
+
+class PostCommentRequest(BaseModel):
+    """Request model for posting a comment."""
+    videoUrl: str = Field(..., min_length=10)
+    commentText: str = Field(..., min_length=1, max_length=10000)
+
+    @field_validator('videoUrl')
+    @classmethod
+    def validate_youtube_url(cls, v: str) -> str:
+        if not extract_video_id(v):
+            raise ValueError('Invalid YouTube URL format')
+        return v
+
+
+class VideoDetailsResponse(BaseModel):
+    """Response model for video details."""
+    videoId: str
+    title: str
+    channelName: str
+    channelId: str
+    description: str
+    thumbnailUrl: Optional[str]
+    viewCount: int
+    likeCount: int
+    commentCount: int
+    duration: int
+    publishedAt: Optional[str]
+    subscriberCount: Optional[int] = None
+
+
+class GenerateCommentResponse(BaseModel):
+    """Response model for comment generation."""
+    status: str
+    generatedText: str
+    videoDetails: VideoDetailsResponse
+    processingTime: float
+    hasTranscript: bool
+
+
+class PostCommentResponse(BaseModel):
+    """Response model for posting a comment."""
+    status: str
+    message: str
+    commentId: Optional[str] = None
+    postedAt: Optional[str] = None
+
+
+class CommendHealthResponse(BaseModel):
+    """Health check response for Commend service."""
+    status: str
+    geminiConfigured: bool
+    youtubeConfigured: bool
+    message: str
+
+
+# --- API Endpoints ---
+
+@router.get("/health", response_model=CommendHealthResponse)
+async def commend_health_check():
+    """Check Commend service health and configuration."""
+    gemini_key = os.getenv('COMMEND_GEMINI_API_KEY')
+    youtube_token = os.getenv('COMMEND_TOKEN_JSON')
+
+    return CommendHealthResponse(
+        status="ok" if gemini_key and youtube_token else "degraded",
+        geminiConfigured=bool(gemini_key),
+        youtubeConfigured=bool(youtube_token),
+        message="Crown Commend service is running"
+    )
+
+
+@router.post("/video-details", response_model=VideoDetailsResponse)
+async def get_video_info(request: GenerateCommentRequest):
+    """
+    Fetch video details without generating a comment.
+    Useful for preview before generation.
+    """
+    video_id = extract_video_id(request.videoUrl)
+
+    details, error = get_video_details(request.videoUrl)
+    if error:
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail=error
+        )
+
+    # Optionally fetch channel subscriber count
+    if details.get('channelId'):
+        channel_info, _ = get_channel_details(details['channelId'])
+        if channel_info:
+            details['subscriberCount'] = channel_info.get('subscriberCount')
+
+    return VideoDetailsResponse(**details)
+
+
+@router.post("/generate", response_model=GenerateCommentResponse)
+async def generate_youtube_comment(request: GenerateCommentRequest):
+    """
+    Generate an AI-powered comment for a YouTube video.
+
+    The comment is generated based on:
+    - Video title, description, and metadata
+    - Existing comments on the video
+    - Video transcript (if available)
+    - Selected language and style
+    """
+    start_time = time.time()
+    video_id = extract_video_id(request.videoUrl)
+
+    # 1. Fetch video details
+    details, error = get_video_details(request.videoUrl)
+    if error:
+        logger.warning(f"Video details error: {error}")
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail=f"Could not fetch video details: {error}"
+        )
+
+    # 2. Fetch channel stats
+    if details.get('channelId'):
+        channel_info, _ = get_channel_details(details['channelId'])
+        if channel_info:
+            details['subscriberCount'] = channel_info.get('subscriberCount')
+
+    # 3. Fetch existing comments
+    existing_comments, _ = get_video_comments(video_id, max_results=10)
+
+    # 4. Fetch and summarize transcript
+    transcript_summary = None
+    has_transcript = False
+    transcript_text, _ = get_video_transcript(video_id)
+    if transcript_text:
+        has_transcript = True
+        summary, _ = summarize_transcript(transcript_text, request.language)
+        if summary:
+            transcript_summary = summary
+
+    # 5. Generate comment
+    generated_text, gen_error = generate_comment(
+        video_details=details,
+        comment_style=request.commentStyle,
+        language=request.language,
+        existing_comments=existing_comments,
+        transcript_summary=transcript_summary
+    )
+
+    if gen_error:
+        logger.error(f"Comment generation failed: {gen_error}")
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail=f"Comment generation failed: {gen_error}"
+        )
+
+    processing_time = time.time() - start_time
+
+    return GenerateCommentResponse(
+        status="success",
+        generatedText=generated_text,
+        videoDetails=VideoDetailsResponse(**details),
+        processingTime=round(processing_time, 2),
+        hasTranscript=has_transcript
+    )
+
+
+@router.post("/post", response_model=PostCommentResponse)
+async def post_comment_to_youtube(request: PostCommentRequest):
+    """
+    Post a comment to YouTube.
+
+    Note: This requires valid OAuth credentials with YouTube posting permissions.
+    Comments include an AI disclaimer as required by platform policies.
+    """
+    video_id = extract_video_id(request.videoUrl)
+
+    # Post to YouTube
+    result, error = post_youtube_comment(video_id, request.commentText)
+
+    if error:
+        logger.error(f"Comment posting failed: {error}")
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail=error
+        )
+
+    return PostCommentResponse(
+        status="success",
+        message="Comment posted successfully",
+        commentId=result.get('commentId'),
+        postedAt=result.get('postedAt')
+    )
+
+
+@router.get("/styles")
+async def get_comment_styles():
+    """Get available comment styles with descriptions."""
+    return {
+        "styles": [
+            {
+                "id": "supportive",
+                "name": {"tr": "Destekleyici", "en": "Supportive"},
+                "description": {"tr": "Pozitif ve teşvik edici", "en": "Positive and encouraging"}
+            },
+            {
+                "id": "analytical",
+                "name": {"tr": "Analitik", "en": "Analytical"},
+                "description": {"tr": "Detaylı ve düşündürücü", "en": "Detailed and thought-provoking"}
+            },
+            {
+                "id": "humorous",
+                "name": {"tr": "Esprili", "en": "Humorous"},
+                "description": {"tr": "Eğlenceli ve samimi", "en": "Fun and friendly"}
+            },
+            {
+                "id": "curious",
+                "name": {"tr": "Meraklı", "en": "Curious"},
+                "description": {"tr": "Soru soran ve ilgili", "en": "Questioning and engaged"}
+            },
+            {
+                "id": "professional",
+                "name": {"tr": "Profesyonel", "en": "Professional"},
+                "description": {"tr": "Resmi ve saygılı", "en": "Formal and respectful"}
+            }
+        ],
+        "languages": [
+            {"code": "Turkish", "name": "Türkçe", "flag": "🇹🇷"},
+            {"code": "English", "name": "English", "flag": "🇬🇧"},
+            {"code": "Russian", "name": "Русский", "flag": "🇷🇺"},
+            {"code": "Chinese", "name": "中文", "flag": "🇨🇳"},
+            {"code": "Japanese", "name": "日本語", "flag": "🇯🇵"}
+        ]
+    }