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 load.js

Browse source
This commit is contained in:
Aleksandr Statciuk 2022-07-06 20:00:49 +03:00
parent 79393806a6
commit f88f5cce97
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
scripts/commands/cluster/load.js
View file

@ -1,5 +1,5 @@
const _ = require('lodash') const _ = require('lodash')
const { EPGGrabber } = require('epg-grabber') const { EPGGrabber, Channel } = require('epg-grabber')
const { program } = require('commander') const { program } = require('commander')
const { db, logger, timer, file, parser } = require('../../core') const { db, logger, timer, file, parser } = require('../../core')
const dayjs = require('dayjs') const dayjs = require('dayjs')
@ -47,9 +47,10 @@ async function main() {
}) })
const grabber = new EPGGrabber(config) const grabber = new EPGGrabber(config)
for (const item of items) { for (const item of items) {
await grabber.grab(item.channel, item.date, async (data, err) => { const channel = new Channel(item.channel)
await grabber.grab(channel, item.date, async (data, err) => {
logger.info( logger.info(
`[${i}/${total}] ${item.channel.site} (${item.channel.lang}) - ${item.channel.id} - ${dayjs `[${i}/${total}] ${channel.site} (${channel.lang}) - ${channel.id} - ${dayjs
.utc(data.date) .utc(data.date)
.format('MMM D, YYYY')} (${data.programs.length} programs)` .format('MMM D, YYYY')} (${data.programs.length} programs)`
) )