Creepso/webstreamr-github
1
0
Fork 0
Code Issues 27 Pull requests 7 Projects Releases 240 Packages Wiki Activity Actions

Update TurboVIPlay.ts

Browse source
This commit is contained in:
GSTAR 2025-10-31 21:32:14 +01:00 committed by webstreamr
parent 9d90f12164
commit 70c66ce4f9
1 changed files with 65 additions and 54 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

119
src/extractor/TurboVIPlay.ts
View file

@ -26,67 +26,78 @@ export class TurboVIPlay extends Extractor {
return new URL(url.href.replace(/\/(e|d|embed-)\//, '/t/'));
}
protected async extractInternal(ctx: Context, url: URL, meta: Meta): Promise<UrlResult[]> {
const headers = { Referer: url.origin };
protected async extractInternal(ctx: Context, url: URL, meta: Meta): Promise<UrlResult[]> {
const headers: Record<string, string> = { Referer: url.origin };
// Fetch HTML page
const html = await this.fetcher.text(ctx, url, { headers });
if (!html || html.includes('File Not Found') || html.includes('Pending in queue')) {
throw new NotFoundError();
}
// Extract media URL
const match = html.match(/(?:urlPlay|data-hash)\s*=\s*['"](?<url>[^"']+)/);
const mediaUrl = match?.groups?.['url'];
if (!mediaUrl) throw new NotFoundError('Video link not found');
// Fetch HTML page
const html = await this.fetcher.text(ctx, url, headers);
if (!html || html.includes('File Not Found') || html.includes('Pending in queue')) {
throw new NotFoundError();
}
// Normalize URL
const masterUrl = mediaUrl.startsWith('//') ? 'https:' + mediaUrl :
mediaUrl.startsWith('/') ? url.origin + mediaUrl :
mediaUrl;
// Extract media URL
const match = html.match(/(?:urlPlay|data-hash)\s*=\s*['"](?<url>[^"']+)/);
const mediaUrl = match?.groups?.['url'];
if (!mediaUrl) throw new NotFoundError('Video link not found');
let hlsUrl = masterUrl;
// Normalize URL
const masterUrl = mediaUrl.startsWith('//')
? 'https:' + mediaUrl
: mediaUrl.startsWith('/')
? url.origin + mediaUrl
: mediaUrl;
// Parse master playlist to pick highest resolution variant
try {
const playlistText = await this.fetcher.text(ctx, new URL(masterUrl), { headers });
if (playlistText.includes('#EXT-X-STREAM-INF')) {
const variants = Array.from(
playlistText.matchAll(/#EXT-X-STREAM-INF:.*RESOLUTION=(\d+)x(\d+)[^\n]*\n([^\n]+)/g)
);
if (variants.length) {
variants.sort((a, b) => parseInt(b[2] ?? '0', 10) - parseInt(a[2] ?? '0', 10));
const best = variants[0]?.[3];
if (best) {
const base = new URL(masterUrl);
hlsUrl = best.startsWith('http') ? best :
best.startsWith('/') ? new URL(best, base.origin).href :
new URL(best, base.href).href;
}
let hlsUrl = masterUrl;
// Parse master playlist to pick highest resolution variant
try {
const playlistText = await this.fetcher.text(ctx, new URL(masterUrl), headers);
if (playlistText.includes('#EXT-X-STREAM-INF')) {
const variants = Array.from(
playlistText.matchAll(/#EXT-X-STREAM-INF:.*RESOLUTION=(\d+)x(\d+)[^\n]*\n([^\n]+)/g)
);
if (variants.length) {
// Sort by height descending
variants.sort((a, b) => parseInt(b[2] ?? '0', 10) - parseInt(a[2] ?? '0', 10));
const best = variants[0]?.[3];
if (best) {
const base = new URL(masterUrl);
hlsUrl = best.startsWith('http')
? best
: best.startsWith('/')
? new URL(best, base.origin).href
: new URL(best, base.href).href;
}
}
} catch {
// fallback to masterUrl
}
// Guess height from master playlist
let height: number | undefined;
try {
height = await guessHeightFromPlaylist(ctx, this.fetcher, new URL(masterUrl), { headers });
} catch {}
// Extract title
const $ = cheerio.load(html);
const title = $('title').text().trim() || this.label;
return [{
url: new URL(hlsUrl),
format: Format.hls,
label: this.label,
sourceId: `${this.id}_${meta.countryCodes?.join('_') ?? 'all'}`,
ttl: this.ttl,
requestHeaders: headers,
meta: { ...meta, title, height },
}];
} catch {
// fallback to masterUrl
}
// Guess height from master playlist
let height: number | undefined;
try {
height = await guessHeightFromPlaylist(ctx, this.fetcher, new URL(masterUrl), new URL(masterUrl), headers);
} catch {
// ignore
}
// Extract title
const $ = cheerio.load(html);
const title = $('title').text().trim() || this.label;
return [{
url: new URL(hlsUrl),
format: Format.hls,
label: this.label,
sourceId: `${this.id}_${meta.countryCodes?.join('_') ?? 'all'}`,
ttl: this.ttl,
requestHeaders: headers,
meta: { ...meta, title, height },
}];
}
}