De

%%capture
!pip install -q torch torchvision torchaudio
!pip install -q git+https://github.com/openai/whisper.git
!pip install -q yt-dlp moviepy gradio praw google-api-python-client
!sudo apt update
!sudo apt install -y ffmpeg

import os
import shutil
import concurrent.futures
import gradio as gr
import numpy as np
from PIL import Image, ImageEnhance
from moviepy.editor import VideoFileClip, CompositeVideoClip, TextClip, AudioFileClip
import yt_dlp as youtube_dl
import requests
import whisper
import tempfile
import subprocess
import logging
from googleapiclient.discovery import build
import praw
import torch

# Günlük kaydını azalt
logging.basicConfig(level=logging.ERROR)
logger = logging.getLogger()
logger.setLevel(logging.ERROR)

# Colab için özel ayarlar
OUTPUT_DIR = "/content/processed_videos"
TEMP_DIR = "/content/temp_video_files"

for d in [OUTPUT_DIR, TEMP_DIR]:
    if not os.path.exists(d):
        os.makedirs(d)

# Whisper modelini yükle
print("CUDA kullanılabilir mi?", torch.cuda.is_available())
model = whisper.load_model("base")
print("✅ Whisper model başarıyla yüklendi")

# ===== FONKSİYONLAR =====
def get_youtube_trending(youtube_api_key, region_code="TR", max_results=5):
    """YouTube'dan trend videoları al"""
    try:
        youtube = build("youtube", "v3", developerKey=youtube_api_key)
        req = youtube.videos().list(
            part="snippet,contentDetails,statistics",
            chart="mostPopular",
            regionCode=region_code,
            maxResults=max_results
        )
        res = req.execute()
        videos = []
        for item in res.get("items", []):
            videos.append({
                "id": item["id"],
                "title": item["snippet"]["title"]
            })
        return videos
    except Exception as e:
        print(f"❌ YouTube trend hatası: {e}")
        return []

def get_reddit_videos(client_id, client_secret, user_agent, subreddit="funny", limit=5):
    """Reddit'ten popüler videoları al"""
    try:
        reddit = praw.Reddit(
            client_id=client_id,
            client_secret=client_secret,
            user_agent=user_agent
        )
        sub = reddit.subreddit(subreddit)
        videos = []
        for post in sub.hot(limit=limit):
            if post.is_video and post.media and 'reddit_video' in post.media:
                media = post.media['reddit_video']
                video_url = media['fallback_url']

                # Ses dosyası URL'sini oluştur
                audio_url = None
                if media.get('has_audio', False):
                    base_url = video_url.split('_')[0]
                    audio_url = f"{base_url}_audio.mp4"

                videos.append({
                    "id": post.id,
                    "title": post.title,
                    "video_url": video_url,
                    "audio_url": audio_url
                })
        return videos
    except Exception as e:
        print(f"❌ Reddit video hatası: {e}")
        return []

def download_youtube_video(video_id, output_path):
    """YouTube videosunu indir"""
    try:
        url = f"https://www.youtube.com/watch?v={video_id}"
        ydl_opts = {
            'format': 'best[height<=720]',  # 720p çözünürlük
            'outtmpl': output_path,
            'quiet': True,
            'no_warnings': True
        }
        with youtube_dl.YoutubeDL(ydl_opts) as ydl:
            ydl.download([url])
        return True
    except Exception as e:
        print(f"❌ YouTube indirme hatası: {e}")
        return False

