Update save.js

This commit is contained in:
Aleksandr Statciuk 2022-07-06 17:32:49 +03:00
parent e245003a81
commit 79393806a6

View file

@ -1,5 +1,5 @@
const { db, logger, file, parser } = require('../../core') const { db, logger, file, parser } = require('../../core')
const { Program } = require('epg-grabber') const { Program, Channel } = require('epg-grabber')
const _ = require('lodash') const _ = require('lodash')
const LOGS_DIR = process.env.LOGS_DIR || 'scripts/logs' const LOGS_DIR = process.env.LOGS_DIR || 'scripts/logs'
@ -16,8 +16,9 @@ async function main() {
const queue = await db.queue.find({ _id: result._qid }).limit(1) const queue = await db.queue.find({ _id: result._qid }).limit(1)
if (!queue.length) continue if (!queue.length) continue
const item = queue[0] const item = queue[0]
const c = new Channel(item.channel)
const programs = result.programs.map(p => { const programs = result.programs.map(p => {
p = new Program(p) p = new Program(p, c)
p._qid = result._qid p._qid = result._qid
return p return p