ItsSkaiya/WaifuBoard
3
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 8 Wiki Activity

fix on anime stream data

Browse Source
This commit is contained in:
lenafx
2026-01-05 03:58:44 +01:00
parent 4a711accad
commit 5401a5e302
4 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
desktop/src/api/anime/anime.service.ts
View File

@@ -466,7 +466,10 @@ export async function searchEpisodesInExtension(ext: Extension | null, name: str
export async function getStreamData(extension: Extension, episode: string, id: string, source: string, server?: string, category?: string, extensionAnimeId?: string): Promise<StreamData> { export async function getStreamData(extension: Extension, episode: string, id: string, source: string, server?: string, category?: string, extensionAnimeId?: string): Promise<StreamData> {
const providerName = extension.constructor.name; const providerName = extension.constructor.name;
const cacheKey = `anime:stream:${providerName}:${id}:${episode}:${server || 'default'}:${category || 'sub'}`; const finalCategory = category ?? "sub";
const cacheKey =
`anime:stream:${providerName}:${id}:${episode}:${server}:${finalCategory}`;
if (!extensionAnimeId) { if (!extensionAnimeId) {
const cached = await getCache(cacheKey); const cached = await getCache(cacheKey);
@@ -498,7 +501,6 @@ export async function getStreamData(extension: Extension, episode: string, id: s
episodes = await extension.findEpisodes(targetId); episodes = await extension.findEpisodes(targetId);
if (extensionAnimeId) { if (extensionAnimeId) {
const anime: any = await getAnimeById(id); const anime: any = await getAnimeById(id);
animeTitle = anime.title.romaji; animeTitle = anime.title.romaji;
@@ -523,8 +525,7 @@ export async function getStreamData(extension: Extension, episode: string, id: s
throw new Error("Episode not found"); throw new Error("Episode not found");
} }
const serverName = server || "default"; const streamData = await extension.findEpisodeServer(targetEp, server, category);
const streamData = await extension.findEpisodeServer(targetEp, serverName);
await setCache(cacheKey, streamData, CACHE_TTL_MS); await setCache(cacheKey, streamData, CACHE_TTL_MS);
return streamData; return streamData;

2
desktop/src/api/types.ts
View File

@@ -99,7 +99,7 @@ export interface Extension {
mediaType?: 'manga' | 'ln'; mediaType?: 'manga' | 'ln';
search?: (options: ExtensionSearchOptions) => Promise<ExtensionSearchResult[]>; search?: (options: ExtensionSearchOptions) => Promise<ExtensionSearchResult[]>;
findEpisodes?: (id: string) => Promise<Episode[]>; findEpisodes?: (id: string) => Promise<Episode[]>;
findEpisodeServer?: (episode: Episode, server: string) => Promise<any>; findEpisodeServer?: (s: any, server1: string | undefined, category: string | undefined) => Promise<any>;
findChapters?: (id: string) => Promise<Chapter[]>; findChapters?: (id: string) => Promise<Chapter[]>;
findChapterPages?: (chapterId: string) => Promise<any>; findChapterPages?: (chapterId: string) => Promise<any>;
getSettings?: () => ExtensionSettings; getSettings?: () => ExtensionSettings;

9
docker/src/api/anime/anime.service.ts
View File

@@ -466,7 +466,10 @@ export async function searchEpisodesInExtension(ext: Extension | null, name: str
export async function getStreamData(extension: Extension, episode: string, id: string, source: string, server?: string, category?: string, extensionAnimeId?: string): Promise<StreamData> { export async function getStreamData(extension: Extension, episode: string, id: string, source: string, server?: string, category?: string, extensionAnimeId?: string): Promise<StreamData> {
const providerName = extension.constructor.name; const providerName = extension.constructor.name;
const cacheKey = `anime:stream:${providerName}:${id}:${episode}:${server || 'default'}:${category || 'sub'}`; const finalCategory = category ?? "sub";
const cacheKey =
`anime:stream:${providerName}:${id}:${episode}:${server}:${finalCategory}`;
if (!extensionAnimeId) { if (!extensionAnimeId) {
const cached = await getCache(cacheKey); const cached = await getCache(cacheKey);
@@ -498,7 +501,6 @@ export async function getStreamData(extension: Extension, episode: string, id: s
episodes = await extension.findEpisodes(targetId); episodes = await extension.findEpisodes(targetId);
if (extensionAnimeId) { if (extensionAnimeId) {
const anime: any = await getAnimeById(id); const anime: any = await getAnimeById(id);
animeTitle = anime.title.romaji; animeTitle = anime.title.romaji;
@@ -523,8 +525,7 @@ export async function getStreamData(extension: Extension, episode: string, id: s
throw new Error("Episode not found"); throw new Error("Episode not found");
} }
const serverName = server || "default"; const streamData = await extension.findEpisodeServer(targetEp, server, category);
const streamData = await extension.findEpisodeServer(targetEp, serverName);
await setCache(cacheKey, streamData, CACHE_TTL_MS); await setCache(cacheKey, streamData, CACHE_TTL_MS);
return streamData; return streamData;

2
docker/src/api/types.ts
View File

@@ -99,7 +99,7 @@ export interface Extension {
mediaType?: 'manga' | 'ln'; mediaType?: 'manga' | 'ln';
search?: (options: ExtensionSearchOptions) => Promise<ExtensionSearchResult[]>; search?: (options: ExtensionSearchOptions) => Promise<ExtensionSearchResult[]>;
findEpisodes?: (id: string) => Promise<Episode[]>; findEpisodes?: (id: string) => Promise<Episode[]>;
findEpisodeServer?: (episode: Episode, server: string) => Promise<any>; findEpisodeServer?: (s: any, server1: string | undefined, category: string | undefined) => Promise<any>;
findChapters?: (id: string) => Promise<Chapter[]>; findChapters?: (id: string) => Promise<Chapter[]>;
findChapterPages?: (chapterId: string) => Promise<any>; findChapterPages?: (chapterId: string) => Promise<any>;
getSettings?: () => ExtensionSettings; getSettings?: () => ExtensionSettings;