|
|
|
from json import JSONDecodeError
|
|
|
|
from modules import util
|
|
|
|
from modules.util import Failed
|
|
|
|
from tenacity import retry, stop_after_attempt, wait_fixed, retry_if_not_exception_type
|
|
|
|
|
|
|
|
logger = util.logger
|
|
|
|
|
|
|
|
base_url = "https://notifiarr.com/api/v1/"
|
|
|
|
|
|
|
|
|
|
|
|
class Notifiarr:
|
|
|
|
def __init__(self, requests, params):
|
|
|
|
self.requests = requests
|
|
|
|
self.apikey = params["apikey"]
|
|
|
|
self.header = {"X-API-Key": self.apikey}
|
|
|
|
logger.secret(self.apikey)
|
|
|
|
self._request(path="user", params={"fetch": "settings"})
|
|
|
|
|
|
|
|
def notification(self, json):
|
|
|
|
return self._request(json=json)
|
|
|
|
|
|
|
|
@retry(stop=stop_after_attempt(6), wait=wait_fixed(10), retry=retry_if_not_exception_type(Failed))
|
|
|
|
def _request(self, json=None, path="notification", params=None):
|
|
|
|
response = self.requests.get(f"{base_url}{path}/pmm/", json=json, headers=self.header, params=params)
|
|
|
|
try:
|
|
|
|
response_json = response.json()
|
|
|
|
except JSONDecodeError as e:
|
|
|
|
logger.debug(f"Content: {response.content}")
|
|
|
|
logger.error(e)
|
|
|
|
raise Failed("Notifiarr Error: Invalid JSON response received")
|
|
|
|
if response.status_code >= 400 or ("result" in response_json and response_json["result"] == "error"):
|
|
|
|
logger.debug(f"Response: {response_json}")
|
|
|
|
raise Failed(f"({response.status_code} [{response.reason}]) {response_json}")
|
|
|
|
if not response_json["details"]["response"]:
|
|
|
|
raise Failed("Notifiarr Error: Invalid apikey")
|
|
|
|
return response
|