# frozen_string_literal: true

require_relative '../../command'
require_relative '../../utils/table'
require_relative '../../utils/constants'

module Dri
  module Commands
    class Fetch
      class Failures < Dri::Command
        include Dri::Utils::Table
        include Dri::Utils::Constants::Triage::Labels
        using Refinements

        SORT_BY_OPTIONS = {
          title: 0,
          triaged: 1,
          environment: 2,
          author: 3,
          url: 4
        }.freeze

        def initialize(options)
          @options = options
          @today_iso_format = Time.now.strftime('%Y-%m-%dT00:00:00Z')
        end

        def execute(input: $stdin, output: $stdout) # rubocop:disable Metrics/AbcSize, Metrics/CyclomaticComplexity, Metrics/PerceivedComplexity, Metrics/MethodLength
          verify_config_exists

          urgent_environments = %w[canary canary.staging]

          title = add_color('Title', :bright_yellow)
          triaged = add_color('Triaged?', :bright_yellow)
          environment = add_color('Environment', :bright_yellow)
          author = add_color('Author', :bright_yellow)
          url = add_color('URL', :bright_yellow)

          sorted_failures = []
          labels = [title, triaged, environment, author, url]
          triaged_counter = 0

          logger.info "Fetching today's failures..."

          spinner.run do # rubocop:disable Metrics/BlockLength
            failures = api_client.fetch_all_new_failures(date: @today_iso_format, state: 'opened')

            if failures.empty?
              logger.info 'Life is great, there are no new failures today!'
              exit 0
            end

            failures.each do |failure|
              project_id = failure.project_id
              title = failure.title.truncate(60)
              author = failure.to_h.dig('author', 'username')
              url = failure.web_url
              triaged = add_color('x', :red)
              envs = failure.labels.select { |l| l.include?(FOUND) }.map do |l|
                env = l.split(':').last.gsub('.gitlab.com', '')

                env == 'gitlab.com' ? 'production' : env
              end
              urgent = urgent_environments.all? { |env| envs.include?(env) }

              emoji_awards = api_client.fetch_awarded_emojis(failure.iid, project_id: project_id).find do |e|
                e.name == emoji && e.to_h.dig('user', 'username') == username
              end

              if emoji_awards
                triaged = add_color('✓', :green)
                triaged_counter += 1
              end

              if @options[:urgent]
                sorted_failures << [title, triaged, envs.first, author, url] if urgent
              else
                sorted_failures << [title, triaged, envs.first, author, url]
              end
            end

            sorted_failures.sort_by! { |failure| failure[SORT_BY_OPTIONS[@options[:sort_by]&.to_sym || :environment]] }
          end

          msg = if @options[:urgent]
                  <<~MSG
                    Found: #{sorted_failures.size} urgent failures, occurring in both canary.gitlab.com and canary.staging.gitlab.com.
                  MSG
                else
                  <<~MSG
                    Found: #{sorted_failures.size} failures, of these #{triaged_counter} have been triaged with a #{emoji}.
                  MSG
                end

          print_table(labels, sorted_failures, alignments: [:left, :center, :center, :left])
          output.puts(msg)
        end
      end
    end
  end
end