1 files changed, 64 insertions, 0 deletions
diff --git a/services/news-collector/tests/test_reddit.py b/services/news-collector/tests/test_reddit.py
new file mode 100644
index 0000000..31b1dc1
--- /dev/null
+++ b/services/news-collector/tests/test_reddit.py
@@ -0,0 +1,64 @@
+"""Tests for Reddit collector."""
+
+from unittest.mock import AsyncMock, patch
+
+import pytest
+from news_collector.collectors.reddit import RedditCollector
+
+
+@pytest.fixture
+def collector():
+    return RedditCollector()
+
+
+def test_collector_name(collector):
+    assert collector.name == "reddit"
+    assert collector.poll_interval == 900
+
+
+async def test_is_available(collector):
+    assert await collector.is_available() is True
+
+
+async def test_collect_parses_posts(collector):
+    mock_posts = [
+        {
+            "data": {
+                "title": "NVDA to the moon! AI demand is insane",
+                "selftext": "Just loaded up on NVDA calls",
+                "url": "https://reddit.com/r/wallstreetbets/123",
+                "created_utc": 1711929600,
+                "score": 500,
+                "num_comments": 200,
+                "subreddit": "wallstreetbets",
+            }
+        },
+    ]
+    with patch.object(
+        collector, "_fetch_subreddit", new_callable=AsyncMock, return_value=mock_posts
+    ):
+        items = await collector.collect()
+    assert len(items) >= 1
+    assert items[0].source == "reddit"
+    assert items[0].category.value == "social"
+
+
+async def test_collect_filters_low_score(collector):
+    mock_posts = [
+        {
+            "data": {
+                "title": "Random question",
+                "selftext": "",
+                "url": "https://reddit.com/456",
+                "created_utc": 1711929600,
+                "score": 3,
+                "num_comments": 1,
+                "subreddit": "stocks",
+            }
+        },
+    ]
+    with patch.object(
+        collector, "_fetch_subreddit", new_callable=AsyncMock, return_value=mock_posts
+    ):
+        items = await collector.collect()
+    assert items == []