providers/src/providers/sources/soapertv/index.ts

import { load } from 'cheerio';

import { flags } from '@/entrypoint/utils/targets';
import { Caption, labelToLanguageCode } from '@/providers/captions';
import { MovieScrapeContext, ShowScrapeContext } from '@/utils/context';
import { NotFoundError } from '@/utils/errors';

import { InfoResponse } from './types';
import { SourcererOutput, makeSourcerer } from '../../base';

const baseUrl = 'https://soaper.tv';

const universalScraper = async (ctx: MovieScrapeContext | ShowScrapeContext): Promise<SourcererOutput> => {
  const searchResult = await ctx.proxiedFetcher('/search.html', {
    baseUrl,
    query: {
      keyword: ctx.media.title,
    },
  });
  const searchResult$ = load(searchResult);
  let showLink = searchResult$('a')
    .filter((_, el) => searchResult$(el).text() === ctx.media.title)
    .attr('href');
  if (!showLink) throw new NotFoundError('Content not found');

  if (ctx.media.type === 'show') {
    const seasonNumber = ctx.media.season.number;
    const episodeNumber = ctx.media.episode.number;
    const showPage = await ctx.proxiedFetcher(showLink, { baseUrl });
    const showPage$ = load(showPage);
    const seasonBlock = showPage$('h4')
      .filter((_, el) => showPage$(el).text().trim().split(':')[0].trim() === `Season${seasonNumber}`)
      .parent();
    const episodes = seasonBlock.find('a').toArray();
    showLink = showPage$(
      episodes.find((el) => parseInt(showPage$(el).text().split('.')[0], 10) === episodeNumber),
    ).attr('href');
  }
  if (!showLink) throw new NotFoundError('Content not found');
  const contentPage = await ctx.proxiedFetcher(showLink, { baseUrl });
  const contentPage$ = load(contentPage);

  const pass = contentPage$('#hId').attr('value');
  const param = contentPage$('#divU').text();

  if (!pass || !param) throw new NotFoundError('Content not found');

  const formData = new URLSearchParams();
  formData.append('pass', pass);
  formData.append('param', param);
  formData.append('e2', '0');
  formData.append('server', '0');

  const infoEndpoint = ctx.media.type === 'show' ? '/home/index/getEInfoAjax' : '/home/index/getMInfoAjax';
  const streamRes = await ctx.proxiedFetcher<string>(infoEndpoint, {
    baseUrl,
    method: 'POST',
    body: formData,
    headers: {
      referer: `${baseUrl}${showLink}`,
    },
  });

  const streamResJson: InfoResponse = JSON.parse(streamRes);

  const captions: Caption[] = [];
  for (const sub of streamResJson.subs) {
    // Some subtitles are named <Language>.srt, some are named <LanguageCode>:hi, or just <LanguageCode>
    let language: string | null = '';
    if (sub.name.includes('.srt')) {
      language = labelToLanguageCode(sub.name.split('.srt')[0]);
    } else if (sub.name.includes(':')) {
      language = sub.name.split(':')[0];
    } else {
      language = sub.name;
    }
    if (!language) continue;

    captions.push({
      id: sub.path,
      url: sub.path,
      type: 'srt',
      hasCorsRestrictions: false,
      language,
    });
  }

  return {
    embeds: [],
    stream: [
      {
        id: 'primary',
        playlist: streamResJson.val,
        type: 'hls',
        flags: [flags.IP_LOCKED],
        captions,
      },
      ...(streamResJson.val_bak
        ? [
            {
              id: 'backup',
              playlist: streamResJson.val_bak,
              type: 'hls' as const,
              flags: [flags.IP_LOCKED],
              captions,
            },
          ]
        : []),
    ],
  };
};

export const soaperTvScraper = makeSourcerer({
  id: 'soapertv',
  name: 'SoaperTV',
  rank: 115,
  flags: [flags.IP_LOCKED],
  scrapeMovie: universalScraper,
  scrapeShow: universalScraper,
});