124 lines
3.6 KiB
TypeScript
124 lines
3.6 KiB
TypeScript
import got from "got/dist/source"
|
|
import { video_info } from "."
|
|
import { LiveEnded, LiveStreaming, Stream } from "./classes/LiveStream"
|
|
|
|
export enum StreamType{
|
|
Arbitrary = 'arbitrary',
|
|
Raw = 'raw',
|
|
OggOpus = 'ogg/opus',
|
|
WebmOpus = 'webm/opus',
|
|
Opus = 'opus',
|
|
}
|
|
|
|
|
|
interface InfoData{
|
|
LiveStreamData : {
|
|
isLive : boolean
|
|
dashManifestUrl : string
|
|
hlsManifestUrl : string
|
|
}
|
|
html5player : string
|
|
format : any[]
|
|
video_details : any
|
|
}
|
|
|
|
function parseAudioFormats(formats : any[]){
|
|
let result: any[] = []
|
|
formats.forEach((format) => {
|
|
let type = format.mimeType as string
|
|
if(type.startsWith('audio')){
|
|
format.codec = type.split('codecs="')[1].split('"')[0]
|
|
format.container = type.split('audio/')[1].split(';')[0]
|
|
result.push(format)
|
|
}
|
|
})
|
|
return result
|
|
}
|
|
|
|
export async function stream(url : string, error_check : boolean = false): Promise<Stream | LiveStreaming | LiveEnded>{
|
|
let info = await video_info(url)
|
|
let final: any[] = [];
|
|
let type : StreamType;
|
|
if(info.LiveStreamData.isLive === true && info.LiveStreamData.hlsManifestUrl !== null) {
|
|
return live_stream(info as InfoData)
|
|
}
|
|
|
|
if(error_check){
|
|
let response = await got(info.format[info.format.length - 1].url)
|
|
if(response.statusCode >= 400){
|
|
return await stream(info.video_details.url, true)
|
|
}
|
|
}
|
|
|
|
let audioFormat = parseAudioFormats(info.format)
|
|
let opusFormats = filterFormat(audioFormat, "opus")
|
|
|
|
if(opusFormats.length === 0){
|
|
type = StreamType.Arbitrary
|
|
final.push(audioFormat[audioFormat.length - 1])
|
|
}
|
|
else{
|
|
type = StreamType.WebmOpus
|
|
final.push(opusFormats[opusFormats.length - 1])
|
|
}
|
|
|
|
if(final.length === 0) {
|
|
type = StreamType.Arbitrary
|
|
final.push(info.format[info.format.length - 1])
|
|
}
|
|
|
|
return new Stream(final[0].url, type, info.video_details.durationInSec)
|
|
}
|
|
|
|
export async function stream_from_info(info : InfoData, error_check : boolean = false): Promise<Stream | LiveStreaming | LiveEnded>{
|
|
let final: any[] = [];
|
|
let type : StreamType;
|
|
if(info.LiveStreamData.isLive === true && info.LiveStreamData.hlsManifestUrl !== null) {
|
|
return live_stream(info as InfoData)
|
|
}
|
|
|
|
if(error_check){
|
|
let response = await got(info.format[info.format.length - 1].url)
|
|
if(response.statusCode >= 400){
|
|
return await stream(info.video_details.url, true)
|
|
}
|
|
}
|
|
|
|
let audioFormat = parseAudioFormats(info.format)
|
|
let opusFormats = filterFormat(audioFormat, "opus")
|
|
|
|
if(opusFormats.length === 0){
|
|
type = StreamType.Arbitrary
|
|
final.push(audioFormat[audioFormat.length - 1])
|
|
}
|
|
else{
|
|
type = StreamType.WebmOpus
|
|
final.push(opusFormats[opusFormats.length - 1])
|
|
}
|
|
|
|
if(final.length === 0) {
|
|
type = StreamType.Arbitrary
|
|
final.push(info.format[info.format.length - 1])
|
|
}
|
|
|
|
return new Stream(final[0].url, type, info.video_details.durationInSec)
|
|
}
|
|
|
|
function filterFormat(formats : any[], codec : string){
|
|
let result: any[] = []
|
|
formats.forEach((format) => {
|
|
if(format.codec === codec) result.push(format)
|
|
})
|
|
return result
|
|
}
|
|
|
|
function live_stream(info : InfoData): LiveStreaming | LiveEnded{
|
|
let stream : LiveStreaming | LiveEnded
|
|
if(info.video_details.durationInSec === '0') {
|
|
stream = new LiveStreaming(info.LiveStreamData.dashManifestUrl, info.format[info.format.length - 1].targetDurationSec)
|
|
}
|
|
else {
|
|
stream = new LiveEnded(info.LiveStreamData.dashManifestUrl)
|
|
}
|
|
return stream
|
|
} |