module Dexter
  class Client
    extend Logging
    include Logging

    attr_reader :arguments, :options

    def self.start
      Dexter::Client.new(ARGV).perform
    rescue Dexter::Abort, PG::UndefinedFile, PG::FeatureNotSupported => e
      abort colorize(e.message.strip, :red)
    end

    def initialize(args)
      @arguments, @options = parse_args(args)
    end

    def perform
      STDOUT.sync = true
      STDERR.sync = true

      if options[:statement]
        query = Query.new(options[:statement])
        Indexer.new(options).process_queries([query])
      elsif options[:pg_stat_statements]
        # TODO support streaming option
        Indexer.new(options).process_stat_statements
      elsif options[:pg_stat_activity]
        Processor.new(:pg_stat_activity, options).perform
      elsif arguments.any?
        ARGV.replace(arguments)
        if !options[:input_format]
          ext = ARGV.map { |v| File.extname(v) }.uniq
          options[:input_format] = ext.first[1..-1] if ext.size == 1
        end
        Processor.new(ARGF, options).perform
      elsif options[:stdin]
        Processor.new(STDIN, options).perform
      else
        raise Dexter::Abort, "Specify a source of queries: --pg-stat-statements, --pg-stat-activity, --stdin, or a path"
      end
    end

    def parse_args(args)
      opts = Slop.parse(args) do |o|
        o.banner = %(Usage:
    dexter [options])
        o.separator ""

        o.separator "Input options:"
        o.string "--input-format", "input format"
        o.boolean "--pg-stat-activity", "use pg_stat_activity", default: false
        o.boolean "--pg-stat-statements", "use pg_stat_statements", default: false, help: false
        o.boolean "--stdin", "use stdin", default: false
        o.string "-s", "--statement", "process a single statement"
        o.separator ""

        o.separator "Connection options:"
        o.string "-d", "--dbname", "database name"
        o.string "-h", "--host", "database host"
        o.integer "-p", "--port", "database port"
        o.string "-U", "--username", "database user"
        o.separator ""

        o.separator "Processing options:"
        o.integer "--interval", "time to wait between processing queries, in seconds", default: 60
        # TODO change to integer in 0.6.0
        o.float "--min-calls", "only process queries that have been called a certain number of times", default: 0
        o.float "--min-time", "only process queries that have consumed a certain amount of DB time, in minutes", default: 0
        o.separator ""

        o.separator "Indexing options:"
        o.boolean "--analyze", "analyze tables that haven't been analyzed in the past hour", default: false
        o.boolean "--create", "create indexes", default: false
        o.boolean "--enable-hypopg", "enable the HypoPG extension", default: false
        o.array "--exclude", "prevent specific tables from being indexed"
        o.string "--include", "only include specific tables"
        o.integer "--min-cost-savings-pct", default: 50, help: false
        o.string "--tablespace", "tablespace to create indexes"
        o.separator ""

        o.separator "Logging options:"
        o.boolean "--log-explain", "log explain", default: false, help: false
        o.string "--log-level", "log level", default: "info"
        o.boolean "--log-sql", "log sql", default: false
        o.separator ""

        o.separator "Other options:"
        o.on "-v", "--version", "print the version" do
          log Dexter::VERSION
          exit
        end
        o.on "--help", "prints help" do
          log o
          exit
        end
      end

      arguments = opts.arguments
      options = opts.to_hash

      options[:dbname] = arguments.shift unless options[:dbname]

      # TODO don't use global var
      $log_level = options[:log_level].to_s.downcase
      raise Dexter::Abort, "Unknown log level" unless ["error", "info", "debug", "debug2", "debug3"].include?($log_level)

      [arguments, options]
    rescue Slop::Error => e
      raise Dexter::Abort, e.message
    end
  end
end