Add Cinematic Blur layout and fix clear endpoint

TECHNICAL_DOCUMENTATION.md

@@ -1,346 +0,0 @@
-# نظام إدارة نسخ الفيديو المتقدم - التوثيق التقني
-
-## نظرة عامة
-نظام معالجة الفيديو المتكامل يوفر إدارة متقدمة للنسخ مع حماية النسخ الأصلية، ومعالجة منفصلة لكل نوع من التعديلات، وتتبع شامل لجميع الإصدارات.
-
-## المعمارية
-
-### المكونات الرئيسية
-
-#### 1. **نظام إدارة النسخ (VersionManager)**
-```python
-# الموقع: clipping/core/version_manager.py
-# الوظيفة: إدارة النسخ الأصلية والمعدلة مع الحفاظ على سلامة البيانات
-```
-
-**المميزات:**
-- حماية النسخ الأصلية في مجلد منفصل مع صلاحيات قراءة فقط
-- تتبع شجرة النسخ (parent-child relationships)
-- سجل تغييرات شامل
-- معرفات فريدة تلقائية
-- إحصائيات التخزين والاستخدام
-
-#### 2. **معالج الفيديو المتقدم (AdvancedVideoProcessor)**
-```python
-# الموقع: clipping/core/advanced_processor.py
-# الوظيفة: معالجة الفيديو باستخدام FFmpeg وMoviePy
-```
-
-**أنواع المعالجة:**
-- **ترانسكريبت**: إضافة نصوص مع الطوابع الزمنية
-- **قص**: قص مناطق محددة من الفيديو
-- **تأثيرات**: سطوع، تباين، تشبع، فلاتر جمالية
-- **صوت**: تعديل الصوت، تعزيز، إزالة ضوضاء
-- **مشترك**: معالجة متعددة في خطوة واحدة
-
-#### 3. **واجهة برمجة التطبيقات (API)**
-```python
-# الموقع: clipping/routers/video_versions.py
-# الوظيفة: نقاط النهاية REST للتفاعل مع النظام
-```
-
-## نقاط النهاية API
-
-### رفع الفيديو الأصلي
-```http
-POST /api/v1/video-versions/upload-original
-Content-Type: multipart/form-data
-
-Body:
-- video_file: ملف الفيديو (مطلوب)
-- metadata: بيانات وصفية اختيارية (JSON)
-```
-
-**الاستجابة:**
-```json
-{
-  "original_id": "uuid-string",
-  "file_name": "video.mp4",
-  "file_size": 10485760,
-  "upload_date": "2024-01-15T10:30:00Z",
-  "message": "Original video uploaded successfully",
-  "status": "protected"
-}
-```
-
-### معالجة الترانسكريبت
-```http
-POST /api/v1/video-versions/{original_id}/add-transcript
-Content-Type: multipart/form-data
-
-Body:
-- transcript_config: إعدادات الترانسكريبت (JSON مطلوب)
-- version_name: اسم النسخة الاختياري
-```
-
-**مثال transcript_config:**
-```json
-{
-  "segments": [
-    {
-      "start": 0.0,
-      "end": 5.0,
-      "text": "مرحباً بكم في الفيديو",
-      "position": "bottom",
-      "font_size": 28,
-      "font_color": "#FFFFFF"
-    }
-  ],
-  "font_size": 24,
-  "font_color": "#FFFFFF",
-  "font_family": "Arial",
-  "position": "bottom",
-  "background_color": "#000000",
-  "background_alpha": 0.8,
-  "margin": 20,
-  "shadow": true,
-  "outline": true
-}
-```
-
-### معالجة القص
-```http
-POST /api/v1/video-versions/{original_id}/crop
-Content-Type: multipart/form-data
-
-Body:
-- crop_config: إعدادات القص (JSON مطلوب)
-- version_name: اسم النسخة الاختياري
-```
-
-**مثال crop_config:**
-```json
-{
-  "x1": 100,
-  "y1": 50,
-  "width": 800,
-  "height": 600,
-  "center_crop": false,
-  "aspect_ratio": "16:9"
-}
-```
-
-### معالجة التأثيرات
-```http
-POST /api/v1/video-versions/{original_id}/effects
-Content-Type: multipart/form-data
-
-Body:
-- effects_config: إعدادات التأثيرات (JSON مطلوب)
-- version_name: اسم النسخة الاختياري
-```
-
-**مثال effects_config:**
-```json
-{
-  "brightness": 1.2,
-  "contrast": 1.1,
-  "saturation": 1.3,
-  "fade_in": 2.0,
-  "fade_out": 3.0,
-  "blur": 0.5,
-  "vignette": 0.3,
-  "vintage": true
-}
-```
-
-### معالجة الصوت
-```http
-POST /api/v1/video-versions/{original_id}/audio
-Content-Type: multipart/form-data
-
-Body:
-- audio_config: إعدادات الصوت (JSON مطلوب)
-- version_name: اسم النسخة الاختياري
-```
-
-**مثال audio_config:**
-```json
-{
-  "volume": 1.5,
-  "normalize": true,
-  "remove_noise": true,
-  "bass_boost": 0.3,
-  "fade_in": 1.0,
-  "fade_out": 2.0,
-  "speed": 1.1
-}
-```
-
-### معالجة مشتركة
-```http
-POST /api/v1/video-versions/{original_id}/combined
-Content-Type: multipart/form-data
-
-Body:
-- processing_request: طلب المعالجة المشتركة (JSON مطلوب)
-- version_name: اسم النسخة الاختياري
-```
-
-**مثال processing_request:**
-```json
-{
-  "original_id": "uuid-string",
-  "processing_type": "combined",
-  "transcript_config": { /* نفس إعدادات الترانسكريبت */ },
-  "crop_config": { /* نفس إعدادات القص */ },
-  "effects_config": { /* نفس إعدادات التأثيرات */ },
-  "audio_config": { /* نفس إعدادات الصوت */ },
-  "priority": "high",
-  "metadata": {}
-}
-```
-
-### إدارة النسخ
-
-#### قائمة النسخ
-```http
-GET /api/v1/video-versions/versions/{original_id}
-```
-
-#### تفاصيل نسخة
-```http
-GET /api/v1/video-versions/version/{version_id}
-```
-
-#### تحميل نسخة
-```http
-GET /api/v1/video-versions/download/{version_id}
-```
-
-#### حذف نسخة
-```http
-DELETE /api/v1/video-versions/delete/{version_id}
-```
-
-#### شجرة النسخ
-```http
-GET /api/v1/video-versions/version-tree/{original_id}
-```
-
-### إحصائيات النظام
-```http
-GET /api/v1/video-versions/stats
-```
-
-## معايير الأداء
-
-### الجودة
-- **الأصلي**: يتم الحفاظ على جودة الفيديو الأصلي بدون أي تعديلات
-- **المعالجة**: استخدام FFmpeg لضمان أعلى جودة ممكنة
-- **الترميز**: H.264 مع إعدادات مثالية للحفاظ على الجودة
-
-### السرعة
-- **الرفع**: معالجة غير متزامنة مع مؤشرات تقدم
-- **المعالجة**: معالجة متعددة الخيوط مع ThreadPoolExecutor
-- **الذاكرة**: إدارة مثالية للذاكرة مع تنظيف تلقائي
-
-### الموثوقية
-- **الأخطاء**: معالجة شاملة للأخطاء مع استعادة تلقائية
-- **السجل**: سجل تفصيلي لجميع العمليات
-- **النسخ الاحتياطي**: آلية نسخ احتياطي للنسخ الأصلية
-
-## هيكل الملفات
-
-```
-video_storage/
-├── originals/          # النسخ الأصلية (قراءة فقط)
-│   └── {original_id}/
-│       └── {file_name}
-├── versions/           # النسخ المعدلة
-│   └── {version_id}/
-│       ├── video.mp4   # الفيديو المعدل
-│       ├── config.json # إعدادات المعالجة
-│       └── metadata.json # البيانات الوصفية
-└── version_registry.json # سجل جميع النسخ
-```
-
-## أمثلة الاستخدام
-
-### مثال 1: رفع فيديو وإضافة ترانسكريبت
-```python
-import requests
-
-# رفع الفيديو الأصلي
-files = {'video_file': open('video.mp4', 'rb')}
-response = requests.post('http://localhost:7860/api/v1/video-versions/upload-original', files=files)
-original_id = response.json()['original_id']
-
-# إعدادات الترانسكريبت
-transcript_config = {
-    "segments": [
-        {"start": 0, "end": 5, "text": "مرحباً بكم"},
-        {"start": 5, "end": 10, "text": "هذا فيديو تجريبي"}
-    ],
-    "font_size": 24,
-    "font_color": "#FFFFFF",
-    "position": "bottom"
-}
-
-# إضافة الترانسكريبت
-data = {'transcript_config': str(transcript_config).replace("'", '"')}
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/add-transcript', data=data)
-version_id = response.json()['version_id']
-```
-
-### مثال 2: قص فيديو مع تأثيرات
-```python
-# إعدادات القص
-crop_config = {
-    "center_crop": True,
-    "width": 720,
-    "height": 1280,  # 9:16 aspect ratio
-    "aspect_ratio": "9:16"
-}
-
-# إعدادات التأثيرات
-effects_config = {
-    "brightness": 1.2,
-    "contrast": 1.1,
-    "saturation": 1.3,
-    "vintage": True
-}
-
-# معالجة القص
-data = {'crop_config': str(crop_config).replace("'", '"')}
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/crop', data=data)
-crop_version_id = response.json()['version_id']
-
-# معالجة التأثيرات على النسخة المقصوصة
-data = {'effects_config': str(effects_config).replace("'", '"')}
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{crop_version_id}/effects', data=data)
-final_version_id = response.json()['version_id']
-```
-
-## معالجة الأخطاء
-
-### رموز الحالة
-- **200**: نجاح
-- **400**: طلب غير صالح
-- **404**: مورد غير موجود
-- **422**: بيانات غير صالحة
-- **500**: خطأ في الخادم
-
-### رسائل الخطأ
-```json
-{
-  "error": "Invalid processing configuration",
-  "details": "Font size must be between 12 and 72",
-  "suggestion": "Please adjust font_size parameter"
-}
-```
-
-## التحسينات المستقبلية
-
-1. **معالجة GPU**: دعم معالجة GPU لتسريع العمليات
-2. **تخزين سحابي**: دعم تخزين Amazon S3 وGoogle Cloud Storage
-3. **ذكاء اصطناعي**: إضافة تأثيرات AI مثل إزالة الخلفية
-4. **تعاوني**: دعم العمل الجماعي والتعليقات
-5. **تكامل API**: REST API كامل مع Swagger documentation
-
-## التواصل والدعم
-
-للأسئلة والدعم الفني، يرجى التواصل عبر:
-- البريد ا��إلكتروني: support@videosystem.com
-- GitHub Issues: github.com/videosystem/issues
-- الوثائق الكاملة: docs.videosystem.com

