From 40a9d2903e365e396d5a8ebca45bf11d7c66d0f0 Mon Sep 17 00:00:00 2001
From: freearhey <7253922+freearhey@users.noreply.github.com>
Date: Mon, 23 Mar 2026 17:13:25 +0300
Subject: [PATCH] Update update.ts

---
 scripts/commands/playlist/update.ts | 30 +++++++++++++++++++++--------
 1 file changed, 22 insertions(+), 8 deletions(-)

diff --git a/scripts/commands/playlist/update.ts b/scripts/commands/playlist/update.ts
index 1c5f17ee33..38dd69b7e0 100644
--- a/scripts/commands/playlist/update.ts
+++ b/scripts/commands/playlist/update.ts
@@ -2,10 +2,10 @@ import { IssueLoader, PlaylistParser } from '../../core'
 import { Playlist, Issue, Stream } from '../../models'
 import { loadData, data as apiData } from '../../api'
 import { Logger, Collection } from '@freearhey/core'
+import { isURI, getStreamInfo } from '../../utils'
 import { Storage } from '@freearhey/storage-js'
 import { STREAMS_DIR } from '../../constants'
 import * as sdk from '@iptv-org/sdk'
-import { isURI } from '../../utils'
 
 const processedIssues = new Collection()
 
@@ -136,24 +136,38 @@ async function addStreams({
   const requests = issues.filter(
     issue => issue.labels.includes('streams:add') && issue.labels.includes('approved')
   )
-  requests.forEach((issue: Issue) => {
+
+  for (const issue of requests.all()) {
     const data = issue.data
-    if (data.missing('stream_id') || data.missing('stream_url')) return
-    if (streams.includes((_stream: Stream) => _stream.url === data.getString('stream_url'))) return
+    if (data.missing('stream_id') || data.missing('stream_url')) continue
+    if (streams.includes((_stream: Stream) => _stream.url === data.getString('stream_url')))
+      continue
     const streamUrl = data.getString('stream_url') || ''
-    if (!isURI(streamUrl)) return
+    if (!isURI(streamUrl)) continue
 
     const streamId = data.getString('stream_id') || ''
     const [channelId, feedId] = streamId.split('@')
 
     const channel: sdk.Models.Channel | undefined = apiData.channelsKeyById.get(channelId)
-    if (!channel) return
+    if (!channel) continue
 
     const label = data.getString('label') || ''
-    const quality = data.getString('quality') || null
     const httpUserAgent = data.getString('http_user_agent') || null
     const httpReferrer = data.getString('http_referrer') || null
 
+    let quality = data.getString('quality') || null
+    if (!quality) {
+      const streamInfo = await getStreamInfo(streamUrl, { httpUserAgent, httpReferrer })
+
+      if (streamInfo) {
+        const height = streamInfo?.resolution?.height
+
+        if (height) {
+          quality = `${height}p`
+        }
+      }
+    }
+
     const stream = new Stream({
       channel: channelId,
       feed: feedId,
@@ -169,5 +183,5 @@ async function addStreams({
 
     streams.add(stream)
     processedIssues.add(issue.number)
-  })
+  }
 }