Creepso/NuvioStreaming
1
0
Fork 0
mirror of https://github.com/tapframe/NuvioStreaming.git synced 2026-04-20 16:22:04 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Revert "Fix trakt scrobbling algorithm"

Browse source
This commit is contained in:
tapframe 2025-09-30 22:01:00 +05:30 committed by GitHub
parent 9d32c483eb
commit 5e22f3b0da
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 17 additions and 57 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

74
src/components/home/ContinueWatchingSection.tsx
View file

@ -227,47 +227,25 @@ const ContinueWatchingSection = React.forwardRef<ContinueWatchingRef>((props, re
contentGroups[contentKey].episodes.push({ key, episodeId, progress, progressPercent }); contentGroups[contentKey].episodes.push({ key, episodeId, progress, progressPercent });
} }
// Fetch Trakt watched movies and shows once and reuse // Fetch Trakt watched movies once and reuse
const traktDataPromise = (async () => { const traktMoviesSetPromise = (async () => {
try { try {
const traktService = TraktService.getInstance(); const traktService = TraktService.getInstance();
const isAuthed = await traktService.isAuthenticated(); const isAuthed = await traktService.isAuthenticated();
if (!isAuthed) return { watchedMovies: new Set<string>(), watchedShows: new Set<string>() }; if (!isAuthed) return new Set<string>();
if (typeof (traktService as any).getWatchedMovies === 'function') {
const [watchedMovies, watchedShows] = await Promise.all([ const watched = await (traktService as any).getWatchedMovies();
// Get watched movies if (Array.isArray(watched)) {
(async () => { const ids = watched
if (typeof (traktService as any).getWatchedMovies === 'function') { .map((w: any) => w?.movie?.ids?.imdb)
const watched = await (traktService as any).getWatchedMovies(); .filter(Boolean)
if (Array.isArray(watched)) { .map((imdb: string) => (imdb.startsWith('tt') ? imdb : `tt${imdb}`));
const ids = watched return new Set<string>(ids);
.map((w: any) => w?.movie?.ids?.imdb) }
.filter(Boolean) }
.map((imdb: string) => (imdb.startsWith('tt') ? imdb : `tt${imdb}`)); return new Set<string>();
return new Set<string>(ids);
}
}
return new Set<string>();
})(),
// Get watched shows
(async () => {
if (typeof (traktService as any).getWatchedShows === 'function') {
const watched = await (traktService as any).getWatchedShows();
if (Array.isArray(watched)) {
const ids = watched
.map((w: any) => w?.show?.ids?.imdb)
.filter(Boolean)
.map((imdb: string) => (imdb.startsWith('tt') ? imdb : `tt${imdb}`));
return new Set<string>(ids);
}
}
return new Set<string>();
})()
]);
return { watchedMovies, watchedShows };
} catch { } catch {
return { watchedMovies: new Set<string>(), watchedShows: new Set<string>() }; return new Set<string>();
} }
})(); })();
@ -275,13 +253,10 @@ const ContinueWatchingSection = React.forwardRef<ContinueWatchingRef>((props, re
const groupPromises = Object.values(contentGroups).map(async (group) => { const groupPromises = Object.values(contentGroups).map(async (group) => {
try { try {
if (!isSupportedId(group.id)) return; if (!isSupportedId(group.id)) return;
// Get Trakt data for filtering
const { watchedMovies, watchedShows } = await traktDataPromise;
// Skip movies that are already watched on Trakt // Skip movies that are already watched on Trakt
if (group.type === 'movie') { if (group.type === 'movie') {
if (watchedMovies.has(group.id)) { const watchedSet = await traktMoviesSetPromise;
if (watchedSet.has(group.id)) {
// Optional: sync local store to watched to prevent reappearance // Optional: sync local store to watched to prevent reappearance
try { try {
await storageService.setWatchProgress(group.id, 'movie', { await storageService.setWatchProgress(group.id, 'movie', {
@ -295,14 +270,6 @@ const ContinueWatchingSection = React.forwardRef<ContinueWatchingRef>((props, re
return; return;
} }
} }
// Skip shows that are marked as watched on Trakt (entire show)
if (group.type === 'series') {
if (watchedShows.has(group.id)) {
logger.log(`🚫 [TraktFilter] Skipping show marked as watched on Trakt: ${group.id}`);
return;
}
}
const cachedData = await getCachedMetadata(group.type, group.id); const cachedData = await getCachedMetadata(group.type, group.id);
if (!cachedData?.basicContent) return; if (!cachedData?.basicContent) return;
const { metadata, basicContent } = cachedData; const { metadata, basicContent } = cachedData;
@ -425,13 +392,6 @@ const ContinueWatchingSection = React.forwardRef<ContinueWatchingRef>((props, re
return; return;
} }
// Check if this show is marked as watched on Trakt (entire show)
const { watchedShows } = await traktDataPromise;
if (watchedShows.has(showId)) {
logger.log(`🚫 [TraktSync] Skipping show marked as watched on Trakt: ${showId}`);
return;
}
const nextEpisode = info.episode + 1; const nextEpisode = info.episode + 1;
const cachedData = await getCachedMetadata('series', showId); const cachedData = await getCachedMetadata('series', showId);
if (!cachedData?.basicContent) return; if (!cachedData?.basicContent) return;