ED/jubilant-system
1
0 Fork 0
mirror of https://github.com/norohind/jubilant-system.git synced 2026-11-08 01:52:24 +03:00
Code Issues Projects Releases Wiki Activity

change int to float in proxieng logic

Browse Source
This commit is contained in:
norohind committed 2021-10-29 01:16:09 +03:00
1 parent bdcaec9b90
commit 702ce5906d
1 file changed
+6 -6
Download Patch File Download Diff File Expand all files Collapse all files
utils.py
+6 -6
View File
@@ -18,9 +18,9 @@ NEWS_ENDPOINT = 'news/list'
# proxy: last request time
# ssh -C2 -T -n -N -D 2081 patagonia
PROXIES_DICT: list[dict] = [{'url': 'socks5://127.0.0.1:2080', 'last_req': int(time.time())},
{'url': 'socks5://127.0.0.1:2081', 'last_req': int(time.time())},
{'url': None, 'last_req': int(time.time())}]
PROXIES_DICT: list[dict] = [{'url': 'socks5://127.0.0.1:2080', 'last_req': time.time()},
{'url': 'socks5://127.0.0.1:2081', 'last_req': time.time()},
{'url': None, 'last_req': time.time()}]
class FAPIDownForMaintenance(Exception):
@@ -48,14 +48,14 @@ def proxied_request(url: str, method: str = 'get', **kwargs) -> requests.Respons
"""
global PROXIES_DICT
TIME_BETWEEN_REQUESTS: int = 3
TIME_BETWEEN_REQUESTS: float = 3.0
selected_proxy = min(PROXIES_DICT, key=lambda x: x['last_req'])
logger.debug(f'Using {selected_proxy["url"]} proxy')
# let's detect how much we have to wait
time_to_sleep: int = int(time.time()) - selected_proxy['last_req']
time_to_sleep: float = time.time() - selected_proxy['last_req']
if 0 < time_to_sleep <= TIME_BETWEEN_REQUESTS:
logger.debug(f'Sleeping {time_to_sleep} s')
@@ -76,7 +76,7 @@ def proxied_request(url: str, method: str = 'get', **kwargs) -> requests.Respons
for i, proxy in enumerate(PROXIES_DICT):
if proxy['url'] == selected_proxy["url"]:
PROXIES_DICT[i]['last_req'] = int(time.time())
PROXIES_DICT[i]['last_req'] = time.time()
break