# frozen_string_literal: true

module Dri
  class Report # rubocop:disable Metrics/ClassLength
    using Refinements

    attr_reader :header, :failures, :labels

    def initialize(config)
      @labels = ['Title', 'Issue', 'Pipelines', 'Stack Trace', 'Actions']
      @failures = []
      @date = Date.today
      @today = Date.today.strftime("%Y-%m-%d")
      @weekday = Date.today.strftime("%A")
      @header = nil

      @api_client = ApiClient.new(config)
    end

    def set_header(timezone, username)
      @header = "# #{timezone}, #{@weekday} - #{@date}\n posted by: @#{username}"
    end

    def add_failure(failure, actions_opts = [])
      iid = failure["iid"]
      title = format_title(failure["title"])
      link = failure["web_url"]
      labels = failure["labels"]
      created_at = failure["created_at"]
      assignees = failure["assignees"]
      description = failure["description"]

      related_mrs = @api_client.fetch_related_mrs(issue_iid: iid)
      emoji = classify_failure_emoji(created_at)
      emojified_link = "#{emoji} #{link}"

      stack_blob = if description.empty?
                     "No stack trace found"
                   else
                     description.split("### Stack trace").last.gsub(/\n|`|!|\[|\]/, '').squeeze(" ")[0...250]
                   end

      stack_trace = ":link:[`#{stack_blob}...`](#{link}#stack-trace)"

      failure_type = filter_failure_type_labels(labels)
      assigned_status = assigned?(assignees)
      pipelines = filter_pipeline_labels(labels)

      linked_pipelines = link_pipelines(iid, pipelines, description)

      actions_status = actions_status_template(failure_type, assigned_status, actions_opts)
      actions_fixes = actions_fixes_template(related_mrs)

      @failures << [title, emojified_link, linked_pipelines, stack_trace, "#{actions_status}#{actions_fixes}"]
    end

    private

    def link_pipelines(iid, pipelines, description) # rubocop:disable Metrics/CyclomaticComplexity, Metrics/PerceivedComplexity, Metrics/MethodLength
      linked = []
      label_pipeline_map = {
        'gitlab.com' => '/quality/production',
        'canary.gitlab.com' => '/quality/canary',
        'canary.staging.gitlab.com' => '/quality/staging-canary',
        'main' => '/gitlab-org/gitlab-qa-mirror',
        'master' => '/gitlab-org/gitlab-qa-mirror',
        'nightly' => '/quality/nightly',
        'pre.gitlab.com' => '/quality/preprod',
        'staging-ref' => '/quality/staging-ref',
        'staging.gitlab.com' => '/quality/staging',
        'release' => '/quality/release'
      }

      failure_notes = @api_client.fetch_failure_notes(issue_iid: iid)

      return if pipelines.empty?

      pipelines.each do |pipeline|
        next unless label_pipeline_map.has_key?(pipeline)

        pipeline_in_notes_found = false
        pipeline_link = ''
        pipeline_markdown = pipeline.gsub(/.gitlab.com/, '')

        failure_notes.each do |note|
          next unless note["body"].include?(label_pipeline_map.fetch(pipeline))

          pipeline_in_notes_found = true
          pipeline_link = URI.extract(note["body"], %w[https])
        end

        unless pipeline_in_notes_found
          links_description = URI.extract(description, %w[https])
          pipeline_link = links_description.select { |link| link.include? label_pipeline_map.fetch(pipeline) }
        end

        unless pipeline_link.empty?
          pipeline_link_sanitized = pipeline_link.join.strip.chop
          pipeline_markdown = "[#{pipeline_markdown}](#{pipeline_link_sanitized})"
        end

        linked << pipeline_markdown
      end
      linked.join(', ')
    end

    def actions_status_template(failure_type, assigned_status, actions_opts) # rubocop:disable Metrics/CyclomaticComplexity, Metrics/PerceivedComplexity/MethodLength
      quarantined = ''
      reproduced = ''
      transient = ''
      active_investigation = ''
      blocking_pipelines = ''
      wait_for_fix = ''
      notified_team = ''
      feature_flag = ''

      notified_set = '<li>[x] notified SET</li>' if actions_opts.include? 'pinged SET'
      quarantined = '<li>[x] quarantined</li>' if actions_opts.include? 'quarantined'
      reproduced = '<li>[x] reproduced</li>' if actions_opts.include? 'reproduced'
      transient = '<li>[x] transient</li>' if actions_opts.include? 'transient'
      active_investigation = '<li>[x] active investigation</li>' if actions_opts.include? 'active investigation'
      blocking_pipelines = '<li>[x] is blocking pipelines</li>' if actions_opts.include? 'blocking pipelines'
      wait_for_fix = '<li>[x] waiting for fix to merge</li>' if actions_opts.include? 'awaiting for a fix to merge'
      notified_team = '<li>[x] notified the team</li>' if actions_opts.include? 'notified the team'
      feature_flag = '<li>[x] due to feature flag</li>' if actions_opts.include? 'due to feature flag'

      action_status = ["<i>Status:</i><ul>"]
      action_status << "<li>#{failure_type}</li>"
      action_status << "</li><li>#{assigned_status}</li>"
      action_status << notified_set
      action_status << quarantined
      action_status << reproduced
      action_status << transient
      action_status << active_investigation
      action_status << blocking_pipelines
      action_status << wait_for_fix
      action_status << notified_team
      action_status << feature_flag

      action_status.join
    end

    def actions_fixes_template(related_mrs)
      mrs = related_mrs.each_with_object(['<i>Potential fixes:</i><br>']) do |mr, fixes|
        fixes << "<li>[#{mr['title'].truncate(40)}](#{mr['web_url']})</li>"
      end

      "<ul>#{mrs.join}</ul>"
    end

    def assigned?(assignees)
      assignees.empty? ? 'Assigned :x:' : 'Assigned :white_check_mark:'
    end

    def filter_pipeline_labels(labels)
      pipelines = []

      labels.each do |label|
        matchers = { 'found:' => ' ' }

        if label.include? "found:"
          pipeline = label.gsub(/found:/) { |match| matchers[match] }
          pipelines << pipeline.strip
        end
      end
      pipelines
    end

    def filter_failure_type_labels(labels)
      labels.each do |label|
        @type = label.gsub!('failure::', ' ').to_s if label.include? "failure::"
      end
      @type
    end

    def classify_failure_emoji(created_at)
      new_failure_emoji = ':boom:'
      known_failure_emoji = ':fire_engine:'

      if created_at.include? @today
        new_failure_emoji
      else
        known_failure_emoji
      end
    end

    # Turns something like:
    #    Failure in browser_ui/3_create/merge_request/create_merge_request_spec.rb | Create a merge request
    # into
    #    Failure&nbsp;in&nbsp;`browser_ui/3_create/merge_request/create_merge_request_spec.rb` | Create a merge request
    def format_title(title)
      path, desc = title.split('|')
      path = "Failure in `#{path.strip}`" if path.delete_prefix!('Failure in ')
      path = path.strip.gsub(' ', '&nbsp;') if desc

      "#{path} | #{desc}"
    end
  end
end