Add site cubmu.com.

Signed-off-by: Toha <tohenk@yahoo.com>
This commit is contained in:
Toha 2023-11-05 17:04:26 +07:00
parent babd565098
commit ed33315fc3
No known key found for this signature in database
GPG key ID: 2D7AA6389D44DCAB
3 changed files with 229 additions and 0 deletions

View file

@ -0,0 +1,98 @@
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')
}