Files
gulp-haxetool/haxetool/sdk.js

157 lines
4.3 KiB
JavaScript
Executable File

const os = require('os');
const path = require('path');
const fs = require('fs');
const ps = require('promise-streams');
const got = require('got');
const unzip = require('unzip-stream');
const tar = require('tar');
const progress = require('cli-progress');
const fse = require('fs-extra');
const Log = require('./log');
class System {
static get isWindows() {
return os.type() === 'Windows_NT';
}
static get isLinux() {
return os.type() === 'Linux';
}
static get archInt() {
if (os.arch() === 'ia32') return 32;
if (os.arch() === 'x64') return 64;
}
static get isArch32() {
return this.archInt === 32;
}
static get isArch64() {
return this.archInt === 64;
}
}
class Downloader {
static createProgressBar() {
if (Downloader.bar == null) {
Downloader.bar = new progress.MultiBar({
clearOnComplete: true,
}, progress.Presets.shades_grey);
}
return Downloader.bar.create();
}
static releaseProgressBar(bar) {
bar.stop();
if (Downloader.bar != null) {
Downloader.bar.remove(bar);
if (Downloader.bar.bars.length === 0) {
Downloader.bar.stop();
Downloader.bar = null;
}
}
}
static download(url, dest, strip = 1, executable = false) {
fse.ensureDirSync(dest);
const bar = Downloader.createProgressBar();
let stream = got.stream(url);
stream = stream
.on('request', r => {
if (bar) bar.start(1, 0);
})
.on('downloadProgress', p => {
if (bar) {
bar.setTotal(p.total);
bar.update(p.transferred);
if (p.total === p.transferred) {
Downloader.releaseProgressBar(bar);
}
}
});
if (url.endsWith('.zip')) {
stream = stream.pipe(unzip.Parse()).on('entry', entry => {
const filePath = entry.path.split('/').slice(strip).join(path.sep);
if (filePath.length > 0) {
if (entry.type === 'Directory') {
fse.ensureDirSync(path.join(dest, path.normalize(filePath)));
} else if (entry.type === 'File') {
entry.pipe(fs.createWriteStream(path.join(dest, path.normalize(filePath)), {
// ToDo: zip entry file mode?
mode: executable ? 0o755 : undefined,
}));
}
} else {
entry.autodrain();
}
});
} else if (url.endsWith('tar.gz')) {
stream = stream.pipe(tar.x({C: dest, strip: strip}));
} else {
stream = stream.pipe(fs.createWriteStream(path.join(dest, url.split('/').pop())));
}
return ps.wait(stream);
}
}
class Sdk {
static set dir(value) {
Sdk._dir = value
}
static get dir() {
return Sdk._dir || path.join(os.homedir(), 'sdk');
}
static path(name, version) {
return path.join(this.dir, name, version);
}
constructor(name, version) {
this.name = name;
this.log = Log(name);
this.version = version;
this.path = Sdk.path(name, version);
}
get intVersion() {
const vArr = this.version.split('\.').reverse();
let m = 1;
let r = 0;
for (let v of vArr) {
r += parseInt(v) * m;
m *= 10;
}
return r;
}
get prepared() {
throw "Not implemented";
}
get link() {
throw "Not implemented";
}
prepare(strip = 1) {
this.log.i('version: *%s*', this.version);
if (this.prepared) {
return Promise.resolve();
} else {
this.log.d('download: *%s*', this.link);
return Downloader.download(this.link, this.path, strip);
}
}
}
Sdk.Downloader = Downloader;
Sdk.System = System;
module.exports = Sdk;