def download_reddit_video(video_url, audio_url, output_path):
    """Reddit videosunu ve sesini indir ve birleştir"""
    try:
        # Videoyu indir
        video_path = f"{output_path}_video.mp4"
        r = requests.get(video_url, stream=True, timeout=30)
        r.raise_for_status()
        with open(video_path, "wb") as f:
            for chunk in r.iter_content(chunk_size=8192):
                f.write(chunk)

        # Ses dosyası varsa indir ve birleştir
        if audio_url:
            audio_path = f"{output_path}_audio.mp4"
            r_audio = requests.get(audio_url, stream=True, timeout=30)
            r_audio.raise_for_status()
            with open(audio_path, "wb") as f:
                for chunk in r_audio.iter_content(chunk_size=8192):
                    f.write(chunk)

            # Video ve sesi birleştir
            video_clip = VideoFileClip(video_path)
            audio_clip = AudioFileClip(audio_path)
            final_clip = video_clip.set_audio(audio_clip)
            final_clip.write_videofile(
                output_path,
                codec='libx264',
                audio_codec='aac',
                verbose=False,
                logger=None,
                threads=4  # Colab için daha fazla thread
            )

            # Geçici dosyaları temizle
            os.remove(video_path)
            os.remove(audio_path)
        else:
            # Ses yoksa videoyu direkt taşı
            os.rename(video_path, output_path)
        return True
    except Exception as e:
        print(f"❌ Reddit indirme hatası: {e}")
        return False

def generate_subtitle_text(video_path, language='tr'):
    """Whisper ile altyazı oluştur"""
    try:
        clip = VideoFileClip(video_path)
        audio_path = os.path.join(TEMP_DIR, f"temp_audio.wav")
        clip.audio.write_audiofile(audio_path, verbose=False, logger=None)
        result = model.transcribe(audio_path, language=language)
        os.remove(audio_path)
        return result["text"]
    except Exception as e:
        print(f"❌ Altyazı oluşturma hatası: {e}")
        return ""

