Coinbase rate limits impact calls for arbitrarily large number of pages

cbpro/authenticated_client.py

@@ -173,6 +173,45 @@ def get_account_holds(self, account_id, **kwargs):
         endpoint = '/accounts/{}/holds'.format(account_id)
         return self._send_paginated_message(endpoint, params=kwargs)
 
+    def get_profiles(self, **kwargs):
+        """List Profiles
+
+        List all account profiles (also known as portfolios).
+
+        Returns:
+        [
+            {
+                "id": "86602c68-306a-4500-ac73-4ce56a91d83c",
+                "user_id": "5844eceecf7e803e259d0365",
+                "name": "default",
+                "active": true,
+                "is_default": true,
+                "created_at": "2019-11-18T15:08:40.236309Z"
+            }
+        ]
+        """
+        return self._send_message('get', '/profiles')
+
+    def get_profile(self, profile_id, **kwargs):
+        """Get a Profile
+
+        Get a single profile by profile id.
+
+        Args:
+        profile_id(str): The profile id to get
+
+        Returns:
+        {
+            "id": "86602c68-306a-4500-ac73-4ce56a91d83c",
+            "user_id": "5844eceecf7e803e259d0365",
+            "name": "default",
+            "active": true,
+            "is_default": true,
+            "created_at": "2019-11-18T15:08:40.236309Z"
+        }
+        """
+        return self._send_message('get', '/profile/' + profile_id)
+
     def place_order(self, product_id, side, order_type, **kwargs):
         """ Place an order.
 

cbpro/public_client.py

@@ -5,7 +5,7 @@
 # For public requests to the Coinbase exchange
 
 import requests
-
+import time
 
 class PublicClient(object):
     """cbpro public client API.
@@ -269,7 +269,7 @@ def _send_message(self, method, endpoint, params=None, data=None):
                                  auth=self.auth, timeout=30)
         return r.json()
 
-    def _send_paginated_message(self, endpoint, params=None):
+    def _send_paginated_message(self, endpoint, params=None, **kwargs):
         """ Send API message that results in a paginated response.
 
         The paginated responses are abstracted away by making API requests on
@@ -287,6 +287,7 @@ def _send_paginated_message(self, endpoint, params=None):
         Args:
             endpoint (str): Endpoint (to be added to base URL)
             params (Optional[dict]): HTTP request parameters
+            sleep_interval (Optional[float]): Number of seconds to sleep between paginated calls
 
         Yields:
             dict: API response objects
@@ -306,6 +307,11 @@ def _send_paginated_message(self, endpoint, params=None):
             # cbpro API doesn't support multiple pages in that case.
             if not r.headers.get('cb-after') or \
                     params.get('before') is not None:
+                #If a sleep_interval was sent, use it
+                if "sleep_interval" in kwargs.keys():
+                    time.sleep(sleep_interval)
                 break
             else:
                 params['after'] = r.headers['cb-after']
+                if "sleep_interval" in kwargs.keys():
+                    time.sleep(sleep_interval)