File size: 2,229 Bytes
11acfd9 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 |
import axios from "axios";
import createHttpError from "http-errors";
import { type RequestHandler } from "express";
import { type CheerioAPI, load } from "cheerio";
import { scrapeAnimeEpisodeSources } from "../parsers/index.js";
import { USER_AGENT_HEADER, SRC_BASE_URL } from "../utils/constants.js";
import { type AnimeServers, Servers } from "../types/anime.js";
import { type AnimeEpisodeSrcsQueryParams } from "../types/controllers/index.js";
type AnilistID = number | null;
type MalID = number | null;
// /anime/episode-srcs?id=${episodeId}?server=${server}&category=${category (dub or sub)}
const getAnimeEpisodeSources: RequestHandler<
unknown,
Awaited<ReturnType<typeof scrapeAnimeEpisodeSources & AnilistID>>,
unknown,
AnimeEpisodeSrcsQueryParams
> = async (req, res, next) => {
try {
const episodeId = req.query.id ? decodeURIComponent(req.query.id) : null;
const server = (
req.query.server
? decodeURIComponent(req.query.server)
: Servers.VidStreaming
) as AnimeServers;
const category = (
req.query.category ? decodeURIComponent(req.query.category) : "sub"
) as "sub" | "dub";
if (episodeId === null) {
throw createHttpError.BadRequest("Anime episode id required");
}
let malID: MalID;
let anilistID: AnilistID;
const animeURL = new URL(episodeId?.split("?ep=")[0], SRC_BASE_URL)?.href;
const [episodeSrcData, animeSrc] = await Promise.all([
scrapeAnimeEpisodeSources(episodeId, server, category),
axios.get(animeURL, {
headers: {
Referer: SRC_BASE_URL,
"User-Agent": USER_AGENT_HEADER,
"X-Requested-With": "XMLHttpRequest",
},
}),
]);
const $: CheerioAPI = load(animeSrc?.data);
try {
anilistID = Number(
JSON.parse($("body")?.find("#syncData")?.text())?.anilist_id
);
malID = Number(JSON.parse($("body")?.find("#syncData")?.text())?.mal_id);
} catch (err) {
anilistID = null;
malID = null;
}
res.status(200).json({
...episodeSrcData,
anilistID,
malID,
});
} catch (err: any) {
console.error(err);
next(err);
}
};
export default getAnimeEpisodeSources;
|