mirror of
https://github.com/iptv-org/epg.git
synced 2025-05-10 09:00:07 -04:00
116 lines
3 KiB
JavaScript
116 lines
3 KiB
JavaScript
const { db, api, logger, file, zip } = require('../../core')
|
|
const { generateXMLTV, Program, Channel } = require('epg-grabber')
|
|
const _ = require('lodash')
|
|
|
|
const PUBLIC_DIR = process.env.PUBLIC_DIR || '.gh-pages'
|
|
const LOGS_DIR = process.env.LOGS_DIR || 'scripts/logs'
|
|
const CURR_DATE = process.env.CURR_DATE || new Date()
|
|
|
|
const logPath = `${LOGS_DIR}/guides/update.log`
|
|
|
|
let api_channels = {}
|
|
let db_programs = []
|
|
let guides = []
|
|
|
|
async function main() {
|
|
logger.info(`starting...`)
|
|
|
|
logger.info('loading data/channels.json...')
|
|
await api.channels.load()
|
|
|
|
api.channels.all().forEach(channel => {
|
|
api_channels[channel.id] = channel
|
|
})
|
|
|
|
logger.info('loading database/programs.db...')
|
|
await db.programs.load()
|
|
db_programs = await db.programs.find({})
|
|
logger.info(`found ${db_programs.length} programs`)
|
|
|
|
await generate()
|
|
|
|
logger.info(`creating ${logPath}...`)
|
|
await file.create(logPath, guides.map(g => JSON.stringify(g)).join('\r\n'))
|
|
|
|
logger.info('finished')
|
|
}
|
|
|
|
main()
|
|
|
|
async function generate() {
|
|
let programs = _.groupBy(db_programs, p =>
|
|
p.titles.length ? `${p.titles[0].lang}/${p.site}` : `_`
|
|
)
|
|
|
|
delete programs['_']
|
|
|
|
for (let filename in programs) {
|
|
let { channels } = await save(filename, programs[filename])
|
|
|
|
for (let channel of channels) {
|
|
const configPath = `sites/${channel.site}/${channel.site}.config.js`
|
|
const config = require(file.resolve(configPath))
|
|
|
|
guides.push({
|
|
site: channel.site,
|
|
lang: channel.lang,
|
|
days: config.days,
|
|
channel: channel.id,
|
|
filename
|
|
})
|
|
}
|
|
}
|
|
}
|
|
|
|
async function save(filepath, programs) {
|
|
let output = {
|
|
channels: [],
|
|
programs: [],
|
|
date: CURR_DATE
|
|
}
|
|
|
|
for (let programData of programs) {
|
|
let channelData = api_channels[programData.channel]
|
|
if (!channelData) continue
|
|
|
|
channelData.site = programData.site
|
|
channelData.lang = programData.titles[0].lang
|
|
|
|
let channel = new Channel(channelData)
|
|
let program = new Program(programData, channel)
|
|
|
|
output.channels.push(channel)
|
|
output.programs.push(program)
|
|
}
|
|
|
|
output.channels = _.sortBy(output.channels, 'id')
|
|
output.channels = _.uniqBy(output.channels, 'id')
|
|
|
|
output.programs = _.sortBy(output.programs, ['channel', 'start'])
|
|
output.programs = _.uniqBy(output.programs, p => p.channel + p.start)
|
|
|
|
const xmlFilepath = `${PUBLIC_DIR}/guides/${filepath}.xml`
|
|
const gzFilepath = `${PUBLIC_DIR}/guides/${filepath}.xml.gz`
|
|
logger.info(`creating ${xmlFilepath}...`)
|
|
const xmltv = generateXMLTV(output)
|
|
await file.create(xmlFilepath, xmltv)
|
|
logger.info(`creating ${gzFilepath}...`)
|
|
const compressed = await zip.compress(xmltv)
|
|
await file.create(gzFilepath, compressed)
|
|
|
|
return output
|
|
}
|
|
|
|
// function merge(p1, p2) {
|
|
// for (let prop in p1) {
|
|
// if (Array.isArray(p1[prop])) {
|
|
// p1[prop] = _.orderBy(
|
|
// _.uniqWith(p1[prop].concat(p2[prop]), _.isEqual),
|
|
// v => (v.lang === 'en' ? Infinity : 1),
|
|
// 'desc'
|
|
// )
|
|
// }
|
|
// }
|
|
|
|
// return p1
|
|
// }
|