|
|
|
@ -11,7 +11,7 @@ from app.database import TableEpisodes, TableMovies, database, select
|
|
|
|
|
from utilities.analytics import event_tracker
|
|
|
|
|
from radarr.notify import notify_radarr
|
|
|
|
|
from sonarr.notify import notify_sonarr
|
|
|
|
|
from plex.operations import plex_set_added_date_now
|
|
|
|
|
from plex.operations import plex_set_added_date_now, plex_update_library
|
|
|
|
|
from app.event_handler import event_stream
|
|
|
|
|
|
|
|
|
|
from .utils import _get_download_code3
|
|
|
|
@ -78,7 +78,7 @@ def process_subtitle(subtitle, media_type, audio_language, path, max_score, is_u
|
|
|
|
|
if media_type == 'series':
|
|
|
|
|
episode_metadata = database.execute(
|
|
|
|
|
select(TableEpisodes.sonarrSeriesId, TableEpisodes.sonarrEpisodeId)
|
|
|
|
|
.where(TableEpisodes.path == path_mappings.path_replace_reverse(path)))\
|
|
|
|
|
.where(TableEpisodes.path == path_mappings.path_replace_reverse(path))) \
|
|
|
|
|
.first()
|
|
|
|
|
if not episode_metadata:
|
|
|
|
|
return
|
|
|
|
@ -97,7 +97,7 @@ def process_subtitle(subtitle, media_type, audio_language, path, max_score, is_u
|
|
|
|
|
else:
|
|
|
|
|
movie_metadata = database.execute(
|
|
|
|
|
select(TableMovies.radarrId, TableMovies.imdbId)
|
|
|
|
|
.where(TableMovies.path == path_mappings.path_replace_reverse_movie(path)))\
|
|
|
|
|
.where(TableMovies.path == path_mappings.path_replace_reverse_movie(path))) \
|
|
|
|
|
.first()
|
|
|
|
|
if not movie_metadata:
|
|
|
|
|
return
|
|
|
|
@ -116,7 +116,8 @@ def process_subtitle(subtitle, media_type, audio_language, path, max_score, is_u
|
|
|
|
|
if use_postprocessing is True:
|
|
|
|
|
command = pp_replace(postprocessing_cmd, path, downloaded_path, downloaded_language, downloaded_language_code2,
|
|
|
|
|
downloaded_language_code3, audio_language, audio_language_code2, audio_language_code3,
|
|
|
|
|
percent_score, subtitle_id, downloaded_provider, uploader, release_info, series_id, episode_id)
|
|
|
|
|
percent_score, subtitle_id, downloaded_provider, uploader, release_info, series_id,
|
|
|
|
|
episode_id)
|
|
|
|
|
|
|
|
|
|
if media_type == 'series':
|
|
|
|
|
use_pp_threshold = settings.general.use_postprocessing_threshold
|
|
|
|
@ -140,14 +141,20 @@ def process_subtitle(subtitle, media_type, audio_language, path, max_score, is_u
|
|
|
|
|
event_stream(type='series', action='update', payload=episode_metadata.sonarrSeriesId)
|
|
|
|
|
event_stream(type='episode-wanted', action='delete',
|
|
|
|
|
payload=episode_metadata.sonarrEpisodeId)
|
|
|
|
|
if settings.general.use_plex is True:
|
|
|
|
|
if settings.plex.update_movie_library is True:
|
|
|
|
|
plex_update_library(is_movie_library=False)
|
|
|
|
|
|
|
|
|
|
else:
|
|
|
|
|
reversed_path = path_mappings.path_replace_reverse_movie(path)
|
|
|
|
|
reversed_subtitles_path = path_mappings.path_replace_reverse_movie(downloaded_path)
|
|
|
|
|
notify_radarr(movie_metadata.radarrId)
|
|
|
|
|
event_stream(type='movie-wanted', action='delete', payload=movie_metadata.radarrId)
|
|
|
|
|
if settings.plex.set_added is True:
|
|
|
|
|
plex_set_added_date_now(movie_metadata)
|
|
|
|
|
if settings.general.use_plex is True:
|
|
|
|
|
if settings.plex.set_added is True:
|
|
|
|
|
plex_set_added_date_now(movie_metadata)
|
|
|
|
|
if settings.plex.update_movie_library is True:
|
|
|
|
|
plex_update_library(is_movie_library=True)
|
|
|
|
|
|
|
|
|
|
event_tracker.track_subtitles(provider=downloaded_provider, action=action, language=downloaded_language)
|
|
|
|
|
|
|
|
|
|