iptv-org-mirror/iptv
1
0
Fork 0
mirror of https://github.com/iptv-org/iptv.git synced 2025-05-11 17:40:03 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update scripts

Browse source
This commit is contained in:
freearhey 2025-05-01 00:51:41 +03:00
parent 5e5b87404c
commit bfb0d5872d
7 changed files with 39 additions and 47 deletions
Download patch file Download diff file Expand all files Collapse all files

18
scripts/commands/playlist/update.ts
View file

@ -32,7 +32,7 @@ async function main() {
const files = await streamsStorage.list('**/*.m3u')
const streams = await parser.parse(files)
logger.info('removing broken streams...')
logger.info('removing streams...')
await removeStreams({ streams, issues })
logger.info('edit stream description...')
@ -73,12 +73,12 @@ async function removeStreams({ streams, issues }: { streams: Collection; issues:
)
requests.forEach((issue: Issue) => {
const data = issue.data
if (data.missing('brokenLinks')) return
if (data.missing('streamUrl')) return
const brokenLinks = data.getString('brokenLinks') || ''
const streamUrls = data.getString('streamUrl') || ''
let changed = false
brokenLinks
streamUrls
.split(/\r?\n/)
.filter(Boolean)
.forEach(link => {
@ -131,15 +131,7 @@ async function editStreams({
.updateFilepath()
}
const label = data.getString('label') || ''
const quality = data.getString('quality') || ''
const httpUserAgent = data.getString('httpUserAgent') || ''
const httpReferrer = data.getString('httpReferrer') || ''
if (data.has('label')) stream.setLabel(label)
if (data.has('quality')) stream.setQuality(quality)
if (data.has('httpUserAgent')) stream.setUserAgent(httpUserAgent)
if (data.has('httpReferrer')) stream.setReferrer(httpReferrer)
stream.update(data)
processedIssues.add(issue.number)
})

18
scripts/commands/report/create.ts
View file

@ -37,17 +37,17 @@ async function main() {
const streamsGroupedByChannelId = streams.groupBy((stream: Stream) => stream.channelId)
const streamsGroupedById = streams.groupBy((stream: Stream) => stream.getId())
logger.info('checking broken streams reports...')
const brokenStreamReports = issues.filter(issue =>
issue.labels.find((label: string) => label === 'broken stream')
logger.info('checking streams:remove requests...')
const removeRequests = issues.filter(issue =>
issue.labels.find((label: string) => label === 'streams:remove')
)
brokenStreamReports.forEach((issue: Issue) => {
const brokenLinks = issue.data.getArray('brokenLinks') || []
removeRequests.forEach((issue: Issue) => {
const streamUrls = issue.data.getArray('streamUrl') || []
if (!brokenLinks.length) {
if (!streamUrls.length) {
const result = {
issueNumber: issue.number,
type: 'broken stream',
type: 'streams:remove',
streamId: undefined,
streamUrl: undefined,
status: 'missing_link'
@ -55,10 +55,10 @@ async function main() {
report.add(result)
} else {
for (const streamUrl of brokenLinks) {
for (const streamUrl of streamUrls) {
const result = {
issueNumber: issue.number,
type: 'broken stream',
type: 'streams:remove',
streamId: undefined,
streamUrl: truncate(streamUrl),
status: 'pending'