iptv-org-mirror/epg
1
0
Fork 0
mirror of https://github.com/iptv-org/epg.git synced 2025-05-10 09:00:07 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update ziggogo.tv.config.js

Browse source
This commit is contained in:
Aleksandr Statciuk 2022-10-28 21:55:00 +03:00
parent 8b2b472c4c
commit 426148edea
1 changed files with 70 additions and 58 deletions
Download patch file Download diff file Expand all files Collapse all files

128
sites/ziggogo.tv/ziggogo.tv.config.js
View file

@ -1,108 +1,120 @@
const axios = require('axios') const axios = require('axios')
const dayjs = require('dayjs') const dayjs = require('dayjs')
const API_ENDPOINT = `https://obo-prod.oesp.ziggogo.tv/oesp/v4/NL/nld/web` const API_ENDPOINT = `https://static.spark.ziggogo.tv/eng/web/epg-service-lite`
module.exports = { module.exports = {
site: 'ziggogo.tv', site: 'ziggogo.tv',
url: function ({ date }) { request: {
return `${API_ENDPOINT}/programschedules/${date.format('YYYYMMDD')}/1` cache: {
ttl: 60 * 60 * 1000 // 1 hour
}
},
url: function ({ date, channel }) {
return `${API_ENDPOINT}/nl/${channel.lang}/events/segments/${date.format('YYYYMMDDHHmmss')}`
}, },
async parser({ content, channel, date }) { async parser({ content, channel, date }) {
let programs = [] let programs = []
let items = parseItems(content, channel) let items = parseItems(content, channel)
if (!items.length) return programs if (!items.length) return programs
const d = date.format('YYYYMMDD')
const promises = [ const promises = [
axios.get(`${API_ENDPOINT}/programschedules/${d}/2`), axios.get(
axios.get(`${API_ENDPOINT}/programschedules/${d}/3`), `${API_ENDPOINT}/nl/${channel.lang}/events/segments/${date
axios.get(`${API_ENDPOINT}/programschedules/${d}/4`) .add(6, 'h')
.format('YYYYMMDDHHmmss')}`,
{
responseType: 'arraybuffer'
}
),
axios.get(
`${API_ENDPOINT}/nl/${channel.lang}/events/segments/${date
.add(12, 'h')
.format('YYYYMMDDHHmmss')}`,
{
responseType: 'arraybuffer'
}
),
axios.get(
`${API_ENDPOINT}/nl/${channel.lang}/events/segments/${date
.add(18, 'h')
.format('YYYYMMDDHHmmss')}`,
{
responseType: 'arraybuffer'
}
)
] ]
await Promise.allSettled(promises) await Promise.allSettled(promises)
.then(results => { .then(results => {
results.forEach(r => { results.forEach(r => {
if (r.status === 'fulfilled') { if (r.status === 'fulfilled') {
items = items.concat(parseItems(r.value.data, channel)) const parsed = parseItems(r.value.data, channel)
items = items.concat(parsed)
} }
}) })
}) })
.catch(console.error) .catch(console.error)
// items.forEach(item => {
for (let item of items) { for (let item of items) {
const detail = await loadProgramDetails(item) const detail = await loadProgramDetails(item, channel)
programs.push({ programs.push({
title: item.t, title: item.title,
description: parseDescription(detail), description: detail.longDescription,
category: parseCategory(detail), category: detail.genres,
season: parseSeason(detail), actors: detail.actors,
episode: parseEpisode(detail), season: detail.seasonNumber,
start: parseStart(item), episode: detail.episodeNumber,
stop: parseStop(item) start: parseStart(item),
}) stop: parseStop(item)
})
} }
//)
return programs return programs
}, },
async channels() { async channels() {
const data = await axios const data = await axios
.get(`${API_ENDPOINT}/channels`) .get(
`https://prod.spark.ziggogo.tv/eng/web/linear-service/v2/channels?cityId=65535&language=en&productClass=Orion-DASH`
)
.then(r => r.data) .then(r => r.data)
.catch(console.log) .catch(console.log)
return data.channels.map(item => { return data.channels.map(item => {
return { return {
lang: 'be', lang: 'be',
site_id: item.id.replace('lgi-nl-prod-master:65535-', ''), site_id: item.id,
name: item.title name: item.name
} }
}) })
} }
} }
async function loadProgramDetails(item) { async function loadProgramDetails(item, channel) {
if (!item.i) return {} if (!item.id) return {}
const url = `${API_ENDPOINT}/listings/${item.i}` const url = `https://prod.spark.ziggogo.tv/eng/web/linear-service/v2/replayEvent/${item.id}?returnLinearContent=true&language=${channel.lang}`
const data = await axios const data = await axios
.get(url) .get(url)
.then(r => r.data) .then(r => r.data)
.catch(console.log) .catch(console.log)
return data || {}
} return data || {}
}
function parseStart(item) { function parseStart(item) {
return dayjs(item.s) return dayjs.unix(item.startTime)
} }
function parseStop(item) { function parseStop(item) {
return dayjs(item.e) return dayjs.unix(item.endTime)
} }
function parseItems(content, channel) { function parseItems(content, channel) {
const data = typeof content === 'string' ? JSON.parse(content) : content if (!content) return []
const data = JSON.parse(content)
if (!data || !Array.isArray(data.entries)) return [] if (!data || !Array.isArray(data.entries)) return []
const entity = data.entries.find(e => e.o === `lgi-nl-prod-master:${channel.site_id}`) const channelData = data.entries.find(e => e.channelId === channel.site_id)
if (!channelData) return []
return entity ? entity.l : [] return Array.isArray(channelData.events) ? channelData.events : []
} }
function parseDescription(detail){
return detail.program.longDescription || null
}
function parseCategory(detail) {
let categories = []
detail.program.categories.forEach(category => {
categories.push(category.title)
});
return categories
}
function parseSeason(detail) {
return detail.program.seriesNumber || null
}
function parseEpisode(detail) {
return detail.program.seriesEpisodeNumber || null
}