USER_GUIDE.md

@@ -1,720 +0,0 @@
-# دليل استخدام نظام إدارة نسخ الفيديو المتقدم
-
-## 📋 جدول المحتويات
-1. [مقدمة](#مقدمة)
-2. [التثبيت والإعداد](#التثبيت-والإعداد)
-3. [رفع الفيديو الأصلي](#رفع-الفيديو-الأصلي)
-4. [إضافة ترانسكريبت](#إضافة-ترانسكريبت)
-5. [قص الفيديو](#قص-الفيديو)
-6. [إضافة تأثيرات](#إضافة-تأثيرات)
-7. [معالجة الصوت](#معالجة-الصوت)
-8. [المعالجة المشتركة](#المعالجة-المشتركة)
-9. [إدارة النسخ](#إدارة-النسخ)
-10. [أمثلة عملية](#أمثلة-عملية)
-11. [نصائح وتوصيات](#نصائح-وأفضل-الممارسات)
-12. [استكشاف الأخطاء](#استكشاف-الأخطاء)
-
-## 🎯 مقدمة
-
-نظام إدارة نسخ الفيديو المتقدم هو حل شامل لمعالجة الفيديو مع الحفاظ على النسخ الأصلية. يتيح لك إنشاء نسخ متعددة من نفس الفيديو مع تعديلات مختلفة مع الحفاظ على النسخة الأصلية دون أي تغيير.
-
-### المميزات الرئيسية:
-- ✅ حماية النسخ الأصلية (قراءة فقط)
-- ✅ إنشاء نسخ متعددة من نفس الفيديو
-- ✅ معالجة منفصلة لكل نوع من التعديلات
-- ✅ تتبع شامل لجميع الإصدارات
-- ✅ واجهة برمجة تطبيقات REST سهلة الاستخدام
-- ✅ معالجة غير متزامنة لتحسين الأداء
-
-## ⚙️ التثبيت والإعداد
-
-### المتطلبات الأساسية
-```bash
-# Python 3.8 أو أحدث
-python --version
-
-# تثبيت المتطلبات
-pip install fastapi uvicorn python-multipart moviepy ffmpeg-python pydantic
-```
-
-### تشغيل الخادم
-```bash
-# من المجلد الرئيسي
-python main.py
-
-# أو باستخدام uvicorn مباشرة
-uvicorn main:app --host 0.0.0.0 --port 7860 --reload
-```
-
-### التحقق من التشغيل
-افتح المتصفح وانتقل إلى:
-```
-http://localhost:7860/
-```
-
-يجب أن ترى رسالة ترحيب مع معلومات النظام.
-
-## 📤 رفع الفيديو الأصلي
-
-### الخطوة 1: رفع الفيديو
-```python
-import requests
-
-# رفع الفيديو الأصلي
-files = {'video_file': open('video.mp4', 'rb')}
-response = requests.post('http://localhost:7860/api/v1/video-versions/upload-original', files=files)
-
-# استخراج معرف الفيديو الأصلي
-original_id = response.json()['original_id']
-print(f"Original ID: {original_id}")
-```
-
-### الخطوة 2: التحقق من الرفع
-```python
-# التحقق من معلومات الفيديو الأصلي
-response = requests.get(f'http://localhost:7860/api/v1/video-versions/versions/{original_id}')
-print(response.json())
-```
-
-## 📝 إضافة ترانسكريبت
-
-### مثال 1: ترانسكريبت بسيط
-```python
-# إعدادات الترانسكريبت
-transcript_config = {
-    "segments": [
-        {
-            "start": 0.0,
-            "end": 5.0,
-            "text": "مرحباً بكم في الفيديو",
-            "position": "bottom"
-        },
-        {
-            "start": 5.0,
-            "end": 10.0,
-            "text": "سنشرح لكم كيفية استخدام النظام",
-            "position": "bottom"
-        }
-    ],
-    "font_size": 24,
-    "font_color": "#FFFFFF",
-    "font_family": "Arial",
-    "position": "bottom",
-    "background_color": "#000000",
-    "background_alpha": 0.8,
-    "margin": 20,
-    "shadow": True,
-    "outline": True
-}
-
-# إرسال طلب الترانسكريبت
-data = {
-    "transcript_config": json.dumps(transcript_config, ensure_ascii=False),
-    "version_name": "version_with_transcript"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/add-transcript', data=data)
-version_id = response.json()['version_id']
-print(f"Transcript Version ID: {version_id}")
-```
-
-### مثال 2: ترانسكريبت متقدم مع أنيميشن
-```python
-# ترانسكريبت مع أنيميشن
-transcript_config = {
-    "segments": [
-        {
-            "start": 0.0,
-            "end": 3.0,
-            "text": "اهلاً وسهلاً",
-            "position": "center",
-            "font_size": 32,
-            "font_color": "#FFD700"  # لون ذهبي
-        },
-        {
-            "start": 3.0,
-            "end": 8.0,
-            "text": "هذا عرض تقديمي احترافي",
-            "position": "bottom",
-            "font_size": 28,
-            "font_color": "#FFFFFF"
-        }
-    ],
-    "font_size": 24,
-    "font_color": "#FFFFFF",
-    "font_family": "Helvetica",
-    "position": "bottom",
-    "background_color": "#1E3A8A",
-    "background_alpha": 0.9,
-    "margin": 30,
-    "opacity": 1.0,
-    "animation": "fade_in",
-    "shadow": True,
-    "outline": True
-}
-
-# إرسال الطلب
-data = {
-    "transcript_config": json.dumps(transcript_config, ensure_ascii=False),
-    "version_name": "animated_transcript_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/add-transcript', data=data)
-```
-
-## ✂️ قص الفيديو
-
-### مثال 1: قص منطقة محددة
-```python
-# إعدادات القص
-crop_config = {
-    "x1": 200,        # بداية من اليسار
-    "y1": 100,        # بداية من الأعلى
-    "width": 800,     # عرض المنطقة
-    "height": 600,    # ارتفاع المنطقة
-    "center_crop": False
-}
-
-# إرسال طلب القص
-data = {
-    "crop_config": json.dumps(crop_config),
-    "version_name": "cropped_region_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/crop', data=data)
-crop_version_id = response.json()['version_id']
-```
-
-### مثال 2: قص تلقائي من المركز
-```python
-# قص من المركز لإنشاء فيديو عمودي (Shorts)
-crop_config = {
-    "center_crop": True,
-    "width": 720,     # عرض Shorts
-    "height": 1280,   # ارتفاع Shorts (9:16)
-    "aspect_ratio": "9:16"
-}
-
-# إرسال الطلب
-data = {
-    "crop_config": json.dumps(crop_config),
-    "version_name": "shorts_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/crop', data=data)
-shorts_version_id = response.json()['version_id']
-```
-
-### مثال 3: قص لإنشاء فيديو مربع
-```python
-# قص لإنشاء فيديو مربع للإنستغرام
-crop_config = {
-    "center_crop": True,
-    "width": 1080,    # عرض مربع
-    "height": 1080,   # ارتفاع مربع (1:1)
-    "aspect_ratio": "1:1"
-}
-
-# إرسال الطلب
-data = {
-    "crop_config": json.dumps(crop_config),
-    "version_name": "instagram_square_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/crop', data=data)
-instagram_version_id = response.json()['version_id']
-```
-
-## 🎨 إضافة تأثيرات
-
-### مثال 1: تأثيرات أساسية
-```python
-# إعدادات التأثيرات الأساسية
-effects_config = {
-    "brightness": 1.2,      # سطوع +20%
-    "contrast": 1.1,        # تباين +10%
-    "saturation": 1.3,      # تشبع +30%
-    "fade_in": 2.0,         # تلاشي دخول 2 ثانية
-    "fade_out": 3.0         # تلاشي خروج 3 ثواني
-}
-
-# إرسال الطلب
-data = {
-    "effects_config": json.dumps(effects_config),
-    "version_name": "enhanced_effects_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/effects', data=data)
-effects_version_id = response.json()['version_id']
-```
-
-### مثال 2: تأثيرات فنية
-```python
-# تأثيرات فنية (فينتاج)
-effects_config = {
-    "sepia": True,          # تأثير سيبيا (بني قديم)
-    "vintage": True,        # تأثير فينتاج
-    "vignette": 0.4,        # تأثير إطار مظلم
-    "noise": 0.1,           # ضوضاء خفيفة
-    "blur": 0.2             # ضبابية خفيفة
-}
-
-# إرسال الطلب
-data = {
-    "effects_config": json.dumps(effects_config),
-    "version_name": "vintage_artistic_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/effects', data=data)
-vintage_version_id = response.json()['version_id']
-```
-
-### مثال 3: تأثيرات درامية
-```python
-# تأثيرات درامية
-effects_config = {
-    "black_white": True,    # أبيض وأسود
-    "contrast": 1.5,        # تباين عالي
-    "sharpen": 2.0,         # حدة عالية
-    "fade_in": 1.0,         # تلاشي سريع
-    "fade_out": 2.0         # تلاشي بطيء
-}
-
-# إرسال الطلب
-data = {
-    "effects_config": json.dumps(effects_config),
-    "version_name": "dramatic_black_white_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/effects', data=data)
-dramatic_version_id = response.json()['version_id']
-```
-
-## 🔊 معالجة الصوت
-
-### مثال 1: تعزيز الصوت الأساسي
-```python
-# إعدادات الصوت الأساسية
-audio_config = {
-    "volume": 1.3,          # رفع الصوت 30%
-    "normalize": True,      # تطبيع الصوت
-    "remove_noise": True,   # إزالة الضوضاء
-    "fade_in": 1.0,         # تلاشي دخول
-    "fade_out": 2.0         # تلاشي خروج
-}
-
-# إرسال الطلب
-data = {
-    "audio_config": json.dumps(audio_config),
-    "version_name": "enhanced_audio_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/audio', data=data)
-audio_version_id = response.json()['version_id']
-```
-
-### مثال 2: تأثيرات صوتية
-```python
-# تأثيرات صوتية متقدمة
-audio_config = {
-    "bass_boost": 0.5,      # تعزيز الجهير
-    "treble_boost": 0.3,    # تعزيز التريبل
-    "speed": 1.1,           # تسريع 10% (بدون تغيير النبرة)
-    "pitch_shift": 2,       # رفع النبرة 2 نصف نغمة
-    "fade_in": 0.5,         # تلاشي سريع
-    "fade_out": 1.0         # تلاشي متوسط
-}
-
-# إرسال الطلب
-data = {
-    "audio_config": json.dumps(audio_config),
-    "version_name": "processed_audio_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/audio', data=data)
-processed_audio_version_id = response.json()['version_id']
-```
-
-## 🔄 المعالجة المشتركة
-
-### مثال: إنشاء فيديو Shorts احترافي
-```python
-# معالجة مشتركة متكاملة
-processing_request = {
-    "original_id": original_id,
-    "processing_type": "combined",
-    "transcript_config": {
-        "segments": [
-            {
-                "start": 0.0,
-                "end": 5.0,
-                "text": "نصيحة ذهبية للنجاح",
-                "position": "center",
-                "font_size": 28,
-                "font_color": "#FFD700"
-            }
-        ],
-        "font_size": 24,
-        "font_color": "#FFFFFF",
-        "position": "bottom",
-        "shadow": True,
-        "outline": True
-    },
-    "crop_config": {
-        "center_crop": True,
-        "width": 720,
-        "height": 1280,
-        "aspect_ratio": "9:16"
-    },
-    "effects_config": {
-        "brightness": 1.1,
-        "contrast": 1.2,
-        "saturation": 1.1,
-        "fade_in": 1.0,
-        "vintage": False
-    },
-    "audio_config": {
-        "volume": 1.2,
-        "normalize": True,
-        "remove_noise": True,
-        "fade_in": 0.5,
-        "fade_out": 1.0
-    },
-    "priority": "high",
-    "metadata": {
-        "description": "Shorts video with transcript, crop, effects and audio enhancement",
-        "target_platform": "YouTube Shorts"
-    }
-}
-
-# إرسال الطلب المشترك
-data = {
-    "processing_request": json.dumps(processing_request, ensure_ascii=False),
-    "version_name": "professional_shorts_version"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/combined', data=data)
-combined_version_id = response.json()['version_id']
-```
-
-## 📋 إدارة النسخ
-
-### عرض جميع النسخ
-```python
-# الحصول على قائمة جميع النسخ
-response = requests.get(f'http://localhost:7860/api/v1/video-versions/versions/{original_id}')
-versions_info = response.json()
-
-print(f"عدد النسخ: {versions_info['total_count']}")
-for version in versions_info['versions']:
-    print(f"- {version['version_name']}: {version['processing_type']} ({version['status']})")
-```
-
-### عرض تفاصيل نسخة محددة
-```python
-# الحصول على تفاصيل نسخة محددة
-version_id = "your-version-id"  # استبدل بمعرف النسخة
-response = requests.get(f'http://localhost:7860/api/v1/video-versions/version/{version_id}')
-version_details = response.json()
-
-print(f"اسم النسخة: {version_details['version_name']}")
-print(f"نوع المعالجة: {version_details['processing_type']}")
-print(f"الحالة: {version_details['status']}")
-print(f"تاريخ الإنشاء: {version_details['created_at']}")
-print(f"حجم الملف: {version_details['file_size']} بايت")
-print(f"المدة: {version_details['duration']} ثانية")
-print(f"الدقة: {version_details['resolution']}")
-```
-
-### تحميل نسخة
-```python
-# تحميل نسخة معالجة
-response = requests.get(f'http://localhost:7860/api/v1/video-versions/download/{version_id}')
-
-# حفظ الملف
-with open('downloaded_video.mp4', 'wb') as f:
-    f.write(response.content)
-
-print("تم تحميل النسخة بنجاح!")
-```
-
-### حذف نسخة
-```python
-# حذف نسخة غير مرغوب فيها
-response = requests.delete(f'http://localhost:7860/api/v1/video-versions/delete/{version_id}')
-delete_result = response.json()
-
-print(f"تم حذف النسخة: {delete_result['version_id']}")
-```
-
-### عرض شجرة النسخ
-```python
-# عرض العلاقات بين النسخ المختلفة
-response = requests.get(f'http://localhost:7860/api/v1/video-versions/version-tree/{original_id}')
-tree_info = response.json()
-
-print("شجرة النسخ:")
-print(json.dumps(tree_info['version_tree'], indent=2, ensure_ascii=False))
-```
-
-### عرض إحصائيات النظام
-```python
-# عرض إحصائيات التخزين والاستخدام
-response = requests.get('http://localhost:7860/api/v1/video-versions/stats')
-stats = response.json()
-
-print(f"عدد الفيديوهات الأصلية: {stats['storage']['original_videos']}")
-print(f"عدد النسخ المعدلة: {stats['storage']['total_versions']}")
-print(f"حجم الفيديوهات الأصلية: {stats['storage']['originals_size']} بايت")
-print(f"حجم النسخ المعدلة: {stats['storage']['versions_size']} بايت")
-print(f"الحجم الكلي: {stats['storage']['total_size']} بايت")
-print(f"حالة النظام: {stats['system_status']}")
-```
-
-## 💡 أمثلة عملية
-
-### مثال 1: إنشاء فيديو تعليمي مع ترانسكريبت
-```python
-import requests
-import json
-
-# 1. رفع الفيديو الأصلي
-files = {'video_file': open('educational_video.mp4', 'rb')}
-response = requests.post('http://localhost:7860/api/v1/video-versions/upload-original', files=files)
-original_id = response.json()['original_id']
-
-# 2. إضافة ترانسكريبت تعليمي
-transcript_config = {
-    "segments": [
-        {"start": 0, "end": 8, "text": "مرحباً بكم في هذا الدرس التعليمي"},
-        {"start": 8, "end": 20, "text": "اليوم سنتعلم كيفية استخدام Python في معالجة البيانات"},
-        {"start": 20, "end": 35, "text": "Python هو لغة برمجة قوية وسهلة التعلم"}
-    ],
-    "font_size": 26,
-    "font_color": "#2E86AB",
-    "font_family": "Arial",
-    "position": "bottom",
-    "background_color": "#F5F5F5",
-    "background_alpha": 0.9,
-    "margin": 25,
-    "shadow": True,
-    "outline": False
-}
-
-data = {
-    "transcript_config": json.dumps(transcript_config, ensure_ascii=False),
-    "version_name": "educational_with_transcript"
-}
-
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/add-transcript', data=data)
-educational_version_id = response.json()['version_id']
-
-print(f"تم إنشاء نسخة تعليمية مع ترانسكريبت: {educational_version_id}")
-```
-
-### مثال 2: إنشاء فيديو تسويقي للسوشيال ميديا
-```python
-# 1. نبدأ من نفس الفيديو الأصلي
-
-# 2. إنشاء نسخة عمودية مع تأثيرات
-crop_config = {
-    "center_crop": True,
-    "width": 720,
-    "height": 1280,
-    "aspect_ratio": "9:16"
-}
-
-effects_config = {
-    "brightness": 1.15,
-    "contrast": 1.2,
-    "saturation": 1.25,
-    "fade_in": 1.5,
-    "fade_out": 2.0,
-    "vignette": 0.2
-}
-
-audio_config = {
-    "volume": 1.3,
-    "normalize": True,
-    "bass_boost": 0.4,
-    "fade_in": 0.8,
-    "fade_out": 1.5
-}
-
-# إنشاء النسخة المقصوصة أولاً
-data = {
-    "crop_config": json.dumps(crop_config),
-    "version_name": "social_media_cropped"
-}
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/crop', data=data)
-cropped_version_id = response.json()['version_id']
-
-# ثم نضيف التأثيرات على النسخة المقصوصة
-data = {
-    "effects_config": json.dumps(effects_config),
-    "version_name": "social_media_final"
-}
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{cropped_version_id}/effects', data=data)
-final_version_id = response.json()['version_id']
-
-# أخيراً نعالج الصوت
-data = {
-    "audio_config": json.dumps(audio_config),
-    "version_name": "social_media_complete"
-}
-response = requests.post(f'http://localhost:7860/api/v1/video-versions/{final_version_id}/audio', data=data)
-complete_version_id = response.json()['version_id']
-
-print(f"تم إنشاء فيديو تسويقي متكامل: {complete_version_id}")
-```
-
-### مثال 3: معالجة دفعية لعدة فيديوهات
-```python
-def process_video_batch(video_files, processing_config):
-    """معالجة دفعية لعدة فيديوهات"""
-    results = []
-    
-    for video_file in video_files:
-        try:
-            # رفع الفيديو
-            files = {'video_file': open(video_file, 'rb')}
-            response = requests.post('http://localhost:7860/api/v1/video-versions/upload-original', files=files)
-            original_id = response.json()['original_id']
-            
-            # تطبيق نفس المعالجة على جميع الفيديوهات
-            data = {
-                "processing_request": json.dumps(processing_config),
-                "version_name": f"processed_{Path(video_file).stem}"
-            }
-            
-            response = requests.post(f'http://localhost:7860/api/v1/video-versions/{original_id}/combined', data=data)
-            version_id = response.json()['version_id']
-            
-            results.append({
-                'original_file': video_file,
-                'original_id': original_id,
-                'version_id': version_id,
-                'status': 'success'
-            })
-            
-        except Exception as e:
-            results.append({
-                'original_file': video_file,
-                'error': str(e),
-                'status': 'failed'
-            })
-    
-    return results
-
-# إعدادات المعالجة الموحدة
-processing_config = {
-    "original_id": "placeholder",  # سيتم استب��اله لكل فيديو
-    "processing_type": "combined",
-    "transcript_config": {
-        "segments": [{"start": 0, "end": 5, "text": "شاهد هذا الفيديو المميز"}],
-        "font_size": 28,
-        "font_color": "#FF6B35",
-        "position": "center"
-    },
-    "crop_config": {
-        "center_crop": True,
-        "width": 720,
-        "height": 1280,
-        "aspect_ratio": "9:16"
-    },
-    "effects_config": {
-        "brightness": 1.1,
-        "contrast": 1.1,
-        "fade_in": 1.0
-    },
-    "audio_config": {
-        "volume": 1.2,
-        "normalize": True
-    },
-    "priority": "normal"
-}
-
-# قائمة الفيديوهات للمعالجة
-video_files = ['video1.mp4', 'video2.mp4', 'video3.mp4']
-
-# تنفيذ المعالجة الدفعية
-results = process_video_batch(video_files, processing_config)
-
-# عرض النتائج
-for result in results:
-    if result['status'] == 'success':
-        print(f"✅ {result['original_file']} -> {result['version_id']}")
-    else:
-        print(f"❌ {result['original_file']} -> خطأ: {result['error']}")
-```
-
-## 🎯 نصائح وأفضل الممارسات
-
-### 1. اختيار الإعدادات المناسبة
-- **الترانسكريبت**: استخدم أحجام خط مناسبة (20-32) حسب حجم الفيديو
-- **القص**: احتفظ بنسب الأبعاد المناسبة لكل منصة (9:16 للـ Shorts، 1:1 للإنستغرام)
-- **التأثيرات**: لا تبالغ في التأثيرات، ابدأ بقيم صغيرة وزد تدريجياً
-- **الصوت**: استخدم تطبيع الصوت دائماً لضمان جودة متسقة
-
-### 2. إدارة النسخ بكفاءة
-- أطلق على النسخ أسماء واضحة ومعبرة
-- احذف النسخ غير المستخدمة لتوفير المساحة
-- استخدم شجرة النسخ لفهم العلاقات بين النسخ
-- احتفظ بالنسخ الأصلية دائماً كنسخة احتياطية
-
-### 3. تحسين الأداء
-- استخدم المعالجة المشتركة لتقليل عدد خطوات المعالجة
-- حدد أولوية المعالجة حسب أهمية الفيديو
-- راقب إحصائيات النظام لتجنب تجاوز الحدود
-- استخدم معالجة غير متزامنة للفيديوهات الكبيرة
-
-### 4. ضمان الجودة
-- اختبر الإعدادات على نسخة تجريبية أولاً
-- تحقق من جودة الفيديو الناتج قبل الاستخدام النهائي
-- استخدم تنسيقات فيديو مناسبة (MP4 موصى به)
-- احتفظ بنسخة احتياطية من الفيديوهات المهمة
-
-## 🔧 استكشاف الأخطاء
-
-### أخطاء شائعة وحلولها
-
-#### خطأ 1: "File must be a video"
-**السبب**: تم رفع ملف غير مدعوم
-**الحل**: تأكد أن الملف هو فيديو صالح (MP4, AVI, MOV, إلخ)
-
-#### خطأ 2: "Invalid processing configuration"
-**السبب**: قيم إعدادات غير صالحة
-**الحل**: تحقق من نطاق القيم المسموح بها في الوثائق
-
-#### خطأ 3: "Original video not found"
-**السبب**: معرف الفيديو الأصلي غير صحيح
-**الحل**: تحقق من معرف الفيديو الأصلي واستخدم القيمة الصحيحة
-
-#### خطأ 4: "Version not found"
-**السبب**: معرف النسخة غير صحيح
-**الحل**: تحقق من معرف النسخة في قائمة النسخ
-
-#### خطأ 5: معالجة بطيئة
-**السبب**: فيديو كبير أو إعدادات معقدة
-**الحل**: استخدم أولوية "high" أو قسم الفيديو إلى أجزاء أصغر
-
-### نصائح للتصحيح
-1. استخدم نقطة النهاية `/health` للتحقق من حالة النظام
-2. راقب السجلات (logs) للحصول على تفاصيل الخطأ
-3. ابدأ بإعدادات بسيطة وازداد تعقيداً تدريجياً
-4. استخدم أدوات التحقق من صحة JSON قبل الإرسال
-5. احفظ نسخ احتياطية من إعداداتك المفضلة
-
-## 📞 الدعم والمساعدة
-
-إذا واجهت مشاكل أو لديك أسئلة:
-
-1. تحقق من التوثيق التقني الكامل
-2. راجع أمثلة الكود في هذا الدليل
-3. تأكد من أن جميع المتطلبات مثبتة بشكل صحيح
-4. استخدم نقاط النهاية للتحقق من حالة النظام
-5. تواصل مع فريق الدعم الفني إذا استمرت المشكلة
-
----
-
-**نتمنى لك تجربة ممتعة في استخدام نظام إدارة نسخ الفيديو المتقدم! 🎬✨**

hybrid_processor.py

@@ -7,15 +7,17 @@ from typing import List, Optional, Tuple
 from ffmpeg_utils import extract_clip_ffmpeg, get_video_info_ffmpeg
 
 def should_use_ffmpeg_processing(timestamps, custom_dims, export_audio, bg_music, output_format) -> bool:
+    from schemas import LayoutType
    
     # If background music is requested, need MoviePy
     if bg_music:
         return False
     
+    # If complex layout is requested, need MoviePy
+    if custom_dims and hasattr(custom_dims, 'layout_type') and custom_dims.layout_type != LayoutType.CROP:
+        return False
+    
     # If complex custom dimensions, need MoviePy
-    if custom_dims and hasattr(custom_dims, 'width') and hasattr(custom_dims, 'height'):
-        # Simple resize is OK for FFmpeg
-        pass
     
     # If complex output format, need MoviePy
     if output_format and output_format not in ['mp4', 'original']:

main.py

@@ -2,11 +2,23 @@ from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
 import uvicorn
 from datetime import datetime
-from routers import video, files, video_versions
+from routers import video, files
+import os
+
+# إنشاء فولدرات منظمة
+UPLOAD_BASE_DIR = "temp_videos"
+ORIGINALS_DIR = os.path.join(UPLOAD_BASE_DIR, "originals")
+PROCESSED_DIR = os.path.join(UPLOAD_BASE_DIR, "processed") 
+AUDIO_DIR = os.path.join(UPLOAD_BASE_DIR, "audio")
+TEMP_DIR = os.path.join(UPLOAD_BASE_DIR, "temp")
+
+# إنشاء الفولدرات
+for directory in [UPLOAD_BASE_DIR, ORIGINALS_DIR, PROCESSED_DIR, AUDIO_DIR, TEMP_DIR]:
+    os.makedirs(directory, exist_ok=True)
 
 app = FastAPI(
     title="Video Processing API",
-    description="API for video processing with transcript and effects",
+    description="Simple API for video processing - optimized for n8n automation",
     version="1.0.0"
 )
 
@@ -19,10 +31,11 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
-# Include routers
-app.include_router(video.router, prefix="/api/video", tags=["Basic Video Processing"])
-app.include_router(files.router, prefix="/api/files", tags=["File Management"])
-app.include_router(video_versions.router, prefix="/api/versions")
+# Include routers - توحيد الـ tags
+app.include_router(video.router, prefix="/api/video", tags=["Video"])
+app.include_router(files.router, prefix="/api/files", tags=["Files"])
+
+# نحذف نظام إدارة النسخ لحد ما نحتاجه
 
 @app.get("/")
 async def root():

routers/files.py

@@ -4,22 +4,96 @@ import os
 
 router = APIRouter()
 
-UPLOAD_DIR = "temp_videos"
+# الفولدرات الجديدة
+UPLOAD_BASE_DIR = "temp_videos"
+ORIGINALS_DIR = os.path.join(UPLOAD_BASE_DIR, "originals")
+PROCESSED_DIR = os.path.join(UPLOAD_BASE_DIR, "processed")
+AUDIO_DIR = os.path.join(UPLOAD_BASE_DIR, "audio")
+TEMP_DIR = os.path.join(UPLOAD_BASE_DIR, "temp")
 
-@router.get("/get-clip/{filename}", summary="Download/Play Video Clip", tags=["File Retrieval"])
-async def get_clip(filename: str):
+# تم حذف الـ get_clip endpoint القديمة - نستخدم /download بدلاً منه
+
+@router.get("/{filename}", summary="Download File by Name", tags=["Files"])
+async def download_file(filename: str, file_type: str = "processed"):
     """
-    Retrieves a processed video clip, audio file, or zip by its filename.
+    Download any file by its filename - مناسب لـ n8n وغيره
+    file_type: "originals", "processed", "audio", or "temp"
     """
-    path = os.path.join(UPLOAD_DIR, filename)
+    # نحدد الفولدر حسب النوع
+    if file_type == "originals":
+        path = os.path.join(ORIGINALS_DIR, filename)
+    elif file_type == "audio":
+        path = os.path.join(AUDIO_DIR, filename)
+    elif file_type == "temp":
+        path = os.path.join(TEMP_DIR, filename)
+    else:  # processed (default)
+        path = os.path.join(PROCESSED_DIR, filename)
+    
+    print(f"[DOWNLOAD DEBUG] Requested file: {filename}, type: {file_type}, full path: {path}")
+    print(f"[DOWNLOAD DEBUG] File exists: {os.path.exists(path)}")
+    
     if os.path.exists(path):
+        # نحدد الـ media type حسب الامتداد
         media_type = "application/octet-stream"
         if filename.endswith(".mp4"):
             media_type = "video/mp4"
+        elif filename.endswith(".webm"):
+            media_type = "video/webm"
         elif filename.endswith(".mp3"):
             media_type = "audio/mpeg"
+        elif filename.endswith(".wav"):
+            media_type = "audio/wav"
         elif filename.endswith(".zip"):
             media_type = "application/zip"
-            
-        return FileResponse(path, media_type=media_type, filename=filename)
-    raise HTTPException(status_code=404, detail="File not found")
+        
+        # نرجع الملف مباشرة مع header للتحميل
+        return FileResponse(
+            path, 
+            media_type=media_type, 
+            filename=filename,
+            headers={"Content-Disposition": f"attachment; filename={filename}"}
+        )
+    
+    # لو الملف مش موجود، نرجع error واضح
+    raise HTTPException(
+        status_code=404, 
+        detail=f"File not found: {filename} in {file_type} folder. Available folders: originals, processed, audio, temp"
+    )
+
+@router.get("/list-files", summary="List All Available Files", tags=["Files"])
+async def list_files():
+    """
+    List all available files in all folders - مفيد للتأكد من الملفات الموجودة
+    """
+    all_files = {}
+    
+    folders = {
+        "originals": ORIGINALS_DIR,
+        "processed": PROCESSED_DIR,
+        "audio": AUDIO_DIR,
+        "temp": TEMP_DIR
+    }
+    
+    for folder_name, folder_path in folders.items():
+        if os.path.exists(folder_path):
+            files = []
+            for filename in os.listdir(folder_path):
+                file_path = os.path.join(folder_path, filename)
+                if os.path.isfile(file_path):
+                    file_info = {
+                        "filename": filename,
+                        "size_bytes": os.path.getsize(file_path),
+                        "size_mb": round(os.path.getsize(file_path) / (1024 * 1024), 2),
+                        "created": os.path.getctime(file_path)
+                    }
+                    files.append(file_info)
+            all_files[folder_name] = files
+        else:
+            all_files[folder_name] = []
+    
+    return {
+        "status": "success",
+        "total_files": sum(len(files) for files in all_files.values()),
+        "folders": all_files,
+        "message": "Use /files/{filename}?file_type={type} to download any file"
+    }

routers/video.py

@@ -1,17 +1,39 @@
-from fastapi import APIRouter, File, UploadFile, Form, HTTPException, BackgroundTasks, Request
+from fastapi import APIRouter, File, Form, UploadFile, HTTPException, BackgroundTasks, Request, Query
 from fastapi.responses import JSONResponse, FileResponse
+from urllib.parse import urljoin
 import shutil
 import os
 import json
 import uuid
 import requests
+import subprocess
+import imageio_ffmpeg
+from typing import List, Optional
 from schemas import VideoFormat, Timestamp, ClipRequest, Dimensions
 from video_processor import process_video_clips, safe_remove, create_zip_archive
-
 router = APIRouter()
 
-UPLOAD_DIR = "temp_videos"
-os.makedirs(UPLOAD_DIR, exist_ok=True)
+# فولدرات منظمة
+BASE_DIR = "temp_videos"
+ORIGINALS_DIR = os.path.join(BASE_DIR, "originals")
+PROCESSED_DIR = os.path.join(BASE_DIR, "processed") 
+AUDIO_DIR = os.path.join(BASE_DIR, "audio")
+TEMP_DIR = os.path.join(BASE_DIR, "temp")
+
+def build_file_url(request: Request, filename: str, file_type: str = "processed") -> str:
+    """
+    دالة ذكية لبناء URL للملفات تعمل في كل البيئات
+    """
+    # نجيب الـ base URL من الـ request
+    base_url = str(request.base_url).rstrip('/')
+    
+    # نبني الـ URL كامل
+    url_path = f"/api/files/get-clip/{filename}?file_type={file_type}"
+    return urljoin(base_url, url_path)
+
+# إنشاء الفولدرات
+for directory in [BASE_DIR, ORIGINALS_DIR, PROCESSED_DIR, AUDIO_DIR, TEMP_DIR]:
+    os.makedirs(directory, exist_ok=True)
 
 def background_processing(
     task_id: str,
@@ -22,7 +44,8 @@ def background_processing(
     export_audio: bool, 
     audio_path: str = None, 
     webhook_url: str = None,
-    host_url: str = ""
+    base_url: str = "",
+    return_files: bool = False
 ):
     """
     Executes the video processing logic. 
@@ -39,6 +62,7 @@ def background_processing(
         # Prepare result
         clips_filenames = [os.path.basename(p) for p in clip_paths]
         full_clip_paths = clip_paths
+        zip_path = None
 
         if export_audio and not webhook_url:
             # Create ZIP ONLY if it's a direct synchronous request (User waiting in browser)
@@ -48,7 +72,7 @@ def background_processing(
             zip_path = create_zip_archive(all_files, zip_filename)
             
             if zip_path:
-                download_url = f"{host_url}get-clip/{os.path.basename(zip_path)}"
+                download_url = f"{base_url.rstrip('/')}/api/files/get-clip/{os.path.basename(zip_path)}"
                 response_data = {
                     "status": "success",
                     "task_id": task_id,
@@ -57,15 +81,15 @@ def background_processing(
                     "archive_filename": os.path.basename(zip_path)
                 }
             else:
-                 response_data = {"status": "error", "message": "Failed to create zip archive"}
+                response_data = {"status": "error", "message": "Failed to create zip archive"}
         else:
             # For Webhooks OR Normal JSON response without export_audio
             # We return the LIST of URLs so n8n can loop over them
-            clip_urls = [f"{host_url}get-clip/{name}" for name in clips_filenames]
+            clip_urls = [f"{base_url.rstrip('/')}/api/files/get-clip/{name}" for name in clips_filenames]
             
             audio_urls = []
             if export_audio:
-                audio_urls = [f"{host_url}get-clip/{os.path.basename(p)}" if p else None for p in audio_clip_paths]
+                audio_urls = [f"{base_url.rstrip('/')}/api/files/get-clip/{os.path.basename(p)}" if p else None for p in audio_clip_paths]
 
             response_data = {
                 "status": "success",
@@ -77,6 +101,12 @@ def background_processing(
 
         # Send Webhook if requested
         if webhook_url:
+            # enrich response with audio file info
+            if export_audio and not zip_path:
+                response_data["audio_files"] = [
+                    {"filename": os.path.basename(p), "url": f"{base_url.rstrip('/')}/api/files/get-clip/{os.path.basename(p)}"}
+                    for p in audio_clip_paths if p
+                ]
             try:
                 requests.post(webhook_url, json=response_data)
             except Exception as e:
@@ -93,17 +123,94 @@ def background_processing(
         if not webhook_url: raise e # Re-raise if synchronous
 
     finally:
+        # نمسح بس الملفات المؤقتة، مش الأصلي
         for f in files_to_cleanup:
-            safe_remove(f)
+            # نتأكد إن الملف في فولدر التيمب قبل المسح
+            if f and os.path.exists(f) and TEMP_DIR in f:
+                safe_remove(f)
 
-@router.post("/process", tags=["Video Processing"])
+@router.get("/clear-preview", tags=["Video"])
+async def get_clear_preview(folder: str = "temp"):
+    """
+    Preview files that will be deleted before actually clearing them.
+    Returns list of files and total size for each folder.
+    
+    Parameters:
+    - folder: Which folder to preview (temp, processed, audio, originals, all)
+    """
+    try:
+        # نحدد الفولدرات اللي هنعرض منها
+        target_folders = []
+        if folder == "all":
+            target_folders = [TEMP_DIR, PROCESSED_DIR, AUDIO_DIR]  # مش هنعرض originals
+        elif folder == "temp":
+            target_folders = [TEMP_DIR]
+        elif folder == "processed":
+            target_folders = [PROCESSED_DIR]
+        elif folder == "audio":
+            target_folders = [AUDIO_DIR]
+        elif folder == "originals":
+            target_folders = [ORIGINALS_DIR]
+        else:
+            return JSONResponse(
+                status_code=400,
+                content={"error": f"Invalid folder: {folder}. Use: temp, processed, audio, originals, or all"}
+            )
+        
+        preview_data = {}
+        total_files = 0
+        total_size = 0
+        
+        for target_folder in target_folders:
+            folder_name = os.path.basename(target_folder)
+            files_info = []
+            folder_size = 0
+            
+            if os.path.exists(target_folder):
+                for filename in os.listdir(target_folder):
+                    file_path = os.path.join(target_folder, filename)
+                    if os.path.isfile(file_path):
+                        file_size = os.path.getsize(file_path)
+                        files_info.append({
+                            "filename": filename,
+                            "size_bytes": file_size,
+                            "size_mb": round(file_size / (1024 * 1024), 2),
+                            "created": os.path.getctime(file_path)
+                        })
+                        folder_size += file_size
+            
+            preview_data[folder_name] = {
+                "files": files_info,
+                "file_count": len(files_info),
+                "total_size_bytes": folder_size,
+                "total_size_mb": round(folder_size / (1024 * 1024), 2)
+            }
+            
+            total_files += len(files_info)
+            total_size += folder_size
+        
+        return {
+            "status": "success",
+            "folder": folder,
+            "preview": preview_data,
+            "total_files": total_files,
+            "total_size_mb": round(total_size / (1024 * 1024), 2),
+            "message": f"Found {total_files} files ready for cleanup ({round(total_size / (1024 * 1024), 2)} MB)"
+        }
+    
+    except Exception as e:
+        return JSONResponse(
+            status_code=500, 
+            content={"error": f"Preview failed: {str(e)}"}
+        )
+
+@router.post("/process", tags=["Video"])
 async def process_video(
     request: Request,
     background_tasks: BackgroundTasks,
     video: UploadFile = File(...),
     format: VideoFormat = Form(VideoFormat.FILM, description="Select the output video format"),
-    background_music: UploadFile = File(None, description="Upload an audio file for background music"),
-    music_url: str = Form(None, description="URL of an audio file for background music"),
+    background_music: UploadFile = File(None, description="Upload an audio file for background music (files only, no URLs)"),
     video_volume: float = Form(1.0, description="Volume of original video (0.0 to 1.0+)"),
     music_volume: float = Form(0.2, description="Volume of background music (0.0 to 1.0+)"),
     loop_music: bool = Form(True, description="Loop background music if shorter than video"),
@@ -113,7 +220,8 @@ async def process_video(
         description='Optional JSON list of timestamps. If not provided, will process entire video. Recommended duration for weak devices: < 60 seconds per clip.'
     ),
     export_audio: bool = Form(False, description="Export separate audio files for each clip (original audio). Returns a ZIP if True."),
-    webhook_url: str = Form(None, description="Optional URL to receive processing results via POST.")
+    webhook_url: str = Form(None, description="Optional URL to receive processing results via POST."),
+    return_files: bool = Form(False, description="Return processed files directly instead of URLs (for n8n automation)")
 ):
     task_id = uuid.uuid4().hex[:8]
     temp_path = None
@@ -134,35 +242,31 @@ async def process_video(
             except Exception as e:
                 raise HTTPException(status_code=400, detail=f"Invalid timestamps format: {str(e)}")
         
-        # Save uploaded video first
-        temp_path = os.path.join(UPLOAD_DIR, f"{task_id}_{video.filename}")
-        with open(temp_path, "wb") as buffer:
+        # نحفظ الفيديو الأصلي في فولدر الأصلي
+        original_filename = f"{task_id}_original_{video.filename}"
+        original_path = os.path.join(ORIGINALS_DIR, original_filename)
+        with open(original_path, "wb") as buffer:
             shutil.copyfileobj(video.file, buffer)
+        
+        # ننسخ للـ temp عشان المعالجة (دي نسخة مؤقتة هنمسحها بعدين)
+        temp_path = os.path.join(TEMP_DIR, f"{task_id}_temp_{video.filename}")
+        shutil.copy2(original_path, temp_path)
+        
+        # متغير عشان نعرف نمسح بس المؤقت مش الأصلي
+        temp_file_for_processing = temp_path
 
         # If no timestamps provided, process entire video
         if not timestamps:
             # Get video duration to create single timestamp for entire video
             from moviepy import VideoFileClip
-            with VideoFileClip(temp_path) as video:
-                timestamps = [Timestamp(start_time=0, end_time=video.duration)]
+            with VideoFileClip(temp_path) as clip:
+                timestamps = [Timestamp(start_time=0, end_time=clip.duration)]
 
-        # Handle Background Music
+        # Handle Background Music (n8n compatible - files only)
         if background_music:
-            audio_path = os.path.join(UPLOAD_DIR, f"bg_{task_id}_{background_music.filename}")
+            audio_path = os.path.join(BASE_DIR, f"bg_{task_id}_{background_music.filename}")
             with open(audio_path, "wb") as buffer:
                 shutil.copyfileobj(background_music.file, buffer)
-        elif music_url:
-            # Download audio from URL
-            try:
-                response = requests.get(music_url, stream=True)
-                response.raise_for_status()
-                audio_filename = f"bg_url_{task_id}.mp3"
-                audio_path = os.path.join(UPLOAD_DIR, audio_filename)
-                with open(audio_path, "wb") as buffer:
-                    for chunk in response.iter_content(chunk_size=8192):
-                        buffer.write(chunk)
-            except Exception as e:
-                print(f"Failed to download music: {e}")
         
         # Prepare dimensions
         dims = Dimensions(
@@ -178,43 +282,61 @@ async def process_video(
         if webhook_url:
             background_tasks.add_task(
                 background_processing,
-                task_id, temp_path, timestamps, format, dims, export_audio, audio_path, webhook_url, host_url
+                task_id, temp_file_for_processing, timestamps, format, dims, export_audio, audio_path, webhook_url, str(request.base_url)
             )
             return {"status": "processing", "task_id": task_id, "message": "Processing started. Results will be sent to webhook."}
         else:
             # Synchronous execution
             return background_processing(
-                task_id, temp_path, timestamps, format, dims, export_audio, audio_path, None, host_url
+                task_id, temp_file_for_processing, timestamps, format, dims, export_audio, audio_path, None, str(request.base_url)
             )
 
     except Exception as e:
-        if temp_path: safe_remove(temp_path)
-        if audio_path: safe_remove(audio_path)
+        # نمسح بس الملف المؤقت، الأصلي يفضل محفوظ
+        if 'temp_file_for_processing' in locals():
+            safe_remove(temp_file_for_processing)
+        if 'audio_path' in locals() and audio_path:
+            safe_remove(audio_path)
         if isinstance(e, HTTPException): raise e
         return JSONResponse(status_code=500, content={"error": str(e)})
 
-@router.get("/status", tags=["System"])
+@router.get("/status", tags=["Video"])
 async def get_system_status():
     """
-    Get system status including disk usage and temp files count.
+    Get system status including disk usage and temp files count across all subfolders.
     """
     try:
-        import os
-        import shutil
-        
         # Get disk usage
         total, used, free = shutil.disk_usage("/")
         
-        # Count temp files
-        temp_files_count = 0
-        temp_files_size = 0
+        # Count files in all subfolders
+        total_files_count = 0
+        total_files_size = 0
+        folder_stats = {}
         
-        if os.path.exists(UPLOAD_DIR):
-            for filename in os.listdir(UPLOAD_DIR):
-                file_path = os.path.join(UPLOAD_DIR, filename)
-                if os.path.isfile(file_path):
-                    temp_files_count += 1
-                    temp_files_size += os.path.getsize(file_path)
+        folders = {
+            "originals": ORIGINALS_DIR,
+            "processed": PROCESSED_DIR,
+            "audio": AUDIO_DIR,
+            "temp": TEMP_DIR
+        }
+        
+        for name, path in folders.items():
+            count = 0
+            size = 0
+            if os.path.exists(path):
+                for filename in os.listdir(path):
+                    f_path = os.path.join(path, filename)
+                    if os.path.isfile(f_path):
+                        count += 1
+                        size += os.path.getsize(f_path)
+            
+            folder_stats[name] = {
+                "count": count,
+                "size_mb": round(size / (1024**2), 2)
+            }
+            total_files_count += count
+            total_files_size += size
         
         return {
             "status": "healthy",
@@ -225,10 +347,11 @@ async def get_system_status():
                 "usage_percent": round((used / total) * 100, 1)
             },
             "temp_files": {
-                "count": temp_files_count,
-                "size_mb": round(temp_files_size / (1024**2), 2)
+                "total_count": total_files_count,
+                "total_size_mb": round(total_files_size / (1024**2), 2),
+                "by_folder": folder_stats
             },
-            "upload_directory": UPLOAD_DIR
+            "base_directory": BASE_DIR
         }
     except Exception as e:
         return JSONResponse(
@@ -236,64 +359,117 @@ async def get_system_status():
             content={"error": f"Failed to get status: {str(e)}"}
         )
 
-@router.post("/clear", tags=["Cleanup"])
-async def clear_temp_files():
+@router.api_route("/clear", methods=["GET", "POST"], tags=["Video"])
+async def clear_temp_files(
+    folder: str = Query("temp", description="Folder to clear", enum=["temp", "processed", "audio", "originals", "all"]),
+    specific_files: str = Query(None, description="Comma-separated list of specific files to delete (optional). Use /clear-preview to see available files.")
+):
     """
-    Clean up all temporary files in the upload directory.
-    Useful for freeing up disk space.
+    Clear files from specified folder(s). Works with GET and POST.
+    
+    Parameters:
+    - folder: Which folder to clear (temp, processed, audio, originals, all)
+    - specific_files: Optional comma-separated list of specific files to delete
     """
     try:
-        import shutil
-        import os
-        
-        # Count files before cleanup
-        files_count = 0
-        total_size = 0
+        # نحدد الفولدرات المستهدفة
+        target_folders = []
+        if folder == "all":
+            target_folders = [TEMP_DIR, PROCESSED_DIR, AUDIO_DIR]  # مش هنمسح originals
+        elif folder == "temp":
+            target_folders = [TEMP_DIR]
+        elif folder == "processed":
+            target_folders = [PROCESSED_DIR]
+        elif folder == "audio":
+            target_folders = [AUDIO_DIR]
+        elif folder == "originals":
+            target_folders = [ORIGINALS_DIR]
+        else:
+            return JSONResponse(
+                status_code=400,
+                content={"error": f"Invalid folder: {folder}. Use: temp, processed, audio, originals, or all"}
+            )
+
+        deleted_files = []
+        total_size_freed = 0
+
+        # تسجيل مفصل للتأكد من المسارات
+        print(f"[CLEAR DEBUG] Target folders: {target_folders}")
+        print(f"[CLEAR DEBUG] Specific files requested: {specific_files}")
         
-        if os.path.exists(UPLOAD_DIR):
-            for filename in os.listdir(UPLOAD_DIR):
-                file_path = os.path.join(UPLOAD_DIR, filename)
-                if os.path.isfile(file_path):
-                    files_count += 1
-                    total_size += os.path.getsize(file_path)
-                    safe_remove(file_path)
+        # لو فيه ملفات محددة، نمسحها بس
+        if specific_files:
+            files_to_delete = [f.strip() for f in specific_files.split(',') if f.strip()]
+            print(f"[CLEAR DEBUG] Files to delete: {files_to_delete}")
+            
+            for target_folder in target_folders:
+                print(f"[CLEAR DEBUG] Checking folder: {target_folder}")
+                for filename in files_to_delete:
+                    file_path = os.path.join(target_folder, filename)
+                    print(f"[CLEAR DEBUG] Checking file: {file_path} - exists: {os.path.exists(file_path)}")
+                    if os.path.exists(file_path) and os.path.isfile(file_path):
+                        file_size = os.path.getsize(file_path)
+                        print(f"[CLEAR DEBUG] Deleting file: {file_path}")
+                        if safe_remove(file_path):
+                            deleted_files.append(filename)
+                            total_size_freed += file_size
+                            print(f"[CLEAR DEBUG] Successfully deleted: {filename}")
+        else:
+            # نمسح كل الملفات في الفولدرات المستهدفة
+            for target_folder in target_folders:
+                print(f"[CLEAR DEBUG] Processing folder: {target_folder}")
+                if os.path.exists(target_folder):
+                    folder_files = os.listdir(target_folder)
+                    print(f"[CLEAR DEBUG] Files found in {target_folder}: {folder_files}")
+                    for filename in os.listdir(target_folder):
+                        file_path = os.path.join(target_folder, filename)
+                        if os.path.isfile(file_path):
+                            file_size = os.path.getsize(file_path)
+                            print(f"[CLEAR DEBUG] Deleting file: {file_path}")
+                            if safe_remove(file_path):
+                                deleted_files.append(filename)
+                                total_size_freed += file_size
+                                print(f"[CLEAR DEBUG] Successfully deleted: {filename}")
+                else:
+                    print(f"[CLEAR DEBUG] Folder does not exist: {target_folder}")
+
+        print(f"[CLEAR DEBUG] Total deleted: {len(deleted_files)} files, freed: {total_size_freed} bytes")
+
+        size_mb = total_size_freed / (1024 * 1024)
         
-        # Convert size to MB
-        size_mb = total_size / (1024 * 1024)
+        print(f"[CLEAR RESULT] Deleted {len(deleted_files)} files, freed {size_mb:.2f} MB")
+        print(f"[CLEAR RESULT] Deleted files: {deleted_files}")
         
         return {
-            "status": "success", 
-            "message": f"Cleaned up {files_count} files ({size_mb:.2f} MB)",
-            "files_removed": files_count,
-            "space_freed_mb": round(size_mb, 2)
+            "status": "success",
+            "folder": folder,
+            "deleted_files": deleted_files,
+            "files_count": len(deleted_files),
+            "size_freed_mb": round(size_mb, 2),
+            "message": f"Successfully deleted {len(deleted_files)} files ({round(size_mb, 2)} MB freed)"
         }
+
     except Exception as e:
         return JSONResponse(
-            status_code=500, 
-            content={"error": f"Cleanup failed: {str(e)}"}
+            status_code=500,
+            content={"error": f"Clear failed: {str(e)}"}
         )
 
-@router.post("/extract-audio", tags=["Audio Processing"])
+@router.post("/extract-audio", tags=["Video"])
 async def extract_audio(
+    request: Request,
     video: UploadFile = File(...),
     output_format: str = Form("mp3"),
     host_url: str = Form("")
 ):
     """
-    Extract audio from a video file and return the audio file.
-    
-    Args:
-        video: The video file to extract audio from
-        output_format: Output audio format (mp3, wav, etc.)
-        host_url: Base URL for the download link (optional)
-    
-    Returns:
-        Audio file directly if no host_url provided, otherwise JSON with download link
+    Extract audio from a video file using FFmpeg (optimized for speed).
+    أسرع بكثير من استخدام MoviePy.
     """
+    print(f"[EXTRACT-AUDIO DEBUG] Starting extract-audio with file: {video.filename}")
+    print(f"[EXTRACT-AUDIO DEBUG] Request base_url: {request.base_url}")
+    print(f"[EXTRACT-AUDIO DEBUG] Output format: {output_format}")
     try:
-        from video_processor import extract_audio_from_video
-        import uuid
-        
         # Validate output format
         allowed_formats = ["mp3", "wav", "m4a", "aac", "flac"]
         if output_format.lower() not in allowed_formats:
@@ -305,45 +481,68 @@ async def extract_audio(
         # Generate task ID
         task_id = uuid.uuid4().hex[:8]
         
-        # Save uploaded video
-        temp_path = os.path.join(UPLOAD_DIR, f"{task_id}_{video.filename}")
-        with open(temp_path, "wb") as buffer:
-            shutil.copyfileobj(video.file, buffer)
+        # نحفظ الفيديو الأصلي دايماً في فولدر الأصلي
+        original_filename = f"{task_id}_original_{video.filename}"
+        original_path = os.path.join(ORIGINALS_DIR, original_filename)
         
-        # Extract audio
-        audio_path = extract_audio_from_video(temp_path, output_format)
+        if os.path.exists(original_path):
+            # لو لاقينا الأصلي، نستخدمه وما نحفظش تاني
+            temp_path = original_path
+            used_existing_original = True
+        else:
+            # لو مش موجود، نحفظ الفيديو الجديد في الأصلي
+            with open(original_path, "wb") as buffer:
+                shutil.copyfileobj(video.file, buffer)
+            
+            # ننسخ للـ temp عشان المعالجة
+            temp_path = os.path.join(TEMP_DIR, f"{task_id}_temp_{video.filename}")
+            shutil.copy2(original_path, temp_path)
+            used_existing_original = False
         
-        # Clean up video file
-        safe_remove(temp_path)
+        # Extract audio using FFmpeg if available, otherwise use MoviePy
+        audio_filename = f"audio_{task_id}.{output_format.lower()}"
+        audio_path = os.path.join(AUDIO_DIR, audio_filename)
         
-        # If host_url is provided, return JSON with download link
-        if host_url:
-            audio_filename = os.path.basename(audio_path)
-            download_url = f"{host_url}get-clip/{audio_filename}"
-            
-            return {
-                "status": "success",
-                "task_id": task_id,
-                "message": "Audio extracted successfully",
-                "audio_url": download_url,
-                "audio_filename": audio_filename,
-                "format": output_format.lower()
-            }
+        # Use FFmpeg from imageio-ffmpeg (أسرع بكثير)
+        ffmpeg_exe = imageio_ffmpeg.get_ffmpeg_exe()
         
-        # If no host_url, return the audio file directly
-        audio_filename = os.path.basename(audio_path)
+        # FFmpeg command optimized for speed
+        cmd = [
+            ffmpeg_exe, '-i', temp_path,
+            '-vn',  # لا فيديو
+            '-acodec', 'copy' if output_format.lower() == 'aac' else 'libmp3lame',
+            '-y',   # overwrite output file
+            audio_path
+        ]
         
-        # Clean up audio file after response
-        def cleanup_audio():
-            safe_remove(audio_path)
+        # Run FFmpeg
+        result = subprocess.run(cmd, capture_output=True, text=True)
         
-        # Return the audio file directly
-        return FileResponse(
-            audio_path,
-            media_type=f"audio/{output_format.lower()}",
-            filename=audio_filename,
-            background=cleanup_audio
-        )
+        if result.returncode != 0:
+            raise ValueError(f"FFmpeg error: {result.stderr}")
+        
+        # نمسح الملف الملف المؤقت، مش الأصلي
+        if temp_path and TEMP_DIR in temp_path:
+            safe_remove(temp_path)
+        
+        # دايماً نرجع JSON مع الـ filename عشان نقدر نستخدمه لاحقاً
+        audio_filename = os.path.basename(audio_path)
+        
+        # Use build_file_url for consistent URL construction
+        return {
+            "status": "success",
+            "task_id": task_id,
+            "message": "Audio extracted successfully (optimized)",
+            "audio_files": [
+                {
+                    "filename": audio_filename,
+                    "url": build_file_url(request, audio_filename, "audio")
+                }
+            ],
+            "format": output_format.lower(),
+            "method": "ffmpeg_direct",
+            "file_path": audio_path  # مهم عشان نعرف نستخدمه لاحقاً
+        }
         
     except ValueError as e:
         return JSONResponse(
@@ -351,7 +550,108 @@ async def extract_audio(
             content={"error": str(e)}
         )
     except Exception as e:
+        # نمسح بس الملف المؤقت، مش الأصلي
+        if 'temp_path' in locals() and 'temp_path' in locals() and temp_path and not used_existing_original and TEMP_DIR in temp_path:
+            safe_remove(temp_path)
+        if isinstance(e, HTTPException): raise e
         return JSONResponse(
             status_code=500,
             content={"error": f"Audio extraction failed: {str(e)}"}
         )
+
+@router.post("/process-saved", tags=["Video"])
+async def process_saved_video(
+    request: Request,
+    background_tasks: BackgroundTasks,
+    original_filename: str = Form(..., description="اسم الفيديو الأصلي المحفوظ"),
+    format: VideoFormat = Form(VideoFormat.FILM, description="Select the output video format"),
+    timestamps_json: str = Form(None, description='JSON list of timestamps. If not provided, will process entire video.'),
+    export_audio: bool = Form(False, description="Export separate audio files for each clip"),
+    webhook_url: str = Form(None, description="Optional URL to receive processing results via POST.")
+):
+    """
+    معالجة فيديو محفوظ أصلي بدون رفعه تاني - توفير وقت ومساحة
+    """
+    task_id = uuid.uuid4().hex[:8]
+    host_url = str(request.base_url)
+    
+    try:
+        # ندور على الفيديو الأصلي
+        original_path = os.path.join(ORIGINALS_DIR, original_filename)
+        
+        if not os.path.exists(original_path):
+            return JSONResponse(
+                status_code=404,
+                content={"error": f"Original video not found: {original_filename}"}
+            )
+        
+        # ننسخ للـ temp عشان المعالجة
+        temp_path = os.path.join(TEMP_DIR, f"{task_id}_temp_{original_filename}")
+        shutil.copy2(original_path, temp_path)
+        
+        # Parse timestamps
+        timestamps = []
+        if timestamps_json:
+            try:
+                timestamps_data = json.loads(timestamps_json)
+                if not isinstance(timestamps_data, list):
+                    raise ValueError("Timestamps must be a list")
+                timestamps = [Timestamp(**ts) for ts in timestamps_data]
+            except Exception as e:
+                raise HTTPException(status_code=400, detail=f"Invalid timestamps format: {str(e)}")
+        
+        # If no timestamps, process entire video
+        if not timestamps:
+            from moviepy import VideoFileClip
+            with VideoFileClip(temp_path) as clip:
+                timestamps = [Timestamp(start_time=0, end_time=clip.duration)]
+        
+        # Prepare dimensions (بدون موسيقى خلفية)
+        dims = Dimensions(width=0, height=0, audio_path=None, video_volume=1.0, music_volume=0, loop_music=False)
+        
+        # Dispatch
+        if webhook_url:
+            background_tasks.add_task(
+                background_processing,
+                task_id, temp_path, timestamps, format, dims, export_audio, None, webhook_url, host_url
+            )
+            return {"status": "processing", "task_id": task_id, "message": "Processing started using saved video. Results will be sent to webhook.", "original_used": original_filename}
+        else:
+            # Synchronous execution
+            return background_processing(
+                task_id, temp_path, timestamps, format, dims, export_audio, None, None, host_url
+            )
+
+    except Exception as e:
+        if 'temp_path' in locals():
+            safe_remove(temp_path)
+        if isinstance(e, HTTPException): raise e
+        return JSONResponse(status_code=500, content={"error": str(e)})
+
+@router.get("/list-saved", tags=["Video"])
+async def list_saved_videos():
+    """
+    عرض قائمة الفيديوهات الأصلية المحفوظة
+    """
+    try:
+        saved_videos = []
+        if os.path.exists(ORIGINALS_DIR):
+            for filename in os.listdir(ORIGINALS_DIR):
+                if filename.endswith(('.mp4', '.avi', '.mov', '.mkv')):
+                    file_path = os.path.join(ORIGINALS_DIR, filename)
+                    file_stats = os.stat(file_path)
+                    saved_videos.append({
+                        "filename": filename,
+                        "size_mb": round(file_stats.st_size / (1024*1024), 2),
+                        "created": file_stats.st_ctime,
+                        "full_path": file_path
+                    })
+        
+        return {
+            "status": "success",
+            "count": len(saved_videos),
+            "videos": saved_videos,
+            "originals_directory": ORIGINALS_DIR
+        }
+    except Exception as e:
+        return JSONResponse(status_code=500, content={"error": f"Failed to list videos: {str(e)}"})

schemas.py

@@ -14,6 +14,12 @@ class VideoFormat(str, Enum):
     ORIGINAL = "Original (No Resize)"
     CUSTOM = "Custom"
 
+class LayoutType(str, Enum):
+    CROP = "crop"                # Current behavior: Crop to fill
+    CINEMATIC = "cinematic"      # Blurred background + Original video
+    SPLIT_SCREEN = "split"       # Two videos stacked
+    FIT = "fit"                  # Fit within canvas with black bars
+
 class ProcessingType(str, Enum):
     TRANSCRIPT = "transcript"
     CROP = "crop"
@@ -40,6 +46,9 @@ class Dimensions(BaseModel):
     video_volume: float = 1.0
     music_volume: float = 0.2
     loop_music: bool = True
+    layout_type: LayoutType = LayoutType.CROP
+    blur_intensity: int = 20  # For cinematic layout
+    background_video_url: Optional[str] = None  # For split screen
 
 class ClipRequest(BaseModel):
     video_url: Optional[str] = None

video_processor.py

@@ -1,8 +1,8 @@
 import os
 import uuid
 from concurrent.futures import ThreadPoolExecutor
-from moviepy import VideoFileClip, vfx
-from schemas import VideoFormat, Dimensions
+from moviepy import VideoFileClip, vfx, CompositeVideoClip, ColorClip
+from schemas import VideoFormat, Dimensions, LayoutType
 from hybrid_processor import process_video_hybrid
 
 def process_video_clips(video_path: str, timestamps, output_format: VideoFormat, custom_dims: Dimensions = None, export_audio: bool = False, use_parallel: bool = True, use_ffmpeg_optimization: bool = True):
@@ -145,12 +145,16 @@ def process_video_clips(video_path: str, timestamps, output_format: VideoFormat,
                         # Apply formatting
                         if output_format == VideoFormat.ORIGINAL:
                             pass # Skip resizing, keep original dimensions
-                        elif output_format != VideoFormat.CUSTOM:
-                            target_ratio = ratios.get(output_format, 16/9)
-                            subclip = format_clip(subclip, target_ratio)
-                        elif custom_dims:
-                            if hasattr(custom_dims, 'width') and hasattr(custom_dims, 'height'):
-                                subclip = subclip.resized(width=custom_dims.width, height=custom_dims.height)
+                        else:
+                            # Standardize on 1080x1920 for Shorts if format is Shorts
+                            target_w, target_h = 1080, 1920
+                            if output_format == VideoFormat.VIDEO:
+                                target_w, target_h = 1920, 1080
+                            elif output_format == VideoFormat.SQUARE:
+                                target_w, target_h = 1080, 1080
+                            
+                            layout = custom_dims.layout_type if custom_dims else LayoutType.CROP
+                            subclip = apply_layout_factory(subclip, layout, target_w, target_h, custom_dims)
                         
                         # Write file - optimized settings for speed
                         subclip.write_videofile(
@@ -177,6 +181,54 @@ def process_video_clips(video_path: str, timestamps, output_format: VideoFormat,
         print(f"Error processing video: {str(e)}")
         raise e
 
+def apply_layout_factory(clip, layout_type, target_w, target_h, config=None):
+    """
+    Factory to apply different video layouts.
+    """
+    if layout_type == LayoutType.CINEMATIC:
+        return apply_cinematic_blur(clip, target_w, target_h, config.blur_intensity if config else 20)
+    elif layout_type == LayoutType.FIT:
+        return apply_fit_layout(clip, target_w, target_h)
+    else:
+        # Default to Crop/Fill
+        target_ratio = target_w / target_h
+        formatted = format_clip(clip, target_ratio)
+        return formatted.resized(width=target_w, height=target_h)
+
+def apply_cinematic_blur(clip, target_w, target_h, blur_intensity=20):
+    """
+    Creates a cinematic blurred background with the original video on top.
+    """
+    # 1. Background: Scale to fill and blur
+    # First, crop/resize to fill target dimensions
+    bg = format_clip(clip, target_w / target_h)
+    bg = bg.resized(width=target_w, height=target_h)
+    bg = bg.with_effects([vfx.GaussianBlur(blur_intensity)])
+    
+    # 2. Foreground: Resize original to fit width while keeping aspect ratio
+    # If original is 16:9, it will have bars top/bottom over the blur
+    fg = clip.resized(width=target_w)
+    
+    # Center the foreground on the background
+    final_clip = CompositeVideoClip([
+        bg,
+        fg.with_position("center")
+    ], size=(target_w, target_h))
+    
+    return final_clip
+
+def apply_fit_layout(clip, target_w, target_h):
+    """
+    Fits the video inside the target dimensions with black bars (Letterboxing).
+    """
+    # Resize to fit within target dims
+    fg = clip.resized(width=target_w) if (clip.w / clip.h) > (target_w / target_h) else clip.resized(height=target_h)
+    
+    # Create black background
+    bg = ColorClip(size=(target_w, target_h), color=(0,0,0), duration=clip.duration)
+    
+    return CompositeVideoClip([bg, fg.with_position("center")], size=(target_w, target_h))
+
 def format_clip(clip, target_ratio):
     """
     Crops and resizes a clip to a target aspect ratio.
@@ -206,14 +258,29 @@ def format_clip(clip, target_ratio):
 def safe_remove(path: str, max_retries: int = 3):
     """Attempt to remove a file with retries for Windows file locking."""
     import time
+    import os
+    
+    if not os.path.exists(path):
+        print(f"[SAFE_REMOVE] File does not exist: {path}")
+        return
+        
     for i in range(max_retries):
         try:
-            if os.path.exists(path):
-                os.remove(path)
-            return
-        except PermissionError:
-            time.sleep(1) # Wait for handles to clear
-    print(f"Warning: Could not delete {path} after {max_retries} attempts.")
+            os.remove(path)
+            print(f"[SAFE_REMOVE] Successfully deleted: {path}")
+            return True
+        except PermissionError as e:
+            print(f"[SAFE_REMOVE] Permission error on attempt {i+1}: {e}")
+            if i < max_retries - 1:
+                time.sleep(1) # Wait for handles to clear
+            else:
+                print(f"[SAFE_REMOVE] Warning: Could not delete {path} after {max_retries} attempts.")
+                return False
+        except Exception as e:
+            print(f"[SAFE_REMOVE] Error deleting {path}: {e}")
+            return False
+    
+    return False
 
 def create_zip_archive(file_paths: list, output_filename: str):
     """
@@ -303,12 +370,16 @@ def process_single_clip(ts, video_path, output_format, custom_dims, export_audio
             # Apply formatting
             if output_format == VideoFormat.ORIGINAL:
                 pass # Skip resizing, keep original dimensions
-            elif output_format != VideoFormat.CUSTOM:
-                target_ratio = ratios.get(output_format, 16/9)
-                subclip = format_clip(subclip, target_ratio)
-            elif custom_dims:
-                if hasattr(custom_dims, 'width') and hasattr(custom_dims, 'height'):
-                    subclip = subclip.resized(width=custom_dims.width, height=custom_dims.height)
+            else:
+                # Standardize on 1080x1920 for Shorts if format is Shorts
+                target_w, target_h = 1080, 1920
+                if output_format == VideoFormat.VIDEO:
+                    target_w, target_h = 1920, 1080
+                elif output_format == VideoFormat.SQUARE:
+                    target_w, target_h = 1080, 1080
+                
+                layout = custom_dims.layout_type if custom_dims else LayoutType.CROP
+                subclip = apply_layout_factory(subclip, layout, target_w, target_h, custom_dims)
             
             # Write file - optimized settings for speed
             subclip.write_videofile(

video_storage/version_registry.json

@@ -1,4 +0,0 @@
-{
-
-  
-}