mirror of
https://github.com/tapframe/NuvioStreaming.git
synced 2026-04-21 00:32:04 +00:00
trakt fix test
This commit is contained in:
parent
3d9d0f297c
commit
a25ede1284
2 changed files with 40 additions and 1 deletions
|
|
@ -227,10 +227,49 @@ 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 once and reuse
|
||||||
|
const traktMoviesSetPromise = (async () => {
|
||||||
|
try {
|
||||||
|
const traktService = TraktService.getInstance();
|
||||||
|
const isAuthed = await traktService.isAuthenticated();
|
||||||
|
if (!isAuthed) return new Set<string>();
|
||||||
|
if (typeof (traktService as any).getWatchedMovies === 'function') {
|
||||||
|
const watched = await (traktService as any).getWatchedMovies();
|
||||||
|
if (Array.isArray(watched)) {
|
||||||
|
const ids = watched
|
||||||
|
.map((w: any) => w?.movie?.ids?.imdb)
|
||||||
|
.filter(Boolean)
|
||||||
|
.map((imdb: string) => (imdb.startsWith('tt') ? imdb : `tt${imdb}`));
|
||||||
|
return new Set<string>(ids);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return new Set<string>();
|
||||||
|
} catch {
|
||||||
|
return new Set<string>();
|
||||||
|
}
|
||||||
|
})();
|
||||||
|
|
||||||
// Process each content group concurrently, merging results as they arrive
|
// Process each content group concurrently, merging results as they arrive
|
||||||
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;
|
||||||
|
// Skip movies that are already watched on Trakt
|
||||||
|
if (group.type === 'movie') {
|
||||||
|
const watchedSet = await traktMoviesSetPromise;
|
||||||
|
if (watchedSet.has(group.id)) {
|
||||||
|
// Optional: sync local store to watched to prevent reappearance
|
||||||
|
try {
|
||||||
|
await storageService.setWatchProgress(group.id, 'movie', {
|
||||||
|
currentTime: 1,
|
||||||
|
duration: 1,
|
||||||
|
lastUpdated: Date.now(),
|
||||||
|
traktSynced: true,
|
||||||
|
traktProgress: 100,
|
||||||
|
} as any);
|
||||||
|
} catch (_e) {}
|
||||||
|
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;
|
||||||
|
|
|
||||||
|
|
@ -224,7 +224,7 @@ const StreamCard = memo(({ stream, onPress, index, isLoading, statusMessage, the
|
||||||
showAlert('Stream URL', stream.url);
|
showAlert('Stream URL', stream.url);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}, [stream.url]);
|
}, [stream.url, showAlert]);
|
||||||
const styles = React.useMemo(() => createStyles(theme.colors), [theme.colors]);
|
const styles = React.useMemo(() => createStyles(theme.colors), [theme.colors]);
|
||||||
|
|
||||||
const streamInfo = useMemo(() => {
|
const streamInfo = useMemo(() => {
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue