CreatBot/GeneralKlipperScreen
7
0
Fork 0
forked from CreatBot/CreatBotKlipperScreen
Code Pull Requests Activity

rest: cleanup requests

Browse Source 
increase timeout to slightly larger than a multiple of 3, which is the default TCP packet retransmission window.
This commit is contained in:
alfrix 2024-03-09 08:07:10 -03:00
parent cdf8d12710
commit ee501f2594
1 changed files with 6 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
ks_includes/KlippyRest.py
View File

@ -32,39 +32,23 @@ class KlippyRest:
def _do_request(self, method, request_method, data=None, json=None, json_response=True, timeout=3):
url = f"{self.endpoint}/{method}"
headers = {} if self.api_key is False else {"x-api-key": self.api_key}
response_data = False
headers = {"x-api-key": self.api_key} if self.api_key else {}
logging.debug(f"Sending {request_method} to {url}")
try:
callee = getattr(requests, request_method)
response = callee(url, json=json, data=data, headers=headers, timeout=timeout)
response.raise_for_status()
if json_response:
logging.debug(f"Sending request to {url}")
response_data = response.json()
else:
response_data = response.content
except requests.exceptions.HTTPError as h:
self.status = self.format_status(h)
except requests.exceptions.ConnectionError as c:
self.status = self.format_status(c)
except requests.exceptions.Timeout as t:
self.status = self.format_status(t)
except requests.exceptions.JSONDecodeError as j:
self.status = self.format_status(j)
except requests.exceptions.RequestException as r:
self.status = self.format_status(r)
self.status = ''
return response.json() if json_response else response.content
except Exception as e:
self.status = self.format_status(e)
if response_data:
self.status = ''
else:
logging.error(self.status.replace('\n', '>>'))
return response_data
return False
def post_request(self, method, data=None, json=None, json_response=True):
return self._do_request(method, "post", data, json, json_response)
def send_request(self, method, json=True, timeout=3):
def send_request(self, method, json=True, timeout=4):
return self._do_request(method, "get", json_response=json, timeout=timeout)
@staticmethod