"""Test ows-abacus-state connector."""

import httpx
from owsclient.test import OwsClientMock

from src.connectors import ows_abacus_event
from src.connectors.ows_abacus_event import (
    ADJUSTMENT_FILE_UPLOAD_EVENT,
    ADJUSTMENT_FILE_UPLOAD_TARGET_TYPE,
)


def test_create_abacus_event(
    ows_client_mock: OwsClientMock,
) -> None:
    """Test successful create abacus event."""
    event_name = ADJUSTMENT_FILE_UPLOAD_EVENT
    target_id = '4877'
    target_type = ADJUSTMENT_FILE_UPLOAD_TARGET_TYPE

    mock_response = {
        'abacus_event_id': 375712,
        'event_date': '2026-02-23T12:18:19.148359',
        'event_name': 'adjustment_file_upload',
        'previous_abacus_event_id': None,
        'rolled_back_at': None,
        'statement_period_id': 325,
        'target_id': 4877,
        'target_type': 'statement_period_adjustment_file',
        'created_by': 'default_user_id',
    }

    ows_client_mock.post(
        'ows-abacus-event',
        '/abacus-event',
    ).mock(
        return_value=httpx.Response(
            201,
            json=mock_response,
        )
    )
    response = ows_abacus_event.create_abacus_event(event_name, target_id, target_type)

    assert response.status_code == 201
    assert response.json() == mock_response