/* webfan (C) Till Wehowski, Webfan.de - All rights reserved. */
const EXITCODE_OK = 0;
const EXITCODE_HALT = 1;
const EXITCODE_ERROR = 2;
const EXITCODE_NOTREADY = 3;
const EXITCODE_SQLERROR = 5;
(function(){
'use strict';
function _cli(argv, options, switches, positionalSwitches, shells){
'use strict';
function f(code){
return '(function(result){'+code+'})';
}
var util = /* require('util'); */ frdl.util;
var escapeshellarg = frdl.escapeshellarg;
var fNFin = null;
var finalized = false;
var _CLI = new frdl.EventEmitter();
_CLI.config = require('../clisetup/clisetup');
var optparse = require('optparse-js/lib/optparse');
if(!util.isArray(argv) && !!util.isString(argv) ){
argv = _CLI.config.parseArgs(argv);
}
var debug=function(type, obj){
var opts = {
showHidden : true,
depth : 4
};
try{
var color = 'black';
if('warn'===type)color = 'orange';
if('error'===type || 'fatal'===type)color = 'red';
if('dir'===type)color = 'blue';
var str = '<p><legend style="color:'+color+';">'+type+'</legend>'+util.inspect(obj, opts)+'</p>';
console[type](str);
frdl.alert[('error'===type || 'warn'===type)?'error':'log'](str);
}catch(err){
console.warn(err);
}
};
/*
try{
var mask = require('16:webfan/webfat/js/flagmask');
console.dir('dir', mask);
}catch(err){
frdl.alert.error(err);
}
*/
_CLI.options = _CLI.config.default_options;
if(null!==options && 'object' === typeof options){
_CLI.options = frdl.extend(_CLI.options, options);
}
var doParse = true;
var exitcode = EXITCODE_NOTREADY;
exitcode=EXITCODE_OK;
var parser = null;
/* var _CLI = this || Object.create({});
var _CLI = Object.create({}); */
var messageLog = [];
var errorlog = [];
_CLI.escapeshellarg = escapeshellarg;
_CLI.finalState = _CLI.required([
'firstarg'
], function (dataArray) {
console.log('CLI exit with ' + exitcode);
if(0<exitcode && 200 !== exitcode){
_CLI.emit('catch', exitcode.toString()+' : '+_CLI.errorlog.join('\s\n\r'));
}else{
_CLI.emit('success', _CLI.data.data);
}
}, _CLI);
_CLI.finalState.add('parse');
_CLI.finalState.add('exit');
_CLI.finalState.add('finalize.before');
_CLI.finalState.add('finalize');
_CLI.shell = '$ webfan';
_CLI.shells = shells || {
'webfan' : {
},
'frdl' : {
//error (used by other cli)
},
'flow' : {
},
'js' : {
}
};
_CLI.WinID = 'cli.html';
_CLI.cmd = null;
_CLI.argv = argv;
_CLI.callbackName = false;
_CLI.data = {
DIRECTORIES : [],
FILES : [],
URLS : [],
ACTION : null,
data : null,
options : {
}
};
_CLI.switches = switches || [];
var _tokensToBuild = [];
var _filtersToBuild = [];
var _sfn = {
};
_CLI.positionalSwitches = positionalSwitches || [];
_CLI.addOption = function(optName, description, callback, filterStr, _short){
if('string' !== typeof filterStr)var filterStr = ' [TEXT]';
if('string'===typeof _short){
_CLI.switches.push([_short, '--' + optName + filterStr, description]);
}else{
_CLI.switches.push(['--' + optName + filterStr, description]);
}
_sfn[optName] = callback;
return _CLI;
};
_CLI.filter = function(filterName, filter){
_filtersToBuild.push([filterName, filter]);
return _CLI;
};
_CLI.addToken = function(option, arg, fn){
_tokensToBuild.push([option, arg, fn]);
return _CLI;
};
try{
Object.defineProperty(_CLI, 'exitcode', {
get : function(){
return ((0===_CLI.errorlog.length)
? EXITCODE_OK
: (EXITCODE_OK<exitcode) ? /* ++exitcode */ exitcode : EXITCODE_ERROR);
},
set : function(val){
throw 'write to cli.exitcode from public scope';
}
});
Object.defineProperty(_CLI, 'messageLog', {
get : function(){
return messageLog;
},
set : function(val){
console.warn('Do not set cli.messageLog manually!');
}
});
Object.defineProperty(_CLI, 'errorlog', {
get : function(){
return errorlog;
},
set : function(val){
console.warn('Do not set cli.errorlog manually!');
}
});
Object.defineProperty(_CLI, 'util', {
get : function(){
return frdl.util;
},
set : function(val){
console.warn('Do not set cli.util manually!');
}
});
}catch(err){
if(Object.prototype.__defineGetter__ && Object.prototype.__defineSetter__) {
this.__defineGetter__('exitcode', function(){
return ((0===_CLI.errorlog.length)
? 0
: (0===exitcode) ? ++exitcode : exitcode);
} );
this.__defineSetter__('exitcode', function(val){
throw 'write to cli.exitcode from public scope';
} );
this.__defineGetter__('messageLog', function(){
return messageLog;
} );
this.__defineSetter__('messageLog', function(val){
console.warn('Do not set cli.messageLog manually!');
} );
this.__defineGetter__('errorlog', function(){
return errorlog;
} );
this.__defineSetter__('errorlog', function(val){
console.warn('Do not set cli.errorlog manually!');
} );
this.__defineGetter__('util', function(){
return frdl.util;
} );
this.__defineSetter__('util', function(val){
console.warn('Do not set cli.util manually!');
} );
}else{
console.deprecated('Missing Object.defineProperty and Object.prototype.__defineGetter__ - Fallback to UNSAFE configuration readable!');
_CLI.exitcode = exitcode;
_CLI.messageLog = messageLog;
_CLI.errorlog = errorlog;
_CLI.util = frdl.util;
}
}
_CLI.log = function(m){
_CLI.emit('log', m);
};
_CLI.error = function(m){
_CLI.emit('error', m);
};
var Finalize = function(scope, THAT){
if(!!finalized)return;
finalized=true;
if(true === THAT.options.debug) _CLI.log('>>>Finalize<<<');
if(true === THAT.parser._halt){
// if(true === THAT.options.debug) _CLI.log('>>>HALT<<<');
// return;
}
/*if(!THAT.parser._halt)*/_CLI.emit('finalize.before', THAT);
/* if(!THAT.parser._halt)*/_CLI.emit('finalize', THAT);
if(true === THAT.options.debug) _CLI.log('>>>RESULT BEGIN<<<');
if(true === THAT.options.debug) _CLI.log(JSON.stringify(THAT.result));
if(true === THAT.options.debug) _CLI.log('>>>RESULT END<<<');
};
if(!!_CLI.options.defaults.onceFinalize){
_CLI.once('finalize', function(THAT){
if('function'===typeof fNFin && !THAT.parser._halt){
fNFin.call(_CLI, THAT);
}
_CLI.emit('exit', _CLI.exitcode);
});
}
var onHalt = function(tokens){
_CLI.emit('exit', EXITCODE_HALT);
if(true === THAT.options.debug) _CLI.log('>>>HALT<<<');
if(true === _CLI.options.debug)_CLI.log(JSON.stringify(_CLI.data.rest));
};
var Test=function(THAT){
THAT.result = 'This is any testresult!';
_CLI.log('Run the "test" command');
};
if(!!_CLI.options.defaults.logs){
_CLI.on('log', function(m){
messageLog.push(m);
console.log(m);
});
_CLI.on('error', function(m){
errorlog.push(m);
console.error(m);
});
}
_CLI.cmd = _CLI.argv[0].trim();
if(!!_CLI.options.defaults.sql){
frdl.each(_CLI.config.sqlstarts, function(i, command){
if(_CLI.cmd.toLowerCase() === command){
doParse=false;
fNFin = function(){
_CLI.emit('sql',_CLI.argv.join(' '));
};
// _CLI.emit('exit');
return false;
}
});
_CLI.on('sql', function(query){
console.log('cli>sql '+query);
try{
frdl.sql.query(query, function(err, result) {
if (err) {
_CLI.error(err);
return;
}
var _Result = result;
// _CLI.once('finalize.before', function(THAT){
if(null===_CLI.data.data){
_CLI.data.data =_Result;
}else if(true === _Result instanceof Array && true === _CLI.data.data instanceof Array){
_CLI.data.data.push(_Result);
}else{
_CLI.data.data =_Result;
}
//});
});
} catch(err) {
_CLI.error(err);
}
});
}
if(!!_CLI.options.defaults.sql){
_CLI.addOption('sql', 'Run a sql query', function(name, value) {
_CLI.emit('sql',value, false);
}, ' [TEXT]');
}
if(!!_CLI.options.defaults.firstArg){
try{
var cli;
if(null===fNFin)cli = require('16:webfan/cli/commands/webfan/'+_CLI.cmd);
if('function' === typeof cli.prepare)cli.prepare(_CLI);
fNFin = ('function' === typeof cli.finalize) ? cli.finalize : fNFin;
}catch(err){
//_CLI.error('Command "'+_CLI.cmd+'" not found. '+err);
}
}
_CLI.emit('firstarg', _CLI.cmd);
_CLI.exit = function(exitcode){
_CLI.emit('exit', exitcode)
return _CLI;
};
_CLI.once('exit', function(_exitcode){
_CLI.parser._halt=true;
if('undefined' === typeof _exitcode)_exitcode = _CLI.exitcode;
if(isNaN(_exitcode)){
throw 'exitcode is not a number';
}
exitcode=_exitcode;
// _CLI.parser.on_halt.apply(_CLI.parser, [_CLI.data.data]);
// if(0<exitcode && 200 !== exitcode){
// fNFin = null;
// _CLI.emit('catch', exitcode.toString()+' : '+_CLI.errorlog.join('\s\n\r'));
// }else{
// if(!finalized){
// _CLI.finalize(_CLI);
// }
// _CLI.emit('success', _CLI.data.data);
// }
});
if(!!_CLI.options.defaults.standards){
_CLI.addOption('debug', 'Debug mode', function(name, value) {
_CLI.options.debug = value;
if(!_CLI.options.debug){
frdl.debug.mode(3);
}
}, ' [SWITCH]', '-d')
.addOption('help', 'Shows help', function() {
var txt = _CLI.parser.toString();
txt += '\n\r';
txt += Object.keys(_CLI.shells).toString();
_CLI.log(txt);
_CLI.data.data=txt;
}, ' [SWITCH]', '-h')
.addOption('callback', 'Poplulate a callback function to the global.frdl.cbs[CALLBACKVALUE] if not exists already\nand call it with result as arguments finally,\nafter that remove the function from the frdl.cbs stack',
function(name, value) {
if(/^\w+$/.test(value)){
var c = _CLI.callbackName = value;
_CLI.once('finalize', function(r){
if('function'===typeof frdl.cbs[_CLI.callbackName]){
frdl.cbs[_CLI.callbackName].apply(_CLI, [r]);
}
});
return;
}
try{
var callback = eval(f(value));
_CLI.once('finalize', function(r){
callback.apply(_CLI, [r]);
});
}catch(err){
_CLI.error(err);
}
/*
var fTok = '()=>', fTok2 = '=>';
if(fTok === value.substr(0,fTok.length)){
var t = value.substr(fTok.length,value.length);
try{
var callback = eval(f(t));
_CLI.once('finalize', function(r){
callback.apply(_CLI, [r]);
});
}catch(err){
console.warn(err);
}
return;
}else if(fTok2 === value.substr(0,fTok2.length)){
var t = value.substr(fTok2.length,value.length);
try{
var callback = eval(f(t));
_CLI.once('finalize', function(r){
callback.apply(_CLI, [r]);
});
}catch(err){
console.warn(err);
}
return;
}
if('undefined' === typeof frdl.cbs[c]){
frdl.cbs[c] = function(result){
var util = require('util');
var opts = {
showHidden : true,
depth : 4
};
var type = (result && null !== result) ? 'log' : 'error';
try{
var color = 'black';
if('warn'===type)color = 'orange';
if('error'===type || 'fatal'===type)color = 'red';
if('dir'===type)color = 'blue';
frdl.alert[('error'===type)?'error':'log']('<p><legend style="color:'+color+';">'+type+'</legend>'+util.inspect(result, opts)+'</p>');
frdl.cbs[c] = undefined;
}catch(err){
console.warn(err);
}
};
}
*/
}, ' [CALLBACK]')
.addOption('dir', 'Take a directory', function(name, value) {
_CLI.data.DIRECTORIES.push(value);
_CLI.emit('op.dir', value);
}, ' [DIRECTORY]')
.addOption('file', 'Take a file', function(name, value) {
_CLI.data.FILES.push(value);
_CLI.emit('op.file', value);
}, ' [FILE]')
/**
_CLI.addOption('test', 'Run a test', function(name, value) {
finalized=true;
alert(name+'='+value);
}, ' [TEXT]');
frdl.fs5.polyfill.getFiler().cd(frdl.fs5.polyfill.getFiler().fs.root);
fs.mkdir(dir, '0755', function(err,dirEntry) {
if(err){
console.warn(err);
}else{
console.log('mdir ' + dir);
}
});
*/
.addOption('mkdir', 'Create directory', function(name, value) {
var fs = require('fs');
frdl.fs5.polyfill.getFiler().cd(frdl.fs5.polyfill.getFiler().fs.root);
fs.mkdir(value, '0755', function(err,dirEntry) {
if(err){
_CLI.error(err);
}else{
_CLI.log('mdir ' + value);
_CLI.emit('op.mkdir success', value);
}
});
_CLI.emit('op.mkdir', value);
}, ' [TEXT]')
.addOption('rmdir', 'Remove directory', function(name, value) {
var fs = require('fs');
frdl.fs5.polyfill.getFiler().cd(frdl.fs5.polyfill.getFiler().fs.root);
fs.rmdir(value, function(err,dirEntry) {
if(err){
_CLI.error(err);
}else{
_CLI.log('rmdir ' + value);
_CLI.emit('op.rmdir success', value);
}
});
_CLI.emit('op.rmdir', value);
}, ' [TEXT]')
.addOption('unlink', 'Remove file', function(name, value) {
var fs = require('fs');
frdl.fs5.polyfill.getFiler().cd(frdl.fs5.polyfill.getFiler().fs.root);
fs.unlink(value, function(err,dirEntry) {
if(err){
_CLI.error(err);
}else{
_CLI.log('unlink ' + value);
_CLI.emit('op.unlink success', value);
}
});
_CLI.emit('op.unlink', value);
}, ' [TEXT]');
}
//ende of !!defaults.standards
_CLI.parser = parser = new optparse(_CLI.switches);
_CLI.parser.banner = 'Usage: webfan.exe [[$|!#]shell] [arguments]';
_CLI.parser.halt(function(tokens) {
return onHalt(tokens);
});
_CLI.filter('CALLBACK', function(value) {
var fTok = '()=>', fTok2 = '=>', t = false;
if(fTok === value.substr(0,fTok.length)){
t = value.substr(fTok.length,value.length);
}else if(fTok2 === value.substr(0,fTok2.length)){
t = value.substr(fTok2.length,value.length);
}
try{
return (!t && !!_CLI.util.isString(value) )
|| ('string'===typeof t && !!_CLI.util.isFunction(eval(f(t))) )
? value
: undefined
;
}catch(err){
if(0<frdl.debug.mode())console.warn(err);
return (!t && !!_CLI.util.isString(value) )
? value
: undefined
;
}
})
.filter('SQLQUERY', function(value) {
return value;
})
.filter('DIRECTORY', function(value) {
//value = _CLI.escapeshellarg (value);
if(!frdl.nw)return value;
var fs = require('fs');
var stats = fs.statSync(value);
if(true !== stats.isDirectory()) throw "Directory "+value+' does not exist.';
return value;
})
.filter('FILE', function(value) {
// value = _CLI.escapeshellarg (value);
if(!frdl.nw)return value;
var fs = require('fs');
var stats = fs.statSync(value);
if(true !== stats.isFile()) throw "File "+value+' does not exist.';
return value;
})
.filter('SWITCH', function(value) {
return _CLI.util.StringToBoolean(value);
})
;
try{
var parse = function(argv){
frdl.each(_filtersToBuild, function(i, f){
_CLI.parser.filter(f[0], f[1]);
});
_CLI.positionalSwitches.forEach(function($switch, $position, $switches){
_CLI.parser.on($position, $switch);
});
var k;
for(k in _sfn){
_CLI.parser.on(k, _sfn[k]);
}
frdl.each(_tokensToBuild, function(i, t){
_CLI.parser.token(t[0], t[1], t[2]);
});
_CLI.parser.on('*', function(opt, value) {
if(true === _CLI.options.debug)_CLI.log('Passing argument ' + opt + '=' + value);
if(!_CLI.data.options[opt]){
_CLI.data.options[opt] = value;
}else{
if(!_CLI.data.options[opt].length){
_CLI.data.options[opt] = [_CLI.data.options[opt]];
}
_CLI.data.options[opt].push(value);
}
});
var pr = _CLI.parser.parse(_CLI.argv);
_CLI.emit('parse', pr);
return pr;
};
_CLI.finalize = function(scope){
if('undefined' === typeof scope)var scope = _CLI;
Finalize(scope, _CLI);
};
if(!!doParse){
parse(_CLI.argv);
}else{
_CLI.emit('parse', []);
}
}catch(err){
_CLI.error(err);
}
return _CLI;
}
exports = module.exports = _cli;
}());
|
Download
