Update app.py

app.py

@@ -2,6 +2,9 @@ import os
 import sys
 import subprocess
 import importlib.util
+import uuid
+import json
+from datetime import datetime
 
 print("=" * 60)
 print("🚀 STARTING VIDEO PROJECT MANAGER")
@@ -12,11 +15,10 @@ def ensure_package(package_name, import_name=None):
     if import_name is None:
         import_name = package_name
     
-    # Check if package is installed
     if importlib.util.find_spec(import_name) is None:
         print(f"📦 Installing {package_name}...")
         try:
-            subprocess.check_call([sys.executable, "-m", "pip", "install", package_name])
+            subprocess.check_call([sys.executable, "-m", "pip", "install", package_name, "--quiet"])
             print(f"✅ {package_name} installed successfully!")
             return True
         except Exception as e:
@@ -33,9 +35,6 @@ ensure_package("python-dotenv")
 
 # Now import after ensuring they're installed
 import gradio as gr
-import uuid
-import json
-from datetime import datetime
 from supabase import create_client
 
 print("\n" + "=" * 60)
@@ -44,7 +43,6 @@ print("\n" + "=" * 60)
 # SUPABASE CONNECTION
 # =============================================
 
-# Get Supabase credentials from environment variables
 SUPABASE_URL = os.environ.get("SUPABASE_URL")
 SUPABASE_KEY = os.environ.get("SUPABASE_KEY")
 
@@ -78,17 +76,19 @@ else:
 def create_project(title, content, tags, image_prompt, channel):
     """Create a new project and save to Supabase"""
     print(f"\n📝 Creating project: {title}")
+    print(f"   Content length: {len(content)}")
+    print(f"   Tags: {tags}")
     
     try:
         # Generate proper UUID
-        project_id = str(uuid.uuid4())  # Full UUID
+        project_id = str(uuid.uuid4())
         folder_name = title.lower().replace(' ', '_').replace('/', '-')[:20]
         
         project_data = {
             "project_id": project_id,
             "folder_name": folder_name,
             "title": title,
-            "content": content,
+            "content": content[:5000],
             "tags": tags,
             "image_prompt": image_prompt,
             "channel_details": channel,
@@ -99,27 +99,39 @@ def create_project(title, content, tags, image_prompt, channel):
         print(f"💾 Saving project with UUID: {project_id}")
         
         if supabase:
-            result = supabase.table("projects").insert(project_data).execute()
-            print("✅ Saved to database")
-            
-            return {
-                "status": "success",
-                "project_id": project_id,
-                "folder": folder_name,
-                "title": title,
-                "message": "Project created!"
-            }
+            try:
+                result = supabase.table("projects").insert(project_data).execute()
+                print(f"✅ Saved to database! Record ID: {result.data[0]['id'] if result.data else 'unknown'}")
+                
+                return {
+                    "status": "success",
+                    "project_id": project_id,
+                    "folder": folder_name,
+                    "title": title,
+                    "message": "Project created successfully in database!"
+                }
+            except Exception as e:
+                print(f"❌ Database error: {e}")
+                return {
+                    "status": "error",
+                    "message": f"Database error: {str(e)}",
+                    "project_id": project_id,
+                    "folder": folder_name
+                }
         else:
+            print("⚠️ No database connection - memory only")
             return {
                 "status": "memory_only",
                 "project_id": project_id,
                 "folder": folder_name,
                 "title": title,
-                "message": "No database connection"
+                "message": "Project created in memory only (no database)"
             }
             
     except Exception as e:
         print(f"❌ Error: {e}")
+        import traceback
+        traceback.print_exc()
         return {"status": "error", "message": str(e)}
 
 def search_projects(term):
@@ -127,11 +139,9 @@ def search_projects(term):
     print(f"\n🔍 Searching for: {term}")
     
     if not supabase:
-        print("⚠️ No database connection - returning demo data")
         return [
             ["Demo Project 1", "memory", datetime.now().strftime("%Y-%m-%d"), "demo_1"],
             ["How to Make Videos", "demo", datetime.now().strftime("%Y-%m-%d"), "tutorial"],
-            [term or "Search Demo", "demo", datetime.now().strftime("%Y-%m-%d"), "demo"]
         ]
     
     try:
@@ -160,7 +170,6 @@ def search_projects(term):
                 p.get("folder_name", "")
             ])
         
