| 385 | |
| 386 | |
| 387 | class MockedResponse: |
| 388 | def __init__(self, **kwargs) -> None: |
| 389 | self.kwargs = kwargs |
| 390 | self.exception = kwargs.get("exception") |
| 391 | self.keep = kwargs.get("keep", False) |
| 392 | |
| 393 | @property |
| 394 | def status(self): |
| 395 | return self.kwargs.get("status", 200) |
| 396 | |
| 397 | @property |
| 398 | def url(self): |
| 399 | return self.kwargs.get("url", "http://127.0.0.1") |
| 400 | |
| 401 | @property |
| 402 | def headers(self): |
| 403 | return self.kwargs.get("headers", {}) |
| 404 | |
| 405 | async def read(self, **kwargs): |
| 406 | if (content := self.kwargs.get("content")) is not None: |
| 407 | return content |
| 408 | return await self.kwargs.get("read", AsyncMock())() |
| 409 | |
| 410 | async def json(self, **kwargs): |
| 411 | if (content := self.kwargs.get("content")) is not None: |
| 412 | return content |
| 413 | return await self.kwargs.get("json", AsyncMock())() |
| 414 | |
| 415 | async def text(self, **kwargs): |
| 416 | if (content := self.kwargs.get("content")) is not None: |
| 417 | return content |
| 418 | return await self.kwargs.get("text", AsyncMock())() |
| 419 | |
| 420 | def raise_for_status(self) -> None: |
| 421 | if self.status >= 300: |
| 422 | raise ClientError(self.status) |
| 423 | |
| 424 | |
| 425 | class ResponseMocker: |
no outgoing calls
searching dependent graphs…