feat: Add Background Worker for Async AI Jobs

worker.py

@@ -1,141 +0,0 @@
-import time
-import os
-import json
-import httpx 
-import datetime
-from supabase import create_client
-from dotenv import load_dotenv
-
-# Environment Load
-load_dotenv()
-
-# Setup Database
-url = os.environ.get("SUPABASE_URL")
-key = os.environ.get("SUPABASE_SERVICE_KEY")
-if not url or not key:
-    print("❌ CRITICAL: Supabase Creds missing in .env")
-    exit(1)
-
-supabase = create_client(url, key)
-
-# ========================================================
-# 🧠 AI LOGIC HANDLER
-# ========================================================
-def perform_ai_task(job_type, inputs):
-    """
-    Dispatcher: Inputs leke asli logic chalata hai.
-    Heavy processing ya LLM calls yahan honge.
-    """
-    print(f"   🤖 Processing logic for: {job_type}")
-    
-    # --- TASK 1: BRAND STRATEGY ---
-    if job_type == 'generate_campaign_strategy':
-        time.sleep(5) # Simulate AI thinking
-        return {
-            "title": f"Viral Campaign for {inputs.get('brand_name')}",
-            "description": f"Focusing on {inputs.get('target_audience')} with high-energy content.",
-            "budget": inputs.get('budget_range'),
-            "goalKpi": inputs.get('campaign_goal'),
-            "contentGuidelines": ["Use trending audio", "Keep duration under 30s", "Show product in first 3s"],
-            "suggestedInfluencers": inputs.get('influencers_context', [])[:3] 
-        }
-
-    # --- TASK 2: INFLUENCER RECOMMENDATIONS (NEW) ---
-    elif job_type == 'generate_recommendations':
-        print(f"   🔍 AI Matching campaigns for User: {inputs.get('user_id')}...")
-        time.sleep(4) # Simulate DB scanning + Matching
-        
-        # MOCK DATA: Isse real database se replace kar sakte ho baad mein
-        # Abhi ke liye, AI ye campaigns 'dhoond' kar laya hai:
-        return [
-            {
-                "id": "mock-ai-1", 
-                "title": "Nike Summer Fitness", 
-                "description": "High energy fitness campaign for Gen-Z runners.",
-                "budget": 5000, 
-                "brand": {"fullName": "Nike Official"}
-            },
-            {
-                "id": "mock-ai-2", 
-                "title": "Tech Unboxing 2025", 
-                "description": "Reviewing the latest AI gadgets.",
-                "budget": 1200, 
-                "brand": {"fullName": "Sony Tech"}
-            },
-            {
-                "id": "mock-ai-3",
-                "title": "Sustainable Fashion",
-                "description": "Eco-friendly clothing line launch.",
-                "budget": 3000,
-                "brand": {"fullName": "H&M Conscious"}
-            }
-        ]
-
-    # --- UNKNOWN ---
-    else:
-        raise ValueError(f"Unknown job type: {job_type}")
-
-
-# ========================================================
-# 👷 MAIN WORKER LOOP
-# ========================================================
-def worker_loop():
-    print("👷 AI Worker online. Polling 'system_jobs' for PENDING tasks...")
-    
-    while True:
-        try:
-            # 1. Fetch PENDING Jobs (Limit 1 to avoid overlap)
-            res = supabase.table('system_jobs')\
-                .select('*')\
-                .eq('status', 'PENDING')\
-                .order('created_at', desc=False)\
-                .limit(1)\
-                .execute()
-            
-            jobs = res.data
-            
-            # Agar koi kaam nahi, to 3 second so jao
-            if not jobs:
-                time.sleep(3) 
-                continue
-
-            current_job = jobs[0]
-            # Safety: Supabase v2 might return different structures, safe get
-            job_id = current_job['id']
-            print(f"🔄 Picked Job [{job_id}] - {current_job.get('job_type')}")
-
-            # 2. Mark as PROCESSING (Lock the job)
-            supabase.table('system_jobs').update({
-                'status': 'PROCESSING',
-                'started_at': datetime.datetime.utcnow().isoformat()
-            }).eq('id', job_id).execute()
-
-            # 3. DO THE WORK (Call Dispatcher)
-            try:
-                result = perform_ai_task(current_job.get('job_type'), current_job.get('input_params'))
-                
-                # 4. Success! Save Result
-                supabase.table('system_jobs').update({
-                    'status': 'COMPLETED',
-                    'result_data': result,
-                    'completed_at': datetime.datetime.utcnow().isoformat()
-                }).eq('id', job_id).execute()
-                
-                print(f"✅ Job [{job_id}] Completed Successfully.")
-
-            except Exception as task_error:
-                # Job Logic mein error (Code phat gaya)
-                print(f"❌ Job [{job_id}] Logic Failed: {task_error}")
-                supabase.table('system_jobs').update({
-                    'status': 'FAILED',
-                    'error_message': str(task_error),
-                    'completed_at': datetime.datetime.utcnow().isoformat()
-                }).eq('id', job_id).execute()
-
-        except Exception as conn_error:
-            # Database/Network Error
-            print(f"⚠️ Worker Loop Warning: {conn_error}")
-            time.sleep(5) # Thoda lamba so jao agar net gaya hai
-
-if __name__ == "__main__":
-    worker_loop()