feat: implement RSS news collector (Yahoo, Google News, MarketWatch)

1 files changed, 48 insertions, 0 deletions

diff --git a/services/news-collector/tests/test_rss.py b/services/news-collector/tests/test_rss.py
new file mode 100644
index 0000000..58c5f7c
--- /dev/null
+++ b/services/news-collector/tests/test_rss.py
@@ -0,0 +1,48 @@
+"""Tests for RSS news collector."""
+
+import pytest
+from unittest.mock import AsyncMock, patch
+from datetime import datetime, timezone
+
+from news_collector.collectors.rss import RSSCollector
+
+
+@pytest.fixture
+def collector():
+    return RSSCollector()
+
+
+def test_collector_name(collector):
+    assert collector.name == "rss"
+    assert collector.poll_interval == 600
+
+
+async def test_is_available(collector):
+    assert await collector.is_available() is True
+
+
+async def test_collect_parses_feed(collector):
+    mock_feed = {
+        "entries": [
+            {
+                "title": "NVDA surges on AI demand",
+                "link": "https://example.com/nvda",
+                "published_parsed": (2026, 4, 2, 12, 0, 0, 0, 0, 0),
+                "summary": "Nvidia stock jumped 5%...",
+            },
+            {
+                "title": "Markets rally on jobs data",
+                "link": "https://example.com/market",
+                "published_parsed": (2026, 4, 2, 11, 0, 0, 0, 0, 0),
+                "summary": "The S&P 500 rose...",
+            },
+        ],
+    }
+
+    with patch.object(collector, "_fetch_feeds", new_callable=AsyncMock, return_value=[mock_feed]):
+        items = await collector.collect()
+
+    assert len(items) == 2
+    assert items[0].source == "rss"
+    assert items[0].headline == "NVDA surges on AI demand"
+    assert isinstance(items[0].sentiment, float)