mirror of
https://github.com/meisnate12/Plex-Meta-Manager
synced 2024-09-20 06:22:07 +00:00
70 lines
3.1 KiB
Python
70 lines
3.1 KiB
Python
import logging, requests
|
|
from modules import util
|
|
from modules.util import Failed
|
|
from plexapi.exceptions import BadRequest, NotFound
|
|
from plexapi.video import Movie, Show
|
|
from retrying import retry
|
|
|
|
logger = logging.getLogger("Plex Meta Manager")
|
|
|
|
builders = ["tautulli_popular", "tautulli_watched"]
|
|
|
|
class TautulliAPI:
|
|
def __init__(self, params):
|
|
try:
|
|
response = requests.get(f"{params['url']}/api/v2?apikey={params['apikey']}&cmd=get_library_names").json()
|
|
except Exception:
|
|
util.print_stacktrace()
|
|
raise Failed("Tautulli Error: Invalid url")
|
|
if response["response"]["result"] != "success":
|
|
raise Failed(f"Tautulli Error: {response['response']['message']}")
|
|
self.url = params["url"]
|
|
self.apikey = params["apikey"]
|
|
|
|
def get_items(self, library, time_range=30, stats_count=20, list_type="popular", stats_count_buffer=20):
|
|
logger.info(f"Processing Tautulli Most {'Popular' if list_type == 'popular' else 'Watched'}: {stats_count} {'Movies' if library.is_movie else 'Shows'}")
|
|
response = self._request(f"{self.url}/api/v2?apikey={self.apikey}&cmd=get_home_stats&time_range={time_range}&stats_count={int(stats_count) + int(stats_count_buffer)}")
|
|
stat_id = f"{'popular' if list_type == 'popular' else 'top'}_{'movies' if library.is_movie else 'tv'}"
|
|
|
|
items = None
|
|
for entry in response["response"]["data"]:
|
|
if entry["stat_id"] == stat_id:
|
|
items = entry["rows"]
|
|
break
|
|
if items is None:
|
|
raise Failed("Tautulli Error: No Items found in the response")
|
|
|
|
section_id = self._section_id(library.name)
|
|
rating_keys = []
|
|
count = 0
|
|
for item in items:
|
|
if item["section_id"] == section_id and count < int(stats_count):
|
|
rk = None
|
|
try:
|
|
library.fetchItem(int(item["rating_key"]))
|
|
rk = item["rating_key"]
|
|
except (BadRequest, NotFound):
|
|
new_item = library.exact_search(item["title"])
|
|
if new_item:
|
|
rk = new_item[0].ratingKey
|
|
else:
|
|
logger.error(f"Plex Error: Item {item} not found")
|
|
continue
|
|
rating_keys.append(rk)
|
|
count += 1
|
|
return rating_keys
|
|
|
|
def _section_id(self, library_name):
|
|
response = self._request(f"{self.url}/api/v2?apikey={self.apikey}&cmd=get_library_names")
|
|
section_id = None
|
|
for entry in response["response"]["data"]:
|
|
if entry["section_name"] == library_name:
|
|
section_id = entry["section_id"]
|
|
break
|
|
if section_id: return section_id
|
|
else: raise Failed(f"Tautulli Error: No Library named {library_name} in the response")
|
|
|
|
@retry(stop_max_attempt_number=6, wait_fixed=10000)
|
|
def _request(self, url):
|
|
logger.debug(f"Tautulli URL: {url.replace(self.apikey, '################################')}")
|
|
return requests.get(url).json()
|