add webhook

Author: vs

outscraper/api_client.py

@@ -206,7 +206,8 @@ def google_maps_search_v1(self, query: list, limit: int = 500, extract_contacts:
         raise Exception(f'Response status code: {response.status_code}')
 
     def google_maps_search(self, query: Union[list, str], limit: int = 20, drop_duplicates: bool = False,
-        language: str = 'en', region: str = None, skip: int = 0, enrichment: list = None, fields: list = None, async_request: bool = False, ui: bool = None
+        language: str = 'en', region: str = None, skip: int = 0, enrichment: list = None, fields: list = None, async_request: bool = False,
+        ui: bool = None, webhook: bool = None
     ) -> Union[list, dict]:
         '''
             Get Google Maps Data V2 (speed optimized endpoint for real time data)
@@ -246,6 +247,7 @@ def google_maps_search(self, query: Union[list, str], limit: int = 20, drop_dupl
             'enrichment': as_list(enrichment) if enrichment else '',
             'fields': ','.join(fields) if fields else '',
             'ui': ui,
+            'webhook': webhook,
         }, headers=self._api_headers)
 
         return self._handle_response(response, wait_async, async_request)
@@ -343,7 +345,8 @@ def google_maps_reviews_v2(self, query: list, reviews_limit: int = 100, limit: i
 
     def google_maps_reviews(self, query: Union[list, str], reviews_limit: int = 10, limit: int = 1, sort: str = 'most_relevant',
         skip: int = 0, start: int = None, cutoff: int = None, cutoff_rating: int = None, ignore_empty: bool = False,
-        language: str = 'en', region: str = None, reviews_query: str = None, fields: list = None, async_request: bool = False, ui: bool = None
+        language: str = 'en', region: str = None, reviews_query: str = None, fields: list = None, async_request: bool = False,
+        ui: bool = None, webhook: bool = None
     ) -> Union[list, dict]:
         '''
             Get Google Maps Reviews V3 (speed optimized endpoint for real time data)
@@ -394,6 +397,7 @@ def google_maps_reviews(self, query: Union[list, str], reviews_limit: int = 10,
             'async': wait_async,
             'fields': ','.join(fields) if fields else '',
             'ui': ui,
+            'webhook': webhook,
         }, headers=self._api_headers)
 
         return self._handle_response(response, wait_async, async_request)
@@ -515,7 +519,8 @@ def phones_enricher(self, query: list, fields: list = None) -> list:
 
         raise Exception(f'Response status code: {response.status_code}')
 
-    def amazon_products(self, query: Union[list, str], limit: int = 24, fields: list = None, async_request: bool = False, ui: bool = None
+    def amazon_products(self, query: Union[list, str], limit: int = 24, fields: list = None, async_request: bool = False,
+        ui: bool = None, webhook: bool = None
     ) -> Union[list, dict]:
         '''
             Returns information about products on Amazon.
@@ -541,11 +546,13 @@ def amazon_products(self, query: Union[list, str], limit: int = 24, fields: list
             'async': wait_async,
             'fields': ','.join(fields) if fields else '',
             'ui': ui,
+            'webhook': webhook,
         }, headers=self._api_headers)
 
         return self._handle_response(response, wait_async, async_request)
 
-    def amazon_reviews(self, query: Union[list, str], limit: int = 10, sort: str = 'helpful', filter_by_reviewer: str = 'all_reviews', filter_by_star: str = 'all_stars', fields: list = None, async_request: bool = False, ui: bool = None
+    def amazon_reviews(self, query: Union[list, str], limit: int = 10, sort: str = 'helpful', filter_by_reviewer: str = 'all_reviews',
+        filter_by_star: str = 'all_stars', fields: list = None, async_request: bool = False, ui: bool = None, webhook: bool = None
     ) -> Union[list, dict]:
         '''
             Returns reviews from Amazon products.
@@ -577,12 +584,13 @@ def amazon_reviews(self, query: Union[list, str], limit: int = 10, sort: str = '
             'async': wait_async,
             'fields': ','.join(fields) if fields else '',
             'ui': ui,
+            'webhook': webhook,
         }, headers=self._api_headers)
 
         return self._handle_response(response, wait_async, async_request)
 
     def yelp_search(self, query: Union[list, str], limit: int = 100,
-        fields: list = None, async_request: bool = False, ui: bool = None
+        fields: list = None, async_request: bool = False, ui: bool = None, webhook: bool = None
     ) -> Union[list, dict]:
         '''
             Yelp
@@ -610,12 +618,13 @@ def yelp_search(self, query: Union[list, str], limit: int = 100,
             'async': wait_async,
             'fields': ','.join(fields) if fields else '',
             'ui': ui,
+            'webhook': webhook,
         }, headers=self._api_headers)
 
         return self._handle_response(response, wait_async, async_request)
 
     def yelp_reviews(self, query: Union[list, str], limit: int = 100, sort: str = 'relevance_desc', cutoff: int = None,
-        fields: list = None, async_request: bool = False, ui: bool = None
+        fields: list = None, async_request: bool = False, ui: bool = None, webhook: bool = None
     ) -> Union[list, dict]:
         '''
             Yelp Reviews
@@ -647,12 +656,13 @@ def yelp_reviews(self, query: Union[list, str], limit: int = 100, sort: str = 'r
             'async': wait_async,
             'fields': ','.join(fields) if fields else '',
             'ui': ui,
+            'webhook': webhook,
         }, headers=self._api_headers)
 
         return self._handle_response(response, wait_async, async_request)
 
     def tripadvisor_reviews(self, query: Union[list, str], limit: int = 100,
-        fields: list = None, async_request: bool = False, ui: bool = None
+        fields: list = None, async_request: bool = False, ui: bool = None, webhook: bool = None
     ) -> Union[list, dict]:
         '''
             Tripadvisor Reviews
@@ -680,6 +690,7 @@ def tripadvisor_reviews(self, query: Union[list, str], limit: int = 100,
             'async': wait_async,
             'fields': ','.join(fields) if fields else '',
             'ui': ui,
+            'webhook': webhook,
         }, headers=self._api_headers)
 
         return self._handle_response(response, wait_async, async_request)

setup.py

@@ -8,7 +8,7 @@ def readme():
 
 setup(
     name='outscraper',
-    version='4.0.0',
+    version='4.0.1',
     description='Python bindings for the Outscraper API',
     long_description=readme(),
     classifiers = ['Programming Language :: Python',