Module: BpmManager::RedHat

Defined in:
lib/bpm_manager/red_hat.rb

Class Method Summary collapse

Class Method Details

.assign_task(task_id, user_id) ⇒ Object

Assigns a Task for an User



42
43
44
 
# File 'lib/bpm_manager/red_hat.rb', line 42

def self.assign_task(task_id, user_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/delegate?targetEntityId=' + user_id.to_s)), :headers => {:content_type => :json, :accept => :json})
end

.complete_task(task_id, opts = {}) ⇒ Object

Completes a Task



77
78
79
 
# File 'lib/bpm_manager/red_hat.rb', line 77

def self.complete_task(task_id, opts = {})
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/complete')), :headers => {:content_type => :json, :accept => :json})
end

.deployments ⇒ Object

Gets all server deployments



8
9
10
 
# File 'lib/bpm_manager/red_hat.rb', line 8

def self.deployments()
  return JSON.parse(RestClient.get(BpmManager.uri('/deployment'), :accept => :json))
end

.exit_task(task_id) ⇒ Object

Exits a Task



87
88
89
 
# File 'lib/bpm_manager/red_hat.rb', line 87

def self.exit_task(task_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/exit')), :headers => {:content_type => :json, :accept => :json})
end

.fail_task(task_id) ⇒ Object

Fails a Task



82
83
84
 
# File 'lib/bpm_manager/red_hat.rb', line 82

def self.fail_task(task_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/fail')), :headers => {:content_type => :json, :accept => :json})
end

.process_instance(process_instance_id) ⇒ Object

Gets a Process Instance



28
29
30
 
# File 'lib/bpm_manager/red_hat.rb', line 28

def self.process_instance(process_instance_id)
  JSON.parse(RestClient.get(BpmManager.uri('/history/instance/' + process_instance_id.to_s), :accept => :json))
end

.process_instance_variables(deployment_id, process_instance_id) ⇒ Object

Gets a Process Instance Variables



33
34
35
36
37
38
39
 
# File 'lib/bpm_manager/red_hat.rb', line 33

def self.process_instance_variables(deployment_id, process_instance_id)
  begin
    JSON.parse(RestClient.get(BpmManager.uri('/runtime/' + deployment_id.to_s + '/withvars/process/instance/' + process_instance_id.to_s), :accept => :json))['variables']
  rescue
    return nil
  end
end

.process_instances ⇒ Object

Gets all Process Instances



23
24
25
 
# File 'lib/bpm_manager/red_hat.rb', line 23

def self.process_instances
  JSON.parse(RestClient.get(BpmManager.uri('/history/instances'), :accept => :json))
end

.release_task(task_id) ⇒ Object

Releases a Task



52
53
54
 
# File 'lib/bpm_manager/red_hat.rb', line 52

def self.release_task(task_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/release')), :headers => {:content_type => :json, :accept => :json})
end

.resume_task(task_id) ⇒ Object

Resumes a Task



67
68
69
 
# File 'lib/bpm_manager/red_hat.rb', line 67

def self.resume_task(task_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/resumes')), :headers => {:content_type => :json, :accept => :json})
end

.skip_task(task_id) ⇒ Object

Skips a Task



72
73
74
 
# File 'lib/bpm_manager/red_hat.rb', line 72

def self.skip_task(task_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/skip')), :headers => {:content_type => :json, :accept => :json})
end

.start_task(task_id) ⇒ Object

Starts a Task



47
48
49
 
# File 'lib/bpm_manager/red_hat.rb', line 47

def self.start_task(task_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/start')), :headers => {:content_type => :json, :accept => :json})
end

.stop_task(task_id) ⇒ Object

Stops a Task



57
58
59
 
# File 'lib/bpm_manager/red_hat.rb', line 57

def self.stop_task(task_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/stop')), :headers => {:content_type => :json, :accept => :json})
end

.suspend_task(task_id) ⇒ Object

Suspends a Task



62
63
64
 
# File 'lib/bpm_manager/red_hat.rb', line 62

def self.suspend_task(task_id)
  RestClient.post(URI.encode(BpmManager.uri('/task/' + task_id.to_s + '/suspend')), :headers => {:content_type => :json, :accept => :json})
end

.tasks(user_id = "") ⇒ Object

Gets all tasks, optionally you could specify an user id



13
14
15
 
# File 'lib/bpm_manager/red_hat.rb', line 13

def self.tasks(user_id = "")
  self.structure_task_data(JSON.parse(RestClient.get(BpmManager.uri('/task/query' + (user_id.empty? ? '' : '?taskOwner=' + user_id)), :accept => :json)))
end

.tasks_with_opts(opts = {}) ⇒ Object

Gets all tasks with options



18
19
20
 
# File 'lib/bpm_manager/red_hat.rb', line 18

def self.tasks_with_opts(opts = {})
  self.structure_task_data(JSON.parse(RestClient.get(BpmManager.uri('/task/query' + (opts.empty? ? '' : '?' + opts.map{|k,v| k.to_s + '=' + v.to_s}.join('&'))), :accept => :json)))
end