| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101 |
- #!/usr/bin/env node
- const fs = require('fs');
- const minimist = require('minimist');
- const path = require('path');
- const waitOn = require('../');
- const interval = ['timeout', 'httpTimeout', 'tcpTimeout'];
- const minimistOpts = {
- string: ['c', 'd', 'i', 's', 't', 'w'].concat(interval),
- 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]) {
- let value = argv[x];
- if (interval.includes(x)) {
- value = parseInterval(value);
- }
- accum[x] = value;
- }
- 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);
- }
- function parseInterval(arg) {
- const res = /^([\d.]+)(|ms|s|m|h)$/i.exec(arg);
- if (!res) {
- return arg;
- }
- const value = parseFloat(res[1]);
- switch (res[2]) {
- case '':
- case 'ms': return Math.floor(value);
- case 's': return Math.floor(value * 1000);
- case 'm': return Math.floor(value * 1000 * 60);
- case 'h': return Math.floor(value * 1000 * 60 * 60);
- }
- }
|