iptv/scripts/commands/playlist/generate.js

const { db, generator, api, logger, file } = require('../../core')
const { orderBy } = require('natural-orderby')
const _ = require('lodash')

async function main() {
  const streams = await loadStreams()

  logger.info('generating categories/...')
  await generator.generate('categories', streams)
  logger.info('generating countries/...')
  await generator.generate('countries', streams)
  logger.info('generating languages/...')
  await generator.generate('languages', streams)
  logger.info('generating regions/...')
  await generator.generate('regions', streams)
  logger.info('generating index.category.m3u...')
  await generator.generate('index_category_m3u', streams)
  logger.info('generating index.country.m3u...')
  await generator.generate('index_country_m3u', streams)
  logger.info('generating index.language.m3u...')
  await generator.generate('index_language_m3u', streams)
  logger.info('generating index.m3u...')
  await generator.generate('index_m3u', streams)
  logger.info('generating index.nsfw.m3u...')
  await generator.generate('index_nsfw_m3u', streams)
  logger.info('generating index.region.m3u...')
  await generator.generate('index_region_m3u', streams)
}

main()

async function loadStreams() {
  await db.streams.load()
  let streams = await db.streams.find({})
  streams = _.filter(streams, stream => stream.status !== 'error')
  const levels = { online: 1, blocked: 2, timeout: 3, error: 4, default: 5 }
  streams = orderBy(
    streams,
    ['channel', s => levels[s.status] || levels['default'], 'height', 'frame_rate', 'url'],
    ['asc', 'asc', 'desc', 'desc', 'asc']
  )
  streams = _.uniqBy(streams, stream => stream.channel || _.uniqueId())

  await api.channels.load()
  let channels = await api.channels.all()
  channels = _.keyBy(channels, 'id')

  await api.categories.load()
  let categories = await api.categories.all()
  categories = _.keyBy(categories, 'id')

  await api.languages.load()
  let languages = await api.languages.all()
  languages = _.keyBy(languages, 'code')

  await api.guides.load()
  let guides = await api.guides.all()
  guides = _.groupBy(guides, 'channel')

  streams = streams.map(stream => {
    const channel = channels[stream.channel] || null
    const filename = file.getFilename(stream.filepath)
    const [_, code] = filename.match(/^([a-z]{2})(_|$)/) || [null, null]
    const defaultBroadcastArea = code ? [`c/${code.toUpperCase()}`] : []

    if (channel) {
      stream.guides = Array.isArray(guides[channel.id]) ? guides[channel.id] : []
      stream.categories = channel.categories.map(id => categories[id]).filter(i => i)
      stream.languages = channel.languages.map(id => languages[id]).filter(i => i)
      stream.broadcast_area = channel.broadcast_area
      stream.is_nsfw = channel.is_nsfw
      stream.logo = channel.logo
    } else {
      stream.guides = []
      stream.categories = []
      stream.languages = []
      stream.broadcast_area = defaultBroadcastArea
      stream.is_nsfw = false
      stream.logo = null
    }

    return stream
  })

  streams = orderBy(streams, ['title'], ['asc'])

  return streams
}