iptv-org/epg
2
0 Fork 0
mirror of https://github.com/iptv-org/epg synced 2026-10-28 22:04:01 -04:00
Code Issues Packages Projects Releases Wiki Activity

crlf fix

Browse Source
This commit is contained in:
StrangeDrVN authored and GitHub committed 2026-02-22 18:24:23 +05:30
1 parent a425f60c05
commit ccf40773a2
2 files changed
+297 -297
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

sites/watch.whaletvplus.com/watch.whaletvplus.com.config.js
+166 -166
View File
@@ -1,167 +1,167 @@
const axios = require('axios') const axios = require('axios')
const dayjs = require('dayjs') const dayjs = require('dayjs')
const HEADERS = { const HEADERS = {
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:147.0) Gecko/20100101 Firefox/147.0', 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:147.0) Gecko/20100101 Firefox/147.0',
'Referer': 'https://watch.whaletvplus.com/', 'Referer': 'https://watch.whaletvplus.com/',
'Origin': 'https://watch.whaletvplus.com' 'Origin': 'https://watch.whaletvplus.com'
} }
const apiToken = '4ef13b5f3d2744e3b0a569feb8dde298' const apiToken = '4ef13b5f3d2744e3b0a569feb8dde298'
let authTokenPromise = null let authTokenPromise = null
module.exports = { module.exports = {
site: 'watch.whaletvplus.com', site: 'watch.whaletvplus.com',
days: 2, days: 2,
request: { request: {
cache: { cache: {
ttl: 60 * 60 * 1000 // Cache 1 hour ttl: 60 * 60 * 1000 // Cache 1 hour
}, },
headers: async function() { headers: async function() {
const token = await getAuthToken() const token = await getAuthToken()
return { return {
...HEADERS, ...HEADERS,
'token': token 'token': token
} }
} }
}, },
url: function ({ channel, date }) { url: function ({ channel, date }) {
const start = date.valueOf() const start = date.valueOf()
const end = date.add(1, 'day').valueOf() const end = date.add(1, 'day').valueOf()
return `https://rlaxx.zeasn.tv/livetv/api/device/browser/v1/epg?channelIds=${channel.site_id}&startTime=${start}&endTime=${end}` return `https://rlaxx.zeasn.tv/livetv/api/device/browser/v1/epg?channelIds=${channel.site_id}&startTime=${start}&endTime=${end}`
}, },
parser: async function ({ content }) { parser: async function ({ content }) {
let json let json
try { try {
json = JSON.parse(content) json = JSON.parse(content)
} catch (e) { } catch (e) {
console.error('Error parsing JSON:', e) console.error('Error parsing JSON:', e)
return [] return []
} }
if (!json.data || !Array.isArray(json.data) || !json.data[0] || !Array.isArray(json.data[0].ptList)) { if (!json.data || !Array.isArray(json.data) || !json.data[0] || !Array.isArray(json.data[0].ptList)) {
return [] return []
} }
const programs = json.data[0].ptList const programs = json.data[0].ptList
const detailsCache = {} const detailsCache = {}
return await limit(programs, async (p) => { return await limit(programs, async (p) => {
const program = { const program = {
title: p.prgTitle, title: p.prgTitle,
start: dayjs(Number(p.prgStm)), start: dayjs(Number(p.prgStm)),
stop: dayjs(Number(p.prgEtm)) stop: dayjs(Number(p.prgEtm))
} }
if (p.prgchId) { if (p.prgchId) {
if (!detailsCache[p.prgchId]) { if (!detailsCache[p.prgchId]) {
detailsCache[p.prgchId] = fetchProgramDetail(p.prgchId) detailsCache[p.prgchId] = fetchProgramDetail(p.prgchId)
} }
const detail = await detailsCache[p.prgchId] const detail = await detailsCache[p.prgchId]
if (detail) { if (detail) {
program.description = detail.prgDesc || null program.description = detail.prgDesc || null
program.season = detail.seasonNumber || null program.season = detail.seasonNumber || null
program.episode = detail.episodeNumber || null program.episode = detail.episodeNumber || null
program.sub_title = detail.prgTitle || detail.seriesTitle || null program.sub_title = detail.prgTitle || detail.seriesTitle || null
if (program.title === program.sub_title) { if (program.title === program.sub_title) {
program.sub_title = null program.sub_title = null
} }
if (detail.images && Array.isArray(detail.images)) { if (detail.images && Array.isArray(detail.images)) {
const bestImg = detail.images.find((i) => i.pimgWidth === '1920') || detail.images[0] const bestImg = detail.images.find((i) => i.pimgWidth === '1920') || detail.images[0]
if (bestImg) program.image = bestImg.pimgUrl if (bestImg) program.image = bestImg.pimgUrl
} }
} }
} }
return program return program
}) })
}, },
async channels() { async channels() {
const token = await getAuthToken() const token = await getAuthToken()
const countries = [ const countries = [
'IN', 'AU', 'NZ', 'ZA', 'US', 'BR', 'MX', 'AR', 'CO', 'CL', 'CA', 'IN', 'AU', 'NZ', 'ZA', 'US', 'BR', 'MX', 'AR', 'CO', 'CL', 'CA',
'GB', 'DE', 'FR', 'IT', 'ES', 'PL', 'TR', 'AT', 'CH', 'NL', 'PT', 'GB', 'DE', 'FR', 'IT', 'ES', 'PL', 'TR', 'AT', 'CH', 'NL', 'PT',
'BE', 'SE', 'NO', 'DK', 'FI' 'BE', 'SE', 'NO', 'DK', 'FI'
] ]
const requests = countries.map(country => const requests = countries.map(country =>
axios.get('https://rlaxx.zeasn.tv/livetv/api/device/browser/v1/category/channels', { axios.get('https://rlaxx.zeasn.tv/livetv/api/device/browser/v1/category/channels', {
params: { countryCode: country, langCode: 'en' }, params: { countryCode: country, langCode: 'en' },
headers: { ...HEADERS, token } headers: { ...HEADERS, token }
}).then(r => r.data?.data || []).catch(() => []) }).then(r => r.data?.data || []).catch(() => [])
) )
const results = await Promise.all(requests) const results = await Promise.all(requests)
const allChannels = results.flat().flatMap(group => group.channels || []) const allChannels = results.flat().flatMap(group => group.channels || [])
const uniqueChannels = new Map() const uniqueChannels = new Map()
for (const ch of allChannels) { for (const ch of allChannels) {
if (!uniqueChannels.has(ch.chlId)) { if (!uniqueChannels.has(ch.chlId)) {
uniqueChannels.set(ch.chlId, { uniqueChannels.set(ch.chlId, {
lang: (ch.chlLangCode ? ch.chlLangCode.split('-')[0] : 'en'), lang: (ch.chlLangCode ? ch.chlLangCode.split('-')[0] : 'en'),
site_id: ch.chlId, site_id: ch.chlId,
name: ch.chlName, name: ch.chlName,
// logo: ch.imageIdentifier ? `https://d3b6luslimvglo.cloudfront.net/images/79/rlaxximages/channels-rescaled/icon-white/${ch.imageIdentifier}_white.png` : null // logo: ch.imageIdentifier ? `https://d3b6luslimvglo.cloudfront.net/images/79/rlaxximages/channels-rescaled/icon-white/${ch.imageIdentifier}_white.png` : null
}) })
} }
} }
return Array.from(uniqueChannels.values()) return Array.from(uniqueChannels.values())
} }
} }
async function limit(items, fn, concurrency = 20) { async function limit(items, fn, concurrency = 20) {
const results = [] const results = []
for (let i = 0; i < items.length; i += concurrency) { for (let i = 0; i < items.length; i += concurrency) {
const batch = items.slice(i, i + concurrency) const batch = items.slice(i, i + concurrency)
results.push(...(await Promise.all(batch.map(fn)))) results.push(...(await Promise.all(batch.map(fn))))
} }
return results return results
} }
async function getAuthToken() { async function getAuthToken() {
if (authTokenPromise) return authTokenPromise if (authTokenPromise) return authTokenPromise
authTokenPromise = (async () => { authTokenPromise = (async () => {
try { try {
const response = await axios.get('https://rlaxx.zeasn.tv/livetv/api/v1/auth/access', { const response = await axios.get('https://rlaxx.zeasn.tv/livetv/api/v1/auth/access', {
params: { uuid: '1', apiToken, langCode: 'en' }, params: { uuid: '1', apiToken, langCode: 'en' },
headers: HEADERS headers: HEADERS
}) })
if (response.data && response.data.data && response.data.data.token) { if (response.data && response.data.data && response.data.data.token) {
return response.data.data.token return response.data.data.token
} }
throw new Error('apiToken invalid or expired. Please update config.') throw new Error('apiToken invalid or expired. Please update config.')
} catch (error) { } catch (error) {
authTokenPromise = null authTokenPromise = null
throw new Error(error.message) throw new Error(error.message)
} }
})() })()
return authTokenPromise return authTokenPromise
} }
async function fetchProgramDetail(programId) { async function fetchProgramDetail(programId) {
const token = await getAuthToken() const token = await getAuthToken()
try { try {
const response = await axios.get(`https://rlaxx.zeasn.tv/livetv/api/device/browser/v1/epg/detail/${programId}`, { const response = await axios.get(`https://rlaxx.zeasn.tv/livetv/api/device/browser/v1/epg/detail/${programId}`, {
headers: { headers: {
...HEADERS, ...HEADERS,
'token': token 'token': token
}, },
timeout: 5000 timeout: 5000
}) })
return response.data && response.data.data ? response.data.data : null return response.data && response.data.data ? response.data.data : null
} catch { } catch {
return null return null
} }
} }
sites/watch.whaletvplus.com/watch.whaletvplus.com.test.js
+131 -131
View File
@@ -1,132 +1,132 @@
const { parser, url, channels } = require('./watch.whaletvplus.com.config.js') const { parser, url, channels } = require('./watch.whaletvplus.com.config.js')
const fs = require('fs') const fs = require('fs')
const path = require('path') const path = require('path')
const dayjs = require('dayjs') const dayjs = require('dayjs')
const utc = require('dayjs/plugin/utc') const utc = require('dayjs/plugin/utc')
const customParseFormat = require('dayjs/plugin/customParseFormat') const customParseFormat = require('dayjs/plugin/customParseFormat')
const axios = require('axios') const axios = require('axios')
dayjs.extend(customParseFormat) dayjs.extend(customParseFormat)
dayjs.extend(utc) dayjs.extend(utc)
jest.mock('axios') jest.mock('axios')
const date = dayjs.utc('2026-01-08', 'YYYY-MM-DD').startOf('d') const date = dayjs.utc('2026-01-08', 'YYYY-MM-DD').startOf('d')
const content = fs.readFileSync(path.resolve(__dirname, '__data__/content.json'), 'utf8') const content = fs.readFileSync(path.resolve(__dirname, '__data__/content.json'), 'utf8')
it('can generate valid url', () => { it('can generate valid url', () => {
const channel = { site_id: '878765717599035555' } const channel = { site_id: '878765717599035555' }
const generatedUrl = url({ channel, date }) const generatedUrl = url({ channel, date })
expect(generatedUrl).toBe( expect(generatedUrl).toBe(
'https://rlaxx.zeasn.tv/livetv/api/device/browser/v1/epg?channelIds=878765717599035555&startTime=1767830400000&endTime=1767916800000' 'https://rlaxx.zeasn.tv/livetv/api/device/browser/v1/epg?channelIds=878765717599035555&startTime=1767830400000&endTime=1767916800000'
) )
}) })
it('can parse response', async () => { it('can parse response', async () => {
axios.get.mockImplementation((url) => { axios.get.mockImplementation((url) => {
if (url.includes('auth/access')) { if (url.includes('auth/access')) {
return Promise.resolve({ return Promise.resolve({
data: { data: { token: 'mock_token' } } data: { data: { token: 'mock_token' } }
}) })
} }
if (url.includes('epg/detail')) { if (url.includes('epg/detail')) {
return Promise.resolve({ return Promise.resolve({
data: { data: { prgDesc: 'Test Description' } } data: { data: { prgDesc: 'Test Description' } }
}) })
} }
return Promise.resolve({ data: {} }) return Promise.resolve({ data: {} })
}) })
const json = JSON.parse(content) const json = JSON.parse(content)
const firstChannel = json.data && json.data.length > 0 ? json.data[0] : null const firstChannel = json.data && json.data.length > 0 ? json.data[0] : null
const validSiteId = firstChannel ? firstChannel.chlId : '878765717599035555' const validSiteId = firstChannel ? firstChannel.chlId : '878765717599035555'
const channel = { const channel = {
site_id: validSiteId, site_id: validSiteId,
xmltv_id: 'Test.Channel' xmltv_id: 'Test.Channel'
} }
const result = await parser({ content, channel }) const result = await parser({ content, channel })
expect(result).toBeInstanceOf(Array) expect(result).toBeInstanceOf(Array)
expect(result.length).toBeGreaterThan(0) expect(result.length).toBeGreaterThan(0)
expect(result[0]).toMatchObject({ expect(result[0]).toMatchObject({
title: expect.any(String), title: expect.any(String),
start: expect.any(Object), start: expect.any(Object),
stop: expect.any(Object) stop: expect.any(Object)
}) })
}) })
it('can handle empty guide', async () => { it('can handle empty guide', async () => {
const result = await parser({ const result = await parser({
content: '{"data":[]}', content: '{"data":[]}',
channel: { site_id: '123' } channel: { site_id: '123' }
}) })
expect(result).toMatchObject([]) expect(result).toMatchObject([])
}) })
it('can parse channel list', async () => { it('can parse channel list', async () => {
axios.get.mockImplementation((reqUrl) => { axios.get.mockImplementation((reqUrl) => {
if (reqUrl.includes('auth/access')) { if (reqUrl.includes('auth/access')) {
return Promise.resolve({ return Promise.resolve({
data: { data: { token: 'mock_token_123' } } data: { data: { token: 'mock_token_123' } }
}) })
} }
if (reqUrl.includes('category/channels')) { if (reqUrl.includes('category/channels')) {
return Promise.resolve({ return Promise.resolve({
data: { data: {
data: [ data: [
{ {
channels: [ channels: [
{ {
chlId: '878765717599035555', chlId: '878765717599035555',
chlName: 'Wedo Movies', chlName: 'Wedo Movies',
chlLangCode: 'en' chlLangCode: 'en'
}, },
{ {
chlId: '999420644834214633', chlId: '999420644834214633',
chlName: 'FIFA+', chlName: 'FIFA+',
chlLangCode: 'es' chlLangCode: 'es'
} }
] ]
} }
] ]
} }
}) })
} }
return Promise.resolve({ data: {} }) return Promise.resolve({ data: {} })
}) })
const result = await channels() const result = await channels()
expect(result).toBeInstanceOf(Array) expect(result).toBeInstanceOf(Array)
expect(result.length).toBeGreaterThan(0) expect(result.length).toBeGreaterThan(0)
expect(result[0]).toMatchObject({ expect(result[0]).toMatchObject({
name: expect.any(String), name: expect.any(String),
site_id: expect.any(String), site_id: expect.any(String),
lang: expect.any(String) lang: expect.any(String)
}) })
}) })
it('can parse token', async () => { it('can parse token', async () => {
jest.resetModules() jest.resetModules()
const { request } = require('./watch.whaletvplus.com.config.js') const { request } = require('./watch.whaletvplus.com.config.js')
const axios = require('axios') const axios = require('axios')
axios.get.mockImplementation((url) => { axios.get.mockImplementation((url) => {
if (url.includes('auth/access')) { if (url.includes('auth/access')) {
return Promise.resolve({ return Promise.resolve({
data: { data: { token: 'test_token' } } data: { data: { token: 'test_token' } }
}) })
} }
return Promise.resolve({ data: {} }) return Promise.resolve({ data: {} })
}) })
const headers = await request.headers() const headers = await request.headers()
expect(headers.token).toBe('test_token') expect(headers.token).toBe('test_token')
}) })