gnezim
82 lines
1.9 KiB
JavaScript
Executable File
82 lines
1.9 KiB
JavaScript
Executable File
#!/usr/bin/env node
|
|
|
|
const fs = require('fs');
|
|
const minimist = require('minimist');
|
|
const path = require('path');
|
|
const waitOn = require('../');
|
|
|
|
const minimistOpts = {
|
|
string: ['c', 'd', 'i', 's', 't', 'w', 'httpTimeout', 'tcpTimeout'],
|
|
boolean: ['h', 'l', 'r', 'v'],
|
|
alias: {
|
|
c: 'config',
|
|
d: 'delay',
|
|
i: 'interval',
|
|
l: 'log',
|
|
r: 'reverse',
|
|
s: 'simultaneous',
|
|
t: 'timeout',
|
|
v: 'verbose',
|
|
w: 'window',
|
|
h: 'help'
|
|
}
|
|
};
|
|
|
|
const argv = minimist(process.argv.slice(2), minimistOpts);
|
|
// if a js/json configuration file is provided require it
|
|
const configOpts = argv.config ? require(path.resolve(argv.config)) : {};
|
|
const hasResources = argv._.length || (configOpts.resources && configOpts.resources.length);
|
|
|
|
if (argv.help || !hasResources) {
|
|
// help
|
|
fs.createReadStream(path.join(__dirname, '/usage.txt'))
|
|
.pipe(process.stdout)
|
|
.on('close', function () {
|
|
process.exit(1);
|
|
});
|
|
} else {
|
|
// if resources are present in the command line then they take
|
|
// precedence over those in the config file.
|
|
if (argv._.length) {
|
|
configOpts.resources = argv._;
|
|
}
|
|
|
|
// now check for specific options and set those
|
|
const opts = [
|
|
'delay',
|
|
'httpTimeout',
|
|
'interval',
|
|
'log',
|
|
'reverse',
|
|
'simultaneous',
|
|
'timeout',
|
|
'tcpTimeout',
|
|
'verbose',
|
|
'window'
|
|
].reduce(function (accum, x) {
|
|
if (argv[x]) {
|
|
accum[x] = argv[x];
|
|
}
|
|
return accum;
|
|
}, configOpts);
|
|
|
|
waitOn(opts, function (err) {
|
|
if (err) {
|
|
return errorExit(err);
|
|
}
|
|
// success, could just let it exit on its own, however since
|
|
// rxjs window waits an extra loop before heeding the unsubscribe
|
|
// we can exit to speed things up
|
|
process.exit(0);
|
|
});
|
|
}
|
|
|
|
function errorExit(err) {
|
|
if (err.stack) {
|
|
console.error(err.stack);
|
|
} else {
|
|
console.error(String(err));
|
|
}
|
|
process.exit(1);
|
|
}
|