Class: Kymera::TestResultsCollector

Inherits:
Object
  • Object
show all
Defined in:
lib/kymera/test_results_collector.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ TestResultsCollector

Returns a new instance of TestResultsCollector.



10
11
12
13
14
15
 
# File 'lib/kymera/test_results_collector.rb', line 10

def initialize
  @config = Kymera::Config.new
  @zmq = Kymera::SZMQ.new
  @out_socket = @zmq.socket(@config.result_collector["result_bus_address"], 'pub')
  @out_socket.connect
end

Instance Method Details

#finalize_results(test_count, run_id, results, runner, start_time) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/kymera/test_results_collector.rb', line 37

def finalize_results(test_count, run_id, results, runner, start_time)
  if runner.downcase == 'cucumber'

    begin
      puts "Summarizing results.."
      r_results = Kymera::Cucumber::ResultsParser.summarize_results(results)
      puts "Getting pass count..."
      pass_count = Kymera::Cucumber::ResultsParser.scenario_counts[:pass]
      puts "Getting fail count..."
      fail_count = Kymera::Cucumber::ResultsParser.scenario_counts[:fail]
      puts "Converting results to html..."
      html_results = Kymera::Cucumber::HTMLResultsParser.to_html(results)
      puts "Converting summary to html..."
      html_summary = Kymera::Cucumber::HTMLResultsParser.to_html(r_results)
      puts "Setting end time"
      end_time = Time.now
      puts "Starting database logging processes..."
      Kymera::MongoDriver.log_results(build_test_log(test_count, run_id, html_results, html_summary, start_time, end_time.to_s, pass_count, fail_count), @config.result_collector["mongodb_address"],
                                      @config.result_collector["mongodb_port"].to_i, @config.result_collector["mongodb_database_name"], @config.result_collector["mongodb_collection_name"])
      puts "Setting run id..."
    rescue => e
      puts "There was an error in the logging process:"
      puts e
    ensure
      run_id = "end_#{run_id}"
      puts "Sending results to client...#{run_id}"
      @out_socket.publish_message(run_id, r_results)
    end
  end
end

#listen ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/kymera/test_results_collector.rb', line 17

def listen
  puts "Test collector started..."
  @run_id = ''
  results = ''
  @inc_socket.receive do |message|
    parsed_message = JSON.parse message
    @run_id = parsed_message["run_id"]
    test_count = parsed_message["test_count"].to_i
    start_test_count = parsed_message["test_count"]
    runner = parsed_message["runner"]
    results << parsed_message["results"]
    start_time = parsed_message["start_time"]
    puts 'Results run started with the following configuration:'
    puts "Run ID: #{@run_id}"
    puts "Test count: #{test_count}"
    finalize_results(start_test_count, @run_id, results, runner, start_time)
  end

end