110 lines
2.7 KiB
JavaScript
110 lines
2.7 KiB
JavaScript
|
const fetch = require('node-fetch')
|
||
|
|
|
||
|
|
class APIWrapper {
|
||
|
|
#base;
|
||
|
|
constructor(base_url){
|
||
|
|
this.#base = base_url.toString()
|
||
|
|
}
|
||
|
|
|
||
|
|
async query(endpoint, options={}){
|
||
|
|
const url = new URL(endpoint, this.#base).href;
|
||
|
|
return await fetch(url, options)
|
||
|
|
.then(res=>res.json())
|
||
|
|
.then(res=>{if(res.data)return res.data; throw new Error(res.message)});
|
||
|
|
}
|
||
|
|
|
||
|
|
get(endpoint){
|
||
|
|
return this.query(endpoint);
|
||
|
|
}
|
||
|
|
|
||
|
|
post(endpoint, body={}){
|
||
|
|
return this.query(endpoint, {
|
||
|
|
method: 'post',
|
||
|
|
headers: {'Content-Type': 'application/json'},
|
||
|
|
body: JSON.stringify(body)
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
delete(endpoint, body={}){
|
||
|
|
return this.query(endpoint, {
|
||
|
|
method: 'delete',
|
||
|
|
headers: {'Content-Type': 'application/json'},
|
||
|
|
body: JSON.stringify(body)
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
get_child_object(endpoint, class_type){
|
||
|
|
return this.get(endpoint).then(x => new class_type(this, x))
|
||
|
|
}
|
||
|
|
|
||
|
|
get url_base(){
|
||
|
|
return this.#base
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
class PistonEngineRepositoryPackage extends APIWrapper {
|
||
|
|
constructor(repo, {language, language_version, author, buildfile, size, dependencies, installed}){
|
||
|
|
super(new URL(`/packages/${language}/${language_version}`,repo.url_base))
|
||
|
|
|
||
|
|
this.language = language;
|
||
|
|
this.language_version = language_version;
|
||
|
|
this.author = author;
|
||
|
|
this,buildfile = buildfile;
|
||
|
|
this.size = size;
|
||
|
|
this.dependencies = dependencies;
|
||
|
|
this.installed = installed;
|
||
|
|
}
|
||
|
|
|
||
|
|
install(){
|
||
|
|
return this.post('/', {});
|
||
|
|
}
|
||
|
|
|
||
|
|
uninstall(){
|
||
|
|
return this.delete('/', {});
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
class PistonEngineRepository extends APIWrapper {
|
||
|
|
|
||
|
|
constructor(engine, {slug, url, packages}){
|
||
|
|
super(new URL(`/repos/${slug}`, engine.url_base,))
|
||
|
|
|
||
|
|
this.slug = slug;
|
||
|
|
this.url = url;
|
||
|
|
this.package_count = packages
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
list_packages(){
|
||
|
|
return this.get(`/packages`).then(x=>x.packages)
|
||
|
|
}
|
||
|
|
|
||
|
|
get_package(language, language_version){
|
||
|
|
return this.get_child_object(`/packages/${language}/${language_version}`, PistonEngineRepositoryPackage)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
class PistonEngine extends APIWrapper {
|
||
|
|
constructor(base_url = 'http://127.0.0.1:6969'){
|
||
|
|
super(base_url);
|
||
|
|
}
|
||
|
|
|
||
|
|
list_repos(){
|
||
|
|
return this.get(`/repos`);
|
||
|
|
}
|
||
|
|
|
||
|
|
add_repo(slug, url){
|
||
|
|
return this.post(`/repos`, {slug, url})
|
||
|
|
}
|
||
|
|
|
||
|
|
get_repo(slug){
|
||
|
|
return this.get_child_object(`/repos/${slug}`, PistonEngineRepository)
|
||
|
|
}
|
||
|
|
|
||
|
|
run_job(language, version, files, main, args, stdin, compile_timeout, run_timeout){
|
||
|
|
return this.post(`/jobs`, {language, version, files, main, args, stdin, compile_timeout, run_timeout})
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
module.exports = {PistonEngine}
|