feat: sync active background generation status across devices and sessions via /api/user-active-job

backend/server.py

@@ -789,6 +789,8 @@ class F23DHTTPRequestHandler(SimpleHTTPRequestHandler):
             self.handle_space_status()
         elif self.path.startswith('/api/job-status'):
             self.handle_job_status()
+        elif self.path == '/api/user-active-job':
+            self.handle_user_active_job()
         elif self.path == '/api/me':
             username = self.get_logged_in_user()
             credits = 0
@@ -1708,7 +1710,7 @@ class F23DHTTPRequestHandler(SimpleHTTPRequestHandler):
                 "status": row[3],
                 "progress": row[4],
                 "message": row[5],
-                "result": json.loads(row[6]) if row[6] else None
+                "result": json.loads(row[6]) if row[6] and (row[6].startswith('{') or row[6].startswith('[')) else row[6]
             }
             
             self.send_response(200)
@@ -1720,6 +1722,47 @@ class F23DHTTPRequestHandler(SimpleHTTPRequestHandler):
             print(f"[Backend Error in handle_job_status] {e}")
             self.send_error_response(500, str(e))
 
+    def handle_user_active_job(self):
+        try:
+            username = self.get_logged_in_user()
+            if not username:
+                self.send_error_response(401, "No has iniciado sesión.")
+                return
+
+            conn = get_db_connection()
+            cursor = conn.cursor()
+            cursor.execute(
+                "SELECT id, username, type, status, progress, message, result FROM jobs WHERE username = ? AND status IN ('pending', 'processing') ORDER BY created_at DESC LIMIT 1",
+                (username,)
+            )
+            row = cursor.fetchone()
+            conn.close()
+
+            if not row:
+                self.send_response(200)
+                self.send_header('Content-Type', 'application/json')
+                self.end_headers()
+                self.wfile.write(json.dumps({"has_active": False}).encode('utf-8'))
+                return
+
+            job_data = {
+                "has_active": True,
+                "job_id": row[0],
+                "username": row[1],
+                "type": row[2],
+                "status": row[3],
+                "progress": row[4],
+                "message": row[5],
+                "result": json.loads(row[6]) if row[6] and (row[6].startswith('{') or row[6].startswith('[')) else row[6]
+            }
+
+            self.send_response(200)
+            self.send_header('Content-Type', 'application/json')
+            self.end_headers()
+            self.wfile.write(json.dumps(job_data).encode('utf-8'))
+        except Exception as e:
+            self.send_error_response(500, str(e))
+
     def handle_get_gallery(self):
         try:
             username = self.get_logged_in_user()

frontend/app.js

@@ -244,11 +244,67 @@ async function refreshLibraryThumbnails() {
         const data = await response.json();
         cachedGalleryItems = data.items || [];
         renderLibraryThumbnails(cachedGalleryItems);
+        checkActiveUserJob();
     } catch (e) {
         console.error('Error loading library thumbnails:', e);
     }
 }
 
