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 Options fixed

Browse Source
This commit is contained in:
killer069
2021-09-06 16:18:42 +05:30
parent 63e32716ef
commit e9bc1a4461
4 changed files with 32 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -10,11 +10,6 @@ export enum StreamType{
Opus = 'opus',
}
interface StreamOptions{
cookie? : string;
retry? : boolean;
}
interface InfoData{
LiveStreamData : {
isLive : boolean
@@ -39,24 +34,28 @@ function parseAudioFormats(formats : any[]){
return result
}
export async function stream(url : string, options : StreamOptions = { retry : false }): Promise<Stream | LiveStreaming>{
let info = await video_info(url, options.cookie)
export async function stream(url : string, cookie? : string): Promise<Stream | LiveStreaming>{
let info = await video_info(url, 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)
}
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)
})
console.time('Time to Retry')
let resp = await got(info.format[info.format.length - 1].url, {
headers : {
"range" : `bytes=0-1`
},
retry : 0
}).catch(() => {
return 0
})
if(resp === 0){
return await stream(info.video_details.url)
}
else if(typeof resp !== "number") resp.destroy()
console.timeEnd('Time to Retry')
let audioFormat = parseAudioFormats(info.format)
let opusFormats = filterFormat(audioFormat, "opus")
@@ -77,23 +76,25 @@ export async function stream(url : string, options : StreamOptions = { retry : f
return new Stream(final[0].url, type, info.video_details.durationInSec)
}
export async function stream_from_info(info : InfoData, options : StreamOptions = { retry : false }): Promise<Stream | LiveStreaming>{
export async function stream_from_info(info : InfoData): 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)
}
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 resp = await got(info.format[info.format.length - 1].url, {
headers : {
"range" : `bytes=0-1`
},
retry : 0
}).catch(() => {
return 0
})
if(resp === 0){
return await stream(info.video_details.url)
}
else if(typeof resp !== "number") resp.destroy()
let audioFormat = parseAudioFormats(info.format)
let opusFormats = filterFormat(audioFormat, "opus")