Fix RSS sync: switch to feedparser, add feed_title to output

xml.etree.ElementTree was failing silently on CDATA links and encoding
declarations. feedparser handles all RSS/Atom variants correctly.

Also: show feed title in dashboard output, better empty-feed messaging.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

requirements.txt

@@ -2,3 +2,4 @@ fastapi==0.115.6
 uvicorn[standard]==0.32.1
 pydantic==2.10.3
 httpx==0.28.1
+feedparser==6.0.11

signalmesh_api.py

@@ -45,8 +45,8 @@ _app_pkg.logger = _logger_pkg.logger
 
 import asyncio
 import re
-import xml.etree.ElementTree as ET
 
+import feedparser
 import httpx
 from fastapi import FastAPI, Header, HTTPException, Request
 from fastapi.middleware.cors import CORSMiddleware
@@ -446,9 +446,13 @@ async function doRssSync() {
     appendFeed('rss-feed', `<span class="tag err">ERR</span>${escHtml(String(d.error||d.detail))}`);
     return;
   }
-  appendFeed('rss-feed', `<span class="tag rss">RSS</span><b>${d.synced}</b> items synced → ${d.signals_in_mesh} signals in mesh`);
-  (d.items||[]).slice(0,8).forEach(it =>
-    appendFeed('rss-feed', `<span class="dim">↳ node <b>${it.node}</b> (${it.agent})</span> ${escHtml(it.title?.slice(0,60)||'')}`)
+  const feedLabel = d.feed_title ? `<b style="color:var(--accent2)">${escHtml(d.feed_title)}</b> · ` : '';
+  appendFeed('rss-feed', `<span class="tag rss">RSS</span>${feedLabel}<b>${d.synced}</b> items → ${d.signals_in_mesh} signals in mesh`);
+  if (d.synced === 0) {
+    appendFeed('rss-feed', `<span class="dim">Feed returned no items. Try a different URL.</span>`);
+  }
+  (d.items||[]).slice(0,10).forEach(it =>
+    appendFeed('rss-feed', `<span class="dim">↳ node <b>${it.node}</b> (${it.agent})</span> ${escHtml(it.title?.slice(0,70)||'')}`)
   );
   refreshMesh();
 }
@@ -465,7 +469,7 @@ async function doContextDiscovery() {
   }
   appendFeed('ctx-feed', `<span class="tag live">FOUND</span><b>${d.urls_found}</b> URLs · <b>${d.signals_broadcast}</b> broadcast · <b>${(d.rss_feeds_synced||[]).length}</b> RSS feeds`);
   (d.rss_feeds_synced||[]).forEach(r =>
-    appendFeed('ctx-feed', `<span class="tag rss">RSS</span>${escHtml(r.url?.slice(0,50))} → ${r.synced ?? r.error} ${r.error?'<span class="tag err">ERR</span>':'items'}`)
+    appendFeed('ctx-feed', `<span class="tag rss">RSS</span>${escHtml(r.url?.slice(0,50))} → ${r.error ? '<span class="tag err">ERR</span> '+escHtml(r.error) : '<b>'+r.synced+'</b> items'}`)
   );
   refreshMesh();
 }
@@ -695,32 +699,32 @@ async def tool_rss_sync(
 ):
     """
     **Tool: rss_matrix_sync**
-    Fetch an RSS feed and sync each item into the spatial grid via SHA-256 URI routing.
-    Each feed item is broadcast onto its deterministically assigned grid node.
+    Fetch an RSS/Atom feed and sync each item into the spatial grid via SHA-256 URI routing.
     """
     _check_key(x_signalmesh_key)
+
+    # feedparser handles RSS 0.9x/1.0/2.0, Atom, encoding, CDATA — all of it
     try:
         async with httpx.AsyncClient(timeout=30.0) as client:
-            resp = await client.get(req.url, follow_redirects=True)
+            resp = await client.get(
+                req.url,
+                follow_redirects=True,
+                headers={"User-Agent": "ToolTuner-SignalMesh/1.0 (RSS reader; +https://huggingface.co/spaces/acecalisto3/ToolTuner)"},
+            )
             resp.raise_for_status()
+            raw = resp.text
     except Exception as e:
-        raise HTTPException(status_code=502, detail=f"Failed to fetch RSS feed: {e}")
+        raise HTTPException(status_code=502, detail=f"Fetch failed: {e}")
 
-    try:
-        root_el = ET.fromstring(resp.content)
-    except ET.ParseError as e:
-        raise HTTPException(status_code=422, detail=f"Invalid XML in feed: {e}")
+    feed = feedparser.parse(raw)
+    if feed.bozo and not feed.entries:
+        raise HTTPException(status_code=422, detail=f"Feed parse error: {feed.bozo_exception}")
 
-    items = root_el.findall(".//item") or root_el.findall(".//{http://www.w3.org/2005/Atom}entry")
     synced = []
-    for item in items:
-        title_el = item.find("title") or item.find("{http://www.w3.org/2005/Atom}title")
-        link_el = item.find("link") or item.find("{http://www.w3.org/2005/Atom}link")
-        desc_el = item.find("description") or item.find("{http://www.w3.org/2005/Atom}summary")
-
-        title = title_el.text if title_el is not None else "Untitled"
-        link = (link_el.text or link_el.get("href", "")) if link_el is not None else ""
-        desc = (desc_el.text or "")[:400] if desc_el is not None else ""
+    for entry in feed.entries:
+        title = entry.get("title", "Untitled")
+        link = entry.get("link", "") or entry.get("id", "")
+        summary = entry.get("summary", entry.get("description", ""))[:400]
 
         if not link:
             continue
@@ -732,7 +736,7 @@ async def tool_rss_sync(
         signal_registry.broadcast(
             name=f"rss_{agent_kw}",
             source_type="rss_cp",
-            data={"title": title, "link": link, "summary": desc},
+            data={"title": title, "link": link, "summary": summary},
             metadata={"node": node_idx, "agent": agent_kw, "feed_url": req.url},
         )
         synced.append({"title": title, "node": node_idx, "agent": agent_kw, "link": link})
@@ -740,6 +744,7 @@ async def tool_rss_sync(
     return {
         "synced": len(synced),
         "feed_url": req.url,
+        "feed_title": feed.feed.get("title", ""),
         "items": synced[:20],
         "signals_in_mesh": _signals_in_mesh(),
     }