|
2 | 2 | import re |
3 | 3 | import requests |
4 | 4 |
|
5 | | -from requests.adapters import HTTPAdapter |
6 | | -from requests.packages.urllib3.util.retry import Retry |
7 | | - |
8 | 5 |
|
9 | 6 | class PancakeSwapAPI: |
10 | 7 | __BASE_URL = "https://api.pancakeswap.info/api/v2/" |
| 8 | + |
11 | 9 | """ |
12 | 10 | Basic API request wrapper for PancakeSwap |
13 | 11 | Scott Burlovich (github.com/scottburlovich) |
14 | | - Last Update: May 9, 2021 |
| 12 | + Last Update: Jul 28, 2021 |
15 | 13 | """ |
16 | 14 |
|
17 | 15 | def __init__(self, base_url=__BASE_URL): |
18 | 16 | self.base_url = base_url |
19 | 17 | self.request_timeout = 60 |
20 | | - self.session = requests.session() |
21 | | - retries = Retry(total=3, backoff_factor=0.5, status_forcelist=[502, 503, 504]) |
22 | | - self.session.mount('https://', HTTPAdapter(max_retries=retries)) |
23 | | - |
24 | | - def __exit__(self): |
25 | | - self.session.close() |
26 | 18 |
|
27 | 19 | def __get(self, request_url: str): |
28 | 20 | """ |
29 | 21 | GET request wrapper |
30 | 22 | :param request_url: str |
31 | 23 | """ |
32 | | - try: |
33 | | - response = self.session.get(request_url, timeout=self.request_timeout) |
34 | | - except requests.exceptions.RequestException: |
35 | | - raise |
| 24 | + with requests.Session() as session: |
| 25 | + try: |
| 26 | + response = session.get(request_url, timeout=self.request_timeout) |
| 27 | + except requests.exceptions.RequestException: |
| 28 | + raise |
36 | 29 |
|
37 | | - try: |
38 | | - response.raise_for_status() |
39 | | - return json.loads(response.content.decode('utf-8')) |
40 | | - except Exception as err: |
41 | 30 | try: |
42 | | - content = json.loads(response.content.decode('utf-8')) |
43 | | - raise ValueError(content) |
44 | | - except json.decoder.JSONDecodeError: |
45 | | - pass |
46 | | - raise |
| 31 | + response.raise_for_status() |
| 32 | + return json.loads(response.content.decode('utf-8')) |
| 33 | + except Exception as err: |
| 34 | + try: |
| 35 | + content = json.loads(response.content.decode('utf-8')) |
| 36 | + raise ValueError(content) |
| 37 | + except json.decoder.JSONDecodeError: |
| 38 | + pass |
| 39 | + raise |
47 | 40 |
|
48 | 41 | def summary(self): |
49 | 42 | """ |
|
0 commit comments