movie-web/providers
1
0
Fork 0
mirror of https://github.com/movie-web/providers.git synced 2025-09-13 16:53:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix remotestream for real

Browse Source
This commit is contained in:
mrjvs
2024-01-05 19:36:26 +01:00
parent 39a6082a19
commit d49c408197
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/providers/sources/remotestream.ts
View File

@@ -16,8 +16,12 @@ export const remotestreamScraper = makeSourcerer({
const playlistLink = `${remotestreamBase}/Shows/${ctx.media.tmdbId}/${seasonNumber}/${episodeNumber}/${episodeNumber}.m3u8`; const playlistLink = `${remotestreamBase}/Shows/${ctx.media.tmdbId}/${seasonNumber}/${episodeNumber}/${episodeNumber}.m3u8`;
ctx.progress(30); ctx.progress(30);
const streamRes = await ctx.fetcher<Blob>(playlistLink); // TODO support blobs in fetchers const streamRes = await ctx.fetcher.full(playlistLink, {
if (streamRes.type !== 'application/x-mpegurl') throw new NotFoundError('No watchable item found'); method: 'HEAD',
readHeaders: ['content-type'],
});
if (!streamRes.headers.get('content-type')?.toLowerCase().includes('application/x-mpegurl'))
throw new NotFoundError('No watchable item found');
ctx.progress(90); ctx.progress(90);
return { return {
@@ -37,8 +41,12 @@ export const remotestreamScraper = makeSourcerer({
const playlistLink = `${remotestreamBase}/Movies/${ctx.media.tmdbId}/${ctx.media.tmdbId}.m3u8`; const playlistLink = `${remotestreamBase}/Movies/${ctx.media.tmdbId}/${ctx.media.tmdbId}.m3u8`;
ctx.progress(30); ctx.progress(30);
const streamRes = await ctx.fetcher<Blob>(playlistLink); const streamRes = await ctx.fetcher.full(playlistLink, {
if (streamRes.type !== 'application/x-mpegurl') throw new NotFoundError('No watchable item found'); method: 'HEAD',
readHeaders: ['content-type'],
});
if (!streamRes.headers.get('content-type')?.toLowerCase().includes('application/x-mpegurl'))
throw new NotFoundError('No watchable item found');
ctx.progress(90); ctx.progress(90);
return { return {