summaryrefslogtreecommitdiff
path: root/services/news-collector/tests/test_truth_social.py
diff options
context:
space:
mode:
Diffstat (limited to 'services/news-collector/tests/test_truth_social.py')
-rw-r--r--services/news-collector/tests/test_truth_social.py30
1 files changed, 30 insertions, 0 deletions
diff --git a/services/news-collector/tests/test_truth_social.py b/services/news-collector/tests/test_truth_social.py
new file mode 100644
index 0000000..bcf8a8c
--- /dev/null
+++ b/services/news-collector/tests/test_truth_social.py
@@ -0,0 +1,30 @@
+"""Tests for Truth Social collector."""
+import pytest
+from unittest.mock import AsyncMock, patch
+from news_collector.collectors.truth_social import TruthSocialCollector
+
+@pytest.fixture
+def collector():
+ return TruthSocialCollector()
+
+def test_collector_name(collector):
+ assert collector.name == "truth_social"
+ 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 = [
+ {"content": "<p>We are imposing 25% tariffs on all steel imports!</p>", "created_at": "2026-04-02T12:00:00.000Z", "url": "https://truthsocial.com/@realDonaldTrump/12345", "id": "12345"},
+ ]
+ with patch.object(collector, "_fetch_posts", new_callable=AsyncMock, return_value=mock_posts):
+ items = await collector.collect()
+ assert len(items) == 1
+ assert items[0].source == "truth_social"
+ assert items[0].category.value == "policy"
+
+async def test_collect_handles_empty(collector):
+ with patch.object(collector, "_fetch_posts", new_callable=AsyncMock, return_value=[]):
+ items = await collector.collect()
+ assert items == []