Merge pull request #28 from CSCfi/devel

bump to 0.4.7

Author: blankdots

Dockerfile

@@ -1,4 +1,4 @@
-FROM python:3.7-alpine3.12 as BACKEND
+FROM python:3.8-alpine3.12 as BACKEND
 
 RUN apk add --update \
     && apk add --no-cache build-base curl-dev linux-headers bash git\
@@ -13,15 +13,15 @@ RUN pip install --upgrade pip\
     && pip install -r /root/swift_request/requirements.txt \
     && pip install /root/swift_request
 
-FROM python:3.7-alpine3.12
+FROM python:3.8-alpine3.12
 
 RUN apk add --no-cache --update bash
 
 LABEL maintainer "CSC Developers"
 LABEL org.label-schema.schema-version="1.0"
 LABEL org.label-schema.vcs-url="https://github.com/CSCFI/swift-sharing-request"
 
-COPY --from=BACKEND /usr/local/lib/python3.7 /usr/local/lib/python3.7/
+COPY --from=BACKEND /usr/local/lib/python3.8 /usr/local/lib/python3.8/
 
 COPY --from=BACKEND /usr/local/bin/gunicorn /usr/local/bin/
 

requirements.txt

@@ -2,3 +2,4 @@ asyncpg
 aiohttp
 uvloop
 gunicorn>=20.0.1
+certifi

setup.py

@@ -16,6 +16,7 @@
         "aiohttp",
         "uvloop",
         "asyncpg",
+        "certifi"
     ],
     extras_require={
         "test": ["tox", "pytest", "pytest-cov", "coverage", "flake8",
@@ -37,7 +38,7 @@
 
         "License :: OSI Approved :: MIT License",
 
-        "Programming Language :: Python :: 3.6",
         "Programming Language :: Python :: 3.7",
+        "Programming Language :: Python :: 3.8",
     ],
 )

swift_sharing_request/__init__.py

@@ -2,6 +2,6 @@
 
 
 __name__ = "swift_sharing_request"
-__version__ = "0.4.6"
+__version__ = "0.4.7"
 __author__ = "CSC Developers"
 __license__ = "MIT License"

swift_sharing_request/bindings/bind.py

@@ -4,11 +4,18 @@
 import os
 import json
 import typing
-
+import logging
 import aiohttp
 
 from .signature import sign_api_request
 
+import ssl
+import certifi
+
+
+ssl_context = ssl.create_default_context()
+ssl_context.load_verify_locations(certifi.where())
+
 
 class SwiftSharingRequest:
     """Swift Sharing Request backend client."""
@@ -29,6 +36,26 @@ async def __aexit__(self, *excinfo: BaseException) -> None:
         """."""
         await self.session.close()
 
+    async def _handler_response(
+            self,
+            resp: aiohttp.ClientResponse
+    ) -> typing.Any:
+        """Handle API response."""
+        if resp.status == 200:
+            try:
+                return json.loads(await resp.text())
+            except json.decoder.JSONDecodeError:
+                logging.error("Decoding JSON error \
+                    response was not possible.")
+                raise
+            except Exception as e:
+                logging.error(f"Unknown exception \
+                    occured with content: {e}.")
+                raise
+        else:
+            logging.error(f"response status: {resp.status}.")
+            raise Exception(f"response status: {resp.status}.")
+
     async def add_access_request(
             self,
             user: str,
@@ -47,8 +74,11 @@ async def add_access_request(
             "signature": signature["signature"],
         }
 
-        async with self.session.post(url, params=params) as resp:
-            return json.loads(await resp.text())
+        async with self.session.post(url,
+                                     params=params,
+                                     ssl=ssl_context) as resp:
+
+            return await self._handler_response(resp)
 
     async def list_made_requests(
             self,
@@ -65,8 +95,11 @@ async def list_made_requests(
             "signature": signature["signature"],
         }
 
-        async with self.session.get(url, params=params) as resp:
-            return json.loads(await resp.text())
+        async with self.session.get(url,
+                                    params=params,
+                                    ssl=ssl_context) as resp:
+
+            return await self._handler_response(resp)
 
     async def list_owned_requests(
             self,
@@ -83,8 +116,11 @@ async def list_owned_requests(
             "signature": signature["signature"],
         }
 
-        async with self.session.get(url, params=params) as resp:
-            return json.loads(await resp.text())
+        async with self.session.get(url,
+                                    params=params,
+                                    ssl=ssl_context) as resp:
+
+            return await self._handler_response(resp)
 
     async def list_container_requests(
             self,
@@ -106,7 +142,9 @@ async def list_container_requests(
         if project:
             params["project"] = project
 
-        async with self.session.get(url, params=params) as resp:
+        async with self.session.get(url,
+                                    params=params,
+                                    ssl=ssl_context) as resp:
             return json.loads(await resp.text())
 
     async def share_delete_access(
@@ -127,5 +165,7 @@ async def share_delete_access(
             "signature": signature["signature"],
         }
 
-        async with self.session.delete(url, params=params) as resp:
+        async with self.session.delete(url,
+                                       params=params,
+                                       ssl=ssl_context) as resp:
             return bool(resp.status == 200)

tests/test_bindings_bind.py

@@ -20,7 +20,7 @@ def __init__(self, *args, **kwargs):
             "text": asynctest.CoroutineMock(
                 return_value="[]"
             ),
-            "status": 204
+            "status": 200
         })
 
     async def __aenter__(self, *args, **kwargs):