StuffAnThings/qbit_manage
1
1
Fork 0
mirror of https://github.com/StuffAnThings/qbit_manage.git synced 2024-09-20 07:16:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixup! refactor webhooks request & add 2s delay

Browse source
This commit is contained in:
Bakerboy448 2023-03-31 17:59:15 -05:00
parent 57db8f3a66
commit c08665c640
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
modules/webhooks.py
View file

@ -29,7 +29,7 @@ class Webhooks:
self.notifiarr = notifiarr
self.apprise = apprise
def request_and_check(self, webhook_type, json):
def request_and_check(self, webhook, json):
"""
Send a webhook request and check for errors.
retry up to 6 times if the response is a 500+ error.
@ -38,18 +38,18 @@ class Webhooks:
retry_attempts = 6
request_delay = 2
for retry_count in range(retry_attempts):
if webhook_type == "notifiarr":
if webhook == "notifiarr":
response = self.notifiarr.notification(json=json)
else:
if webhook_type == "apprise":
if webhook == "apprise":
json["urls"] = self.apprise.notify_url
webhook_type = f"{self.apprise.api_url}/notify"
response = self.config.post(webhook_type, json=json)
response = self.config.post(webhook_type, json=json)
if response.status_code < 500:
return response
time.sleep(request_delay)
retry_count += 1
raise Failed(f"({response.status_code} [{response.reason}]) after {retry_attempts} attempts.")
logger.warning(f"({response.status_code} [{response.reason}]) after {retry_attempts} attempts.")
def _request(self, webhooks, json):
"""Send a webhook request."""