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-03-09 19:53:25 +03:00
parent a14ef9181a
commit 970b74aef2
5 changed files with 51 additions and 47 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -60,9 +60,9 @@ async function removeStreams(loader: IssueLoader) {
)
requests.forEach((issue: Issue) => {
const data = issue.data
if (data.missing('broken_links')) return
if (data.missing('brokenLinks')) return
const brokenLinks = data.getString('broken_links').split(/\r?\n/).filter(Boolean)
const brokenLinks = data.getString('brokenLinks').split(/\r?\n/).filter(Boolean)
let changed = false
brokenLinks.forEach(link => {
@ -84,20 +84,20 @@ async function editStreams(loader: IssueLoader) {
requests.forEach((issue: Issue) => {
const data = issue.data
if (data.missing('stream_url')) return
if (data.missing('streamUrl')) return
let stream = streams.first(
(_stream: Stream) => _stream.url === data.getString('stream_url')
(_stream: Stream) => _stream.url === data.getString('streamUrl')
) as Stream
if (!stream) return
if (data.has('channel_id')) {
const channel = groupedChannels.get(data.getString('channel_id'))
if (data.has('channelId')) {
const channel = groupedChannels.get(data.getString('channelId'))
if (!channel) return
stream.channel = data.getString('channel_id')
stream.channel = data.getString('channelId')
stream.filepath = `${channel.country.toLowerCase()}.m3u`
stream.line = -1
stream.name = channel.name
@ -105,8 +105,8 @@ async function editStreams(loader: IssueLoader) {
if (data.has('label')) stream.label = data.getString('label')
if (data.has('quality')) stream.quality = data.getString('quality')
if (data.has('user_agent')) stream.userAgent = data.getString('user_agent')
if (data.has('http_referrer')) stream.httpReferrer = data.getString('http_referrer')
if (data.has('httpUserAgent')) stream.httpUserAgent = data.getString('httpUserAgent')
if (data.has('httpReferrer')) stream.httpReferrer = data.getString('httpReferrer')
processedIssues.add(issue.number)
})
@ -118,24 +118,24 @@ async function addStreams(loader: IssueLoader) {
)
requests.forEach((issue: Issue) => {
const data = issue.data
if (data.missing('channel_id') || data.missing('stream_url')) return
if (streams.includes((_stream: Stream) => _stream.url === data.getString('stream_url'))) return
if (!validUrl.isUri(data.getString('stream_url'))) return
if (data.missing('channelId') || data.missing('streamUrl')) return
if (streams.includes((_stream: Stream) => _stream.url === data.getString('streamUrl'))) return
if (!validUrl.isUri(data.getString('streamUrl'))) return
const channel = groupedChannels.get(data.getString('channel_id'))
const channel = groupedChannels.get(data.getString('channelId'))
if (!channel) return
const stream = new Stream({
channel: data.getString('channel_id'),
url: data.getString('stream_url'),
channel: data.getString('channelId'),
url: data.getString('streamUrl'),
label: data.getString('label'),
quality: data.getString('quality'),
userAgent: data.getString('user_agent'),
httpReferrer: data.getString('http_referrer'),
httpUserAgent: data.getString('httpUserAgent'),
httpReferrer: data.getString('httpReferrer'),
filepath: `${channel.country.toLowerCase()}.m3u`,
line: -1,
name: data.getString('channel_name') || channel.name
name: data.getString('channelName') || channel.name
})
streams.add(stream)

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

@ -38,8 +38,8 @@ async function main() {
const addRequests = issues.filter(issue => issue.labels.includes('streams:add'))
const addRequestsBuffer = new Dictionary()
addRequests.forEach((issue: Issue) => {
const channelId = issue.data.getString('channel_id') || undefined
const streamUrl = issue.data.getString('stream_url')
const channelId = issue.data.getString('channelId') || undefined
const streamUrl = issue.data.getString('streamUrl')
const result = new Dictionary({
issueNumber: issue.number,
@ -65,8 +65,8 @@ async function main() {
logger.info('checking streams:edit requests...')
const editRequests = issues.filter(issue => issue.labels.find(label => label === 'streams:edit'))
editRequests.forEach((issue: Issue) => {
const channelId = issue.data.getString('channel_id') || undefined
const streamUrl = issue.data.getString('stream_url') || undefined
const channelId = issue.data.getString('channelId') || undefined
const streamUrl = issue.data.getString('streamUrl') || undefined
const result = new Dictionary({
issueNumber: issue.number,
@ -88,7 +88,7 @@ async function main() {
issue.labels.find(label => label === 'broken stream')
)
brokenStreamReports.forEach((issue: Issue) => {
const brokenLinks = issue.data.getArray('broken_links') || []
const brokenLinks = issue.data.getArray('brokenLinks') || []
if (!brokenLinks.length) {
const result = new Dictionary({
@ -126,7 +126,7 @@ async function main() {
)
const channelSearchRequestsBuffer = new Dictionary()
channelSearchRequests.forEach((issue: Issue) => {
const channelId = issue.data.getString('channel_id')
const channelId = issue.data.getString('channelId')
const result = new Dictionary({
issueNumber: issue.number,