Class: QuartzPlugin

Inherits:
Object
  • Object
show all
Defined in:
lib/plugins/quartz_plugin.rb

Constant Summary collapse

@@version_major = 
0
@@version_minor = 
0
@@version_revision = 
0

Instance Method Summary collapse

Constructor Details

#initialize(log, options) ⇒ QuartzPlugin

Returns a new instance of QuartzPlugin.



6
7
8
9
 
# File 'lib/plugins/quartz_plugin.rb', line 6

def initialize(log, options)
  @log = log
  @options = options
end

Instance Method Details

#get_version ⇒ Object 



47
48
49
 
# File 'lib/plugins/quartz_plugin.rb', line 47

def get_version
  "#{@@version_major}.#{@@version_minor}.#{@@version_revision}"
end

#payload(message) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/plugins/quartz_plugin.rb', line 18

def payload(message)
  raw_payload = message['payload']
  @log.debug "Payload #{raw_payload}"
  parsed_payload = JSON.parse(raw_payload) unless raw_payload.nil?
  @log.debug "Parsed payload #{parsed_payload}"

  v = parsed_payload
  v = v.merge({'job_name' => message['job_name']})

  @log.debug "Payload #{v}"

  v
end

#run_result(success, message) ⇒ Object 



11
12
13
14
15
16
 
# File 'lib/plugins/quartz_plugin.rb', line 11

def run_result(success, message)
  result = { :ok => success, :message => message }
  @log.debug "Job finished with result #{result}"

  result
end

#run_shell(command) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
 
# File 'lib/plugins/quartz_plugin.rb', line 32

def run_shell(command)
  pid, stdin, stdout, stderr = Open4::popen4("#{command}")
  ignored, status = Process::waitpid2 pid

  if status.exitstatus == 0
    { :ok => true, :message => stdout.read.strip }
  else
    { :ok => false, :message => stderr.read.strip}
  end
end