Class: Kaya::API::Execution

Inherits:
Object
  • Object
show all
Defined in:
lib/kaya/API/execution.rb

Class Method Summary collapse

Class Method Details

.reset(result_id, ip) ⇒ Object

RESET EXECUTION

Kill associated process to the running execution Sets as finished the result and associated suite as READY



97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
 
# File 'lib/kaya/API/execution.rb', line 97

def self.reset(result_id, ip)

  $K_LOG.debug "Reset execution request for #{result_id}"

  result = Kaya::Results::Result.get(result_id)

  suite = Kaya::Suites::Suite.get(result.suite_id)

  #
  if result.ip == ip # is the owner of execution

    if result.process_running? or !result.finished? or !result.stopped?
      begin
        Kaya::Support::Processes.kill_by_result_id(result.id)
        killed = true
        $K_LOG.debug "Execution (id=#{results.id}) killed"
      rescue => e
        $K_LOG.error "#{e}#{e.backtrace}"
      end

      begin
        Kaya::Support::FilesCleanner.delete_report_which_has(result.id)
        $K_LOG.debug "Execution files(id=#{result.id}) cleanned"
        cleanned = true
      rescue
      end

      result.append_result_to_console_output!
      result.save_report!
      result.reset!("forced"); $K_LOG.debug "Execution stopped! Kaya restarted"
      result.show_as = "pending"
      result.save!
      # Reset if suite is setted as "RUNNING" and its result_id value corresponds to the result reset request
      suite.set_ready! if suite.last_result == result.id
      if killed and cleanned
        {"message" => "Execution stopped"}
      else
        {"message" => "Could not stop execution. Process killing: #{filled}. Files cleanned: #{celanned}"}
      end
    end
  else
    {"message" => "You are not the owner of this execution"}
  end
end

.start(suite_name, query_string, ip) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
 
# File 'lib/kaya/API/execution.rb', line 4

def self.start suite_name, query_string, ip
  $K_LOG.debug "Starting suite #{suite_name}" if $K_LOG

  suite_name.gsub!("%20", " ")

  git_log = Kaya::Support::Configuration.use_git? ? Kaya::Support::Git.log_last_commit : ""


  unless query_string.empty?

    execution_name = query_string.delete("execution_name") if query_string.has_key? "execution_name"
    query_string.each_pair do |param, value|
      query_string.delete(param) if (value =~ /Enter/ or value.nil? or value == "")
    end
    custom_params = query_string || {}

  else
    execution_name =  nil
    custom_params = {}
  end

  if Kaya::Suites.is_there_suite_with? suite_name
    $K_LOG.debug "Suite #{suite_name} found" if $K_LOG

    # suite_id = Kaya::Suites.suite_id_for suite_name

    suite = Kaya::Suites::Suite.get_suite_with(suite_name)

    suite_is_ready_for_ip = !Kaya::Results.running_for_suite_id_and_ip?(suite.id, ip)

    if suite_is_ready_for_ip

      $K_LOG.debug "Suite #{suite_name} is ready to run" if $K_LOG

      execution_request_data = {
        "type"            => "cucumber",
        "suite"           => {"id" => suite.id, "name" => suite.name},
        "execution_name"  => execution_name,
        "custom_params"   => custom_params,
        "git_log"         => git_log,
        "ip"              => ip
      }

      suite.last_result = Kaya::Execution.run!(execution_request_data) # Returns result_id

      suite.set_running!

      suite.save!

      $K_LOG.debug "Suite #{suite_name} setted as running" if $K_LOG

      # Starts workers
      Kaya::Workers::ExecutionChecker.perform_async(suite.id) # Work until execution finish

      execution_id = suite.last_result
      started = true
      message = "Suite%20#{suite.name}%20started"
      status = 200
      $K_LOG.error "Suite #{suite.name} started" if $K_LOG

    else
      # suite_id = suite.id
      execution_id = nil
      started = false
      status = 423
      message = "Requested%20suite%20#{suite.name}%20is%20still%20running"
      $K_LOG.error "Suite #{suite_name} not started. It is still running" if $K_LOG
    end

  else # No suite for  suite_name
    $K_LOG.error "Suite not found for name #{suite_name}" if $K_LOG
    started = false
    execution_id = nil
    status = 404
    message = "Suite #{suite_name} not found"
  end
    {
      "suite" => {
        "name" => suite_name,
        "id" => suite.id,
        "started" => started
        },
      "execution_id" => execution_id,
      "message" => message,
      "status" => status
    }
end