Skip to content

Commit

Permalink
add webhook
Browse files Browse the repository at this point in the history
  • Loading branch information
vs committed Aug 18, 2023
1 parent 4cb60f3 commit 3936882
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 8 deletions.
25 changes: 18 additions & 7 deletions outscraper/api_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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.
Expand All @@ -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.
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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)
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -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',
Expand Down

0 comments on commit 3936882

Please sign in to comment.