Merge pull request #44 from jerome-viveret-onfido/async-iterable-payload

Switch BufferedReaderPayload to AsyncIterablePayload

onfido/aio_resource.py

@@ -1,4 +1,4 @@
-from aiohttp import BufferedReaderPayload, ClientSession, MultipartWriter, StringPayload
+from aiohttp import AsyncIterablePayload, ClientSession, MultipartWriter, StringPayload
 from .exceptions import OnfidoRequestError
 from aiohttp.client_reqrep import ClientResponse
 from .onfido_download import OnfidoAioDownload
@@ -69,7 +69,7 @@ async def _upload_request(self, path, file: BinaryIO, **request_body):
                 )
 
             file_part = mpwriter.append_payload(
-                BufferedReaderPayload(
+                AsyncIterablePayload(
                     file,
                     content_type=mimetype_from_name(file.name),
                     headers={

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "onfido-python"
-version = "2.8.0"
+version = "2.8.1"
 description = "The official wrapper for the Onfido API"
 homepage = "https://github.com/onfido/onfido-python"
 readme = "README.md"
@@ -29,6 +29,7 @@ flake8 = "^3.8.3"
 [tool.poetry.group.dev.dependencies]
 aioresponses = "^0.7.4"
 pytest-asyncio = "^0.21.1"
+aiofiles = "^23.2.1"
 
 [build-system]
 requires = ["poetry-core>=1.0.0"]

tests/test_documents.py

@@ -1,3 +1,4 @@
+import aiofiles
 import onfido
 from onfido.exceptions import OnfidoRequestError
 from onfido.regions import Region
@@ -46,9 +47,8 @@ async def test_async_upload_document(m):
 
         m.post("https://api.eu.onfido.com/v3.6/documents/", payload=request_body)
 
-        sample_file = open("sample_driving_licence.png", "rb")
-
-        await async_api.document.upload(sample_file, request_body)
+        async with aiofiles.open("sample_driving_licence.png", "rb") as sample_file:
+            await async_api.document.upload(sample_file, request_body)
 
         m.assert_called_once()