cli.js

#! /usr/bin/env node
'use strict'

const minimist = require('minimist')
const pump = require('pump')
const fs = require('fs')
const path = require('path')
const pinoElasticSearch = require('./lib')

function start (opts) {
  if (opts.help) {
    console.log(fs.readFileSync(path.join(__dirname, './usage.txt'), 'utf8'))
    return
  }

  if (opts.version) {
    console.log('pino-elasticsearch', require('./package.json').version)
    return
  }

  if (opts.username && opts.password) {
    opts.auth = {
      username: opts.username,
      password: opts.password
    }
  }

  if (opts['api-key']) {
    opts.auth = { apiKey: opts['api-key'] }
  }

  if (opts.cloud) {
    opts.cloud = { id: opts.cloud }
  }

  if (opts.rejectUnauthorized) {
    opts.rejectUnauthorized = opts.rejectUnauthorized !== 'false'
  }

  pump(process.stdin, pinoElasticSearch(opts))
}

start(minimist(process.argv.slice(2), {
  alias: {
    version: 'v',
    help: 'h',
    node: 'n',
    index: 'i',
    'bulk-size': 'b',
    'flush-bytes': 'f',
    'flush-interval': 't',
    'trace-level': 'l',
    username: 'u',
    password: 'p',
    'api-key': 'k',
    cloud: 'c'
  },
  default: {
    node: 'http://localhost:9200'
  }
}))