Mirrors/cloudcmd
1
0
Fork 0
mirror of https://github.com/coderaiser/cloudcmd.git synced 2026-07-28 18:23:35 +00:00
Code Issues Projects Releases Wiki Activity

refactor(files) es2015-ify

Browse source
This commit is contained in:
coderaiser 2017-02-15 18:40:06 +02:00
parent 66763faef8
commit a7d77a9cc7
1 changed files with 150 additions and 154 deletions
Download patch file Download diff file Expand all files Collapse all files

304
client/files.js
View file

@ -1,172 +1,168 @@
/* global Promise */
/* global CloudCmd */
'use strict';
module.exports = new FilesProto();
const itype = require('itype/legacy');
const currify = require('currify/legacy');
const exec = require('execon');
const Storage = require('./storage');
const load = require('./load');
const RESTful = require('./rest');
function FilesProto() {
var Promises = {},
Files = this,
FILES_JSON = 'config|modules',
FILES_HTML = 'file|path|link|pathLink|media',
FILES_HTML_ROOT = 'view/media-tmpl|config-tmpl|upload',
funcs = [],
DIR_HTML = '/tmpl/',
DIR_HTML_FS = DIR_HTML + 'fs/',
DIR_JSON = '/json/',
timeout = getTimeoutOnce(2000);
const Promises = {};
const FILES_JSON = 'config|modules';
const FILES_HTML = 'file|path|link|pathLink|media';
const FILES_HTML_ROOT = 'view/media-tmpl|config-tmpl|upload';
const DIR_HTML = '/tmpl/';
const DIR_HTML_FS = DIR_HTML + 'fs/';
const DIR_JSON = '/json/';
const timeout = getTimeoutOnce(2000);
const get = currify(getFile);
const unaryMap = (array, fn) => array.map((a) => fn(a));
module.exports.get = get;
function getFile(name, callback) {
const type = itype(name);
let array;
this.get = function(name, callback) {
var type = itype(name);
check(name, callback);
switch(type) {
case 'string':
getModule(name, callback);
break;
case 'array':
funcs = name.map(function(name) {
return function(callback) {
Files.get(name, callback);
};
});
exec.parallel(funcs, callback);
break;
}
return Files;
};
check(name, callback);
function check(name, callback) {
if (!name)
throw Error('name could not be empty!');
if (typeof callback !== 'function')
throw Error('callback should be a function');
}
switch(type) {
case 'string':
getModule(name, callback);
break;
function getModule(name, callback) {
var path,
regExpHTML = new RegExp(FILES_HTML + '|' + FILES_HTML_ROOT),
regExpJSON = new RegExp(FILES_JSON),
isHTML = regExpHTML.test(name),
isJSON = regExpJSON.test(name);
case 'array':
array = unaryMap(name, get);
if (!isHTML && !isJSON) {
showError(name);
} else if (name === 'config') {
getConfig(callback);
} else {
path = getPath(name, isHTML, isJSON);
getSystemFile(path, callback);
}
}
function getPath(name, isHTML, isJSON) {
var path,
regExp = new RegExp(FILES_HTML_ROOT),
isRoot = regExp.test(name);
if (isHTML) {
if (isRoot)
path = DIR_HTML + name.replace('-tmpl', '');
else
path = DIR_HTML_FS + name;
path += '.hbs';
} else if (isJSON) {
path = DIR_JSON + name + '.json';
}
return path;
}
function showError(name) {
var str = 'Wrong file name: ' + name,
error = new Error(str);
throw(error);
}
function getSystemFile(url, callback) {
var prefix = CloudCmd.PREFIX;
if (!Promises[url])
Promises[url] = new Promise(function(resolve, reject) {
load.ajax({
url : prefix + url,
success : resolve,
error : reject
});
});
Promises[url].then(function(data) {
callback(null, data);
}, function(error) {
Promises[url] = null;
callback(error);
});
}
function getConfig(callback) {
let is;
if (!Promises.config)
Promises.config = new Promise(function(resolve, reject) {
is = true;
RESTful.Config.read(function(error, data) {
if (error)
reject(error);
else
resolve(data);
});
});
Promises.config.then(function(data) {
is = false;
Storage.setAllowed(data.localStorage);
callback(null, data);
timeout(function() {
if (!is)
Promises.config = null;
});
}, function() {
if (!is)
Promises.config = null;
});
}
function getTimeoutOnce(time) {
var is,
fn = function(callback) {
if (!is) {
is = true;
setTimeout(function() {
is = false;
callback();
}, time);
}
};
return fn;
exec.parallel(array, callback);
break;
}
}
function check(name, callback) {
if (!name)
throw Error('name could not be empty!');
if (typeof callback !== 'function')
throw Error('callback should be a function');
}
function getModule(name, callback) {
let path;
const regExpHTML = new RegExp(FILES_HTML + '|' + FILES_HTML_ROOT);
const regExpJSON = new RegExp(FILES_JSON);
const isHTML = regExpHTML.test(name);
const isJSON = regExpJSON.test(name);
if (!isHTML && !isJSON) {
showError(name);
} else if (name === 'config') {
getConfig(callback);
} else {
path = getPath(name, isHTML, isJSON);
getSystemFile(path, callback);
}
}
function getPath(name, isHTML, isJSON) {
let path;
const regExp = new RegExp(FILES_HTML_ROOT);
const isRoot = regExp.test(name);
if (isHTML) {
if (isRoot)
path = DIR_HTML + name.replace('-tmpl', '');
else
path = DIR_HTML_FS + name;
path += '.hbs';
} else if (isJSON) {
path = DIR_JSON + name + '.json';
}
return path;
}
function showError(name) {
const str = 'Wrong file name: ' + name;
const error = new Error(str);
throw(error);
}
function getSystemFile(url, callback) {
const prefix = CloudCmd.PREFIX;
if (!Promises[url])
Promises[url] = new Promise((success, error) => {
url = prefix + url;
load.ajax({
url,
success,
error
});
});
Promises[url].then((data) => {
callback(null, data);
}, (error) => {
Promises[url] = null;
callback(error);
});
}
function getConfig(callback) {
let is;
if (!Promises.config)
Promises.config = new Promise((resolve, reject) => {
is = true;
RESTful.Config.read((error, data) => {
if (error)
return reject(error);
resolve(data);
});
});
Promises.config.then(function(data) {
is = false;
Storage.setAllowed(data.localStorage);
callback(null, data);
timeout(() => {
if (!is)
Promises.config = null;
});
}, function() {
if (!is)
Promises.config = null;
});
}
function getTimeoutOnce(time) {
let is;
return (callback) => {
if (is)
return;
is = true;
setTimeout(() => {
is = false;
callback();
}, time);
};
}