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 update-guides.js

Browse source
This commit is contained in:
Aleksandr Statciuk 2022-01-15 18:26:03 +03:00
parent d6c1ff4482
commit a4d2717a6e
1 changed files with 18 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

26
scripts/commands/update-guides.js
View file

@ -4,10 +4,10 @@ const _ = require('lodash')
const DB_DIR = process.env.DB_DIR || 'scripts/database' const DB_DIR = process.env.DB_DIR || 'scripts/database'
const LOGS_DIR = process.env.LOGS_DIR || 'scripts/logs' const LOGS_DIR = process.env.LOGS_DIR || 'scripts/logs'
const PUBLIC_DIR = process.env.PUBLIC_DIR || '.gh-pages' const PUBLIC_DIR = process.env.PUBLIC_DIR || '.gh-pages'
const LOG_PATH = `${LOGS_DIR}/update-guides.log`
async function main() { async function main() {
await setUp() await setUp()
await generateGuides() await generateGuides()
} }
@ -16,10 +16,10 @@ main()
async function generateGuides() { async function generateGuides() {
logger.info(`Generating guides/...`) logger.info(`Generating guides/...`)
const channels = await db.channels.find({}).sort({ xmltv_id: 1 }) const channels = await loadChannels()
const programs = await loadPrograms() const programs = await loadPrograms()
const grouped = _.groupBy(programs, i => `${i.gid}_${i.site}`)
const grouped = _.groupBy(programs, i => `${i.gid}_${i.site}`)
for (let key in grouped) { for (let key in grouped) {
const [gid, site] = key.split('_') || [null, null] const [gid, site] = key.split('_') || [null, null]
const filepath = `${PUBLIC_DIR}/guides/${gid}/${site}.epg.xml` const filepath = `${PUBLIC_DIR}/guides/${gid}/${site}.epg.xml`
@ -45,7 +45,19 @@ async function generateGuides() {
} }
} }
async function loadChannels() {
logger.info('Loading channels from database...')
await db.channels.load()
return await db.channels.find({}).sort({ xmltv_id: 1 })
}
async function loadPrograms() { async function loadPrograms() {
logger.info('Loading programs from database...')
await db.programs.load()
let programs = await db.programs.find({}).sort({ channel: 1, start: 1 }) let programs = await db.programs.find({}).sort({ channel: 1, start: 1 })
programs = programs.map(program => { programs = programs.map(program => {
@ -69,12 +81,10 @@ async function loadPrograms() {
} }
async function setUp() { async function setUp() {
const logPath = `${LOGS_DIR}/update-guides.log` logger.info(`Creating '${LOG_PATH}'...`)
await file.create(LOG_PATH)
logger.info(`Creating '${logPath}'...`)
await file.create(logPath)
} }
async function log(data) { async function log(data) {
await file.append(`${LOGS_DIR}/update-guides.log`, JSON.stringify(data) + '\n') await file.append(LOG_PATH, JSON.stringify(data) + '\n')
} }