Merge pull request #154 from ztpn/tugaflix

add Tugaflix source

src/providers/all.ts

@@ -19,9 +19,11 @@ import { kissAsianScraper } from '@/providers/sources/kissasian/index';
 import { lookmovieScraper } from '@/providers/sources/lookmovie';
 import { remotestreamScraper } from '@/providers/sources/remotestream';
 import { showboxScraper } from '@/providers/sources/showbox/index';
+import { tugaflixScraper } from '@/providers/sources/tugaflix';
 import { vidsrcScraper } from '@/providers/sources/vidsrc/index';
 import { zoechipScraper } from '@/providers/sources/zoechip';
 
+import { bflixScraper } from './embeds/bflix';
 import { closeLoadScraper } from './embeds/closeload';
 import { fileMoonScraper } from './embeds/filemoon';
 import { ridooScraper } from './embeds/ridoo';
@@ -38,6 +40,7 @@ import { wootlyScraper } from './embeds/wootly';
 import { goojaraScraper } from './sources/goojara';
 import { hdRezkaScraper } from './sources/hdrezka';
 import { nepuScraper } from './sources/nepu';
+import { nitesScraper } from './sources/nites';
 import { primewireScraper } from './sources/primewire';
 import { ridooMoviesScraper } from './sources/ridomovies';
 import { smashyStreamScraper } from './sources/smashystream';
@@ -65,7 +68,9 @@ export function gatherAllSources(): Array<Sourcerer> {
     primewireScraper,
     warezcdnScraper,
     insertunitScraper,
+    nitesScraper,
     soaperTvScraper,
+    tugaflixScraper,
   ];
 }
 
@@ -98,5 +103,6 @@ export function gatherAllEmbeds(): Array<Embed> {
     vTubeScraper,
     warezcdnembedHlsScraper,
     warezcdnembedMp4Scraper,
+    bflixScraper,
   ];
 }

src/providers/embeds/bflix.ts

@@ -0,0 +1,42 @@
+import { unpack } from 'unpacker';
+
+import { makeEmbed } from '@/providers/base';
+
+const evalCodeRegex = /eval\((.*)\)/g;
+const mp4Regex = /https?:\/\/.*\.mp4/;
+
+export const bflixScraper = makeEmbed({
+  id: 'bflix',
+  name: 'bFlix',
+  rank: 113,
+  scrape: async (ctx) => {
+    const mainPage = await ctx.proxiedFetcher<string>(ctx.url);
+
+    const evalCode = mainPage.match(evalCodeRegex);
+    if (!evalCode) throw new Error('Failed to find eval code');
+    const unpacked = unpack(evalCode[0]);
+
+    const file = unpacked.match(mp4Regex);
+    if (!file?.[0]) throw new Error('Failed to find file');
+
+    return {
+      stream: [
+        {
+          id: 'primary',
+          type: 'file',
+          flags: [],
+          captions: [],
+          qualities: {
+            unknown: {
+              type: 'mp4',
+              url: file[0],
+            },
+          },
+          headers: {
+            Referer: 'https://bflix.gs/',
+          },
+        },
+      ],
+    };
+  },
+});

src/providers/sources/nites.ts

