iptv-org-mirror/epg
1
0
Fork 0
mirror of https://github.com/iptv-org/epg.git synced 2025-05-10 00:50:09 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update create-queue.js

Browse source
This commit is contained in:
Aleksandr Statciuk 2022-01-31 04:47:06 +03:00
parent 6b775ecba4
commit 036fdf537d
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
scripts/commands/create-queue.js
View file

@ -1,4 +1,4 @@
const { db, file, parser, logger, date } = require('../core') const { db, file, parser, logger, date, api } = require('../core')
const { program } = require('commander') const { program } = require('commander')
const { shuffle } = require('lodash') const { shuffle } = require('lodash')
@ -31,6 +31,7 @@ async function createQueue() {
let queue = {} let queue = {}
await api.channels.load()
const files = await file.list(CHANNELS_PATH) const files = await file.list(CHANNELS_PATH)
const utcDate = date.getUTC() const utcDate = date.getUTC()
const dates = Array.from({ length: options.days }, (_, i) => utcDate.add(i, 'd')) const dates = Array.from({ length: options.days }, (_, i) => utcDate.add(i, 'd'))
@ -46,6 +47,11 @@ async function createQueue() {
const groupId = `${region}/${site}` const groupId = `${region}/${site}`
for (const item of items) { for (const item of items) {
if (!item.site || !item.site_id || !item.xmltv_id) continue if (!item.site || !item.site_id || !item.xmltv_id) continue
const channel = api.channels.find({ id: item.xmltv_id })
if (!channel) {
console.log(item.xmltv_id)
continue
}
for (const d of dates) { for (const d of dates) {
const dString = d.toJSON() const dString = d.toJSON()
const key = `${item.site}:${item.site_id}:${item.lang}:${dString}` const key = `${item.site}:${item.site_id}:${item.lang}:${dString}`