ckyri015
/
iptv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Small refactoring

This commit is contained in:
freearhey 2019-08-07 16:51:34 +03:00
parent 10ff2eac6a
commit 34efa18658
2 changed files with 89 additions and 84 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
helpers/format.js
View File

@ -1,7 +1,6 @@
const util = require('./util')
const debug = true
const verbal = false
const debug = false
let stats = {
countries: 0,
channels: 0,
@ -10,20 +9,22 @@ let stats = {
let buffer = {}
async function main() {
console.log('Parsing index.m3u...')
console.log(`Parsing 'index.m3u'...`)
const playlist = util.parsePlaylist('index.m3u')
let countries = playlist.items
if(debug) {
console.log('Debug mode is turn on')
// countries = countries.slice(0, 1)
countries = countries.slice(0, 1)
// countries = [{ url: 'channels/au.m3u' }]
}
for(let country of countries) {
console.log(`Parsing ${country.url}...`)
console.log(`Parsing '${country.url}'...`)
const playlist = util.parsePlaylist(country.url)
console.log(`Creating channels list...`)
if(debug) {
console.log(`Creating channels list...`)
}
let channels = []
for(let item of playlist.items) {
let channel = util.createChannel({
@ -39,45 +40,49 @@ async function main() {
const epgUrl = playlist.attrs['x-tvg-url']
if(epgUrl && !buffer[epgUrl]) {
console.log(`Loading ${epgUrl}...`)
console.log(`Loading '${epgUrl}'...`)
const epg = await util.loadEPG(epgUrl)
console.log(`Adding ${epgUrl} to buffer...`)
console.log(`Adding '${epgUrl}' to buffer...`)
buffer[epgUrl] = epg
}
console.log(`Fills in missing channel's data...`)
for(let channel of channels) {
let channelId = channel.id
if(!channelId) continue
let c = buffer[epgUrl] ? buffer[epgUrl].channels[channelId] : null
if(!c) continue
let updated = false
if(!channel.name && c.names[0]) {
channel.name = c.names[0]
updated = true
if(verbal) {
console.log(`Added name '${c.names[0]}' to '${channel.id}'`)
if(buffer[epgUrl]) {
console.log(`Fills in missing channel's data...`)
for(let channel of channels) {
let channelId = channel.id
if(!channelId) continue
let c = buffer[epgUrl].channels[channelId]
if(!c) continue
let updated = false
if(!channel.name && c.names[0]) {
channel.name = c.names[0]
updated = true
if(debug) {
console.log(`Added name '${c.names[0]}' to '${channel.id}'`)
}
}
}
if(!channel.logo && c.icon) {
channel.logo = c.icon
updated = true
if(verbal) {
console.log(`Added logo '${c.icon}' to '${channel.id}'`)
if(!channel.logo && c.icon) {
channel.logo = c.icon
updated = true
if(debug) {
console.log(`Added logo '${c.icon}' to '${channel.id}'`)
}
}
}
if(updated) {
stats.updated++
if(updated) {
stats.updated++
}
}
}
console.log(`Sorting channels...`)
if(debug) {
console.log(`Sorting channels...`)
}
channels = util.sortByTitle(channels)
console.log(`Writing result to file...`)
console.log(`Updating '${country.url}'...`)
util.createFile(country.url, playlist.getHeader())
channels.forEach(channel => {
util.appendToFile(country.url, channel.toString())

104
helpers/util.js
View File

@ -52,27 +52,41 @@ class Channel {
}
}
function getGzipped(url) {
return new Promise((resolve, reject) => {
var buffer = []
https.get(url, function(res) {
var gunzip = zlib.createGunzip()
res.pipe(gunzip)
gunzip.on('data', function(data) {
buffer.push(data.toString())
}).on("end", function() {
resolve(buffer.join(""))
}).on("error", function(e) {
reject(e)
})
}).on('error', function(e) {
reject(e)
})
function parsePlaylist(filename) {
const parser = new M3U8FileParser()
const content = readFile(filename)
parser.read(content)
let results = parser.getResult()
let contentMatches = content.match(/^.+(?=#|\n|\r)/g)
let head = contentMatches.length ? contentMatches[0] : null
let attrs = {}
if(head) {
const parts = head.split(' ').filter(p => p !== '#EXTM3U').filter(p => p)
for(const attr of parts) {
let attrParts = attr.split('=')
attrs[attrParts[0]] = attrParts[1].replace(/\"/g, '')
}
}
results.attrs = attrs
return new Playlist({
attrs: results.attrs,
items: results.segments
})
}
function readFile(filename) {
return fs.readFileSync(path.resolve(__dirname) + `/../${filename}`, { encoding: "utf8" })
function createChannel(data) {
return new Channel({
id: data.id,
name: data.name,
logo: data.logo,
group: data.group,
url: data.url,
title: data.title
})
}
async function loadEPG(url) {
@ -105,40 +119,22 @@ async function loadEPG(url) {
})
}
function createChannel(data) {
return new Channel({
id: data.id,
name: data.name,
logo: data.logo,
group: data.group,
url: data.url,
title: data.title
})
}
function parsePlaylist(filename) {
const parser = new M3U8FileParser()
const content = readFile(filename)
parser.read(content)
let results = parser.getResult()
let contentMatches = content.match(/^.+(?=#|\n|\r)/g)
let head = contentMatches.length ? contentMatches[0] : null
let attrs = {}
if(head) {
const parts = head.split(' ').filter(p => p !== '#EXTM3U').filter(p => p)
for(const attr of parts) {
let attrParts = attr.split('=')
attrs[attrParts[0]] = attrParts[1].replace(/\"/g, '')
}
}
results.attrs = attrs
return new Playlist({
attrs: results.attrs,
items: results.segments
function getGzipped(url) {
return new Promise((resolve, reject) => {
var buffer = []
https.get(url, function(res) {
var gunzip = zlib.createGunzip()
res.pipe(gunzip)
gunzip.on('data', function(data) {
buffer.push(data.toString())
}).on("end", function() {
resolve(buffer.join(""))
}).on("error", function(e) {
reject(e)
})
}).on('error', function(e) {
reject(e)
})
})
}
@ -159,6 +155,10 @@ function sortByTitle(arr) {
return arr.sort(byTitle)
}
function readFile(filename) {
return fs.readFileSync(path.resolve(__dirname) + `/../${filename}`, { encoding: "utf8" })
}
function appendToFile(filename, data) {
fs.appendFileSync(path.resolve(__dirname) + '/../' + filename, data)
}