def process_video_with_subtitle(input_path, output_path, subtitle_text, apply_filter=True):
    """Videoyu işle ve altyazı ekle"""
    try:
        clip = VideoFileClip(input_path)
        target_w, target_h = 720, 1280  # Reels formatı

        # Reels formatına uygun boyutlandırma
        clip_ratio = clip.w / clip.h
        target_ratio = target_w / target_h

        if clip_ratio > target_ratio:
            # Yatay video, yüksekliği sabitleyip genişliği kırp
            clip = clip.resize(height=target_h)
            excess_width = clip.w - target_w
            clip = clip.crop(x1=excess_width//2, x2=clip.w - excess_width//2)
        else:
            # Dikey video, genişliği sabitleyip yüksekliği kırp
            clip = clip.resize(width=target_w)
            excess_height = clip.h - target_h
            clip = clip.crop(y1=excess_height//2, y2=clip.h - excess_height//2)

        # Efekt uygula
        if apply_filter:
            def enhance_frame(get_frame, t):
                frame = get_frame(t)
                img = Image.fromarray(frame)
                # Parlaklık ve renk artırma
                enhancer = ImageEnhance.Brightness(img)
                img = enhancer.enhance(1.1)
                enhancer = ImageEnhance.Color(img)
                img = enhancer.enhance(1.2)
                return np.array(img)

            clip = clip.fl(enhance_frame)

        # Altyazı ekle
        if subtitle_text.strip():
            txt_clip = TextClip(
                subtitle_text,
                fontsize=40,
                font='Arial-Bold',
                color='yellow',
                stroke_color='black',
                stroke_width=2,
                method='caption',
                size=(target_w-40, None),
                align='center'
            )
            txt_clip = txt_clip.set_position(('center', target_h - 150)).set_duration(clip.duration)
            final = CompositeVideoClip([clip, txt_clip])
        else:
            final = clip

        # Videoyu kaydet
        final.write_videofile(
            output_path,
            codec='libx264',
            audio_codec='aac',
            fps=24,
            verbose=False,
            logger=None,
            threads=4  # Colab için daha fazla thread
        )
        return True
    except Exception as e:
        print(f"❌ Video işleme hatası: {e}")
        return False

def process_single_youtube(video_id, title):
    """Tek bir YouTube videosunu işle"""
    vid_path = os.path.join(TEMP_DIR, f"yt_{video_id}.mp4")
    out_path = os.path.join(OUTPUT_DIR, f"yt_{video_id}_processed.mp4")

    print(f"⏬ YouTube indiriliyor: {title}")
    if not download_youtube_video(video_id, vid_path):
        return None

    print("🔤 Altyazı oluşturuluyor...")
    subtitle = generate_subtitle_text(vid_path)
    print(f"✅ Altyazı tamamlandı ({len(subtitle)} karakter)")

    print("🎞️ Video işleniyor...")
    if process_video_with_subtitle(vid_path, out_path, subtitle, apply_filter=True):
        print(f"✅ İşlenen video kaydedildi: {out_path}")
        # Geçici dosyayı temizle
        if os.path.exists(vid_path):
            os.remove(vid_path)
        return out_path
    else:
        print(f"❌ Video işleme başarısız: {title}")
        return None

def process_single_reddit(video_url, audio_url, post_id, title):
    """Tek bir Reddit videosunu işle"""
    vid_path = os.path.join(TEMP_DIR, f"reddit_{post_id}.mp4")
    out_path = os.path.join(OUTPUT_DIR, f"reddit_{post_id}_processed.mp4")

    print(f"⏬ Reddit indiriliyor: {title}")
    if not download_reddit_video(video_url, audio_url, vid_path):
        return None

    print("🔤 Altyazı oluşturuluyor...")
    subtitle = generate_subtitle_text(vid_path)
    print(f"✅ Altyazı tamamlandı ({len(subtitle)} karakter)")

    print("🎞️ Video işleniyor...")
    if process_video_with_subtitle(vid_path, out_path, subtitle, apply_filter=True):
        print(f"✅ İşlenen video kaydedildi: {out_path}")
        # Geçici dosyayı temizle
        if os.path.exists(vid_path):
            os.remove(vid_path)
        return out_path
    else:
        print(f"❌ Video işleme başarısız: {title}")
        return None

# ===== ANA OTOMASYON FONKSİYONU =====
def run_automation(youtube_api_key, reddit_client_id, reddit_client_secret, reddit_user_agent,
                   yt_max=2, reddit_max=2, reddit_subreddit="funny"):
    """Ana otomasyon fonksiyonu"""
    results = []

    # YouTube trending videoları
    print("📊 YouTube trend videoları alınıyor...")
    yt_videos = get_youtube_trending(youtube_api_key, max_results=yt_max)
    print(f"✅ {len(yt_videos)} YouTube videosu bulundu")

    # Reddit viral videolar
    print("📊 Reddit popüler videolar alınıyor...")
    reddit_videos = get_reddit_videos(
        reddit_client_id,
        reddit_client_secret,
        reddit_user_agent,
        subreddit=reddit_subreddit,
        limit=reddit_max
    )
    print(f"✅ {len(reddit_videos)} Reddit videosu bulundu")

    # Paralel işleme (Colab için daha fazla thread)
    with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:
        futures = []

        # YouTube işlemleri
        for v in yt_videos:
            futures.append(
                executor.submit(
                    process_single_youtube,
                    v["id"],
                    v["title"]
                )
            )

        # Reddit işlemleri
        for v in reddit_videos:
            futures.append(
                executor.submit(
                    process_single_reddit,
                    v["video_url"],
                    v["audio_url"],
                    v["id"],
                    v["title"]
                )
            )

        # Sonuçları topla
        for future in concurrent.futures.as_completed(futures):
            try:
                out_path = future.result()
                if out_path:
                    results.append(out_path)
            except Exception as e:
                print(f"❌ İşleme hatası: {e}")

    return results

# ===== GRADIO ARAYÜZÜ =====
def start_process(youtube_api_key, reddit_client_id, reddit_client_secret, reddit_user_agent,
                  yt_max, reddit_max, reddit_subreddit):
    """Gradio arayüzü için başlatma fonksiyonu"""
    print("🚀 Otomasyon başlatıldı...")
    outputs = run_automation(
        youtube_api_key,
        reddit_client_id,
        reddit_client_secret,
        reddit_user_agent,
        int(yt_max),
        int(reddit_max),
        reddit_subreddit
    )

    # Sonuç mesajını oluştur
    result_msg = f"✅ {len(outputs)} video başarıyla işlendi!\n\n"
    for p in outputs:
        filename = os.path.basename(p)
        result_msg += f"• {filename}\n"

    # Colab'da dosyaları indirme linki oluştur
    if outputs:
        result_msg += "\n📥 İşlenen Videoları İndir:\n"
        for p in outputs:
            filename = os.path.basename(p)
            result_msg += f"<a href='/content/processed_videos/{filename}' download>{filename}</a><br>"

    return result_msg

# Gradio arayüzünü oluştur
with gr.Blocks(title="YouTube & Reddit Otomasyonu", css=".download-link {color: blue; text-decoration: underline;}") as demo:
    gr.Markdown("# 🎬 Otomatik YouTube & Reddit Video İşleme Sistemi")
    gr.Markdown("Trend videoları indir, altyazı ekle ve Reels formatına dönüştür!")

    with gr.Row():
        with gr.Column():
            gr.Markdown("### 🔑 API Ayarları")
            youtube_api_key = gr.Textbox(
                label="YouTube API Anahtarı",
                value="AIzaSyAg9ucUlixeslEWVDY7vxdIQukxzrvEHAc"
            )
            reddit_client_id = gr.Textbox(
                label="Reddit Client ID",
                value="LhklcvvwDar42dPUSxjYtg"
            )
            reddit_client_secret = gr.Textbox(
                label="Reddit Client Secret",
                value="dzja3SHDkCbEECSya_nZ7qgUGm-T1w"
            )
            reddit_user_agent = gr.Textbox(
                label="Reddit User Agent",
                value="Specialist-Arm-391"
            )

        with gr.Column():
            gr.Markdown("### ⚙️ İşlem Ayarları")
            yt_max = gr.Slider(
                1, 5, value=2, step=1,
                label="YouTube Video Sayısı",
                info="İşlenecek YouTube video sayısı"
            )
            reddit_max = gr.Slider(
                1, 5, value=2, step=1,
                label="Reddit Video Sayısı",
                info="İşlenecek Reddit video sayısı"
            )
            reddit_subreddit = gr.Textbox(
                label="Reddit Subreddit",
                value="funny",
                placeholder="Örnek: funny, videos, memes"
            )

    btn = gr.Button("🚀 Otomasyonu Başlat", variant="primary")
    output_html = gr.HTML(label="📋 Sonuçlar")  # HTML çıktı için

    btn.click(
        fn=start_process,
        inputs=[
            youtube_api_key,
            reddit_client_id,
            reddit_client_secret,
            reddit_user_agent,
            yt_max,
            reddit_max,
            reddit_subreddit
        ],
        outputs=output_html
    )

    gr.Markdown("### 📌 Colab Özel Notlar")
    gr.Markdown("""
    1. **İlk Çalıştırma:** Bağımlılıklar otomatik kurulur (1-2 dakika)
    2. **GPU Desteği:** Whisper transkripsiyonu için GPU kullanılır
    3. **Dosya Konumları:**
       - İşlenen videolar: `/content/processed_videos`
       - Geçici dosyalar: `/content/temp_video_files`
    4. **İndirme:** İşlem tamamlandığında videoları indirebileceğiniz linkler gösterilir
    5. **Oturum Sonu:** Colab oturumu kapatıldığında tüm dosyalar silinir
    """)

# ===== UYGULAMAYI BAŞLAT =====
print("🔥 Uygulama başlatılıyor...")
demo.launch(share=True, debug=True)