Added throttle as method

Author: sergioteula

amazon/paapi.py

@@ -44,7 +44,7 @@ def __init__(self, key: str, secret: str, tag: str, country: str, throttling=0.8
                 self.throttling = False
             else:
                 self.throttling = float(throttling)
-                if not self.throttling > 0:
+                if self.throttling <= 0:
                     raise ValueError
         except ValueError:
             raise AmazonException('ValueError', 'Throttling should be False or greater than 0')
@@ -59,6 +59,13 @@ def __init__(self, key: str, secret: str, tag: str, country: str, throttling=0.8
         self.api = DefaultApi(access_key=self.key, secret_key=self.secret, host=self.host,
                               region=self.region)
 
+    def _throttle(self):
+        if self.throttling:
+            wait_time = 1 / self.throttling - (time.time() - self.last_query_time)
+            if wait_time > 0:
+                time.sleep(wait_time)
+        self.last_query_time = time.time()
+
     def get_products(self, product_ids: [str, list], condition='Any', merchant='All',
                      async_req=False):
         """Find product information for multiple products on Amazon.
@@ -105,14 +112,8 @@ def get_products(self, product_ids: [str, list], condition='Any', merchant='All'
 
             for x in range(3):
                 try:
-                    # Wait before doing the request
-                    if self.throttling:
-                        wait_time = 1 / self.throttling - (time.time() - self.last_query_time)
-                        if wait_time > 0:
-                            time.sleep(wait_time)
-                    self.last_query_time = time.time()
-
                     # Send the request and create results
+                    self._throttle()
                     if async_req:
                         thread = self.api.get_items(request, async_req=True)
                         response = thread.get()
@@ -265,14 +266,8 @@ def search_products(self, item_count=10, item_page=1, items_per_page=10, keyword
 
             for x in range(3):
                 try:
-                    # Wait before doing the request
-                    if self.throttling:
-                        wait_time = 1 / self.throttling - (time.time() - self.last_query_time)
-                        if wait_time > 0:
-                            time.sleep(wait_time)
-                    self.last_query_time = time.time()
-
                     # Send the request and create results
+                    self._throttle()
                     if async_req:
                         thread = self.api.search_items(request, async_req=True)
                         response = thread.get()
@@ -357,14 +352,8 @@ def get_variations(self, asin, item_count=10, item_page=1, items_per_page=10, co
 
             for x in range(3):
                 try:
-                    # Wait before doing the request
-                    if self.throttling:
-                        wait_time = 1 / self.throttling - (time.time() - self.last_query_time)
-                        if wait_time > 0:
-                            time.sleep(wait_time)
-                    self.last_query_time = time.time()
-
                     # Send the request and create results
+                    self._throttle()
                     if async_req:
                         thread = self.api.get_variations(request, async_req=True)
                         response = thread.get()