"""Test event_handling."""

from unittest.mock import MagicMock
from unittest.mock import patch

from kafka_utils.exceptions import IneligibleEventException
import pytest

from src.logic import event_handling


@patch('src.logic.event_handling.ProductEventMessage')
def test_skip_explicit_skip_product(mock_product_event_message):
    """Test skipping explicitly skipped products."""
    mock_event = MagicMock(product_id=3577604)
    mock_product_event_message.return_value = mock_event
    mock_message = MagicMock(topic='foo', value='bar')
    with pytest.raises(IneligibleEventException) as e:
        event_handling.processing_logic(mock_message, None)
    assert e.value.args[0] == 'skip operation: product in explicit skip list'