From 42bdeb5db8cfd305468d12d2033777d7aac6c3e9 Mon Sep 17 00:00:00 2001
From: Aleksandr Statciuk <github@oiya.xyz>
Date: Mon, 28 Feb 2022 14:53:35 +0300
Subject: [PATCH] Stop generate extra logs

---
 scripts/commands/guides/update.js    | 87 +++-------------------------
 tests/commands/guides/update.test.js |  8 +--
 2 files changed, 8 insertions(+), 87 deletions(-)

diff --git a/scripts/commands/guides/update.js b/scripts/commands/guides/update.js
index d7af0924..d40a28aa 100644
--- a/scripts/commands/guides/update.js
+++ b/scripts/commands/guides/update.js
@@ -2,18 +2,9 @@ const { db, logger, file, api } = require('../../core')
 const grabber = require('epg-grabber')
 const _ = require('lodash')
 
-const LOGS_DIR = process.env.LOGS_DIR || 'scripts/logs'
 const PUBLIC_DIR = process.env.PUBLIC_DIR || '.gh-pages'
-const GUIDES_PATH = `${LOGS_DIR}/guides/update.log`
 
 async function main() {
-  await setUp()
-  await generateGuides()
-}
-
-main()
-
-async function generateGuides() {
   logger.info(`Generating guides/...`)
 
   logger.info('Loading "database/programs.db"...')
@@ -22,53 +13,17 @@ async function generateGuides() {
 
   const grouped = groupByGroup(await loadQueue())
   for (const key in grouped) {
-    const filepath = `${PUBLIC_DIR}/guides/${key}.epg.xml`
-    const criticalErrors = []
     let channels = {}
     let programs = []
     for (const item of grouped[key]) {
+      if (item.error) continue
+
       const itemPrograms = await loadProgramsForItem(item)
       programs = programs.concat(itemPrograms)
 
       if (channels[item.channel.xmltv_id]) continue
-
-      if (item.error) {
-        const error = {
-          xmltv_id: item.channel.xmltv_id,
-          site: item.channel.site,
-          site_id: item.channel.site_id,
-          lang: item.channel.lang,
-          date: item.date,
-          error: item.error
-        }
-        criticalErrors.push(error)
-        await logError(key, error)
-      } else {
-        if (!itemPrograms.length) {
-          await logError(key, {
-            xmltv_id: item.channel.xmltv_id,
-            site: item.channel.site,
-            site_id: item.channel.site_id,
-            lang: item.channel.lang,
-            date: item.date,
-            error: 'Programs not found'
-          })
-          continue
-        }
-
-        const channel = api.channels.find({ id: item.channel.xmltv_id })
-        if (!channel) {
-          await logError(key, {
-            xmltv_id: item.channel.xmltv_id,
-            site: item.channel.site,
-            site_id: item.channel.site_id,
-            lang: item.channel.lang,
-            date: item.date,
-            error: 'The channel has the wrong xmltv_id'
-          })
-          continue
-        }
-
+      const channel = api.channels.find({ id: item.channel.xmltv_id })
+      if (channel) {
         channels[channel.id] = {
           xmltv_id: channel.id,
           name: item.channel.display_name,
@@ -77,30 +32,21 @@ async function generateGuides() {
         }
       }
     }
-
     channels = Object.values(channels)
     channels = _.sortBy(channels, 'xmltv_id')
     programs = _.sortBy(programs, ['channel', 'start'])
 
+    const filepath = `${PUBLIC_DIR}/guides/${key}.epg.xml`
     logger.info(`Creating "${filepath}"...`)
     const output = grabber.convertToXMLTV({ channels, programs })
     await file.create(filepath, output)
-
-    let status = 0
-    if (criticalErrors.length > 0 || !channels.length) {
-      status = 1
-    }
-
-    await logGuide({
-      group: key,
-      count: channels.length,
-      status
-    })
   }
 
   logger.info(`Done`)
 }
 
+main()
+
 function groupByGroup(items = []) {
   const groups = {}
 
@@ -128,22 +74,3 @@ async function loadQueue() {
 async function loadProgramsForItem(item) {
   return await db.programs.find({ _qid: item._id }).sort({ channel: 1, start: 1 })
 }
-
-async function setUp() {
-  logger.info(`Creating '${GUIDES_PATH}'...`)
-  await file.create(GUIDES_PATH)
-  await file.createDir(`${LOGS_DIR}/errors`)
-}
-
-async function logGuide(data) {
-  await file.append(GUIDES_PATH, JSON.stringify(data) + '\r\n')
-}
-
-async function logError(key, data) {
-  const filepath = `${LOGS_DIR}/errors/${key}.log`
-  if (!(await file.exists(filepath))) {
-    await file.create(filepath)
-  }
-
-  await file.append(filepath, JSON.stringify(data) + '\r\n')
-}
diff --git a/tests/commands/guides/update.test.js b/tests/commands/guides/update.test.js
index bf326424..98c8455a 100644
--- a/tests/commands/guides/update.test.js
+++ b/tests/commands/guides/update.test.js
@@ -8,7 +8,7 @@ beforeEach(() => {
   fs.copyFileSync('tests/__data__/input/database/programs.db', 'tests/__data__/output/programs.db')
 
   const stdout = execSync(
-    'DB_DIR=tests/__data__/output DATA_DIR=tests/__data__/input/data PUBLIC_DIR=tests/__data__/output LOGS_DIR=tests/__data__/output/logs npm run guides:update',
+    'DB_DIR=tests/__data__/output DATA_DIR=tests/__data__/input/data PUBLIC_DIR=tests/__data__/output npm run guides:update',
     { encoding: 'utf8' }
   )
 })
@@ -23,12 +23,6 @@ it('can generate /guides', () => {
   )
 })
 
-it('can create guides.log', () => {
-  expect(content('tests/__data__/output/logs/guides/update.log')).toBe(
-    content('tests/__data__/expected/logs/guides/update.log')
-  )
-})
-
 function content(filepath) {
   const data = fs.readFileSync(path.resolve(filepath), {
     encoding: 'utf8'