Merge pull request #158 from omarryhan/feature/add-proxy

Feature/add proxy

Author: omarryhan

aiogoogle/__version__.py

@@ -2,7 +2,7 @@
 __about__ = "Async Google API client"
 __description__ = __about__
 __url__ = "https://github.com/omarryhan/aiogoogle"
-__version_info__ = ("5", "14", "1")
+__version_info__ = ("5", "15", "0")
 __version__ = ".".join(__version_info__)
 __author__ = "Omar Ryhan"
 __author_email__ = "omarryhan@gmail.com"

aiogoogle/auth/managers.py

@@ -1261,7 +1261,7 @@ async def detect_default_creds_source(self):
                         url=GCE_METADATA_IP_ROOT,
                         headers=GCE_METADATA_HEADERS,
                         timeout=GCE_METADATA_DEFAULT_TIMEOUT,
-                        _verify_ssl=False
+                        _verify_ssl=False,
                     ), full_res=True)
                 except Exception:
                     raise RuntimeError(
@@ -1316,7 +1316,7 @@ async def _get_oauth2_authorization_grant(self):
                 data=parse.urlencode({
                     "assertion": google_auth_lib_creds._make_authorization_grant_assertion(),
                     "grant_type": JWT_GRANT_TYPE
-                }).encode("utf-8")
+                }).encode("utf-8"),
             ))
 
         if not json_res.get('access_token'):

aiogoogle/models.py

@@ -175,6 +175,7 @@ class Request:
         _verify_ssl (boolean): Defaults to True.
 
         upload_file_content_type (str): Optional content-type header string. In case you don't want to use the default application/octet-stream (Or whatever is auto-detected by your transport handler)
+        
         """
 
     def __init__(

aiogoogle/sessions/aiohttp_session.py

@@ -11,6 +11,9 @@
 
 from ..models import Response
 from .abc import AbstractSession
+import os
+
+HTTP_PROXY = os.getenv("AIOGOOGLE_HTTP_PROXY", "")
 
 
 async def _get_file_size(full_file_path):
@@ -126,6 +129,7 @@ async def fire_request(request):
                             data=mpwriter,
                             timeout=request.timeout,
                             ssl=request._verify_ssl,
+                            proxy=HTTP_PROXY,
                         )
                 # Else load file to memory and send
                 else:
@@ -140,6 +144,7 @@ async def fire_request(request):
                         json=request.json,
                         timeout=request.timeout,
                         ssl=request._verify_ssl,
+                        proxy=HTTP_PROXY
                     )
             # Else, if no file upload
             else:
@@ -151,6 +156,7 @@ async def fire_request(request):
                     json=request.json,
                     timeout=request.timeout,
                     ssl=request._verify_ssl,
+                    proxy=HTTP_PROXY,
                 )
 
         # ----------------- send sequence ------------------#