starred/reiverr
1
0
Fork 0
mirror of https://github.com/aleksilassila/reiverr.git synced 2026-04-22 00:35:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

Initial work on getting series working

Browse Source
This commit is contained in:
Aleksi Lassila
2023-07-11 00:59:47 +03:00
parent a6a994fa05
commit 7a738c0459
21 changed files with 20153 additions and 115 deletions
Download Patch File Download Diff File Expand all files Collapse all files

106
src/lib/stores/library.store.ts
View File

@@ -1,17 +1,24 @@
import { getJellyfinContinueWatching, type JellyfinItem } from '$lib/apis/jellyfin/jellyfinApi';
import {
getRadarrDownloads,
getRadarrMovies,
RadarrApi,
type RadarrDownload,
type RadarrMovie
} from '$lib/apis/radarr/radarrApi';
import type { CardProps } from '$lib/components/Card/card';
import {
getSonarrDownloads,
getSonarrSeries,
type SonarrDownload,
type SonarrSeries
} from '$lib/apis/sonarr/sonarrApi';
import {
fetchTmdbMovieImages,
getTmdbIdFromTvdbId,
getTmdbSeriesImages
} from '$lib/apis/tmdb/tmdbApi';
import { writable } from 'svelte/store';
import { fetchCardProps } from '$lib/components/Card/card';
import { fetchTmdbMovieImages } from '$lib/apis/tmdbApi';
import { getJellyfinContinueWatching, type JellyfinItem } from '$lib/apis/jellyfin/jellyfinApi';
export interface PlayableRadarrMovie extends RadarrMovie {
interface PlayableItem {
cardBackdropUrl: string;
download?: {
progress: number;
@@ -23,15 +30,27 @@ export interface PlayableRadarrMovie extends RadarrMovie {
};
}
export interface PlayableRadarrMovie extends RadarrMovie, PlayableItem {}
export interface PlayableSonarrSeries extends SonarrSeries, PlayableItem {
tmdbId?: number;
}
export interface Library {
movies: PlayableRadarrMovie[];
totalMovies: number;
getItem: (tmdbId: number) => PlayableRadarrMovie | undefined;
series: PlayableSonarrSeries[];
totalSeries: number;
getMovie: (tmdbId: number) => PlayableRadarrMovie | undefined;
getSeries: (tmdbId: number) => PlayableSonarrSeries | undefined;
}
async function getLibrary(): Promise<Library> {
const radarrMoviesPromise = getRadarrMovies();
const radarrDownloadsPromise = getRadarrDownloads();
const sonarrSeriesPromise = getSonarrSeries();
const sonarrDownloadsPromise = getSonarrDownloads();
const continueWatchingPromise = getJellyfinContinueWatching();
const movies: PlayableRadarrMovie[] = await radarrMoviesPromise.then(async (radarrMovies) => {
@@ -41,10 +60,20 @@ async function getLibrary(): Promise<Library> {
return getLibraryMovies(radarrMovies, radarrDownloads, continueWatching);
});
const series: PlayableSonarrSeries[] = await sonarrSeriesPromise.then(async (sonarrSeries) => {
const sonarrDownloads = await sonarrDownloadsPromise;
const continueWatching = await continueWatchingPromise;
return getLibrarySeries(sonarrSeries, sonarrDownloads, continueWatching);
});
return {
movies,
totalMovies: movies?.length || 0,
getItem: (tmdbId: number) => movies.find((m) => m.tmdbId === tmdbId)
series,
totalSeries: series?.length || 0,
getMovie: (tmdbId: number) => movies.find((m) => m.tmdbId === tmdbId),
getSeries: (tmdbId: number) => series.find((s) => s.tmdbId === tmdbId)
};
}
@@ -61,12 +90,11 @@ async function getLibraryMovies(
(i) => i.ProviderIds?.Tmdb === String(m.tmdbId)
);
const downloadProgress = radarrDownload
? radarrDownload.sizeleft && radarrDownload.size
const downloadProgress =
radarrDownload?.sizeleft && radarrDownload?.size
? ((radarrDownload.size - radarrDownload.sizeleft) / radarrDownload.size) * 100
: 0
: undefined;
const completionTime = radarrDownload ? radarrDownload.estimatedCompletionTime : undefined;
: undefined;
const completionTime = radarrDownload?.estimatedCompletionTime || undefined;
const download =
downloadProgress && completionTime
? { progress: downloadProgress, completionTime }
@@ -80,12 +108,12 @@ async function getLibraryMovies(
length && watchingProgress ? { length, progress: watchingProgress } : undefined;
const backdropUrl = await fetchTmdbMovieImages(String(m.tmdbId)).then(
(r) => r.backdrops.filter((b) => b.iso_639_1 === 'en')[0].file_path
(r) => r.backdrops.find((b) => b.iso_639_1 === 'en')?.file_path
);
return {
...m,
cardBackdropUrl: backdropUrl,
cardBackdropUrl: backdropUrl || '',
download,
continueWatching
};
@@ -93,3 +121,51 @@ async function getLibraryMovies(
return await Promise.all(playableMoviesPromises);
}
async function getLibrarySeries(
sonarrSeries: SonarrSeries[],
sonarrDownloads: SonarrDownload[],
jellyfinContinueWatching: JellyfinItem[]
): Promise<PlayableSonarrSeries[]> {
const playableSeriesPromises = sonarrSeries.map(async (s) => {
const sonarrDownload = sonarrDownloads.find((d) => d.series.tvdbId === s.tvdbId);
const jellyfinItem = jellyfinContinueWatching.find(
(i) => i.ProviderIds?.TvdbId === String(s.tvdbId)
);
const downloadProgress =
sonarrDownload?.sizeleft && sonarrDownload?.size
? ((sonarrDownload.size - sonarrDownload.sizeleft) / sonarrDownload.size) * 100
: undefined;
const completionTime = sonarrDownload?.estimatedCompletionTime || undefined;
const download =
downloadProgress && completionTime
? { progress: downloadProgress, completionTime }
: undefined;
const length = jellyfinItem?.RunTimeTicks
? jellyfinItem.RunTimeTicks / 10_000_000 / 60
: undefined;
const watchingProgress = jellyfinItem?.UserData?.PlayedPercentage;
const continueWatching =
length && watchingProgress ? { length, progress: watchingProgress } : undefined;
const tmdbId = s.tvdbId ? await getTmdbIdFromTvdbId(s.tvdbId) : undefined;
const backdropUrl = tmdbId
? await getTmdbSeriesImages(tmdbId).then(
(r) => r?.backdrops?.find((b) => b.iso_639_1 === 'en')?.file_path
)
: undefined;
return {
...s,
tmdbId,
cardBackdropUrl: backdropUrl || '',
download,
continueWatching
};
});
return await Promise.all(playableSeriesPromises);
}