lesion/radiomanifest.js
1
0
Fork 0
forked from boyska/radiomanifest.js
Code Releases Activity

basic karma/mocha test suite setup

Browse source
This commit is contained in:
lesion 2021-11-18 15:35:32 +01:00
parent af9f6c2598
commit 221430c017
5 changed files with 229 additions and 90 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
.gitignore vendored Normal file
View file

@ -0,0 +1 @@
node_modules

34
karma.config.js Normal file
View file

@ -0,0 +1,34 @@
module.exports = function (config) {
config.set({
frameworks: ['mocha'],
// plugins: ['karma-webpack', 'karma-mocha', 'karma-chai-as-promised'],
webpack: {
// karma watches the test entry points
// Do NOT specify the entry option
// webpack watches dependencies
// webpack configuration
},
preprocessors: {
'test/**/*.js': ['webpack'],
'radiomanifest.js': ['webpack']
},
files: [
'radiomanifest.js',
'test/**/*.js'
],
reporters: ['progress'],
port: 9876, // karma web server port
colors: true,
logLevel: config.LOG_INFO,
browsers: ['ChromeHeadless', 'FirefoxHeadless'],
autoWatch: false,
concurrency: Infinity,
customLaunchers: {
FirefoxHeadless: {
base: 'Firefox',
flags: ['-headless'],
},
},
})
}

34
package.json Normal file
View file

@ -0,0 +1,34 @@
{
"name": "radiomanifest",
"version": "0.1.0",
"description": "",
"main": "radiomanifest.js",
"directories": {
"test": "tests"
},
"repository": {
"type": "git",
"url": "gogs@git.lattuga.net:lesion/radiomanifest.js.git"
},
"scripts": {
"test": "npm run test:node && npm run test:browser",
"test:node": "mocha",
"test:browser": "karma start --single-run --browsers ChromeHeadless,FirefoxHeadless karma.config.js"
},
"author": "",
"license": "ISC",
"devDependencies": {
"chai": "^4.3.4",
"chai-as-promised": "^7.1.1",
"karma": "^6.3.9",
"karma-chrome-launcher": "^3.1.0",
"karma-firefox-launcher": "^2.1.2",
"karma-mocha": "^2.0.1",
"karma-webpack": "^5.0.0",
"mocha": "^9.1.3",
"webpack": "^5.64.1"
},
"dependencies": {
"isomorphic-unfetch": "^3.1.0"
}
}

219
radiomanifest.js
View file

