epg/sites/cubmu.com/cubmu.com.config.js

const dayjs = require('dayjs')
const timezone = require('dayjs/plugin/timezone')
const utc = require('dayjs/plugin/utc')

dayjs.extend(timezone)
dayjs.extend(utc)

module.exports = {
  site: 'cubmu.com',
  days: 2,
  url: function ({ channel, date }) {
    return `https://servicebuss.transvision.co.id/v2/cms/getEPGData?app_id=cubmu&tvs_platform_id=standalone&schedule_date=${date.format('YYYY-MM-DD')}&channel_id=${channel.site_id}`
  },
  parser({ content }) {
    const programs = []
    const items = parseItems(content)
    items.forEach(item => {
      programs.push({
        title: parseTitle(item),
        description: parseDescription(item),
        episode: parseEpisode(item),
        start: parseStart(item).toISOString(),
        stop: parseStop(item).toISOString()
      })
    })

    return programs
  },
  async channels() {
    const axios = require('axios')
    const cheerio = require('cheerio')
    const result = await axios
      .get('https://cubmu.com/live-tv')
      .then(response => response.data)
      .catch(console.error)

    const $ = cheerio.load(result)

    // retrieve service api data
    const config = JSON.parse($('#__NEXT_DATA__').text()).runtimeConfig || {}

    const options = {
      headers: {
        Origin: 'https://cubmu.com',
        Referer: 'https://cubmu.com/live-tv'
      }
    }
    // login to service bus
    const token = await axios
      .post(`https://servicebuss.transvision.co.id/tvs/login/external?email=${config.email}&password=${config.password}&deviceId=${config.deviceId}&deviceType=${config.deviceType}&deviceModel=${config.deviceModel}&deviceToken=&serial=&platformId=${config.platformId}`, options)
      .then(response => response.data)
      .catch(console.error)
    // list channels
    const subscribedChannels = await axios
      .post(`https://servicebuss.transvision.co.id/tvs/subscribe_product/list?platformId=${config.platformId}`, options)
      .then(response => response.data)
      .catch(console.error)

    const channels = []
    if (Array.isArray(subscribedChannels.channelPackageList)) {
      subscribedChannels.channelPackageList.forEach(pkg => {
        channels.push(...pkg.channelList.map(channel => {
          return {
            lang: 'id',
            site_id: channel.id,
            name: channel.name
          }
        }))
      })
    }

    return channels
  }
}

function parseItems(content) {
  return content ? JSON.parse(content.trim()).result || [] : []
}

function parseTitle(item) {
  return item.scehedule_title
}

function parseDescription(item) {
  return item.schedule_json.primarySynopsis
}

function parseEpisode(item) {
  return item.schedule_json.episodeName
}

function parseStart(item) {
  return dayjs.tz(item.schedule_date, 'YYYY-MM-DD HH:mm:ss', 'Asia/Jakarta')
}

function parseStop(item) {
  return dayjs.tz([item.schedule_date.split(' ')[0], item.schedule_end_time].join(' '), 'YYYY-MM-DD HH:mm:ss', 'Asia/Jakarta')
}