Added: prefix async getattr, atom response

Author: Albo90

pyodata/client.py

@@ -6,18 +6,16 @@
 import pyodata.v2.model
 import pyodata.v2.service
 from pyodata.exceptions import PyODataException, HttpError
-from pyodata.v2.response import Response
 
 
 async def _async_fetch_metadata(connection, url, logger):
     logger.info('Fetching metadata')
 
     async with connection.get(url + '$metadata') as async_response:
-        resp = Response()
-        resp.url = async_response.url
-        resp.headers = async_response.headers
-        resp.status_code = async_response.status
-        resp.content = await async_response.read()
+        resp = pyodata.v2.service.ODataHttpResponse(url=async_response.url,
+                                                    headers=async_response.headers,
+                                                    status_code=async_response.status,
+                                                    content=await async_response.read())
 
         return _common_fetch_metadata(resp, logger)
 

pyodata/v2/response.py

@@ -18,7 +18,6 @@
 
 from pyodata.exceptions import HttpError, PyODataException, ExpressionError, ProgramError
 from . import model
-from .response import Response
 
 LOGGER_NAME = 'pyodata.service'
 
@@ -103,7 +102,8 @@ def decode(message):
 class ODataHttpResponse:
     """Representation of http response"""
 
-    def __init__(self, headers, status_code, content=None):
+    def __init__(self, headers, status_code, content=None, url=None):
+        self.url = url
         self.headers = headers
         self.status_code = status_code
         self.content = content
@@ -327,11 +327,10 @@ async def async_execute(self):
                                             headers=headers,
                                             params=params,
                                             data=body) as async_response:
-            response = Response()
-            response.url = async_response.url
-            response.headers = async_response.headers
-            response.status_code = async_response.status
-            response.content = await async_response.read()
+            response = ODataHttpResponse(url=async_response.url,
+                                         headers=async_response.headers,
+                                         status_code=async_response.status,
+                                         content=await async_response.read())
         return self._call_handler(response)
 
     def execute(self):
@@ -889,7 +888,7 @@ def __getattr__(self, attr):
                 raise AttributeError('EntityType {0} does not have Property {1}: {2}'
                                      .format(self._entity_type.name, attr, str(ex)))
 
-    async def getattr(self, attr):
+    async def async_getattr(self, attr):
         """Get cached value of attribute or do async call to service to recover attribute value"""
         try:
             return self._cache[attr]