"""Test PayeeLedgerProcessor."""

from decimal import Decimal
from unittest.mock import MagicMock
from unittest.mock import patch

from accounting_period_close.ledger_entry_queue import LedgerEntryQueue
from accounting_period_close.payee_ledger_processor import PayeeLedgerProcessor


def test_payee_ledger_processor_process_row(
    mock_event,
    mock_ledger_payees,
    mock_results
):
    """Test processing a row."""
    mock_queue = LedgerEntryQueue()
    with patch.object(mock_queue, 'flush_entries', mock_flush):
        processor = PayeeLedgerProcessor(1, mock_event, mock_queue)
        for ledger_payee in mock_ledger_payees:
            processor.process_row(ledger_payee)
        assert processor._payee_ledger_amount == Decimal('-25.00')


def mock_flush(self):
    """Mock flush method."""
    self._entries = []


def test_payee_ledger_processor_process(
        mock_event, mock_ledger_payees, mock_results, request_engine):
    """Test process()."""
    request_engine['ows-ledger'].add_spec('POST', '/ledger/bulk', status=201)
    mock_queue = MagicMock()
    processor = PayeeLedgerProcessor(1, mock_event, mock_queue)
    processor.process(mock_ledger_payees)