-
Notifications
You must be signed in to change notification settings - Fork 68
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
b4f2758
commit f6210b6
Showing
13 changed files
with
1,450 additions
and
480 deletions.
There are no files selected for viewing
This file was deleted.
Oops, something went wrong.
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,216 @@ | ||
| "use server"; | ||
| import { ANIME } from "@consumet/extensions"; | ||
| import { CombineEpisodeMeta } from "@/utils/EpisodeFunctions"; | ||
| import { redis } from "@/lib/rediscache"; | ||
| import { getMappings } from "./mappings"; | ||
|
|
||
| const gogo = new ANIME.Gogoanime(); | ||
| const zoro = new ANIME.Zoro(); | ||
|
|
||
| export async function fetchGogoEpisodes(id) { | ||
| try { | ||
| const data = await gogo.fetchAnimeInfo(id); | ||
|
|
||
| return data?.episodes || []; | ||
| } catch (error) { | ||
| console.error("Error fetching gogoanime:", error.message); | ||
| return []; | ||
| } | ||
| } | ||
|
|
||
| export async function fetchZoroEpisodes(id) { | ||
| try { | ||
| const data = await zoro.fetchAnimeInfo(id); | ||
|
|
||
| return data?.episodes || []; | ||
| } catch (error) { | ||
| console.error("Error fetching zoro:", error.message); | ||
| return []; | ||
| } | ||
| } | ||
|
|
||
| async function fetchEpisodeMeta(id, available = false) { | ||
| try { | ||
| if (available) { | ||
| return null; | ||
| } | ||
| const res = await fetch( | ||
| `https://api.ani.zip/mappings?anilist_id=${id}` | ||
| ); | ||
| const data = await res.json() | ||
| const episodesArray = Object.values(data?.episodes); | ||
|
|
||
| if (!episodesArray) { | ||
| return []; | ||
| } | ||
| return episodesArray; | ||
| } catch (error) { | ||
| console.error("Error fetching and processing meta:", error.message); | ||
| return []; | ||
| } | ||
| } | ||
|
|
||
| const fetchAndCacheData = async (id, meta, redis, cacheTime, refresh) => { | ||
| let mappings; | ||
| let subEpisodes = []; | ||
| let dubEpisodes = []; | ||
| let allepisodes = []; | ||
|
|
||
| if (id) { | ||
| mappings = await getMappings(id); | ||
| } | ||
|
|
||
| if (mappings) { | ||
| if (mappings.gogoanime && Object.keys(mappings.gogoanime).length >= 1) { | ||
| // Fetch sub episodes if available | ||
| if ( | ||
| mappings?.gogoanime?.uncensored || | ||
| mappings?.gogoanime?.sub || | ||
| mappings?.gogoanime?.tv | ||
| ) { | ||
| subEpisodes = await fetchGogoEpisodes( | ||
| mappings?.gogoanime?.uncensored || | ||
| mappings.gogoanime.sub || | ||
| mappings?.gogoanime?.tv | ||
| ); | ||
| } | ||
|
|
||
| // Fetch dub episodes if available | ||
| if (mappings?.gogoanime?.dub) { | ||
| dubEpisodes = await fetchGogoEpisodes(mappings?.gogoanime?.dub); | ||
| } | ||
|
|
||
| if (subEpisodes?.length > 0 || dubEpisodes?.length > 0) { | ||
| allepisodes.push({ | ||
| episodes: { sub: subEpisodes, dub: dubEpisodes }, | ||
| providerId: "gogoanime", | ||
| consumet: true, | ||
| }); | ||
| } | ||
| } | ||
| if (mappings?.zoro && Object.keys(mappings.zoro).length >= 1) { | ||
| let subEpisodes = []; | ||
|
|
||
| // Fetch sub episodes if available | ||
| if ( | ||
| mappings?.zoro?.uncensored || | ||
| mappings?.zoro?.sub || | ||
| mappings?.zoro?.tv | ||
| ) { | ||
| subEpisodes = await fetchZoroEpisodes( | ||
| mappings?.zoro?.uncensored | ||
| ? mappings?.zoro?.uncensored | ||
| : mappings.zoro.sub | ||
| ); | ||
| } | ||
| if (subEpisodes?.length > 0) { | ||
| allepisodes.push({ | ||
| episodes: subEpisodes, | ||
| providerId: "zoro", | ||
| }); | ||
| } | ||
| } | ||
| } | ||
| const cover = await fetchEpisodeMeta(id, !refresh) | ||
|
|
||
| // Check if redis is available | ||
| if (redis) { | ||
| if (allepisodes) { | ||
| await redis.setex( | ||
| `episode:${id}`, | ||
| cacheTime, | ||
| JSON.stringify(allepisodes) | ||
| ); | ||
| } | ||
|
|
||
| let data = allepisodes; | ||
| if (refresh) { | ||
| if (cover && cover?.length > 0) { | ||
| try { | ||
| await redis.setex(`meta:${id}`, cacheTime, JSON.stringify(cover)); | ||
| data = await CombineEpisodeMeta(allepisodes, cover); | ||
| } catch (error) { | ||
| console.error("Error serializing cover:", error.message); | ||
| } | ||
| } else if (meta) { | ||
| data = await CombineEpisodeMeta(allepisodes, JSON.parse(meta)); | ||
| } | ||
| } else if (meta) { | ||
| data = await CombineEpisodeMeta(allepisodes, JSON.parse(meta)); | ||
| } | ||
|
|
||
| return data; | ||
| } else { | ||
| console.error("Redis URL not provided. Caching not possible."); | ||
| return allepisodes; | ||
| } | ||
| }; | ||
|
|
||
| export const getEpisodes = async (id, status, refresh = false) => { | ||
| let cacheTime = null; | ||
| if (status) { | ||
| cacheTime = 60 * 60 * 3; | ||
| } else { | ||
| cacheTime = 60 * 60 * 24 * 45; | ||
| } | ||
|
|
||
| let meta = null; | ||
| let cached; | ||
|
|
||
| if (redis) { | ||
| try { | ||
| // // Find keys matching the pattern "meta:*" | ||
| // const keys = await redis.keys("meta:*"); | ||
|
|
||
| // // Delete keys matching the pattern "meta:*" | ||
| // if (keys.length > 0) { | ||
| // await redis.del(keys); | ||
| // console.log(`Deleted ${keys.length} keys matching the pattern "meta:*"`); | ||
| // } | ||
| meta = await redis.get(`meta:${id}`); | ||
| if (JSON.parse(meta)?.length === 0) { | ||
| await redis.del(`meta:${id}`); | ||
| console.log("deleted meta cache"); | ||
| meta = null; | ||
| } | ||
| cached = await redis.get(`episode:${id}`); | ||
| if (JSON.parse(cached)?.length === 0) { | ||
| await redis.del(`episode:${id}`); | ||
| cached = null; | ||
| } | ||
| let data; | ||
| if (refresh) { | ||
| data = await fetchAndCacheData(id, meta, redis, cacheTime, refresh); | ||
| } | ||
| if (data?.length > 0) { | ||
| console.log("deleted cache"); | ||
| return data; | ||
| } | ||
|
|
||
| console.log("using redis"); | ||
| } catch (error) { | ||
| console.error("Error checking Redis cache:", error.message); | ||
| } | ||
| } | ||
|
|
||
| if (cached) { | ||
| try { | ||
| let cachedData = JSON.parse(cached); | ||
| if (meta) { | ||
| cachedData = await CombineEpisodeMeta(cachedData, JSON.parse(meta)); | ||
| } | ||
| return cachedData; | ||
| } catch (error) { | ||
| console.error("Error parsing cached data:", error.message); | ||
| } | ||
| } else { | ||
| const fetchdata = await fetchAndCacheData( | ||
| id, | ||
| meta, | ||
| redis, | ||
| cacheTime, | ||
| !refresh | ||
| ); | ||
| return fetchdata; | ||
| } | ||
| }; |
Oops, something went wrong.