Fix slow homepage with fast RSS endpoints

ai_runtime_final6.py

@@ -653,3 +653,105 @@ Yêu cầu:
     post['images']=[img]
     posts=f5.base._load_ai_wall();posts.insert(0,post);f5.base._save_ai_wall(posts)
     return JSONResponse({'post':post,'mode':'fast_rss','sources_count':len(sources)})
+
+
+# ===== FINAL6D: FAST HOME LOAD =====
+_FAST_HOME_CACHE={"t":0,"d":[]}
+_FAST_DT_CACHE={"t":0,"d":[]}
+_FAST_VNEGO_CACHE={"t":0,"d":[]}
+_FAST_HL_CACHE={"t":0,"d":[]}
+
+def _rss_articles_fast(feed_url, group, source='vne', limit=6):
+    out=[]
+    try:
+        r=requests.get(feed_url,headers=UA,timeout=4);r.encoding='utf-8'
+        soup=BeautifulSoup(r.text,'xml')
+        for it in soup.find_all('item')[:limit*2]:
+            title=clean(it.find('title').get_text(' ',strip=True) if it.find('title') else '')
+            link=clean(it.find('link').get_text(strip=True) if it.find('link') else '')
+            desc_raw=it.find('description').get_text(' ',strip=True) if it.find('description') else ''
+            ds=BeautifulSoup(desc_raw,'lxml')
+            im=ds.find('img'); img=im.get('src','') if im else ''
+            desc=clean(ds.get_text(' ',strip=True))[:160]
+            if title and link:
+                out.append({'title':title,'link':link,'img':img,'summary':desc,'source':source,'group':group})
+            if len(out)>=limit:break
+    except Exception:pass
+    return out
+
+def _fast_homepage():
+    now=time.time()
+    if _FAST_HOME_CACHE['d'] and now-_FAST_HOME_CACHE['t']<600:return _FAST_HOME_CACHE['d']
+    feeds=[('Thời Sự','https://vnexpress.net/rss/thoi-su.rss'),('Thế Giới','https://vnexpress.net/rss/the-gioi.rss'),('Kinh Doanh','https://vnexpress.net/rss/kinh-doanh.rss'),('Công Nghệ','https://vnexpress.net/rss/so-hoa.rss'),('Thể Thao','https://vnexpress.net/rss/the-thao.rss'),('Giải Trí','https://vnexpress.net/rss/giai-tri.rss'),('Sức Khỏe','https://vnexpress.net/rss/suc-khoe.rss'),('Giáo Dục','https://vnexpress.net/rss/giao-duc.rss'),('Pháp Luật','https://vnexpress.net/rss/phap-luat.rss'),('Du Lịch','https://vnexpress.net/rss/du-lich.rss')]
+    arts=[]
+    try:
+        from concurrent.futures import ThreadPoolExecutor, as_completed
+        with ThreadPoolExecutor(max_workers=6) as ex:
+            futs=[ex.submit(_rss_articles_fast,u,g,'vne',6) for g,u in feeds]
+            for f in as_completed(futs,timeout=7):
+                try:arts.extend(f.result() or [])
+                except Exception:pass
+    except Exception:
+        for g,u in feeds[:5]:arts.extend(_rss_articles_fast(u,g,'vne',4))
+    if arts:_FAST_HOME_CACHE.update({'t':now,'d':arts})
+    return _FAST_HOME_CACHE['d'] or arts
+
+def _fast_dantri_hot():
+    now=time.time()
+    if _FAST_DT_CACHE['d'] and now-_FAST_DT_CACHE['t']<900:return _FAST_DT_CACHE['d']
+    data=_rss_articles_fast('https://dantri.com.vn/rss/home.rss','Tin Nổi Bật','dantri',12)
+    if data:_FAST_DT_CACHE.update({'t':now,'d':data})
+    return data
+
+def _fast_vnego():
+    now=time.time()
+    if _FAST_VNEGO_CACHE['d'] and now-_FAST_VNEGO_CACHE['t']<900:return _FAST_VNEGO_CACHE['d']
+    out=[]
+    try:
+        r=requests.get('https://vnexpress.net/vne-go',headers=UA,timeout=4);r.encoding='utf-8'
+        soup=BeautifulSoup(r.text,'lxml');seen=set()
+        for a in soup.find_all('a',href=True):
+            href=a.get('href','');title=clean(a.get('title','') or a.get_text(' ',strip=True))
+            if not title or len(title)<8 or not href.startswith('http') or href in seen:continue
+            if '/vne-go' not in href and '/video/' not in href:continue
+            seen.add(href);img='';im=a.find('img') or (a.parent.find('img') if a.parent else None)
+            if im:img=im.get('data-src') or im.get('src','')
+            out.append({'title':title,'link':href,'img':img,'source':'vne-video'})
+            if len(out)>=10:break
+    except Exception:pass
+    _FAST_VNEGO_CACHE.update({'t':now,'d':out})
+    return out
+
+def _fast_highlights():
+    now=time.time()
+    if _FAST_HL_CACHE['d'] and now-_FAST_HL_CACHE['t']<900:return _FAST_HL_CACHE['d']
+    _FAST_HL_CACHE.update({'t':now,'d':[]})
+    return []
+
+for _p in ['/api/homepage','/api/dantri_hot','/api/vne_video','/api/highlights']:
+    app.router.routes=[r for r in app.router.routes if not (getattr(r,'path',None)==_p and 'GET' in getattr(r,'methods',set()))]
+@app.get('/api/homepage')
+def api_homepage_fast():return JSONResponse(_fast_homepage())
+@app.get('/api/dantri_hot')
+def api_dantri_hot_fast():return JSONResponse(_fast_dantri_hot())
+@app.get('/api/vne_video')
+def api_vne_video_fast():return JSONResponse(_fast_vnego())
+@app.get('/api/highlights')
+def api_highlights_fast():return JSONResponse(_fast_highlights())
+
+FINAL6_FAST_HOME_INJECT = """
+<script>
+(function(){
+const oldFetch=window.fetch;
+window.__allowShortRefresh=false;
+window.fetch=function(url,opts){try{let u=String(url||'');if(u.includes('/api/shorts?refresh=1')&&!window.__allowShortRefresh)url='/api/shorts';}catch(e){}return oldFetch.call(this,url,opts)};
+setTimeout(()=>{window.__allowShortRefresh=true;},7000);
+})();
+</script>
+"""
+app.router.routes=[r for r in app.router.routes if not (getattr(r,'path',None)=='/' and 'GET' in getattr(r,'methods',set()))]
+@app.get('/')
+async def index_final6_fast_home():
+    html=f5.f4.f3.f2.f1._load_index_html()
+    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+FINAL6_INJECT+FINAL6_FAST_HOME_INJECT
+    return HTMLResponse(html.replace('</body>',body+'\n</body>') if '</body>' in html else html+body)