-        print(f"✅ Found {len(projects)} projects")
         return projects if projects else [["No projects found", "", "", ""]]
         
     except Exception as e:
@@ -172,14 +181,66 @@ def health_check():
     return {
         "status": "healthy",
         "supabase_connected": bool(supabase),
-        "timestamp": datetime.now().isoformat(),
-        "endpoints": {
-            "create": "/api/create",
-            "search": "/api/search",
-            "health": "/api/health"
-        }
+        "timestamp": datetime.now().isoformat()
     }
 
+# =============================================
+# FASTAPI ROUTES (Direct API endpoints)
+# =============================================
+
+from fastapi import FastAPI, Request
+from fastapi.responses import JSONResponse
+import uvicorn
+import threading
+
+# Create FastAPI app
+fastapi_app = FastAPI()
+
+@fastapi_app.post("/api/create")
+async def api_create(request: Request):
+    """Direct API endpoint for creating projects"""
+    try:
+        data = await request.json()
+        # Extract data from the request
+        if "data" in data and len(data["data"]) >= 5:
+            result = create_project(
+                data["data"][0],
+                data["data"][1],
+                data["data"][2],
+                data["data"][3],
+                data["data"][4]
+            )
+            return JSONResponse(content={"data": [result]})
+        else:
+            return JSONResponse(
+                status_code=400,
+                content={"error": "Invalid data format"}
+            )
+    except Exception as e:
+        return JSONResponse(
+            status_code=500,
+            content={"error": str(e)}
+        )
+
+@fastapi_app.post("/api/health")
+async def api_health():
+    """Health check endpoint"""
+    return JSONResponse(content=health_check())
+
+@fastapi_app.post("/api/search")
+async def api_search(request: Request):
+    """Search endpoint"""
+    try:
+        data = await request.json()
+        term = data.get("data", [""])[0] if data.get("data") else ""
+        result = search_projects(term)
+        return JSONResponse(content={"data": [result]})
+    except Exception as e:
+        return JSONResponse(
+            status_code=500,
+            content={"error": str(e)}
+        )
+
 # =============================================
 # GRADIO INTERFACE
 # =============================================
@@ -200,28 +261,11 @@ with gr.Blocks(title="Video Project Manager") as demo:
         with gr.TabItem("📁 Create Project"):
             with gr.Row():
                 with gr.Column():
-                    title_input = gr.Textbox(
-                        label="Title",
-                        placeholder="Enter video title"
-                    )
-                    content_input = gr.Textbox(
-                        label="Content",
-                        lines=3,
-                        placeholder="Enter TTS content"
-                    )
-                    tags_input = gr.Textbox(
-                        label="Tags",
-                        placeholder="tag1, tag2, tag3"
-                    )
-                    image_input = gr.Textbox(
-                        label="Image Prompt",
-                        lines=2,
-                        placeholder="Describe images"
-                    )
-                    channel_input = gr.Textbox(
-                        label="Channel Details",
-                        value='{"platform": "youtube"}'
-                    )
+                    title_input = gr.Textbox(label="Title", placeholder="Enter video title")
+                    content_input = gr.Textbox(label="Content", lines=3, placeholder="Enter TTS content")
+                    tags_input = gr.Textbox(label="Tags", placeholder="tag1, tag2, tag3")
+                    image_input = gr.Textbox(label="Image Prompt", lines=2, placeholder="Describe images")
+                    channel_input = gr.Textbox(label="Channel Details", value='{"platform": "youtube"}')
                     
                     create_btn = gr.Button("🚀 Create Project", variant="primary")
                     
