# frozen_string_literal: true

require "optparse"
require "uri"

require "wsdirector"

module WSDirector
  # Command line interface for WsDirector
  class CLI
    class Configuration
      attr_accessor :ws_url, :scenario_path, :colorize, :scale,
        :sync_timeout, :json_scenario, :subprotocol, :verbose

      def initialize
        reset!
      end

      def colorize?
        colorize == true
      end

      # Restore to defaults
      def reset!
        @scale = 1
        @colorize = $stdout.tty?
        @sync_timeout = 5
      end
    end

    attr_reader :config

    def run
      @config = Configuration.new

      parse_args!

      begin
        require "colorize" if config.colorize?
      rescue LoadError
        config.colorize = false
        warn "Install colorize to use colored output"
      end

      connection_options = {
        subprotocol: config.subprotocol
      }.compact

      scenario = config.scenario_path || config.json_scenario

      config.ws_url = "ws://#{config.ws_url}" unless config.ws_url.start_with?(/wss?:\/\//)

      url = config.ws_url
      scale = config.scale
      sync_timeout = config.sync_timeout
      colorize = config.colorize

      logger = $stdout if config.verbose

      result = WSDirector.run(
        scenario,
        url: url,
        connection_options: connection_options,
        scale: scale,
        sync_timeout: sync_timeout,
        logger: logger,
        colorize: colorize
      )

      puts "\n\n" if config.verbose

      result.print_summary(colorize: config.colorize?)
      result.success? || exit(1)
    end

    private

    FILE_FORMAT = /.+.(json|yml)\z/
    private_constant :FILE_FORMAT

    def parse_args!
      parser = OptionParser.new do |opts|
        opts.banner = "Usage: wsdirector scenario_path ws_url [options]"

        opts.on("-s SCALE", "--scale=SCALE", Integer, "Scale factor") do |_1|
          config.scale = _1
        end

        opts.on("-t TIMEOUT", "--timeout=TIMEOUT", Integer, "Synchronization (wait_all) timeout") do |_1|
          config.sync_timeout = _1
        end

        opts.on("-i JSON", "--include=JSON", String, "Include JSON to parse") do |_1|
          config.json_scenario = _1
        end

        opts.on("-u URL", "--url=URL", Object, "Websocket server URL") do |_1|
          config.ws_url = _1
        end

        opts.on("-f PATH", "--file=PATH", String, "Scenario path") do |_1|
          config.scenario_path = _1
        end

        opts.on("--subprotocol=VALUE", String, "WebSocket subprotocol") do |_1|
          config.subprotocol = _1
        end

        opts.on("-c", "--[no-]color", "Colorize output") do |_1|
          config.colorize = _1
        end

        opts.on("-v", "--version", "Print version") do
          $stdout.puts WSDirector::VERSION
          exit 0
        end

        opts.on("-vv", "Print verbose logs") do
          config.verbose = true
        end

        opts.on("-r", "--require=PATH", "Load Ruby file (e.g., protocol)") do |_1|
          Kernel.load(_1)
        end
      end

      parser.parse!

      unless config.scenario_path
        config.scenario_path = ARGV.grep(FILE_FORMAT).last
      end

      unless config.ws_url
        config.ws_url = ARGV.grep(URI::DEFAULT_PARSER.make_regexp).last
      end

      check_for_errors
    end

    def check_for_errors
      if config.json_scenario.nil?
        raise(Error, "Scenario is missing") unless config.scenario_path

        unless File.file?(config.scenario_path)
          raise(Error, "File doesn't exist # config.scenario_path}")
        end
      end

      raise(Error, "Websocket server url is missing") unless config.ws_url
    end
  end
end