@ -1,121 +1,160 @@
const fetch = require('isomorphic-unfetch')
module.exports = {
/**
*
* @param {String} baseURL to search for a radiomanifest
*/
get (baseURL, options = { shows: false, streaming: false, calendar: false }) {
return new RadioManifest(baseURL, options )
}
}
class RadioManifest {
constructor (baseURL, options) {
this.baseURL = baseURL
this.options = options
const radiomanifest = fetch(`${baseURL}/radiomanifest.xml`)
return radiomanifest
}
getShowByName (showName) {
}
getStreaming () {
}
getSchedule () {
}
getShowAtTime () {
}
}
function getStreaminfoUrl(siteurl) { function getStreaminfoUrl(siteurl) {
return siteurl + '/streaminfo.json'; // XXX: improve this logic return siteurl + '/streaminfo.json'; // XXX: improve this logic
} }
function getManifestUrl(siteurl) { function getManifestUrl(siteurl) {
return siteurl + '/radiomanifest.xml'; // XXX: improve this logic return siteurl + '/radiomanifest.xml'; // XXX: improve this logic
} }
function parseRadioManifest(xml) { function parseRadioManifest(xml) {
var res = xml.evaluate('/radio-manifest/streaming/source', xml) var res = xml.evaluate('/radio-manifest/streaming/source', xml)
var sources = [] var sources = []
while(true) { while(true) {
var src = res.iterateNext() var src = res.iterateNext()
if(src === null) break; if(src === null) break;
if(!src.hasAttribute("priority")) { if(!src.hasAttribute("priority")) {
src.setAttribute("priority", "0") src.setAttribute("priority", "0")
} else if(parseInt(src.getAttribute("priority"), 10) < 0) { } else if(parseInt(src.getAttribute("priority"), 10) < 0) {
continue; continue;
}
sources.push(src)
} }
sources.sort(function cmp(a,b) { sources.push(src)
return parseInt(a.getAttribute("priority", 10)) < parseInt(b.getAttribute("priority", 10)); }
}) sources.sort(function cmp(a,b) {
return parseInt(a.getAttribute("priority", 10)) < parseInt(b.getAttribute("priority", 10));
res = xml.evaluate('/radio-manifest/schedule', xml) })
var scheduleEl = res.iterateNext()
var schedule = null res = xml.evaluate('/radio-manifest/schedule', xml)
if(scheduleEl !== null) { var scheduleEl = res.iterateNext()
schedule = scheduleEl.getAttribute("url") var schedule = null
} if(scheduleEl !== null) {
schedule = scheduleEl.getAttribute("url")
res = xml.evaluate('/radio-manifest/shows', xml) }
var showsEl = res.iterateNext()
var shows = null res = xml.evaluate('/radio-manifest/shows', xml)
if(showsEl !== null) { var showsEl = res.iterateNext()
shows = showsEl.getAttribute("src") var shows = null
} if(showsEl !== null) {
shows = showsEl.getAttribute("src")
var manifest = new Radio(sources, schedule, shows) }
return manifest
var manifest = new Radio(sources, schedule, shows)
return manifest
} }
function Radio(sources, schedule, shows) { function Radio(sources, schedule, shows) {
this.streaming = new RadioStreaming(sources) this.streaming = new RadioStreaming(sources)
this.schedule = schedule this.schedule = schedule
this.shows = shows this.shows = shows
this.name = "" this.name = ""
} }
Radio.prototype.getStreaming = function() { Radio.prototype.getStreaming = function() {
return this.streaming return this.streaming
} }
Radio.prototype.setName = function(name) { Radio.prototype.setName = function(name) {
this.name = name this.name = name
} }
function RadioStreaming(sources) { function RadioStreaming(sources) {
this.sources = sources this.sources = sources
} }
RadioStreaming.prototype.getOptions = function() { RadioStreaming.prototype.getOptions = function() {
return this.sources.map(function(x) { return this.sources.map(function(x) {
return x.getAttribute('name') return x.getAttribute('name')
}) })
} }
RadioStreaming.prototype.getSource = function (name) { RadioStreaming.prototype.getSource = function (name) {
if(name === undefined) { if(name === undefined) {
} }
var s = this.sources.find(function(x) { var s = this.sources.find(function(x) {
return x.getAttribute('name') === name return x.getAttribute('name') === name
}) })
if(s === undefined) return s if(s === undefined) return s
return s.getAttribute('src') return s.getAttribute('src')
} }
async function get(siteurl, options) { async function get(siteurl, options) {
let resp = await fetch(getManifestUrl(siteurl)); let resp = await fetch(getManifestUrl(siteurl));
let text = await resp.text() let text = await resp.text()
var parser = new DOMParser(); var parser = new DOMParser();
var dom = parser.parseFromString(text, 'text/xml') var dom = parser.parseFromString(text, 'text/xml')
var manifest = parseRadioManifest(dom) var manifest = parseRadioManifest(dom)
resp = null resp = null
try { try {
resp = await fetch(getStreaminfoUrl(siteurl)); resp = await fetch(getStreaminfoUrl(siteurl));
text = await resp.text() text = await resp.text()
var data = JSON.parse(text) var data = JSON.parse(text)
var name = data["icy-name"] var name = data["icy-name"]
if(name !== undefined) { if(name !== undefined) {
manifest.setName(name) manifest.setName(name)
}
} catch (e) {
if(e instanceof TypeError && e.message.startsWith('NetworkError')) {
// the fetch has failed
true
} else if(e instanceof SyntaxError && e.message.startsWith('JSON.parse')) {
true
}
else {
console.error('Error', e)
throw e
}
} }
} catch (e) {
// XXX: in base alle options fai fetch anche di altra roba if(e instanceof TypeError && e.message.startsWith('NetworkError')) {
return manifest // the fetch has failed
true
} else if(e instanceof SyntaxError && e.message.startsWith('JSON.parse')) {
true
}
else {
console.error('Error', e)
throw e
}
}
// XXX: in base alle options fai fetch anche di altra roba
return manifest
} }
function parseM3U(body) { function parseM3U(body) {
body.split("\n").filter((e) => { body.split("\n").filter((e) => {
if(e.startsWith("#")) { if(e.startsWith("#")) {
return false return false
} else { } else {
try { new URL(e); return true } try { new URL(e); return true }
catch {return false} catch {return false}
} }
}) })
} }

31
test/radiomanifest.test.js Normal file
View file

@ -0,0 +1,31 @@
const radiomanifest = require('../radiomanifest.js')
const chai = require('chai')
chai.use(require('chai-as-promised'))
const expect = chai.expect
describe('radiomanifest.js', () => {
describe('Get a radiomanifest', () => {
it('should return a Promise', () => {
const p = radiomanifest.get('http://omstring')
expect(p instanceof Promise).to.be.eql(true)
})
it('should reject on invalid URL', () => {
const p = radiomanifest.get('http://invalidurl')
expect(p).to.eventually.be.rejected
})
})
describe('streaming', () => {
it('shoud return a valid streaming URL', () => {
})
})
})