Create mojmaxtv.hrvatskitelekom.hr.config.js

sites/mojmaxtv.hrvatskitelekom.hr/mojmaxtv.hrvatskitelekom.hr.config.js

@@ -0,0 +1,101 @@
+const doFetch = require('@ntlab/sfetch')
+const axios = require('axios')
+const dayjs = require('dayjs')
+const _ = require('lodash')
+
+const cached = {}
+
+module.exports = {
+  site: 'mojmaxtv.hrvatskitelekom.hr',
+  url({ date }) {
+    return `https://tv-hr-prod.yo-digital.com/hr-bifrost/epg/channel/schedules?date=${date.format(
+      'YYYY-MM-DD'
+    )}&hour_offset=0&hour_range=3&channelMap_id&filler=true&app_language=hr&natco_code=hr`
+  },
+  request: {
+    headers: {
+      app_key: 'GWaBW4RTloLwpUgYVzOiW5zUxFLmoMj5',
+      app_version: '02.0.1080',
+      'device-id': 'a78f079d-5527-46d8-af3f-9f0b6b6fb758',
+      'x-request-session-id': 'fc96c9de-7a3b-4b51-8b9d-5d9f9a3c3268',
+      'x-request-tracking-id': '05a8f0bc-f977-4754-b8ad-1d4d1bd742fb',
+      'x-user-agent': 'web|web|Chrome-128|02.0.1080|1'
+    },
+    cache: {
+      ttl: 24 * 60 * 60 * 1000 // 1 day
+    }
+  },
+  async parser({ content, channel, date }) {
+    const data = parseData(content)
+    if (!data) return []
+
+    let items = parseItems(data, channel)
+    if (!items.length) return []
+
+    const queue = [3, 6, 9, 12, 15, 18, 21]
+      .map(offset => {
+        const url = module.exports.url({ date }).replace('hour_offset=0', `hour_offset=${offset}`)
+        const params = module.exports.request
+
+        if (cached[url]) {
+          items = items.concat(parseItems(cached[url], channel))
+
+          return null
+        }
+
+        return { url, params }
+      })
+      .filter(Boolean)
+
+    await doFetch(queue, (_req, _data) => {
+      if (_data) {
+        cached[_req.url] = _data
+
+        items = items.concat(parseItems(_data, channel))
+      }
+    })
+
+    items = _.sortBy(items, i => dayjs(i.start_time).valueOf())
+
+    return items.map(item => ({
+      title: item.description,
+      categories: Array.isArray(item.genres) ? item.genres.map(g => g.name) : [],
+      season: item.season_number,
+      episode: item.episode_number ? parseInt(item.episode_number) : null,
+      date: item['release_year'] ? item['release_year'].toString() : null,
+      start: item.start_time,
+      stop: item.end_time
+    }))
+  },
+  async channels() {
+    const data = await axios
+      .get(
+        'https://tv-hr-prod.yo-digital.com/hr-bifrost/epg/channel?channelMap_id=&includeVirtualChannels=false&natco_key=l2lyvGVbUm2EKJE96ImQgcc8PKMZWtbE&app_language=hr&natco_code=hr',
+        module.exports.request
+      )
+      .then(r => r.data)
+      .catch(console.error)
+
+    return data.channels.map(channel => ({
+      lang: 'hr',
+      name: channel.title,
+      site_id: channel.station_id
+    }))
+  }
+}
+
+function parseData(content) {
+  try {
+    const data = JSON.parse(content)
+
+    return data || null
+  } catch {
+    return null
+  }
+}
+
+function parseItems(data, channel) {
+  if (!data.channels || !Array.isArray(data.channels[channel.site_id])) return []
+
+  return data.channels[channel.site_id]
+}