Refactor: passed parsing of http response responbility to the BaseClient ABC class

Author: dehidehidehi

open_sea_v1/endpoints/assets.py

@@ -74,9 +74,7 @@ def url(self):
 
     @property
     def parsed_http_response(self) -> list[AssetResponse]:
-        assets_json = self._http_response.json()['assets']
-        assets = [AssetResponse(asset_json) for asset_json in assets_json]
-        return assets
+        return self.parse_http_response(AssetResponse, 'assets')
 
     def _get_request(self, **kwargs):
         params = dict(

open_sea_v1/endpoints/client.py

@@ -1,7 +1,7 @@
 import logging
 from abc import ABC
 from dataclasses import dataclass
-from typing import Optional, Generator, Union
+from typing import Optional, Generator, Union, Type
 
 from ratelimit import limits, sleep_and_retry
 from requests import Response, request
@@ -49,16 +49,38 @@ def _set_max_rate_limit(self) -> None:
         if self.api_key:
             raise NotImplementedError("I don't know what the rate limit is for calls with an API key is yet.")
 
-
+@dataclass
 class BaseClient(ABC):
+    """
+    Parameters
+    ----------
+    client_params:
+        ClientParams instance.
+
+    rate_limiting: bool
+        If True, will throttle the amount of requests per second to the OpenSea API.
+        If you pass an API key into the client_params instance, the rate limiting will change accordingly.
+        If False, will not throttle.
+
+    retry: bool
+        OpenSea will occasionally return an empty response object, although the same query would yield
+        a full response object afterwards.
+        If True, will pause the request for one second before trying again once.
+        If it fails again, the empty response is returned.
+        If set to False, the client always returns the first response object, even if it is empty.
+
+    """
+
     client_params: ClientParams
-    processed_pages: int = 0
-    response = None
-    parsed_http_response = None
     url = None
     rate_limiting: bool = True
-    _http_response = None
-    _rate_limiting_timer: float = 0.0
+    retry: bool = True
+
+    def __post_init__(self):
+        self.processed_pages: int = 0
+        self.response = None
+        self.parsed_http_response = None
+        self._http_response = None
 
     @property
     def http_headers(self) -> dict:
@@ -74,6 +96,15 @@ def _get_request(self, **kwargs) -> Response:
         updated_kwargs = kwargs | self.http_headers
         return request('GET', self.url, **updated_kwargs)
 
+    def parse_http_response(self, response_type: Type[BaseResponse], key: str)\
+            -> list[Union[Type[BaseResponse], BaseResponse]]:
+        if self._http_response:
+            the_json = self._http_response.json()
+            the_json = the_json[key] if isinstance(the_json, dict) else the_json  # the collections endpoint needs this
+            responses = [response_type(element) for element in the_json]
+            return responses
+        return list()
+
     def get_pages(self) -> Generator[list[list[BaseResponse]], None, None]:
         self.processed_pages = 0
         self.client_params.offset = 0 if self.client_params.offset is None else self.client_params.offset

open_sea_v1/endpoints/collections.py

@@ -48,10 +48,7 @@ def url(self):
 
     @property
     def parsed_http_response(self) -> list[CollectionResponse]:
-        resp_json = self._http_response.json()
-        collections_json = resp_json if isinstance(resp_json, list) else resp_json['collections']
-        collections = [CollectionResponse(collection_json) for collection_json in collections_json]
-        return collections
+        return self.parse_http_response(CollectionResponse, 'collections')
 
     def _get_request(self, **kwargs):
         params = dict(

open_sea_v1/endpoints/events.py

@@ -104,9 +104,7 @@ def _get_request(self, **kwargs) -> Response:
 
     @property
     def parsed_http_response(self) -> list[EventResponse]:
-        events_json = self._http_response.json()['asset_events']
-        events = [EventResponse(event) for event in events_json]
-        return events
+        return self.parse_http_response(EventResponse, 'asset_events')
 
     def _validate_request_params(self) -> None:
         self._validate_param_auction_type()