Add catflix source

src/providers/all.ts

@@ -13,6 +13,7 @@ import { upstreamScraper } from '@/providers/embeds/upstream';
 import { vidsrcembedScraper } from '@/providers/embeds/vidsrc';
 import { vTubeScraper } from '@/providers/embeds/vtube';
 import { autoembedScraper } from '@/providers/sources/autoembed';
+import { catflixScraper } from '@/providers/sources/catflix';
 import { flixhqScraper } from '@/providers/sources/flixhq/index';
 import { goMoviesScraper } from '@/providers/sources/gomovies/index';
 import { insertunitScraper } from '@/providers/sources/insertunit';
@@ -65,6 +66,7 @@ import { warezcdnScraper } from './sources/warezcdn';
 export function gatherAllSources(): Array<Sourcerer> {
   // all sources are gathered here
   return [
+    catflixScraper,
     flixhqScraper,
     remotestreamScraper,
     kissAsianScraper,

src/providers/sources/catflix.ts

@@ -0,0 +1,66 @@
+import { load } from 'cheerio';
+
+import { SourcererOutput, makeSourcerer } from '@/providers/base';
+import { compareMedia } from '@/utils/compare';
+import { MovieScrapeContext, ShowScrapeContext } from '@/utils/context';
+import { NotFoundError } from '@/utils/errors';
+
+const baseUrl = 'https://catflix.su';
+
+async function comboScraper(ctx: ShowScrapeContext | MovieScrapeContext): Promise<SourcererOutput> {
+  const searchPage = await ctx.proxiedFetcher('/', {
+    baseUrl,
+    query: {
+      s: ctx.media.title,
+    },
+  });
+
+  const $search = load(searchPage);
+  const searchResults: { title: string; year?: number | undefined; url: string }[] = [];
+
+  $search('li').each((_, element) => {
+    const title = $search(element).find('h2').first().text().trim();
+    // the year is always present, but I sitll decided to make it nullable since the impl isn't as future-proof
+    const year = Number($search(element).find('.text-xs > span').eq(1).text().trim()) || undefined;
+    const url = $search(element).find('a').attr('href');
+
+    if (!title || !url) return;
+
+    searchResults.push({ title, year, url });
+  });
+
+  let watchPageUrl = searchResults.find((x) => x && compareMedia(ctx.media, x.title, x.year))?.url;
+  if (!watchPageUrl) throw new NotFoundError('No watchable item found');
+
+  if (ctx.media.type === 'show') {
+    const match = watchPageUrl.match(/\/series\/([^/]+)\/?/);
+    if (!match) throw new Error('Failed to parse watch page url');
+    watchPageUrl = watchPageUrl.replace(
+      `/series/${match[1]}`,
+      `/episode/${match[1]}-${ctx.media.season.number}x${ctx.media.episode.number}`,
+    );
+  }
+
+  const watchPage = load(await ctx.proxiedFetcher(watchPageUrl));
+
+  const url = watchPage('iframe').first().attr('src'); // I couldn't think of a better way
+  if (!url) throw new Error('Failed to find embed url');
+
+  return {
+    embeds: [
+      {
+        embedId: 'turbovid',
+        url,
+      },
+    ],
+  };
+}
+
+export const catflixScraper = makeSourcerer({
+  id: 'catflix',
+  name: 'Catflix',
+  rank: 122,
+  flags: [],
+  scrapeMovie: comboScraper,
+  scrapeShow: comboScraper,
+});