from __future__ import ( division, absolute_import, print_function, unicode_literals ) import hashlib import random import time import datetime import xbmcaddon import xbmcplugin import xbmcgui from .jellyfin import api from .utils import ( get_jellyfin_url, image_url, get_current_user_id, get_art_url, get_default_filters ) from .lazylogger import LazyLogger from .kodi_utils import HomeWindow from .dir_functions import process_directory from .tracking import timer log = LazyLogger(__name__) background_items = [] background_current_item = 0 @timer def set_random_movies(): log.debug("set_random_movies Called") settings = xbmcaddon.Addon() item_limit = settings.getSetting("show_x_filtered_items") hide_watched = settings.getSetting("hide_watched") == "true" user_id = get_current_user_id() url_params = {} url_params["Recursive"] = True url_params["limit"] = item_limit if hide_watched: url_params["IsPlayed"] = False url_params["SortBy"] = "Random" url_params["IncludeItemTypes"] = "Movie" url_params["ImageTypeLimit"] = 0 url = get_jellyfin_url("/Users/{}/Items".format(user_id), url_params) results = api.get(url) randon_movies_list = [] if results is not None: items = results.get("Items", []) for item in items: randon_movies_list.append(item.get("Id")) random.shuffle(randon_movies_list) movies_list_string = ",".join(randon_movies_list) home_window = HomeWindow() m = hashlib.md5() m.update(movies_list_string.encode()) new_widget_hash = m.hexdigest() log.debug("set_random_movies : {0}".format(movies_list_string)) log.debug("set_random_movies : {0}".format(new_widget_hash)) home_window.set_property("random-movies", movies_list_string) home_window.set_property("random-movies-changed", new_widget_hash) @timer def set_random_tvshows(): log.debug("set_random_tvshows Called") settings = xbmcaddon.Addon() item_limit = settings.getSetting("show_x_filtered_items") hide_watched = settings.getSetting("hide_watched") == "true" user_id = get_current_user_id() url_params = {} url_params["Recursive"] = True url_params["limit"] = item_limit if hide_watched: url_params["IsPlayed"] = False url_params["SortBy"] = "Random" url_params["IncludeItemTypes"] = "Series" url_params["ImageTypeLimit"] = 0 url = get_jellyfin_url("/Users/{}/Items".format(user_id), url_params) results = api.get(url) random_tvshows_list = [] if results is not None: items = results.get("Items", []) for item in items: random_tvshows_list.append(item.get("Id")) random.shuffle(random_tvshows_list) tvshow_list_string = ",".join(random_tvshows_list) home_window = HomeWindow() m = hashlib.md5() m.update(tvshow_list_string.encode()) new_widget_hash = m.hexdigest() log.debug("set_random_tvshows: {0}".format(tvshow_list_string)) log.debug("set_random_tvshows: {0}".format(new_widget_hash)) home_window.set_property("random-tvshows", tvshow_list_string) home_window.set_property("random-tvshows-changed", new_widget_hash) @timer def set_random_all(): log.debug("set_random_all Called") settings = xbmcaddon.Addon() item_limit = settings.getSetting("show_x_filtered_items") hide_watched = settings.getSetting("hide_watched") == "true" user_id = get_current_user_id() url_params = {} url_params["Recursive"] = True url_params["limit"] = item_limit if hide_watched: url_params["IsPlayed"] = False url_params["SortBy"] = "Random" url_params["IncludeItemTypes"] = "Movie,Series" url_params["ImageTypeLimit"] = 0 url = get_jellyfin_url("/Users/{}/Items".format(user_id), url_params) results = api.get(url) random_items = [] if results is not None: items = results.get("Items", []) for item in items: random_items.append(item.get("Id")) random.shuffle(random_items) item_list_string = ",".join(random_items) home_window = HomeWindow() m = hashlib.md5() m.update(item_list_string.encode()) new_widget_hash = m.hexdigest() log.debug("set_random_all: {0}".format(item_list_string)) log.debug("set_random_all: {0}".format(new_widget_hash)) home_window.set_property("random-all", item_list_string) home_window.set_property("random-all-changed", new_widget_hash) def set_background_image(force=False): log.debug("set_background_image Called forced={0}".format(force)) global background_current_item global background_items settings = xbmcaddon.Addon() server = settings.getSetting('server_address') user_id = get_current_user_id() if force: background_current_item = 0 del background_items background_items = [] if len(background_items) == 0: log.debug("Need to load more backgrounds {0} - {1}".format( len(background_items), background_current_item) ) url_params = {} url_params["Recursive"] = True url_params["limit"] = 100 url_params["SortBy"] = "Random" url_params["IncludeItemTypes"] = "Movie,Series" url_params["ImageTypeLimit"] = 1 url = get_jellyfin_url('/Users/{}/Items'.format(user_id), url_params) results = api.get(url) if results is not None: items = results.get("Items", []) background_current_item = 0 background_items = [] for item in items: bg_image = get_art_url( item, "Backdrop", server=server) if bg_image: label = item.get("Name") item_background = {} item_background["image"] = bg_image item_background["name"] = label background_items.append(item_background) log.debug("set_background_image: Loaded {0} more backgrounds".format( len(background_items)) ) if len(background_items) > 0: bg_image = background_items[background_current_item].get("image") label = background_items[background_current_item].get("name") log.debug( "set_background_image: {0} - {1} - {2}".format( background_current_item, label, bg_image ) ) background_current_item += 1 if background_current_item >= len(background_items): background_current_item = 0 home_window = HomeWindow() home_window.set_property("random-gb", bg_image) home_window.set_property("random-gb-label", label) @timer def check_for_new_content(): log.debug("checkForNewContent Called") home_window = HomeWindow() settings = xbmcaddon.Addon() simple_new_content_check = settings.getSetting( "simple_new_content_check") == "true" if simple_new_content_check: log.debug("Using simple new content check") current_time_stamp = str(time.time()) home_window.set_property("jellycon_widget_reload", current_time_stamp) log.debug("Setting New Widget Hash: {0}".format(current_time_stamp)) return user_id = get_current_user_id() url_params = {} url_params["Recursive"] = True url_params["limit"] = 1 url_params["Fields"] = "DateCreated,Etag" url_params["SortBy"] = "DateCreated" url_params["SortOrder"] = "Descending" url_params["IncludeItemTypes"] = "Movie,Episode" url_params["ImageTypeLimit"] = 0 added_url = get_jellyfin_url('/Users/{}/Items'.format(user_id), url_params) result = api.get(added_url) log.debug("LATEST_ADDED_ITEM: {0}".format(result)) last_added_date = "" if result is not None: items = result.get("Items", []) if len(items) > 0: item = items[0] last_added_date = item.get("Etag", "") log.debug("last_added_date: {0}".format(last_added_date)) url_params = {} url_params["Recursive"] = True url_params["limit"] = 1 url_params["Fields"] = "DateCreated,Etag" url_params["SortBy"] = "DatePlayed" url_params["SortOrder"] = "Descending" url_params["IncludeItemTypes"] = "Movie,Episode" url_params["ImageTypeLimit"] = 0 played_url = get_jellyfin_url( '/Users/{}/Items'.format(user_id), url_params ) result = api.get(played_url) log.debug("LATEST_PLAYED_ITEM: {0}".format(result)) last_played_date = "" if result is not None: items = result.get("Items", []) if len(items) > 0: item = items[0] user_data = item.get("UserData", None) if user_data is not None: last_played_date = user_data.get("LastPlayedDate", "") log.debug("last_played_date: {0}".format(last_played_date)) current_widget_hash = home_window.get_property("jellycon_widget_reload") log.debug("Current Widget Hash: {0}".format(current_widget_hash)) m = hashlib.md5() m.update((last_played_date + last_added_date).encode()) new_widget_hash = m.hexdigest() log.debug("New Widget Hash: {0}".format(new_widget_hash)) if current_widget_hash != new_widget_hash: home_window.set_property("jellycon_widget_reload", new_widget_hash) log.debug("Setting New Widget Hash: {0}".format(new_widget_hash)) @timer def get_widget_content_cast(handle, params): log.debug("getWigetContentCast Called: {0}".format(params)) settings = xbmcaddon.Addon() server = settings.getSetting('server_address') user_id = get_current_user_id() item_id = params["id"] result = api.get( "/Users/{}/Items/{}".format(user_id, item_id)) log.debug("ItemInfo: {0}".format(result)) if not result: return if (result.get("Type", "") in ["Episode", "Season"] and params.get("auto", "true") == "true"): series_id = result.get("SeriesId") if series_id: params["id"] = series_id return get_widget_content_cast(handle, params) list_items = [] if result is not None: people = result.get("People", []) else: people = [] for person in people: if person.get("Type") == "Actor": person_name = person.get("Name") person_role = person.get("Role") person_id = person.get("Id") person_tag = person.get("PrimaryImageTag") person_thumbnail = None if person_tag: person_thumbnail = image_url( person_id, "Primary", 0, 400, 400, person_tag, server=server ) list_item = xbmcgui.ListItem(label=person_name, offscreen=True) list_item.setProperty("id", person_id) if person_thumbnail: art_links = {} art_links["thumb"] = person_thumbnail art_links["poster"] = person_thumbnail list_item.setArt(art_links) labels = {} labels["mediatype"] = "artist" list_item.setInfo(type="music", infoLabels=labels) if person_role: list_item.setLabel2(person_role) item_tuple = ("", list_item, False) list_items.append(item_tuple) xbmcplugin.setContent(handle, 'artists') xbmcplugin.addDirectoryItems(handle, list_items) xbmcplugin.endOfDirectory(handle, cacheToDisc=False) @timer def get_widget_content(handle, params): log.debug("getWigetContent Called: {0}".format(params)) settings = xbmcaddon.Addon() item_limit = int(settings.getSetting("show_x_filtered_items")) hide_watched = settings.getSetting("hide_watched") == "true" use_cached_widget_data = settings.getSetting( "use_cached_widget_data") == "true" widget_type = params.get("type") if widget_type is None: log.error("getWigetContent type not set") return user_id = get_current_user_id() log.debug("widget_type: {0}".format(widget_type)) url_verb = "/Users/{}/Items".format(user_id) url_params = {} url_params["Limit"] = item_limit url_params["Fields"] = get_default_filters() url_params["ImageTypeLimit"] = 1 url_params["IsMissing"] = False if widget_type == "recent_movies": xbmcplugin.setContent(handle, 'movies') url_params["Recursive"] = True url_params["SortBy"] = "DateCreated" url_params["SortOrder"] = "Descending" url_params["Filters"] = "IsNotFolder" if hide_watched: url_params["IsPlayed"] = False url_params["IsVirtualUnaired"] = False url_params["IncludeItemTypes"] = "Movie" url_params["Limit"] = item_limit elif widget_type == "inprogress_movies": xbmcplugin.setContent(handle, 'movies') url_params["Recursive"] = True url_params["SortBy"] = "DatePlayed" url_params["SortOrder"] = "Descending" url_params["Filters"] = "IsResumable" url_params["IsVirtualUnaired"] = False url_params["IncludeItemTypes"] = "Movie" url_params["Limit"] = item_limit elif widget_type == "random_movies": home_window = HomeWindow() xbmcplugin.setContent(handle, 'movies') url_params["Ids"] = home_window.get_property("random-movies") elif widget_type == "random_tvshows": home_window = HomeWindow() xbmcplugin.setContent(handle, 'tvshows') url_params["Ids"] = home_window.get_property("random-tvshows") elif widget_type == "recent_tvshows": xbmcplugin.setContent(handle, 'episodes') url_verb = '/Users/{}/Items/Latest'.format(user_id) url_params["GroupItems"] = True url_params["Limit"] = 45 url_params["Recursive"] = True url_params["SortBy"] = "DateCreated" url_params["SortOrder"] = "Descending" url_params["Fields"] = get_default_filters() if hide_watched: url_params["IsPlayed"] = False url_params["IsVirtualUnaired"] = False url_params["IncludeItemTypes"] = "Episode" url_params["ImageTypeLimit"] = 1 url_params["Limit"] = item_limit elif widget_type == "recent_episodes": xbmcplugin.setContent(handle, 'episodes') url_params["Recursive"] = True url_params["SortBy"] = "DateCreated" url_params["SortOrder"] = "Descending" url_params["Filters"] = "IsNotFolder" if hide_watched: url_params["IsPlayed"] = False url_params["IsVirtualUnaired"] = False url_params["IncludeItemTypes"] = "Episode" url_params["Limit"] = item_limit elif widget_type == "inprogress_episodes": xbmcplugin.setContent(handle, 'episodes') url_params["Recursive"] = True url_params["SortBy"] = "DatePlayed" url_params["SortOrder"] = "Descending" url_params["Filters"] = "IsResumable" url_params["IsVirtualUnaired"] = False url_params["IncludeItemTypes"] = "Episode" url_params["Limit"] = item_limit elif widget_type == "nextup_episodes": xbmcplugin.setContent(handle, 'episodes') url_verb = "/Shows/NextUp" url_params = url_params.copy() url_params["Limit"] = item_limit url_params["userid"] = user_id url_params["Recursive"] = True url_params["enableResumable"] = False url_params["ImageTypeLimit"] = 1 # check if rewatching is enabled and combine is disabled rewatch_days = int(settings.getSetting("rewatch_days")) if rewatch_days > 0 and settings.getSetting("rewatch_combine") != "true": rewatch_since = datetime.datetime.today() - datetime.timedelta(days=rewatch_days) url_params["nextUpDateCutoff"] = rewatch_since.strftime("%Y-%m-%d") url_params["enableRewatching"] = True # Collect InProgress items to be combined with NextUp inprogress_url_verb = "/Users/{}/Items".format(user_id) inprogress_url_params = url_params.copy() inprogress_url_params["Recursive"] = True inprogress_url_params["SortBy"] = "DatePlayed" inprogress_url_params["SortOrder"] = "Descending" inprogress_url_params["Filters"] = "IsResumable" inprogress_url_params["IsVirtualUnaired"] = False inprogress_url_params["IncludeItemTypes"] = "Episode" inprogress_url_params["Limit"] = item_limit elif widget_type == "movie_recommendations": suggested_items_url_params = {} suggested_items_url_params["userId"] = user_id suggested_items_url_params["categoryLimit"] = 15 suggested_items_url_params["ItemLimit"] = item_limit suggested_items_url_params["ImageTypeLimit"] = 0 suggested_items_url = get_jellyfin_url( "/Movies/Recommendations", suggested_items_url_params) suggested_items = api.get(suggested_items_url) ids = [] set_id = 0 while len(ids) < item_limit and suggested_items: items = suggested_items[set_id] log.debug( "BaselineItemName : {0} - {1}".format( set_id, items.get("BaselineItemName") ) ) items = items["Items"] rand = random.randint(0, len(items) - 1) item = items[rand] if (item["Type"] == "Movie" and item["Id"] not in ids and (not item["UserData"]["Played"] or not hide_watched)): ids.append(item["Id"]) del items[rand] if len(items) == 0: del suggested_items[set_id] set_id += 1 if set_id >= len(suggested_items): set_id = 0 id_list = ",".join(ids) log.debug("Recommended Items : {0}".format(len(ids))) url_params["Ids"] = id_list elif widget_type == "random_all": home_window = HomeWindow() xbmcplugin.setContent(handle, 'movies') url_params["Ids"] = home_window.get_property("random-all") elif widget_type == "recent_all": xbmcplugin.setContent(handle, 'movies') url_verb = '/Users/{}/Items/Latest'.format(user_id) url_params["GroupItems"] = True url_params["Recursive"] = True url_params["SortBy"] = "DateCreated" url_params["SortOrder"] = "Descending" url_params["Limit"] = 45 url_params["Filters"] = "IsNotFolder" url_params["Fields"] = get_default_filters() if hide_watched: url_params["IsPlayed"] = False url_params["IsVirtualUnaired"] = False url_params["IncludeItemTypes"] = "Episode, Movie" url_params["ImageTypeLimit"] = 1 elif widget_type == "favorites_all": home_window = HomeWindow() xbmcplugin.setContent(handle, 'movies') url_params.update({ "Filters": "IsFavorite", "IncludeItemTypes": "Movie,Series", "Recursive": True, "SortBy": "Name", "SortOrder": "Ascending", }) items_url = get_jellyfin_url(url_verb, url_params) if (url_params.get('IncludeItemTypes', '') == 'Episode' or params.get('type', '') == 'nextup_episodes'): params["name_format"] = "Episode|episode_name_format" list_items, detected_type, total_records = process_directory( items_url, None, params, use_cached_widget_data) # Combine In Progress and Next Up Episodes, add next up after In Progress if widget_type == "nextup_episodes": inprogress_url = get_jellyfin_url( inprogress_url_verb, inprogress_url_params) params["name_format"] = "Episode|episode_name_format" inprogress, detected_type, total_records = process_directory( inprogress_url, None, params, use_cached_widget_data) list_items = inprogress + list_items # add rewatch combine is enabled if rewatch_days > 0 and settings.getSetting("rewatch_combine") == "true": rewatch_since = datetime.datetime.today() - datetime.timedelta(days=rewatch_days) url_params["nextUpDateCutoff"] = rewatch_since.strftime("%Y-%m-%d") url_params["enableRewatching"] = True rewatch_items_url = get_jellyfin_url(url_verb, url_params) rewatch_items, detected_type, total_records = process_directory(rewatch_items_url, None, params, use_cached_widget_data) for ri in rewatch_items: if not any(i[1].getProperty("id") == ri[1].getProperty("id") for i in list_items): list_items.append(ri) if detected_type is not None: # if the media type is not set then try to use the detected type log.debug("Detected content type: {0}".format(detected_type)) content_type = None if detected_type == "Movie": content_type = 'movies' elif detected_type == "Episode": content_type = 'episodes' elif detected_type == "Series": content_type = 'tvshows' elif detected_type in ["Music", "Audio", "Musicalbum"]: content_type = 'songs' if content_type: xbmcplugin.setContent(handle, content_type) xbmcplugin.addDirectoryItems(handle, list_items) xbmcplugin.endOfDirectory(handle, cacheToDisc=False)