+let isPollingActiveJobPC = false;
+async function checkActiveUserJob() {
+    if (isPollingActiveJobPC) return;
+    try {
+        const res = await fetch(`${apiBase}/api/user-active-job`);
+        if (!res.ok) return;
+        const data = await res.json();
+        if (data.has_active && data.job_id) {
+            isPollingActiveJobPC = true;
+            resumeActiveJobPollingPC(data.job_id, data.type);
+        }
+    } catch (e) {
+        console.warn('[PC] Error checking active job:', e);
+    }
+}
+
+function resumeActiveJobPollingPC(jobId, jobType) {
+    const bgTaskBanner = document.getElementById('bgTaskBanner');
+    const bgTaskText = document.getElementById('bgTaskText');
+    const typeLabel = jobType === '2d' ? '2D' : '3D';
+    
+    if (bgTaskBanner && bgTaskText) {
+        bgTaskText.textContent = `Generando ${typeLabel}... 0%`;
+        bgTaskBanner.style.display = 'flex';
+    }
+
+    const pollInterval = setInterval(async () => {
+        try {
+            const statusRes = await fetch(`${apiBase}/api/job-status?job_id=${jobId}`);
+            if (!statusRes.ok) return;
+            const job = await statusRes.json();
+            
+            if (job.status === 'processing' || job.status === 'pending') {
+                const progress = job.progress || 10;
+                if (bgTaskBanner && bgTaskText) {
+                    bgTaskText.textContent = `Generando ${typeLabel}... ${progress}%`;
+                    bgTaskBanner.style.display = 'flex';
+                }
+            } else if (job.status === 'completed') {
+                clearInterval(pollInterval);
+                isPollingActiveJobPC = false;
+                if (bgTaskBanner) bgTaskBanner.style.display = 'none';
+                try { refreshGallery(); } catch (e) {}
+                try { fetchUserInfo(); } catch (e) {}
+            } else if (job.status === 'failed') {
+                clearInterval(pollInterval);
+                isPollingActiveJobPC = false;
+                if (bgTaskBanner) bgTaskBanner.style.display = 'none';
+            }
+        } catch (e) {
+            console.warn('[PC] Active job poll warning:', e);
+        }
+    }, 2500);
+}
+
 function renderLibraryThumbnails(items) {
     if (!libraryThumbnailGrid) return;
 

frontend/viewer.html

@@ -1084,6 +1084,7 @@
                 galleryItems = data.items || [];
                 renderGallery();
                 renderMobGalleryImageGrid();
+                checkActiveUserJob();
             } catch (err) {
                 console.error(err);
                 if (galleryGrid) {
@@ -1092,6 +1093,61 @@
             }
         }
 
+        let isPollingActiveJob = false;
+        async function checkActiveUserJob() {
+            if (isPollingActiveJob) return;
+            try {
+                const res = await fetch('/api/user-active-job');
+                if (!res.ok) return;
+                const data = await res.json();
+                if (data.has_active && data.job_id) {
+                    isPollingActiveJob = true;
+                    resumeActiveJobPolling(data.job_id, data.type);
+                }
+            } catch (e) {
+                console.warn('[Viewer] Error checking active job:', e);
+            }
+        }
+
+        function resumeActiveJobPolling(jobId, jobType) {
+            const mobBgTaskBanner = document.getElementById('mobBgTaskBanner');
+            const mobBgTaskText = document.getElementById('mobBgTaskText');
+            const typeLabel = jobType === '2d' ? '2D' : '3D';
+            
+            if (mobBgTaskBanner && mobBgTaskText) {
+                mobBgTaskText.textContent = `Generando ${typeLabel}... 0%`;
+                mobBgTaskBanner.style.display = 'flex';
+            }
+
+            const pollInterval = setInterval(async () => {
+                try {
+                    const statusRes = await fetch(`/api/job-status?job_id=${jobId}`);
+                    if (!statusRes.ok) return;
+                    const job = await statusRes.json();
+                    
+                    if (job.status === 'processing' || job.status === 'pending') {
+                        const progress = job.progress || 10;
+                        if (mobBgTaskBanner && mobBgTaskText) {
+                            mobBgTaskText.textContent = `Generando ${typeLabel}... ${progress}%`;
+                            mobBgTaskBanner.style.display = 'flex';
+                        }
+                    } else if (job.status === 'completed') {
+                        clearInterval(pollInterval);
+                        isPollingActiveJob = false;
+                        if (mobBgTaskBanner) mobBgTaskBanner.style.display = 'none';
+                        try { fetchGallery(); } catch (e) {}
+                        try { fetchUserInfo(); } catch (e) {}
+                    } else if (job.status === 'failed') {
+                        clearInterval(pollInterval);
+                        isPollingActiveJob = false;
+                        if (mobBgTaskBanner) mobBgTaskBanner.style.display = 'none';
+                    }
+                } catch (e) {
+                    console.warn('[Viewer] Active job poll warning:', e);
+                }
+            }, 2500);
+        }
+
         function renderGallery() {
             const filtered = galleryItems.filter(item => {
                 if (currentGalleryFilter === 'all') return true;