@@ -0,0 +1,79 @@
+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://w1.nites.is';
+
+async function comboScraper(ctx: ShowScrapeContext | MovieScrapeContext): Promise<SourcererOutput> {
+  const searchPage = await ctx.proxiedFetcher('/wp-admin/admin-ajax.php', {
+    baseUrl,
+    method: 'POST',
+    body: new URLSearchParams({
+      action: 'ajax_pagination',
+      query_vars: 'mixed',
+      search: ctx.media.title,
+    }),
+  });
+
+  const $search = load(searchPage);
+  const searchResults: { title: string; year: number; url: string }[] = [];
+
+  $search('li').each((_, element) => {
+    const title = $search(element).find('.entry-title').first().text().trim();
+    const year = parseInt($search(element).find('.year').first().text().trim(), 10);
+    const url = $search(element).find('.lnk-blk').attr('href');
+    if (!title || !year || !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));
+
+  // it embeds vidsrc when it bflix does not has the stream
+  // i think all shows embed vidsrc, not sure
+  const embedUrl = watchPage('ul.bx-lst li a:contains("- Bflix")')
+    .closest('aside')
+    .next('div.video-options')
+    .find('iframe')
+    .attr('data-lazy-src');
+
+  if (!embedUrl) throw new Error('Failed to find embed url');
+
+  const embedPage = load(await ctx.proxiedFetcher(embedUrl));
+
+  const url = embedPage('iframe').attr('src');
+  if (!url) throw new Error('Failed to find embed url');
+
+  return {
+    embeds: [
+      {
+        embedId: 'bflix',
+        url,
+      },
+    ],
+  };
+}
+
+export const nitesScraper = makeSourcerer({
+  id: 'nites',
+  name: 'Nites',
+  rank: 90,
+  flags: [],
+  scrapeMovie: comboScraper,
+  scrapeShow: comboScraper,
+});

src/providers/sources/tugaflix/common.ts

@@ -0,0 +1,21 @@
+import { load } from 'cheerio';
+
+export const baseUrl = 'https://tugaflix.best/';
+
+export function parseSearch(page: string): { title: string; year?: number; url: string }[] {
+  const results: { title: string; year?: number; url: string }[] = [];
+  const $ = load(page);
+
+  $('.items .poster').each((_, element) => {
+    const $link = $(element).find('a');
+    const url = $link.attr('href');
+    // ex title: Home Alone (1990)
+    const [, title, year] = $link.attr('title')?.match(/^(.*?)\s*(?:\((\d{4})\))?\s*$/) || [];
+    if (!title || !url) return;
+
+    // tiles dont always have the year
+    results.push({ title, year: year ? parseInt(year, 10) : undefined, url });
+  });
+
+  return results;
+}

src/providers/sources/tugaflix/index.ts

@@ -0,0 +1,116 @@
+import { load } from 'cheerio';
+
+import { flags } from '@/entrypoint/utils/targets';
+import { SourcererEmbed, makeSourcerer } from '@/providers/base';
+import { compareMedia } from '@/utils/compare';
+import { NotFoundError } from '@/utils/errors';
+
+import { baseUrl, parseSearch } from './common';
+
+export const tugaflixScraper = makeSourcerer({
+  id: 'tugaflix',
+  name: 'Tugaflix',
+  rank: 73,
+  flags: [flags.IP_LOCKED],
+  scrapeMovie: async (ctx) => {
+    const searchResults = parseSearch(
+      await ctx.proxiedFetcher<string>('/filmes/', {
+        baseUrl,
+        query: {
+          s: ctx.media.title,
+        },
+      }),
+    );
+    if (searchResults.length === 0) throw new NotFoundError('No watchable item found');
+
+    const url = searchResults.find((x) => x && compareMedia(ctx.media, x.title, x.year))?.url;
+    if (!url) throw new NotFoundError('No watchable item found');
+
+    const videoPage = await ctx.proxiedFetcher<string>(url, {
+      method: 'POST',
+      body: new URLSearchParams({ play: '' }),
+    });
+    const $ = load(videoPage);
+
+    const embeds: SourcererEmbed[] = [];
+
+    for (const element of $('.play a')) {
+      const embedUrl = $(element).attr('href');
+      if (!embedUrl) continue;
+
+      const embedPage = await ctx.proxiedFetcher.full(
+        embedUrl.startsWith('https://') ? embedUrl : `https://${embedUrl}`,
+      );
+
+      const finalUrl = load(embedPage.body)('a:contains("Download Filme")').attr('href');
+      if (!finalUrl) continue;
+
+      if (finalUrl.includes('streamtape')) {
+        embeds.push({
+          embedId: 'streamtape',
+          url: finalUrl,
+        });
+        // found doodstream on a few shows, maybe movies use it too?
+        // the player 2 is just streamtape in a custom player
+      } else if (finalUrl.includes('dood')) {
+        embeds.push({
+          embedId: 'dood',
+          url: finalUrl,
+        });
+      }
+    }
+
+    return {
+      embeds,
+    };
+  },
+  scrapeShow: async (ctx) => {
+    const searchResults = parseSearch(
+      await ctx.proxiedFetcher<string>('/series/', {
+        baseUrl,
+        query: {
+          s: ctx.media.title,
+        },
+      }),
+    );
+    if (searchResults.length === 0) throw new NotFoundError('No watchable item found');
+
+    const url = searchResults.find((x) => x && compareMedia(ctx.media, x.title, x.year))?.url;
+    if (!url) throw new NotFoundError('No watchable item found');
+
+    const s = ctx.media.season.number < 10 ? `0${ctx.media.season.number}` : ctx.media.season.number.toString();
+    const e = ctx.media.episode.number < 10 ? `0${ctx.media.episode.number}` : ctx.media.episode.number.toString();
+    const videoPage = await ctx.proxiedFetcher(url, {
+      method: 'POST',
+      body: new URLSearchParams({ [`S${s}E${e}`]: '' }),
+    });
+
+    const embedUrl = load(videoPage)('iframe[name="player"]').attr('src');
+    if (!embedUrl) throw new Error('Failed to find iframe');
+
+    const playerPage = await ctx.proxiedFetcher(embedUrl.startsWith('https:') ? embedUrl : `https:${embedUrl}`, {
+      method: 'POST',
+      body: new URLSearchParams({ submit: '' }),
+    });
+
+    const embeds: SourcererEmbed[] = [];
+
+    const finalUrl = load(playerPage)('a:contains("Download Episodio")').attr('href');
+
+    if (finalUrl?.includes('streamtape')) {
+      embeds.push({
+        embedId: 'streamtape',
+        url: finalUrl,
+      });
+    } else if (finalUrl?.includes('dood')) {
+      embeds.push({
+        embedId: 'dood',
+        url: finalUrl,
+      });
+    }
+
+    return {
+      embeds,
+    };
+  },
+});