Upload ai_runtime_patch_fast.py

ai_runtime_patch_fast.py

@@ -138,6 +138,54 @@ button[onclick*="rewriteCurrentArticle"]{display:none!important}
 function esc(s){return String(s||'').replace(/[&<>"']/g,m=>({'&':'&amp;','<':'&lt;','>':'&gt;','"':'&quot;',"'":'&#39;'}[m]));}
 fetch('/api/storage_status').then(r=>r.json()).then(j=>{if(!j.persistent){let h=document.getElementById('view-home');if(h){let w=document.createElement('div');w.className='storage-warn';w.innerHTML='⚠️ <b>Persistent Storage chưa bật.</b> Bật: Space Settings → Persistent Storage → Small.';h.prepend(w);}}});
 
+// === SSE Auto-update listener ===
+let _sseSource = null;
+function connectSSE(){
+    try{
+        _sseSource = new EventSource('/api/events');
+        _sseSource.onmessage = function(e){
+            try{
+                const data = JSON.parse(e.data);
+                if(data.type==='new_post' || data.type==='new_short'){
+                    console.log('[SSE] Update received:', data.type);
+                    fetch('/api/ai_wall').then(r=>r.json()).then(j=>{
+                        _wallPosts = j.posts || [];
+                        if(typeof renderShortAISlide==='function') renderShortAISlide();
+                        const track=document.getElementById('ai-wall-track');
+                        if(track && _wallPosts.length){
+                            track.innerHTML = _wallPosts.slice(0,20).map((p,i)=>makeWallItem(p,i)).join('');
+                        }
+                    });
+                }
+            }catch(err){}
+        };
+        _sseSource.onerror = function(){
+            setTimeout(connectSSE, 5000);
+        };
+    }catch(err){}
+}
+
+// Fallback polling (30s)
+let _lastWallLen = 0;
+setInterval(function(){
+    if(typeof _wallPosts==='undefined') return;
+    fetch('/api/ai_wall').then(r=>r.json()).then(j=>{
+        const wall = j.posts || [];
+        if(wall.length !== _lastWallLen){
+            _lastWallLen = wall.length;
+            _wallPosts = wall;
+            const track=document.getElementById('ai-wall-track');
+            if(track && wall.length){
+                track.innerHTML = wall.slice(0,20).map((p,i)=>makeWallItem(p,i)).join('');
+            }
+            if(typeof renderShortAISlide==='function') renderShortAISlide();
+        }
+    }).catch(()=>{});
+}, 30000);
+
+// Start SSE
+connectSSE();
+
 // === Short AI Slide on homepage (same as Dantri shorts) ===
 async function renderShortAISlide(){let home=document.getElementById('view-home');if(!home)return;document.getElementById('short-ai-final-slide')?.remove();let wall=(await fetch('/api/ai_wall').then(r=>r.json()).catch(()=>({posts:[]}))).posts||[];let vids=wall.filter(p=>p.video);if(!vids.length)return;let wrap=document.createElement('div');wrap.id='short-ai-final-slide';wrap.className='slider-wrap';wrap.innerHTML='<div class="slider-header"><span class="slider-label">🎬 Short AI</span></div><div class="slider-track">'+vids.slice(0,30).map((p,i)=>`<div class="slider-item shorts-item" onclick="openAIShortFeed(${i})"><div class="slider-thumb shorts-thumb"><video src="${p.video}" muted preload="metadata" style="width:100%;height:100%;object-fit:cover"></video><div class="card-play">▶</div></div><div class="slider-title">${esc(p.title)}</div></div>`).join('')+'</div>';let comp=home.querySelector('.ai-compose');if(comp&&comp.nextSibling)comp.parentNode.insertBefore(wrap,comp.nextSibling);else home.prepend(wrap);}
 setTimeout(renderShortAISlide,2500);
@@ -185,4 +233,4 @@ async def _index():
     body=getattr(rt.old,'PATCH_INJECT','')+f5.f4.f3.f2.f1.FINAL_INJECT+f5.f4.f3.FINAL3_INJECT+f5.f4.FINAL4_INJECT+f5.FINAL5_INJECT
     body+=getattr(f6,'FINAL6_INJECT','');body+=getattr(f6,'FINAL6_FAST_HOME_INJECT','');body+=getattr(f6,'FINAL6E_INJECT','')
     body+=PATCH_INJECT
-    return HTMLResponse(html.replace('</body>',body+'\n</body>') if '</body>' in html else html+body)
+    return HTMLResponse(html.replace('</body>',body+'\n</body>') if '</body>' in html else html+body)