Mirrors/Plex-Meta-Manager
2
0
Fork 0
mirror of https://github.com/meisnate12/Plex-Meta-Manager synced 2024-11-22 04:23:08 +00:00
Code Issues Projects Releases Packages Wiki Activity

[98] update notifiarr hooks

Browse source
This commit is contained in:
meisnate12 2022-05-15 22:42:41 -04:00
parent 9171dd409b
commit b5c31ec2a2
3 changed files with 29 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
VERSION
View file

@ -1 +1 @@
1.16.5-develop97
1.16.5-develop98

2
docs/config/webhooks.md
View file

@ -2,6 +2,8 @@
Configuring Webhooks is optional but can allow you to receive notifications when certain events happen.
Discord and Slack Direct webhooks are supported just use the correct urls.
A `webhooks` mapping is in the root of the config file.
Below is a `webhooks` mapping example and the full set of attributes:

31
modules/webhooks.py
View file

@ -1,6 +1,6 @@
from json import JSONDecodeError
from modules import util
from modules.util import Failed
from modules.util import Failed, YAML
logger = util.logger
@ -30,17 +30,38 @@ class Webhooks:
response = self.config.get(url, json=json, params=params)
if response.status_code < 500:
break
elif webhook.startswith("https://discord.com/api/webhooks"):
response = self.config.post(webhook, json=self.discord(json))
elif webhook.startswith("https://hooks.slack.com/services"):
response = self.config.post(webhook, json=self.slack(json))
else:
if webhook.startswith("https://discord.com/api/webhooks"):
json = self.discord(json)
elif webhook.startswith("https://hooks.slack.com/services"):
json = self.slack(json)
response = self.config.post(webhook, json=json)
if response:
try:
response_json = response.json()
if self.config.trace_mode:
logger.debug(f"Response: {response_json}")
if webhook == "notifiarr" and self.notifiarr and response.status_code == 400:
def remove_from_config(text, hook_cat):
if response_json["details"]["response"] == text:
yaml = YAML(self.config.config_path)
changed = False
if hook_cat in yaml.data and yaml.data["webhooks"][hook_cat]:
if isinstance(yaml.data["webhooks"][hook_cat], list) and "notifiarr" in yaml.data["webhooks"][hook_cat]:
changed = True
yaml.data["webhooks"][hook_cat].pop("notifiarr")
elif yaml.data["webhooks"][hook_cat] == "notifiarr":
changed = True
yaml.data["webhooks"][hook_cat] = None
if changed:
yaml.save()
remove_from_config("PMM updated trigger is not enabled", "changes")
remove_from_config("PMM created trigger is not enabled", "changes")
remove_from_config("PMM deleted trigger is not enabled", "changes")
remove_from_config("PMM failure trigger is not enabled", "error")
remove_from_config("PMM start/complete trigger is not enabled", "run_start")
remove_from_config("PMM start/complete trigger is not enabled", "run_end")
remove_from_config("PMM app updates trigger is not enabled", "version")
if "result" in response_json and response_json["result"] == "error" and "details" in response_json and "response" in response_json["details"]:
raise Failed(f"Notifiarr Error: {response_json['details']['response']}")
if response.status_code >= 400 or ("result" in response_json and response_json["result"] == "error"):