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

Installed epg-parser package

Browse source
This commit is contained in:
freearhey 2019-10-30 18:44:26 +03:00
parent bb9e23e738
commit fc39bcebce
4 changed files with 48 additions and 39 deletions
Download patch file Download diff file Expand all files Collapse all files

34
helpers/util.js
View file

@ -3,7 +3,7 @@ const path = require('path')
const parser = require('iptv-playlist-parser')
const axios = require('axios')
const zlib = require("zlib")
const DOMParser = require('xmldom').DOMParser
const epgParser = require('epg-parser')
const urlParser = require('url')
const supportedCategories = [ 'Auto','Business', 'Classic','Comedy','Documentary','Education','Entertainment', 'Family','Fashion','Food', 'General', 'Health', 'History', 'Hobby', 'Kids', 'Legislative','Lifestyle','Local', 'Movies', 'Music', 'News', 'Quiz', 'Religious','Sci-Fi', 'Shop', 'Sport', 'Travel', 'Weather', 'XXX' ]
@ -78,38 +78,20 @@ function createChannel(data) {
}
async function loadEPG(url) {
const data = await getGzipped(url)
const doc = new DOMParser().parseFromString(data, 'text/xml')
const channelElements = doc.getElementsByTagName('channel')
let channels = {}
for(let i = 0; i < channelElements.length; i++) {
let channel = {}
let channelElement = channelElements[i]
channel.id = channelElement.getAttribute('id')
channel.names = []
for(let nameElement of Object.values(channelElement.getElementsByTagName('display-name'))) {
if(nameElement.firstChild) {
channel.names.push(nameElement.firstChild.nodeValue)
}
}
channel.names = channel.names.filter(n => n)
const iconElements = channelElement.getElementsByTagName('icon')
if(iconElements.length) {
channel.icon = iconElements[0].getAttribute('src')
}
const content = await getEPGFile(url)
const result = epgParser.parse(content)
const channels = {}
for(let channel of result.channels) {
channels[channel.id] = channel
}
return Promise.resolve({
url,
channels
channels
})
}
function getGzipped(url) {
const supportedTypes = ['application/x-gzip', 'application/octet-stream']
function getEPGFile(url) {
return new Promise((resolve, reject) => {
var buffer = []
axios({
@ -118,7 +100,7 @@ function getGzipped(url) {
responseType:'stream'
}).then(res => {
let stream
if(supportedTypes.indexOf(res.headers['content-type']) > -1) {
if(/\.gz$/i.test(url)) {
let gunzip = zlib.createGunzip()
res.data.pipe(gunzip)
stream = gunzip