@@ -230,73 +274,83 @@ with gr.Blocks(title="Video Project Manager") as demo:
         
         # Search Tab
         with gr.TabItem("🔍 Search"):
-            search_input = gr.Textbox(
-                label="Search Term",
-                placeholder="Enter search term"
-            )
+            search_input = gr.Textbox(label="Search Term", placeholder="Enter search term")
             search_btn = gr.Button("🔍 Search", variant="secondary")
             results = gr.Dataframe(
                 headers=["Title", "Status", "Date", "Folder"],
                 label="Search Results"
             )
         
-        # Debug Tab
-        with gr.TabItem("🔧 Debug"):
-            gr.Markdown("### System Information")
-            status_json = gr.JSON(label="Status", value=health_check)
-            refresh_btn = gr.Button("🔄 Refresh Status")
+        # API Info Tab
+        with gr.TabItem("📚 API Info"):
+            gr.Markdown("""
+            ## API Endpoints
             
-            gr.Markdown("### Test API Commands")
-            gr.Markdown(f"""
+            ### Create Project
             ```bash
-            # Test create endpoint
             curl -X POST "https://yukee1992-video-project-manager.hf.space/api/create" \\
               -H "Content-Type: application/json" \\
-              -d '{{"data": ["Test", "Content", "tags", "prompt", "{{}}"]}}'
+              -d '{"data": ["Title", "Content", "tags", "prompt", "{}"]}'
+            ```
+            
+            ### Health Check
+            ```bash
+            curl -X POST "https://yukee1992-video-project-manager.hf.space/api/health" \\
+              -H "Content-Type: application/json" \\
+              -d '{}'
+            ```
+            
+            ### Search
+            ```bash
+            curl -X POST "https://yukee1992-video-project-manager.hf.space/api/search" \\
+              -H "Content-Type: application/json" \\
+              -d '{"data": ["search term"]}'
             ```
             """)
     
-    # =============================================
-    # EVENT HANDLERS
-    # =============================================
-    
-    print("\n📡 Registering API endpoints...")
-    
+    # Gradio event handlers
     create_btn.click(
         fn=create_project,
         inputs=[title_input, content_input, tags_input, image_input, channel_input],
-        outputs=[output],
-        api_name="create"
+        outputs=[output]
     )
-    print("  ✅ Registered: /api/create")
     
     search_btn.click(
         fn=search_projects,
         inputs=[search_input],
-        outputs=[results],
-        api_name="search"
-    )
-    print("  ✅ Registered: /api/search")
-    
-    refresh_btn.click(
-        fn=health_check,
-        inputs=[],
-        outputs=[status_json]
+        outputs=[results]
     )
     
-    print("📡 API endpoints registered successfully!")
+    print("✅ Gradio interface created")
 
 # =============================================
-# LAUNCH
+# RUN BOTH FASTAPI AND GRADIO
 # =============================================
-if __name__ == "__main__":
-    print("\n" + "=" * 60)
-    print("🌐 Launching Gradio server...")
-    print("=" * 60)
-    
+
+def run_fastapi():
+    """Run FastAPI server in a separate thread"""
+    uvicorn.run(fastapi_app, host="0.0.0.0", port=8000)
+
+def run_gradio():
+    """Run Gradio interface"""
     demo.launch(
         server_name="0.0.0.0",
         server_port=7860,
         share=False,
         debug=True
-    )
+    )
+
+if __name__ == "__main__":
+    print("\n" + "=" * 60)
+    print("🌐 Launching servers...")
+    print("   - Gradio UI: http://0.0.0.0:7860")
+    print("   - FastAPI: http://0.0.0.0:8000")
+    print("   - API endpoints: /api/create, /api/health, /api/search")
+    print("=" * 60)
+    
+    # Start FastAPI in a thread
+    fastapi_thread = threading.Thread(target=run_fastapi, daemon=True)
+    fastapi_thread.start()
+    
+    # Start Gradio in main thread
+    run_gradio()