semaphore_parser_old.rb

require 'nokogiri'
require 'open-uri'

class SemaphoreParserOld
  def initialize(semaphore_build_filename, folder_name)
    @semaphore_build_file = open_file(semaphore_build_filename)

    @build_number = @semaphore_build_file.css(".c-build-meta_list_status.btn-group").text.scan(/\d+/).first
    @project_name = @semaphore_build_file.css(".list-inline.neutralize.c-project-headline_list").css("b").text
    @branch_name  = @semaphore_build_file.css(".c-build_branch").css("b").text
    @commit_sha   = @semaphore_build_file.css(".u-hover-undelrine").last.text

    @totals = { tests: 0, assertions: 0, failures: 0, errors: 0, skips: 0 }

    build = "build_#{@build_number}"
    @stats_filename           = "#{folder_name}#{build}_stats.txt"
    @combined_output_filename = "#{folder_name}#{build}_thread_output_combined.txt"
    @common_lines_filename    = "#{folder_name}#{build}_thread_output_common_lines.txt"
    @test_numbers_filename    = "#{folder_name}#{build}_thread_output_test_numbers.txt"
  end

  def parse
    @combined_output = File.open("#{@combined_output_filename}", "w+")
    @stats           = File.open("#{@stats_filename}", "w+")

    puts "Downloading and compiling all output to: #{@combined_output_filename} ..."
    generate_combined_output_and_stats
    @combined_output.close
    @stats.close

    puts "Outputting the common lines in the compiled output to: #{@common_lines_filename} ..."
    generate_common_output_lines

    puts "Outputting the test numbers for errors and failures: #{@test_numbers_filename} ..."
    generate_test_numbers

    puts "Outputted all statistics to #{@stats_filename}"
  end

  private

  def open_file(filename)
    Nokogiri::HTML(open(filename))
  end

  def generate_combined_output_and_stats
    @stats.write(build_information)

    @semaphore_build_file.css(".panel.panel-secondary-pastel").each do |thread|
      thread_num    = thread.css(".c-results_list_command.ng-binding").text.scan(/\d+/).first
      download_node = thread.css(".text-info").css("a").first
      download_link = download_node.attributes["href"].value if download_node.respond_to?(:attributes)

      @stats.write("#{thread_num}: ")
      @combined_output.write("THREAD #{thread_num}:\n\n")

      if download_link
        download_thread_and_add_to_outputs(download_link)
      else
        add_thread_to_outputs(thread.text)
      end

      @combined_output.write("\n")
    end

    write_totals_to_stats
  end

  def thread_stats_regex_universal
    /\d+ (tests|runs), \d+ assertions, \d+ failures, \d+ errors, \d+ skips/
  end

  def thread_stats_regex_runs
    /\d+ runs, \d+ assertions, \d+ failures, \d+ errors, \d+ skips/
  end

  def thread_stats_regex_tests
    /\d+ tests, \d+ assertions, \d+ failures, \d+ errors, \d+ skips/
  end

  def build_information
    ["build #{@build_number} for #{@project_name}",
     "branch: #{@branch_name}",
     "commit sha: #{@commit_sha}\n\n"].join("\n")
  end

  def add_to_totals(stats_line)
    line_totals = stats_line.scan(/\d+/)
    @totals.each_with_index { |(key, _), i| @totals[key] += line_totals[i].to_i }
  end

  def write_totals_to_stats
    @stats.write("\n")
    @totals.each { |key, value| @stats.write("#{value} #{key}\n") }
    @stats.write("\nfailures + errors + skips: #{@totals[:failures] + @totals[:errors] + @totals[:skips]}")
  end

  def download_thread_and_add_to_outputs(download_link)
    open(download_link) do |file|
      alignment = ""

      file.each_line do |line|
        @combined_output.write(line)

        if line =~ thread_stats_regex_universal
          add_to_totals(line)

          @stats.write("#{alignment}#{line}")
          alignment = "   " if alignment.empty?
        end
      end
    end
  end

  def add_thread_to_outputs(thread_text)
    @combined_output.write(thread_text)

    stats_line_array = thread_text.scan(thread_stats_regex_tests)
    stats_line_array = thread_text.scan(thread_stats_regex_runs) if stats_line_array.empty?

    @stats.write(stats_line_array.join("\n   ") + "\n")
    stats_line_array.map { |thread_output_line| add_to_totals(thread_output_line) }
  end

  def generate_common_output_lines
    common_lines_command = "cat #{@combined_output_filename} | grep -v \"^\s*$\" | sort | uniq -c | sort -nr > #{@common_lines_filename}"
    system(common_lines_command)
  end

  def generate_test_numbers
    common_lines_command = "grep -oG '.*Test#' #{@combined_output_filename} | uniq -c | sort -n > #{@test_numbers_filename}"
    system(common_lines_command)
  end
end

if __FILE__ == $0
  semaphore_parser = SemaphoreParserOld.new(ARGV[0], ARGV[1] || "")
  semaphore_parser.parse
end