@commercetools/customer-groups-exporter/lib/cli.js

"use strict";

var _fs = _interopRequireDefault(require("fs"));

var _getCredentials = require("@commercetools/get-credentials");

var _pino = _interopRequireDefault(require("pino"));

var _prettyError = _interopRequireDefault(require("pretty-error"));

var _yargs = _interopRequireDefault(require("yargs"));

var _main = _interopRequireDefault(require("./main"));

var _package = require("../package.json");

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

process.title = 'customer-groups-exporter';

const args = _yargs.default.usage(`
Usage: $0 [options]
${_package.description}`).showHelpOnFail(false).option('output', {
  alias: 'o',
  default: 'stdout',
  describe: 'Path to output file.'
}).coerce('output', arg => {
  if (arg !== 'stdout') return _fs.default.createWriteStream(String(arg));
  return process.stdout;
}).option('apiUrl', {
  default: 'https://api.sphere.io',
  describe: 'The host URL of the HTTP API service.'
}).option('authUrl', {
  default: 'https://auth.sphere.io',
  describe: 'The host URL of the OAuth API service.'
}).option('accessToken', {
  describe: 'CTP client access token.'
}).option('projectKey', {
  alias: 'p',
  describe: 'API project key.',
  demand: true
}).option('where', {
  alias: 'w',
  describe: 'Specify where predicate.'
}).option('logLevel', {
  default: 'info',
  describe: 'Logging level: error, warn, info or debug.'
}).option('prettyLogs ', {
  describe: 'Pretty print logs to the terminal',
  type: 'boolean'
}).option('logFile', {
  default: 'customer-groups-export.log',
  describe: 'Path to where to save logs file.',
  type: 'string'
}).argv; // instantiate logger


const loggerConfig = {
  level: args.logLevel,
  prettyPrint: args.prettyLogs // If the stdout is used for a data output, save all logs to a log file.
  // pino writes logs to stdout by default

};
let logDestination;
if (args.output === process.stdout) logDestination = _fs.default.createWriteStream(args.logFile);
const logger = (0, _pino.default)(loggerConfig, logDestination); // print errors to stderr if we use stdout for data output
// if we save data to output file errors are already logged by pino

const logError = error => {
  const errorFormatter = new _prettyError.default();
  if (args.logLevel === 'debug') process.stderr.write(`ERR: ${errorFormatter.render(error)}`);else process.stderr.write(`ERR: ${error.message || error}`);
};

const errorHandler = errors => {
  if (Array.isArray(errors)) errors.forEach(logError);else logError(errors);
  process.exitCode = 1;
};

const resolveCredentials = _args => {
  if (_args.accessToken) return Promise.resolve({});
  return (0, _getCredentials.getCredentials)(_args.projectKey);
}; // Register error listener


args.output.on('error', errorHandler);
resolveCredentials(args).then(credentials => {
  const apiConfig = {
    host: args.authUrl,
    apiUrl: args.apiUrl,
    projectKey: args.projectKey,
    credentials
  };
  const exporterOptions = {
    apiConfig,
    accessToken: args.accessToken,
    predicate: args.where,
    logger: {
      error: logger.error.bind(logger),
      warn: logger.warn.bind(logger),
      info: logger.info.bind(logger),
      debug: logger.debug.bind(logger)
    }
  };
  return new _main.default(exporterOptions);
}).then(customerGroupsExporter => customerGroupsExporter.run(args.output)).catch(errorHandler);