bel/JellyPlex-Watched
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Cleanup

Browse Source
This commit is contained in:
Luigi311
2022-08-17 22:09:11 -06:00
parent 942ec3533f
commit dd319271bd
4 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/functions.py
View File

@@ -103,7 +103,7 @@ def generate_library_guids_dict(user_list: dict):
else: else:
show_output_dict[provider_key.lower()].append(provider_value.lower()) show_output_dict[provider_key.lower()].append(provider_value.lower())
except: except:
logger(f"Generating show_output_dict failed, skipping", 1) logger("Generating show_output_dict failed, skipping", 1)
try: try:
for show in user_list: for show in user_list:
@@ -118,7 +118,7 @@ def generate_library_guids_dict(user_list: dict):
else: else:
episode_output_dict[episode_key.lower()].append(episode_value.lower()) episode_output_dict[episode_key.lower()].append(episode_value.lower())
except: except:
logger(f"Generating episode_output_dict failed, skipping", 1) logger("Generating episode_output_dict failed, skipping", 1)
try: try:
for movie in user_list: for movie in user_list:
@@ -131,14 +131,14 @@ def generate_library_guids_dict(user_list: dict):
else: else:
movies_output_dict[movie_key.lower()].append(movie_value.lower()) movies_output_dict[movie_key.lower()].append(movie_value.lower())
except: except:
logger(f"Generating movies_output_dict failed, skipping", 1) logger("Generating movies_output_dict failed, skipping", 1)
return show_output_dict, episode_output_dict, movies_output_dict return show_output_dict, episode_output_dict, movies_output_dict
def combine_watched_dicts(dicts: list): def combine_watched_dicts(dicts: list):
combined_dict = {} combined_dict = {}
for dict in dicts: for single_dict in dicts:
for key, value in dict.items(): for key, value in single_dict.items():
if key not in combined_dict: if key not in combined_dict:
combined_dict[key] = {} combined_dict[key] = {}
for subkey, subvalue in value.items(): for subkey, subvalue in value.items():

4
src/jellyfin.py
View File

@@ -1,5 +1,5 @@
import asyncio, aiohttp import asyncio, aiohttp
from src.functions import logger, search_mapping, str_to_bool, check_skip_logic, generate_library_guids_dict, future_thread_executor, combine_watched_dicts from src.functions import logger, search_mapping, check_skip_logic, generate_library_guids_dict, combine_watched_dicts
class Jellyfin(): class Jellyfin():
def __init__(self, baseurl, token): def __init__(self, baseurl, token):
@@ -389,5 +389,5 @@ class Jellyfin():
await asyncio.gather(*tasks, return_exceptions=True) await asyncio.gather(*tasks, return_exceptions=True)
except Exception as e: except Exception as e:
logger(f"Jellyfin: Error updating watched", 2) logger(f"Jellyfin: Error updating watched, {e}", 2)
raise Exception(e) raise Exception(e)

2
src/main.py
View File

@@ -2,7 +2,7 @@ import copy, os, traceback, json, asyncio
from dotenv import load_dotenv from dotenv import load_dotenv
from time import sleep, perf_counter from time import sleep, perf_counter
from src.functions import logger, str_to_bool, search_mapping, generate_library_guids_dict, future_thread_executor from src.functions import logger, str_to_bool, search_mapping, generate_library_guids_dict
from src.plex import Plex from src.plex import Plex
from src.jellyfin import Jellyfin from src.jellyfin import Jellyfin

2
src/plex.py
View File

@@ -165,7 +165,7 @@ class Plex:
raise Exception(e) raise Exception(e)
def update_user_watched (self, user, user_plex, library, videos, dryrun): def update_user_watched(self, user, user_plex, library, videos, dryrun):
try: try:
logger(f"Plex: Updating watched for {user.title} in library {library}", 1) logger(f"Plex: Updating watched for {user.title} in library {library}", 1)
videos_shows_ids, videos_episodes_ids, videos_movies_ids = generate_library_guids_dict(videos) videos_shows_ids, videos_episodes_ids, videos_movies_ids = generate_library_guids_dict(videos)