class CalyptiaConfigGenerator

# File lib/fluent/command/config_generator.rb, line 27
def initialize(argv = ARGV)
  @argv = argv
  @api_key = nil
  @endpoint = nil
  @enable_input_metrics = true
  @enable_size_metrics = false
  @enable_get_dump = true
  @rpc_endpoint = "127.0.0.1:24444"
  @storage_agent_token_dir = default_storage_dir
  @fluentd_conf_path = nil
  @disable_rpc = false

  prepare_option_parser
end

# File lib/fluent/command/config_generator.rb, line 50
def call
  parse_options!

  puts dump_configuration_for_calyptia
end

# File lib/fluent/command/config_generator.rb, line 42
def default_storage_dir
  if Fluent.windows?
    "C:/path/to/accesible/dir"
  else
    "/path/to/accesible/dir"
  end
end

# File lib/fluent/command/config_generator.rb, line 56
def dump_configuration_for_calyptia
  dumped = ""
  template = template_path("calyptia-conf.erb").read

  dumped <<
    if ERB.instance_method(:initialize).parameters.assoc(:key) # Ruby 2.6+
      ERB.new(template, trim_mode: "-")
    else
      ERB.new(template, nil, "-")
    end.result(binding)
  dumped
end

# File lib/fluent/command/config_generator.rb, line 114
def parse_options!
  @parser.parse!(@argv)

  raise "Must specify api_key" unless @argv.size == 1

  host, port = @rpc_endpoint.split(':')
  if @enable_get_dump && (!host || !port)
    puts "Error: invalid rpc_endpoint format. Specify `host:port' form."
    exit(false)
  end

  @api_key, = @argv
  @options = {
    api_key: @api_key,
    endpoint: @endpoint,
    rpc_endpoint: @rpc_endpoint,
    input_metrics: @enable_input_metrics,
    size_metrics: @enable_size_metrics,
    enable_get_dump: @enable_get_dump,
    storage_agent_token_dir: @storage_agent_token_dir,
    fluentd_conf_path: @fluentd_conf_path,
    disable_rpc: @disable_rpc,
  }
rescue => e
  usage(e)
end

# File lib/fluent/command/config_generator.rb, line 70
  def prepare_option_parser
    @parser = OptionParser.new
    @parser.version = Fluent::VERSION
    @parser.banner = <<BANNER
Usage: #{$0} api_key [options]

Generate Calyptia monitoring plugin config definitions

Arguments:
\tapi_key: Specify your API_KEY

Options:
BANNER
    @parser.on("--endpoint URL", "API Endpoint URL (default: nil, and if omitted, using default endpoint)") do |s|
      @endpoint = s
    end
    @parser.on("--rpc-endpoint URL", "Specify RPC Endpoint URL (default: 127.0.0.1:24444)") do |s|
      @rpc_endpoint = s
    end
    @parser.on("--disable-input-metrics", "Disable Input plugin metrics. Input metrics is enabled by default") do
      @enable_input_metrics = false
    end
    @parser.on("--enable-size-metrics", "Enable event size metrics. Size metrics is disabled by default.") do
      @enable_size_metrics = true
    end
    @parser.on("--disable-get-dump", "Disable RPC getDump procedure. getDump is enabled by default.") do
      @enable_get_dump = false
    end
    @parser.on("--storage-agent-token-dir DIR", "Specify accesible storage token dir. (default: #{default_storage_dir})") do |s|
      @storage_agent_token_dir = s
    end
    @parser.on("--fluentd-conf-path PATH", "Specify fluentd configuration file path. (default: nil)") do |s|
      @fluentd_conf_path = s
      @disable_rpc = true
    end
  end

# File lib/fluent/command/config_generator.rb, line 141
def template_path(name)
  (Pathname(__dir__) + "../../../templates/#{name}").realpath
end

# File lib/fluent/command/config_generator.rb, line 107
def usage(message = nil)
  puts @parser.to_s
  puts
  puts "Error: #{message}" if message
  exit(false)
end