"""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 == []