diff --git a/README.md b/README.md index fce99c9..f813a24 100644 --- a/README.md +++ b/README.md @@ -63,7 +63,7 @@ if(validate(url) || validate_playlist(url)) // This will check both and if anyon ``` ### stream_from_info(info : `infoData`) -*This is basic to create a youtube stream from a info [ from video_info function ].* +*This is basic to create a youtube stream from a info [ from [video_info](https://github.com/play-dl/play-dl#video_infourl--string) function ].* ```js let info = await video_info("url") let source = await stream_from_info(info) // This will create a stream Class which contains type and stream to be played. diff --git a/package-lock.json b/package-lock.json index cb2f904..27757fd 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "play-dl", - "version": "0.7.0", + "version": "0.7.3", "lockfileVersion": 2, "requires": true, "packages": { "": { "name": "play-dl", - "version": "0.7.0", + "version": "0.7.3", "license": "MIT", "dependencies": { "got": "^11.8.2" diff --git a/package.json b/package.json index 0c7335f..625fcdb 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "play-dl", - "version": "0.7.0", + "version": "0.7.3", "description": "YouTube, SoundCloud, Spotify streaming for discord.js bots", "main": "dist/index.js", "typings": "dist/index.d.ts", diff --git a/play-dl/YouTube/classes/LiveStream.ts b/play-dl/YouTube/classes/LiveStream.ts index 3743254..f2771cb 100644 --- a/play-dl/YouTube/classes/LiveStream.ts +++ b/play-dl/YouTube/classes/LiveStream.ts @@ -77,6 +77,9 @@ export class LiveStreaming{ this.packet_count++ resolve('') }) + stream.once('error', (err) => { + this.stream.emit('error', err) + }) }) })() } @@ -151,6 +154,9 @@ export class LiveEnded{ this.packet_count++ resolve('') }) + stream.once('error', (err) => { + this.stream.emit('error', err) + }) }) })() } @@ -198,6 +204,11 @@ export class Stream { } let stream = got.stream(this.url) this.request = stream + + stream.once('error', (err) => { + this.stream.emit('error', err) + }) + stream.pipe(this.stream) } @@ -212,6 +223,10 @@ export class Stream { this.per_sec_bytes = Math.ceil((stream.downloadProgress.total as number)/this.duration) }) + stream.once('error', (err) => { + this.stream.emit('error', err) + }) + stream.on('data', (chunk: any) => { this.bytes_count += chunk.length this.stream.write(chunk) @@ -244,6 +259,11 @@ export class Stream { this.bytes_count += chunk.length this.stream.write(chunk) }) + + stream.once('error', (err) => { + this.stream.emit('error', err) + }) + stream.on('data', () => { if(absolute_bytes > (this.per_sec_bytes * 300)){ stream.destroy() diff --git a/play-dl/YouTube/utils/extractor.ts b/play-dl/YouTube/utils/extractor.ts index dc346a1..1de63b8 100644 --- a/play-dl/YouTube/utils/extractor.ts +++ b/play-dl/YouTube/utils/extractor.ts @@ -32,6 +32,8 @@ export async function video_basic_info(url : string, cookie? : string){ headers : (cookie) ? { 'cookie' : cookie } : {} }) let player_response = JSON.parse(body.split("var ytInitialPlayerResponse = ")[1].split("}};")[0] + '}}') + let initial_response = JSON.parse(body.split("var ytInitialData = ")[1].split("}};")[0] + '}}') + let badge = initial_response.contents.twoColumnWatchNextResults.results.results.contents[1]?.videoSecondaryInfoRenderer?.owner?.videoOwnerRenderer?.badges && initial_response.contents.twoColumnWatchNextResults.results.results.contents[1]?.videoSecondaryInfoRenderer?.owner?.videoOwnerRenderer?.badges[0] if(player_response.playabilityStatus.status === 'ERROR') throw new Error(`While getting info from url \n ${player_response.playabilityStatus.reason}`) if(player_response.playabilityStatus.status === 'LOGIN_REQUIRED') throw new Error(`While getting info from url \n ${ player_response.playabilityStatus.reason || player_response.playabilityStatus.messages[0]}`) let html5player = 'https://www.youtube.com' + body.split('"jsUrl":"')[1].split('"')[0] @@ -50,7 +52,8 @@ export async function video_basic_info(url : string, cookie? : string){ channel : { name : vid.author, id : vid.channelId, - url : `https://www.youtube.com/channel/${vid.channelId}` + url : `https://www.youtube.com/channel/${vid.channelId}`, + verified : Boolean(badge?.metadataBadgeRenderer?.style?.toLowerCase().includes('verified')) }, views : vid.viewCount, tags : vid.keywords, diff --git a/play-dl/YouTube/utils/parser.ts b/play-dl/YouTube/utils/parser.ts index 681a9bd..24afcc6 100644 --- a/play-dl/YouTube/utils/parser.ts +++ b/play-dl/YouTube/utils/parser.ts @@ -143,7 +143,8 @@ export function parseVideo(data?: any): Video | void { verified: Boolean(badge?.metadataBadgeRenderer?.style?.toLowerCase().includes("verified")) }, uploadedAt: data.videoRenderer.publishedTimeText?.simpleText ?? null, - views: data.videoRenderer.viewCountText?.simpleText?.replace(/[^0-9]/g, "") ?? 0 + views: data.videoRenderer.viewCountText?.simpleText?.replace(/[^0-9]/g, "") ?? 0, + live : data.videoRenderer.lengthText ? false : true, }); return res;