modules/Downloader.js - main - ProjectSoft/radioApp-lite

modules/Downloader.js
264 строки7 KB
ProjectSoft
update radiorecord
27 авг 2024, 11:51
27 авг 2024, 11:51365db5c
module.exports = function(grunt) {
	const fs = require("fs");
	const cliProgress = require('cli-progress');
	const _colors = require('ansi-colors');
	var options = {
			version: '0.86.0',
			sdk: false
		},
		versions = '0.86.0';
	const formatTime = function(value){
			function autopadding(v){
				return ("0" + v).slice(-2);
			}
			let s = autopadding(Math.floor((value / 1000) % 60));
			let m = autopadding(Math.floor((value / 1000 / 60) % 60));
			let h = autopadding(Math.floor((value / (1000 * 60 * 60)) % 24));
			return h + ":" + m + ":" + s
		},
		autopaddingVal = function (value, length, opt){
			return (opt.autopaddingChar + value).slice(-length);
		},
		formatBytes = function(bytes, decimals = 2) {
			if (bytes === 0) return '0 Bt';
			const k = 1024;
			const dm = decimals < 0 ? 0 : decimals;
			const sizes = ['Bt', 'KB', 'MB', 'GB', 'TB', 'PB', 'EB', 'ZB', 'YB'];
			const i = Math.floor(Math.log(bytes) / Math.log(k));
			return parseFloat(bytes / Math.pow(k, i)).toFixed(dm) + ' ' + sizes[i];
		},
		formatBar = function(optionsBar, paramsBar, payloadBar){
			function autopadding(value, length){
				return (optionsBar.autopaddingChar + value).slice(-length);
			}
			const completeSize = Math.round(paramsBar.progress * optionsBar.barsize);
			const incompleteSize = optionsBar.barsize - completeSize;
			const bar = optionsBar.barCompleteString.substr(0, completeSize) +
					optionsBar.barGlue +
					optionsBar.barIncompleteString.substr(0, incompleteSize);
			const percentage =  Math.floor(paramsBar.progress * 100) + '';
			const formatValue = formatBytes(paramsBar.value);
			const formatTotal = formatBytes(paramsBar.total);
			const total = formatTotal.length;// params
			const stopTime = paramsBar.stopTime || Date.now();
			const elapsedTime = formatTime(Math.round((stopTime - paramsBar.startTime)));
			
			var barStr = _colors.white('|') + _colors.cyan(bar + ' ' + autopadding(percentage, 3) + '%') + "  " + _colors.white('|') + "  " + elapsedTime;
			return barStr;
		},
		rightpad = function(str, len, ch = false) {
			str = String(str);
			if (!ch && ch !== 0)
				ch = ' ';
			return str.padEnd(len, ch);
		};
	async function fileExists(filePath) {
		let exists = true;
		try {
			await fs.promises.stat(filePath);
		} catch {
			exists = false;
		}
		return exists;
	}

	async function removeFile(file) {
		let exists = true;
		let fl = await fileExists(file);
		if(fl){
			try {
				fs.unlinkSync(file);
			} catch {
				exists = false;
			}
		}
		return exists;
	}

	async function createDirectory(dir) {
		let exists = true;
		let fl = await fileExists(dir);
		if(!fl) {
			try {
				fs.mkdirSync(dir, {recursive: true});
			} catch {
				exists = false;
			}
		}
		return exists;
	}

	function getManifest(){
		return new Promise(async function(resolve, reject){
			let cah = await removeFile(".cache/manifest.json");
			if(cah){
				const { DownloaderHelper } = require('node-downloader-helper');
				const progress = new cliProgress.SingleBar({
					stopOnComplete: true,
					hideCursor: false,
					autopadding: true,
					barsize: 50
				},{
					format: formatBar,
					barCompleteChar: '\u2588',
					barIncompleteChar: '\u2592'
				});
				grunt.log.oklns([`${rightpad('Download MANIFEST', 18, ' ')} -> https://nwjs.io/versions.json`]);
				progress.start(100, 0);
				const dl = new DownloaderHelper('https://nwjs.io/versions.json', ".cache/", {
					fileName: 'manifest.json'
				});
				dl.on('response', function(res){
					//console.log('response');
				});
				dl.on('end', function() {
					progress.stop();
					resolve();
				});
				dl.on('error', function(err){
					progress.stop();
					grunt.log.errorlns('Download Failed', err);
					reject(err);
				});
				dl.on('progress', function(data){
					progress.update(parseInt(data.progress));
				});
				dl.start().catch(function(err) {
					progress.stop();
					reject(err);
				});
			}else{
				reject();
			}
		});
	}
	function getFlavor() {
		return new Promise(async function(resolve, reject){
			let cah = await fileExists(".cache/manifest.json");
			if(cah){
				const file = fs.readFileSync(".cache/manifest.json", {encoding: 'utf8'}),
					flv = options.sdk ? '-sdk' : '',
					dir = options.sdk ? 'sdk' : 'normal';
				try {
					let obj = JSON.parse(file),
						path = options.version ? `v${options.version}` : obj.stable;
					versions = path.slice(1);
					let url = `https://dl.nwjs.io/${path}/nwjs${flv}-${path}-win-ia32.zip`,
						output = `${dir}.zip`,
						nwfile = await removeFile(`.cache/${output}`);
					if (nwfile) {
						const { DownloaderHelper } = require('node-downloader-helper');
						const progress = new cliProgress.SingleBar({
							stopOnComplete: true,
							hideCursor: false,
							autopadding: true,
							barsize: 50
						},{
							format: formatBar,
							barCompleteChar: '\u2588',
							barIncompleteChar: '\u2592'
						});
						grunt.log.oklns([`${rightpad('Download NWJS', 18, ' ')} -> ${url}`]);
						progress.start(100, 0);
						const dl = new DownloaderHelper(url, ".cache/", {
							fileName: output
						});
						dl.on('response', function(res){
							//console.log('response');
						});
						dl.on('end', function() {
							progress.stop();
							resolve();
						});
						dl.on('error', function(err){
							progress.stop();
							grunt.log.errorlns('Download Failed', err);
							reject(err);
						});
						dl.on('progress', function(data){
							progress.update(parseInt(data.progress));
						});
						dl.start().catch(function(err) {
							reject(err);
						});
					}else{
						reject();
					}
				}catch(e){
					reject(e);
				}
			} else {
				reject();
			}
			
		});
	}
	function getFFMPEG() {
		// 0.87.0-win-ia32.zip
		return new Promise(async function(resolve, reject){
			const url = `https://github.com/nwjs-ffmpeg-prebuilt/nwjs-ffmpeg-prebuilt/releases/download/${versions}/${versions}-win-ia32.zip`;
			const out = `ffmpeg.zip`;
			let ffmpegfile = await removeFile(`.cache/${out}`);
			if(ffmpegfile){
				const { DownloaderHelper } = require('node-downloader-helper');
				const progress = new cliProgress.SingleBar({
					stopOnComplete: true,
					hideCursor: false,
					autopadding: true,
					barsize: 50
				},{
					format: formatBar,
					barCompleteChar: '\u2588',
					barIncompleteChar: '\u2592'
				});
				grunt.log.oklns([`${rightpad('Download FFMPEG', 18, ' ')} -> ${url}`]);
				progress.start(100, 0);
				const dl = new DownloaderHelper(url, ".cache/", {
					fileName: out
				});
				dl.on('response', function(res){
					//console.log('response');
				});
				dl.on('end', function() {
					progress.stop();
					// UNZIPED
					resolve();
				});
				dl.on('error', function(err){
					progress.stop();
					grunt.log.errorlns('Download Failed', err);
					reject(err);
				});
				dl.on('progress', function(data){
					progress.update(parseInt(data.progress));
				});
				dl.start().catch(function(err) {
					reject(err);
				});
			}else{
				reject();
			}
		});
	}
	grunt.registerMultiTask('downloader', 'Download NW.JS', async function() {
		var done = this.async();
		options = this.options();
		await createDirectory('.cache/');
		getManifest().then(async function(){
			getFlavor().then(async function(){
				getFFMPEG().then(async function(){
					done();
				}).catch(function(error){
					done("Error FFMPEG");
				});
			}).catch(function(error){
				done("Error NMJS");
			});
		}).catch(function(error){
			done("Error MANIFEST");
		})
	});

}

//https://nwjs.io/versions.json