Merge branch 'developer' of https://github.com/play-dl/play-dl into developer

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.

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"

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",

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()

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,

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;