| 
 | 1 | +import httpx  | 
 | 2 | +import pytest  | 
 | 3 | +import respx  | 
 | 4 | + | 
 | 5 | +from mpt_api_client.resources.accounts.sellers import AsyncSellersService, Seller, SellersService  | 
 | 6 | + | 
 | 7 | + | 
 | 8 | +@pytest.fixture  | 
 | 9 | +def sellers_service(http_client):  | 
 | 10 | +    return SellersService(http_client=http_client)  | 
 | 11 | + | 
 | 12 | + | 
 | 13 | +@pytest.fixture  | 
 | 14 | +def async_sellers_service(async_http_client):  | 
 | 15 | +    return AsyncSellersService(http_client=async_http_client)  | 
 | 16 | + | 
 | 17 | + | 
 | 18 | +@pytest.mark.parametrize(  | 
 | 19 | +    "method",  | 
 | 20 | +    ["get", "create", "update", "delete", "activate", "deactivate", "disable"],  | 
 | 21 | +)  | 
 | 22 | +def test_mixins_present(sellers_service, method):  | 
 | 23 | +    assert hasattr(sellers_service, method)  | 
 | 24 | + | 
 | 25 | + | 
 | 26 | +@pytest.mark.parametrize(  | 
 | 27 | +    "method",  | 
 | 28 | +    ["get", "create", "update", "delete", "activate", "deactivate", "disable"],  | 
 | 29 | +)  | 
 | 30 | +def test_async_mixins_present(async_sellers_service, method):  | 
 | 31 | +    assert hasattr(async_sellers_service, method)  | 
 | 32 | + | 
 | 33 | + | 
 | 34 | +@pytest.mark.parametrize(  | 
 | 35 | +    ("action", "input_status"), [("disable", {"id": "OBJ-0000-0001", "status": "update"})]  | 
 | 36 | +)  | 
 | 37 | +def test_sellers_resource_action(sellers_service, action, input_status):  | 
 | 38 | +    request_expected_content = b'{"id":"OBJ-0000-0001","status":"update"}'  | 
 | 39 | +    response_expected_data = {"id": "OBJ-0000-0001", "status": "new_status"}  | 
 | 40 | +    with respx.mock:  | 
 | 41 | +        mock_route = respx.post(  | 
 | 42 | +            f"https://api.example.com/public/v1/accounts/sellers/OBJ-0000-0001/{action}"  | 
 | 43 | +        ).mock(  | 
 | 44 | +            return_value=httpx.Response(  | 
 | 45 | +                status_code=httpx.codes.OK,  | 
 | 46 | +                json=response_expected_data,  | 
 | 47 | +            )  | 
 | 48 | +        )  | 
 | 49 | +        sellers_obj = getattr(sellers_service, action)("OBJ-0000-0001", input_status)  | 
 | 50 | + | 
 | 51 | +        request = mock_route.calls[0].request  | 
 | 52 | + | 
 | 53 | +        assert request.content == request_expected_content  | 
 | 54 | +        assert sellers_obj.to_dict() == response_expected_data  | 
 | 55 | +        assert isinstance(sellers_obj, Seller)  | 
 | 56 | + | 
 | 57 | + | 
 | 58 | +@pytest.mark.parametrize(("action", "input_status"), [("disable", None)])  | 
 | 59 | +def test_sellers_resource_action_no_data(sellers_service, action, input_status):  | 
 | 60 | +    request_expected_content = b""  | 
 | 61 | +    response_expected_data = {"id": "OBJ-0000-0001", "status": "new_status"}  | 
 | 62 | +    with respx.mock:  | 
 | 63 | +        mock_route = respx.post(  | 
 | 64 | +            f"https://api.example.com/public/v1/accounts/sellers/OBJ-0000-0001/{action}"  | 
 | 65 | +        ).mock(  | 
 | 66 | +            return_value=httpx.Response(  | 
 | 67 | +                status_code=httpx.codes.OK,  | 
 | 68 | +                json=response_expected_data,  | 
 | 69 | +            )  | 
 | 70 | +        )  | 
 | 71 | +        sellers_obj = getattr(sellers_service, action)("OBJ-0000-0001", input_status)  | 
 | 72 | + | 
 | 73 | +        request = mock_route.calls[0].request  | 
 | 74 | + | 
 | 75 | +        assert request.content == request_expected_content  | 
 | 76 | +        assert sellers_obj.to_dict() == response_expected_data  | 
 | 77 | +        assert isinstance(sellers_obj, Seller)  | 
 | 78 | + | 
 | 79 | + | 
 | 80 | +@pytest.mark.parametrize(  | 
 | 81 | +    ("action", "input_status"), [("disable", {"id": "OBJ-0000-0001", "status": "update"})]  | 
 | 82 | +)  | 
 | 83 | +async def test_async_sellers_resource_action(async_sellers_service, action, input_status):  | 
 | 84 | +    request_expected_content = b'{"id":"OBJ-0000-0001","status":"update"}'  | 
 | 85 | +    response_expected_data = {"id": "OBJ-0000-0001", "status": "new_status"}  | 
 | 86 | +    with respx.mock:  | 
 | 87 | +        mock_route = respx.post(  | 
 | 88 | +            f"https://api.example.com/public/v1/accounts/sellers/OBJ-0000-0001/{action}"  | 
 | 89 | +        ).mock(  | 
 | 90 | +            return_value=httpx.Response(  | 
 | 91 | +                status_code=httpx.codes.OK,  | 
 | 92 | +                json=response_expected_data,  | 
 | 93 | +            )  | 
 | 94 | +        )  | 
 | 95 | +        sellers_obj = await getattr(async_sellers_service, action)("OBJ-0000-0001", input_status)  | 
 | 96 | + | 
 | 97 | +        request = mock_route.calls[0].request  | 
 | 98 | + | 
 | 99 | +        assert request.content == request_expected_content  | 
 | 100 | +        assert sellers_obj.to_dict() == response_expected_data  | 
 | 101 | +        assert isinstance(sellers_obj, Seller)  | 
 | 102 | + | 
 | 103 | + | 
 | 104 | +@pytest.mark.parametrize(("action", "input_status"), [("disable", None)])  | 
 | 105 | +async def test_async_sellers_resource_action_no_data(async_sellers_service, action, input_status):  | 
 | 106 | +    request_expected_content = b""  | 
 | 107 | +    response_expected_data = {"id": "OBJ-0000-0001", "status": "new_status"}  | 
 | 108 | +    with respx.mock:  | 
 | 109 | +        mock_route = respx.post(  | 
 | 110 | +            f"https://api.example.com/public/v1/accounts/sellers/OBJ-0000-0001/{action}"  | 
 | 111 | +        ).mock(  | 
 | 112 | +            return_value=httpx.Response(  | 
 | 113 | +                status_code=httpx.codes.OK,  | 
 | 114 | +                json=response_expected_data,  | 
 | 115 | +            )  | 
 | 116 | +        )  | 
 | 117 | +        sellers_obj = await getattr(async_sellers_service, action)("OBJ-0000-0001", input_status)  | 
 | 118 | + | 
 | 119 | +        request = mock_route.calls[0].request  | 
 | 120 | + | 
 | 121 | +        assert request.content == request_expected_content  | 
 | 122 | +        assert sellers_obj.to_dict() == response_expected_data  | 
 | 123 | +        assert isinstance(sellers_obj, Seller)  | 
0 commit comments