e2e_github_reporter.rb

# frozen_string_literal: true

require "json"
require "net/http"
require "uri"

class E2EGitHubReporter
  COMMENT_MARKER = "<!-- checkout-kit-e2e-report -->"

  def initialize(results, repository:, sha:, pr_number:, token: nil)
    @results = results
    @repository = repository
    @sha = sha
    @pr_number = pr_number
    @token = token
  end

  def publish!
    commit_status_payloads.each { |payload| post_json("/repos/#{@repository}/statuses/#{@sha}", payload) }
    post_json("/repos/#{@repository}/check-runs", check_run_payload)
    sync_failure_comment
  end

  def markdown_summary
    lines = []
    lines << "## Checkout Kit E2E results"
    lines << ""
    lines << "| Run | Status | Target | Platform | OS track | Device | Suite |"
    lines << "|---|---|---|---|---|---|---|"
    @results.each do |result|
      lines << "| `#{result.fetch("id")}` | #{status_icon(result)} #{result.fetch("status")} | #{result.fetch("target")} | #{result.fetch("platform")} | #{result.fetch("os_track")} | #{result.fetch("device_selector")} → #{result.fetch("resolved_device")} | `#{result.fetch("execute")}` |"
    end
    failure_lines = failed_results.flat_map { |result| failure_details(result) }
    unless failure_lines.empty?
      lines << ""
      lines << "## Failures"
      lines << ""
      lines << "> BrowserStack artifacts require BrowserStack access. Sign in to [BrowserStack App Automate](https://app-automate.browserstack.com/dashboard/v2/builds) before opening artifact links."
      lines.concat(failure_lines)
    end
    lines.join("\n")
  end

  def commit_status_payloads
    @results.map do |result|
      {
        state: result.fetch("passed") ? "success" : "failure",
        context: result.fetch("status_context"),
        description: status_description(result),
        target_url: browserstack_build_url(result)
      }
    end
  end

  def failure_comment_body
    return nil if failed_results.empty?

    [COMMENT_MARKER, markdown_summary].join("\n")
  end

  private

  def check_run_payload
    conclusion = failed_results.empty? ? "success" : "failure"
    {
      name: "Checkout Kit E2E",
      head_sha: @sha,
      status: "completed",
      conclusion: conclusion,
      output: {
        title: "Checkout Kit E2E #{conclusion}",
        summary: markdown_summary
      }
    }
  end

  def sync_failure_comment
    body = failure_comment_body
    existing = existing_failure_comment
    if body
      if existing
        patch_json("/repos/#{@repository}/issues/comments/#{existing.fetch("id")}", {body: body})
      else
        post_json("/repos/#{@repository}/issues/#{@pr_number}/comments", {body: body})
      end
    elsif existing
      patch_json("/repos/#{@repository}/issues/comments/#{existing.fetch("id")}", {body: "#{COMMENT_MARKER}\n✅ Checkout Kit E2E failures resolved."})
    end
  end

  def existing_failure_comment
    get_json("/repos/#{@repository}/issues/#{@pr_number}/comments").find do |comment|
      comment.fetch("body", "").include?(COMMENT_MARKER)
    end
  end

  def failed_results
    @results.reject { |result| result.fetch("passed") }
  end

  def failure_details(result)
    lines = []
    lines << ""
    lines << "### `#{result.fetch("id")}`"
    lines << ""
    lines << "- Device selector: `#{result.fetch("device_selector")}`"
    lines << "- Resolved device: `#{result.fetch("resolved_device")}`"
    lines << "- Suite: `#{result.fetch("execute")}`"
    lines << "- BrowserStack build: [Open BrowserStack build](#{browserstack_build_url(result)})"
    result.fetch("failed_tests", []).each do |testcase|
      lines << "- Failed test: `#{testcase.fetch("name", "unknown")}` (`#{testcase.fetch("status", "unknown")}`)"
      link_fields.each do |label, key|
        value = testcase[key]
        lines << "  - #{label}: [Open #{link_text(label)}](#{value})" if value && !value.empty?
      end
    end
    lines
  end

  def link_fields
    {
      "Video" => "video",
      "Screenshot" => "screenshots",
      "Maestro commands" => "maestro_commands",
      "Maestro log" => "maestro_log",
      "Device log" => "device_log",
      "Network log" => "network_log"
    }
  end

  def link_text(label)
    label.start_with?("Maestro") ? label : label.downcase
  end

  def status_icon(result)
    result.fetch("passed") ? "✅" : "❌"
  end

  def status_description(result)
    description = result.fetch("passed") ? "passed" : "#{result.fetch("status")} on #{result.fetch("resolved_device")}" 
    description[0, 140]
  end

  def browserstack_build_url(result)
    "https://app-automate.browserstack.com/dashboard/v2/builds/#{result.fetch("build_id")}" 
  end

  def get_json(path)
    execute_request(Net::HTTP::Get.new(path))
  end

  def post_json(path, body)
    request = Net::HTTP::Post.new(path)
    request.body = JSON.generate(body)
    execute_json_request(request)
  end

  def patch_json(path, body)
    request = Net::HTTP::Patch.new(path)
    request.body = JSON.generate(body)
    execute_json_request(request)
  end

  def execute_json_request(request)
    request["Content-Type"] = "application/json"
    execute_request(request)
  end

  def execute_request(request)
    raise "GitHub token is required" unless @token

    request["Accept"] = "application/vnd.github+json"
    request["Authorization"] = "Bearer #{@token}"
    response = Net::HTTP.start("api.github.com", 443, use_ssl: true) { |http| http.request(request) }
    body = response.body.to_s.empty? ? {} : JSON.parse(response.body)
    return body if response.is_a?(Net::HTTPSuccess)

    raise "GitHub request failed #{response.code}: #{body}"
  end
end