Update AI runtime to produce opinion posts instead of summaries

ai_runtime.py

@@ -86,6 +86,50 @@ def _scrape_url_with_images(url):
     return data
 
 
+def _opinion_template(title, source, raw):
+    return f"""Bạn là nhà bình luận tiếng Việt của VNEWS. Nhiệm vụ là viết một bài quan điểm cá nhân đăng lên Tường AI, không phải tóm tắt tin tức.
+
+YÊU CẦU BẮT BUỘC:
+- Viết theo quan điểm cá nhân rõ ràng, có lập trường/thesis ngay từ đầu.
+- Không viết bài kiểu bản tin/tóm tắt, không liệt kê 5 ý chính, không recap nguồn.
+- Nguồn bên dưới chỉ là bằng chứng/gợi ý để lập luận, không phải nội dung chính cần lặp lại.
+- Nếu nguồn không đủ mạnh để bảo vệ quan điểm, hãy nói rõ giới hạn đó thay vì bịa thêm chi tiết.
+- Không sao chép nguyên văn câu từ của nguồn.
+- Giọng văn tự nhiên như một bài opinion trên mạng xã hội: trực diện, có góc nhìn, có lý lẽ.
+- Kết quả cuối cùng chỉ gồm 1 tiêu đề ngắn và 2-4 đoạn văn. Không dùng gạch đầu dòng.
+
+Tiêu đề nguồn: {title}
+Nguồn tham khảo: {source}
+
+Nội dung nguồn dùng làm bằng chứng:
+{raw[:16000]}"""
+
+
+def _opinion_title(text, fallback):
+    text = clean(text)
+    if not text:
+        return fallback
+    first = text.split('\n', 1)[0]
+    if len(first) <= 95 and not any(first.endswith(x) for x in ['.', '!', '?']):
+        return first[:95]
+    return fallback
+
+
+def _postprocess_opinion(text):
+    text = clean(text)
+    if not text:
+        return text
+    text = re.sub(r'^(Tôi nghĩ|Theo tôi|Mình cho rằng|Mình tin|Rất cần nói lại|Cần nhìn lại|Không nên|Phải|Nên)\b.*$', '', text, flags=re.I).strip()
+    text = re.sub(r'\n{3,}', '\n\n', text)
+    text = re.sub(r'\n{2,}', '\n\n', text)
+    # Keep paragraphs but avoid bullet-style output.
+    paras = [p.strip() for p in text.split('\n\n') if p.strip()]
+    if len(paras) > 4:
+        paras = paras[:4]
+    text = '\n\n'.join(paras)
+    return text
+
+
 def rich_context(topic, limit=5):
     try: ctx,sources=base.web_context(topic, limit=limit)
     except Exception: ctx,sources='',[]
