Skip to content

Commit

Permalink
feat: add anilistID in response
Browse files Browse the repository at this point in the history
  • Loading branch information
ghoshRitesh12 committed Dec 16, 2023
1 parent 2453804 commit 4cf7e46
Showing 1 changed file with 33 additions and 3 deletions.
36 changes: 33 additions & 3 deletions src/controllers/animeEpisodeSrcs.controller.ts
Original file line number Diff line number Diff line change
@@ -1,13 +1,18 @@
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 "../models/anime.js";
import { type AnimeEpisodeSrcsQueryParams } from "../models/controllers/index.js";

type AnilistID = number | null;

// /anime/episode-srcs?id=${episodeId}?server=${server}&category=${category (dub or sub)}
const getAnimeEpisodeSources: RequestHandler<
unknown,
Awaited<ReturnType<typeof scrapeAnimeEpisodeSources>>,
Awaited<ReturnType<typeof scrapeAnimeEpisodeSources & AnilistID>>,
unknown,
AnimeEpisodeSrcsQueryParams
> = async (req, res, next) => {
Expand All @@ -28,9 +33,34 @@ const getAnimeEpisodeSources: RequestHandler<
throw createHttpError.BadRequest("Anime episode id required");
}

const data = await scrapeAnimeEpisodeSources(episodeId, server, category);
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
);
} catch (err) {
anilistID = null;
}

res.status(200).json(data);
res.status(200).json({
...episodeSrcData,
anilistID,
});
} catch (err: any) {
console.error(err);
next(err);
Expand Down

0 comments on commit 4cf7e46

Please sign in to comment.