yuzu/play-dl-test
1
0
Fork 0
mirror of https://github.com/YuzuZensai/play-dl-test.git synced 2026-01-06 04:32:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Retry Option added

Browse Source
This commit is contained in:
killer069
2021-09-06 13:12:35 +05:30
parent 3c0e358e20
commit ca87a9877e
5 changed files with 48 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
play-dl/YouTube/stream.ts
View File

@@ -10,6 +10,10 @@ export enum StreamType{
Opus = 'opus',
}
interface StreamOptions{
cookie? : string;
retry? : boolean;
}
interface InfoData{
LiveStreamData : {
@@ -35,22 +39,23 @@ function parseAudioFormats(formats : any[]){
return result
}
export async function stream(url : string, cookie? : string): Promise<Stream | LiveStreaming>{
let info = await video_info(url, cookie)
export async function stream(url : string, options : StreamOptions = { retry : false }): Promise<Stream | LiveStreaming>{
let info = await video_info(url, options.cookie)
let final: any[] = [];
let type : StreamType;
if(info.LiveStreamData.isLive === true && info.LiveStreamData.hlsManifestUrl !== null && info.video_details.durationInSec === '0') {
return new LiveStreaming(info.LiveStreamData.dashManifestUrl, info.format[info.format.length - 1].targetDurationSec, info.video_details.url)
}
await got(info.format[info.format.length - 1].url, {
headers : {
"range" : `bytes=0-1`
},
retry : 0
}).catch(async () => {
return await stream(info.video_details.url)
})
if(options.retry){
await got(info.format[info.format.length - 1].url, {
headers : {
"range" : `bytes=0-1`
},
retry : 0
}).catch(async () => {
return await stream(info.video_details.url)
})
}
let audioFormat = parseAudioFormats(info.format)
let opusFormats = filterFormat(audioFormat, "opus")
@@ -72,21 +77,23 @@ export async function stream(url : string, cookie? : string): Promise<Stream | L
return new Stream(final[0].url, type, info.video_details.durationInSec)
}
export async function stream_from_info(info : InfoData): Promise<Stream | LiveStreaming>{
export async function stream_from_info(info : InfoData, options : StreamOptions = { retry : false }): Promise<Stream | LiveStreaming>{
let final: any[] = [];
let type : StreamType;
if(info.LiveStreamData.isLive === true && info.LiveStreamData.hlsManifestUrl !== null && info.video_details.durationInSec === '0') {
return new LiveStreaming(info.LiveStreamData.dashManifestUrl, info.format[info.format.length - 1].targetDurationSec, info.video_details.url)
}
await got(info.format[info.format.length - 1].url, {
headers : {
"range" : `bytes=0-1`
},
retry : 0
}).catch(async () => {
return await stream(info.video_details.url)
})
if(options.retry){
await got(info.format[info.format.length - 1].url, {
headers : {
"range" : `bytes=0-1`
},
retry : 0
}).catch(async () => {
return await stream(info.video_details.url)
})
}
let audioFormat = parseAudioFormats(info.format)
let opusFormats = filterFormat(audioFormat, "opus")