iptv-org/iptv
1
0
Fork 0
mirror of https://github.com/iptv-org/iptv synced 2025-12-17 10:57:18 -05:00
Code Issues Packages Projects Releases Wiki Activity

Update update.ts

Browse Source
This commit is contained in:
freearhey
2023-09-18 01:51:20 +03:00
parent 1ed4c99fe9
commit 3e526ba370
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
scripts/commands/playlist/update.ts
View File

@@ -35,9 +35,8 @@ async function main() {
logger.info('saving...') logger.info('saving...')
const groupedStreams = streams.groupBy((stream: Stream) => stream.filepath) const groupedStreams = streams.groupBy((stream: Stream) => stream.filepath)
for (let filepath of groupedStreams.keys()) { for (let filepath of groupedStreams.keys()) {
const streams = groupedStreams.get(filepath) || [] let streams = groupedStreams.get(filepath) || []
streams = streams.filter((stream: Stream) => stream.removed === false)
if (!streams.length) return
const playlist = new Playlist(streams, { public: false }) const playlist = new Playlist(streams, { public: false })
await streamsStorage.save(filepath, playlist.toString()) await streamsStorage.save(filepath, playlist.toString())
@@ -55,8 +54,9 @@ async function removeStreams(loader: IssueLoader) {
const data = issue.data const data = issue.data
if (data.missing('stream_url')) return if (data.missing('stream_url')) return
const removed = streams.remove((_stream: Stream) => _stream.url === data.get('stream_url')) const found: Stream = streams.first((_stream: Stream) => _stream.url === data.get('stream_url'))
if (removed.notEmpty()) { if (found) {
found.removed = true
processedIssues.add(issue.number) processedIssues.add(issue.number)
} }
}) })
@@ -93,9 +93,6 @@ async function editStreams(loader: IssueLoader) {
if (data.has('http_referrer')) stream.httpReferrer = data.get('http_referrer') if (data.has('http_referrer')) stream.httpReferrer = data.get('http_referrer')
if (data.has('channel_name')) stream.name = data.get('channel_name') if (data.has('channel_name')) stream.name = data.get('channel_name')
streams.remove((_stream: Stream) => _stream.channel === stream.channel)
streams.add(stream)
processedIssues.add(issue.number) processedIssues.add(issue.number)
}) })
} }