summaryrefslogtreecommitdiff
path: root/services/news-collector/tests/test_fed.py
blob: d1a736b8386967ecd07bb2b065afe740d6c3a906 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
"""Tests for Federal Reserve collector."""

import pytest
from unittest.mock import AsyncMock, patch
from news_collector.collectors.fed import FedCollector


@pytest.fixture
def collector():
    return FedCollector()


def test_collector_name(collector):
    assert collector.name == "fed"
    assert collector.poll_interval == 3600


async def test_is_available(collector):
    assert await collector.is_available() is True


async def test_collect_parses_rss(collector):
    mock_entries = [
        {
            "title": "Federal Reserve issues FOMC statement",
            "link": "https://www.federalreserve.gov/newsevents/pressreleases/monetary20260402a.htm",
            "published_parsed": (2026, 4, 2, 14, 0, 0, 0, 0, 0),
            "summary": "The Federal Open Market Committee decided to maintain the target range...",
        },
    ]
    with patch.object(
        collector, "_fetch_fed_rss", new_callable=AsyncMock, return_value=mock_entries
    ):
        items = await collector.collect()
    assert len(items) == 1
    assert items[0].source == "fed"
    assert items[0].category.value == "fed"