@@ -122,35 +166,36 @@ _PATCH={('/api/topic_post','POST'),('/api/url_wall','POST'),('/api/rewrite_share
 app.router.routes=[r for r in app.router.routes if not any(getattr(r,'path',None)==p and m in getattr(r,'methods',set()) for p,m in _PATCH)]
 
 
+async def _make_opinion_post(title, raw, url, source_url, source_name, image_url=None, opinion_text=''):
+    source = f"{source_name or _domain(source_url or url) or 'nguồn VNEWS'}"
+    prompt = _opinion_template(title, source, raw)
+    if opinion_text:
+        prompt += "\n\nQuan điểm ban đầu của người dùng:\n" + clean(opinion_text)
+    text = await base.qwen_generate(prompt, image_url=(image_url or None), max_tokens=1100)
+    if not text:
+        text = old._fallback_summary_from_prompt(prompt, max_units=5) if hasattr(old,'_fallback_summary_from_prompt') else raw[:900]
+    text = _postprocess_opinion(text)
+    if len(text) < 120:
+        text = clean(raw[:900])
+    src=[{'title':title, 'url':url, 'excerpt':clean(raw)[:500], 'via':source_name or _domain(url)}]
+    if 'Nguồn tham khảo:' not in text:
+        text += '\n\n' + source_line(src)
+    images=_collect_all_images({'image':image_url, 'images':[]})
+    post=base.make_post(_opinion_title(text, title or 'Bài quan điểm'), text, images[0] if images else (image_url or ''), url, 'opinion', sources=src)
+    post['images']=images
+    return post
+
+
 @app.post('/api/url_wall')
 async def url_wall_only(request:Request):
     body=await request.json();url=base._clean_text(body.get('url',''))
+    opinion_text=base._clean_text(body.get('opinion') or body.get('opinion_text') or '')
     if not url.startswith('http'):return JSONResponse({'error':'missing url'},status_code=400)
     try:data=_scrape_url_with_images(url)
     except Exception as e:return JSONResponse({'error':'Không scrape được URL: '+str(e)[:180]},status_code=422)
     raw=(data.get('summary','')+'\n'+data.get('text','')).strip()
-    if len(raw)<120:return JSONResponse({'error':'URL không có đủ nội dung để tóm tắt'},status_code=422)
-    prompt=f"""Tóm tắt bài viết nguồn dưới đây để đăng lên Tường AI VNEWS.
-
-Yêu cầu bắt buộc:
-- Chỉ tóm tắt nội dung chính, không viết lại toàn bộ bài.
-- Ngắn gọn, cụ thể, dễ hiểu.
-- Không lặp lại ý và không thêm chi tiết ngoài nguồn.
-- Tối đa 5 ý chính hoặc 2 đoạn ngắn.
-- Tránh dùng dấu đầu dòng nếu không thật cần thiết.
-
-Tiêu đề gốc: {data.get('title','')}
-Nguồn: {data.get('via','') or _domain(url)}
-Nội dung gốc:
-{raw[:16000]}"""
-    text=await base.qwen_generate(prompt,image_url=(data.get('image') or None),max_tokens=900)
-    if not text:text=old._fallback_summary_from_prompt(prompt,max_units=5) if hasattr(old,'_fallback_summary_from_prompt') else raw[:900]
-    text=postprocess(text)
-    src=[{'title':data.get('title'), 'url':url, 'excerpt':raw[:500], 'via':data.get('via') or _domain(url)}]
-    if 'Nguồn tham khảo:' not in text:text+='\n\n'+source_line(src)
-    images=_collect_all_images(data)
-    post=base.make_post(data.get('title') or 'Bài viết',text,images[0] if images else (data.get('image') or ''),url,'url',sources=src)
-    post['images']=images
+    if len(raw)<120:return JSONResponse({'error':'URL không có đủ nội dung để viết quan điểm'},status_code=422)
+    post=await _make_opinion_post(data.get('title') or 'Bài viết', raw, url, url, data.get('via') or _domain(url), data.get('image') or None, opinion_text)
     posts=base._load_ai_wall();posts.insert(0,post);base._save_ai_wall(posts)
     return JSONResponse({'post':post})
 
@@ -166,8 +211,62 @@ async def ai_url_compat(request:Request):
 
 
 @app.post('/api/topic_post')
-async def topic_disabled(request:Request):
-    return JSONResponse({'error':'Đã tắt tạo bài theo chủ đề. Vui lòng dán URL bài viết để AI tóm tắt.'},status_code=410)
+async def topic_post(request:Request):
+    body=await request.json();topic=base._clean_text(body.get('topic',''))
+    opinion_text=base._clean_text(body.get('opinion') or body.get('opinion_text') or '')
+    if not topic:return JSONResponse({'error':'missing topic'},status_code=400)
+    try:ctx,sources=rich_context(topic, limit=5)
+    except Exception:ctx,sources=('',[])
+    if not sources:return JSONResponse({'error':'Không lấy được bài viết nguồn cho chủ đề này.'},status_code=422)
+    raw_parts=[];src=[];seen=set()
+    for s in sources[:5]:
+        url=s.get('url') or ''
+        if not url.startswith('http') or url in seen:continue
+        seen.add(url)
+        try:
+            data=base.scrape_any_url(url)
+            raw=(data.get('summary','')+'\n'+data.get('text','')).strip()
+            if len(raw)<120:continue
+            title=data.get('title') or s.get('title') or url
+            via=data.get('via') or s.get('via') or _domain(url)
+            raw_parts.append(f"### {title} ({via})\n{raw[:3000]}")
+            src.append({'title':title, 'url':url, 'excerpt':raw[:500], 'via':via})
+        except Exception:
+            continue
+    if not raw_parts:return JSONResponse({'error':'Không lấy được nội dung đủ mạnh cho chủ đề này.'},status_code=422)
+    post=await _make_opinion_post(topic, '\n\n'.join(raw_parts), '', '', 'chủ đề '+topic, opinion_text=opinion_text)
+    post['sources']=src
+    posts=base._load_ai_wall();posts.insert(0,post);base._save_ai_wall(posts)
+    return JSONResponse({'post':post})
+
+
+async def _make_personal_opinion_post(topic, opinion_text, image_url=None):
+    if not opinion_text:
+        return None
+    opinion_text=clean(opinion_text)
+    if len(opinion_text)<20:return None
+    prompt=_opinion_template(topic, 'ý kiến người dùng và bối cảnh chung', opinion_text)
+    text=await base.qwen_generate(prompt, image_url=(image_url or None), max_tokens=1100)
+    if not text:text=opinion_text[:1100]
+    text=_postprocess_opinion(text)
+    if len(text)<120:text=opinion_text
+    src=[{'title':topic, 'url':'', 'excerpt':opinion_text[:500], 'via':'người dùng'}]
+    if 'Nguồn tham khảo:' not in text:text+='\n\n'+source_line(src)
+    post=base.make_post(_opinion_title(text, topic), text, image_url or '', '', 'personal_opinion', sources=src)
+    post['images']=[image_url] if image_url else []
+    return post
+
+
+@app.post('/api/personal_opinion')
+async def personal_opinion_post(request:Request):
+    body=await request.json();topic=base._clean_text(body.get('topic','')) or base._clean_text(body.get('title',''))
+    opinion_text=base._clean_text(body.get('opinion') or body.get('opinion_text') or '')
+    if not topic:return JSONResponse({'error':'missing topic'},status_code=400)
+    if not opinion_text:return JSONResponse({'error':'missing opinion'},status_code=400)
+    post=await _make_personal_opinion_post(topic, opinion_text, body.get('image') or '')
+    if not post:return JSONResponse({'error':'Quan điểm chưa đủ dài'},status_code=422)
+    posts=base._load_ai_wall();posts.insert(0,post);base._save_ai_wall(posts)
+    return JSONResponse({'post':post})
 
 
 def split_segments(post,max_segments=8):
@@ -341,10 +440,10 @@ function esc(s){return String(s||'').replace(/[&<>"']/g,m=>({'&':'&amp;','<':'&l
 function hideTopicControls(){
   document.querySelectorAll('#ai-topic-input').forEach(e=>{let p=e.closest('.ai-compose,.ai-compose-topic,.topic-row,div'); if(p&&p.querySelector('#ai-url-input')) e.style.display='none'; else if(p) p.style.display='none';});
   document.querySelectorAll('button').forEach(b=>{let t=(b.textContent||'').toLowerCase();let oc=b.getAttribute('onclick')||'';if(oc.includes('createTopicPost')||t.includes('chủ đề'))b.style.display='none';});
-  let url=document.getElementById('ai-url-input'); if(url&&!document.getElementById('ai-url-only-note')){let n=document.createElement('div');n.id='ai-url-only-note';n.className='ai-url-only-note';n.textContent='Dán URL bài viết để AI tóm tắt và lấy ảnh từ bài.';url.insertAdjacentElement('afterend',n);}
+  let url=document.getElementById('ai-url-input'); if(url&&!document.getElementById('ai-url-only-note')){let n=document.createElement('div');n.id='ai-url-only-note';n.className='ai-url-only-note';n.textContent='Dán URL bài viết để AI viết quan điểm cá nhân và lấy ảnh từ bài.';url.insertAdjacentElement('afterend',n);}
 }
-window.createTopicPost=function(){alert('Đã tắt ô nhập chủ đề. Vui lòng dán URL bài viết.');};
-window.createUrlPost=function(){let inp=document.getElementById('ai-url-input');let url=(inp&&inp.value||'').trim();if(!url)return alert('Dán URL trước');if(!/^https?:\/\//i.test(url))return alert('URL cần bắt đầu bằng http:// hoặc https://');fetch('/api/url_wall',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({url})}).then(r=>r.json().then(j=>({ok:r.ok,j}))).then(({ok,j})=>{if(ok&&j.post){if(typeof prependWallPost==='function')prependWallPost(j.post);if(window.patchedWall)window.patchedWall=[j.post].concat(window.patchedWall||[]);if(inp)inp.value='';alert('Đã tóm tắt URL, lấy ảnh trong bài và đăng lên Tường AI');location.reload();}else alert(j.error||'Lỗi URL')}).catch(e=>alert(e.message||'Lỗi URL'));};
+window.createTopicPost=function(){alert('Đã tắt ô nhập chủ đề. Vui lòng dán URL bài viết để AI viết quan điểm cá nhân.');};
+window.createUrlPost=function(){let inp=document.getElementById('ai-url-input');let url=(inp&&inp.value||'').trim();if(!url)return alert('Dán URL trước');if(!/^https?:\/\//i.test(url))return alert('URL cần bắt đầu bằng http:// hoặc https://');fetch('/api/url_wall',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({url})}).then(r=>r.json().then(j=>({ok:r.ok,j}))).then(({ok,j})=>{if(ok&&j.post){if(typeof prependWallPost==='function')prependWallPost(j.post);if(window.patchedWall)window.patchedWall=[j.post].concat(window.patchedWall||[]);if(inp)inp.value='';alert('Đã viết bài quan điểm cá nhân, lấy ảnh trong bài và đăng lên Tường AI');location.reload();}else alert(j.error||'Lỗi URL')}).catch(e=>alert(e.message||'Lỗi URL'));};
 function galleryHtml(p){let imgs=(p.images||[]).filter(Boolean);if(!imgs.length&&p.img)imgs=[p.img];if(!imgs.length)return '';return '<div class="ai-wall-gallery">'+imgs.slice(0,12).map(u=>`<img src="${esc(u)}" loading="lazy">`).join('')+'</div>';}
 function patchReaders(){
   let oldRead=window.aiReadWallPatched||window.aiReadWall;