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 scripts

Browse Source
This commit is contained in:
freearhey
2025-02-27 20:55:39 +03:00
parent 86eda24dcc
commit aa215b3fcb
5 changed files with 109 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -7,11 +7,15 @@ import validUrl from 'valid-url'
let processedIssues = new Collection()
let streams: Collection
let groupedChannels: Dictionary
let issues: Collection
async function main() {
const logger = new Logger({ disabled: true })
const loader = new IssueLoader()
logger.info('loading issues...')
issues = await loader.load()
logger.info('loading channels from api...')
const dataStorage = new Storage(DATA_DIR)
const channelsContent = await dataStorage.json('channels.json')
@@ -51,8 +55,10 @@ async function main() {
main()
async function removeStreams(loader: IssueLoader) {
const issues = await loader.load({ labels: ['streams:remove', 'approved'] })
issues.forEach((issue: Issue) => {
const requests = issues.filter(
issue => issue.labels.includes('streams:remove') && issue.labels.includes('approved')
)
requests.forEach((issue: Issue) => {
const data = issue.data
if (data.missing('broken_links')) return
@@ -72,8 +78,10 @@ async function removeStreams(loader: IssueLoader) {
}
async function editStreams(loader: IssueLoader) {
const issues = await loader.load({ labels: ['streams:edit', 'approved'] })
issues.forEach((issue: Issue) => {
const requests = issues.filter(
issue => issue.labels.includes('streams:edit') && issue.labels.includes('approved')
)
requests.forEach((issue: Issue) => {
const data = issue.data
if (data.missing('stream_url')) return
@@ -106,8 +114,10 @@ async function editStreams(loader: IssueLoader) {
}
async function addStreams(loader: IssueLoader) {
const issues = await loader.load({ labels: ['streams:add', 'approved'] })
issues.forEach((issue: Issue) => {
const requests = issues.filter(
issue => issue.labels.includes('streams:add') && issue.labels.includes('approved')
)
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