Update app3.py

app3.py

@@ -265,6 +265,7 @@ class TranslationOrchestrator:
         
         self.handle_worker_failure(worker_id, request_id, "Timeout waiting for completion")
 
+
     def handle_job_completion(self, worker_id: str, request_id: str, worker_response: Dict):
         worker = self.workers[worker_id]
         
@@ -282,13 +283,14 @@ class TranslationOrchestrator:
         completion_data = {
             'request_id': request_id,
             'status': 'completed',
-            'translated_text': worker_response.get('translated_text'),
+            'translated_text': worker_response.get('translated_text', ''),
             'processing_time': processing_time,
             'character_count': worker_response.get('character_count', len(job_data.get('text', ''))),
             'translation_length': worker_response.get('translation_length', 0),
             'from_cache': worker_response.get('from_cache', False),
             'worker_name': worker.config.name,
-            'completed_at': datetime.now().isoformat()
+            'completed_at': datetime.now().isoformat(),
+            'success': True  # اضافه کردن این خط
         }
         
         self.completed_jobs[request_id] = completion_data
@@ -298,7 +300,12 @@ class TranslationOrchestrator:
         
         notification_url = job_data.get('notification_url')
         if notification_url:
+            # اضافه کردن لاگ برای دیباگ
+            print(f"📤 Sending notification to WordPress: {notification_url}")
             self.notify_wordpress(notification_url, completion_data)
+        else:
+            print(f"⚠️ No notification URL for {request_id}")
+
 
     def handle_worker_failure(self, worker_id: str, request_id: str, error_message: str):
         worker = self.workers[worker_id]
@@ -339,6 +346,8 @@ class TranslationOrchestrator:
 
     def notify_wordpress(self, notification_url: str, data: Dict):
         try:
+            print(f"🔔 Notifying WordPress for request {data['request_id']}")
+            
             response = requests.post(
                 notification_url,
                 json=data,
@@ -347,12 +356,19 @@ class TranslationOrchestrator:
             )
             
             if response.status_code == 200:
-                print(f"📤 WordPress notified for {data['request_id']}")
+                print(f"✅ WordPress notified successfully for {data['request_id']}")
+                try:
+                    response_data = response.json()
+                    print(f"📝 WordPress response: {response_data}")
+                except:
+                    print(f"📝 WordPress response: {response.text}")
             else:
-                print(f"⚠ WordPress notification failed: HTTP {response.status_code}")
+                print(f"❌ WordPress notification failed: HTTP {response.status_code}")
+                print(f"📄 Response: {response.text}")
                 
         except Exception as e:
-            print(f"⚠ WordPress notification error: {str(e)}")
+            print(f"💥 WordPress notification error: {str(e)}")
+
 
 # Initialize FastAPI app
 app = FastAPI(
@@ -476,6 +492,53 @@ async def check_status(request_id: str):
         "message": "Translation request not found"
     }
 
+# اضافه کردن endpoint جدید برای بررسی وضعیت
+@app.post("/api/get-translation-result")
+async def get_translation_result(request: dict):
+    request_id = request.get('request_id')
+    
+    if not request_id:
+        raise HTTPException(status_code=400, detail="Request ID is required")
+    
+    # بررسی در jobs تکمیل شده
+    if request_id in orchestrator.completed_jobs:
+        result = orchestrator.completed_jobs[request_id]
+        return {
+            "success": True,
+            "status": "completed",
+            **result
+        }
+    
+    # بررسی در jobs فعال
+    if request_id in orchestrator.active_jobs:
+        job_info = orchestrator.active_jobs[request_id]
+        elapsed_time = time.time() - job_info['start_time']
+        
+        return {
+            "success": True,
+            "status": "processing",
+            "request_id": request_id,
+            "elapsed_time": elapsed_time,
+            "message": "Translation in progress"
+        }
+    
+    # بررسی در صف
+    for job in orchestrator.job_queue:
+        if job['request_id'] == request_id:
+            return {
+                "success": True,
+                "status": "queued",
+                "request_id": request_id,
+                "queue_position": list(orchestrator.job_queue).index(job) + 1,
+                "message": "Translation queued"
+            }
+    
+    return {
+        "success": False,
+        "status": "not_found",
+        "message": "Translation request not found"
+    }
+
 @app.get("/api/workers")
 async def list_workers():
     workers_info = []