Module: BpmManager::RedHat
- Defined in:
- lib/bpm_manager/red_hat.rb
Class Method Summary collapse
-
.assign_task(task_id, user_id) ⇒ Object
Assigns a Task for an User.
-
.complete_task(task_id, opts = {}) ⇒ Object
Completes a Task.
-
.deployments ⇒ Object
Gets all server deployments.
-
.exit_task(task_id) ⇒ Object
Exits a Task.
-
.fail_task(task_id) ⇒ Object
Fails a Task.
-
.process_instance(process_instance_id) ⇒ Object
Gets a Process Instance.
-
.process_instance_variables(deployment_id, process_instance_id) ⇒ Object
Gets a Process Instance Variables.
-
.process_instances ⇒ Object
Gets all Process Instances.
-
.release_task(task_id) ⇒ Object
Releases a Task.
-
.resume_task(task_id) ⇒ Object
Resumes a Task.
-
.skip_task(task_id) ⇒ Object
Skips a Task.
-
.start_task(task_id) ⇒ Object
Starts a Task.
-
.stop_task(task_id) ⇒ Object
Stops a Task.
-
.suspend_task(task_id) ⇒ Object
Suspends a Task.
-
.tasks(user_id = "") ⇒ Object
Gets all tasks, optionally you could specify an user id.
-
.tasks_with_opts(opts = {}) ⇒ Object
Gets all tasks with options.
Class Method Details
.assign_task(task_id, user_id) ⇒ Object
Assigns a Task for an User
38 39 40 |
# File 'lib/bpm_manager/red_hat.rb', line 38 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
73 74 75 |
# File 'lib/bpm_manager/red_hat.rb', line 73 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
83 84 85 |
# File 'lib/bpm_manager/red_hat.rb', line 83 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
78 79 80 |
# File 'lib/bpm_manager/red_hat.rb', line 78 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 |
# File 'lib/bpm_manager/red_hat.rb', line 33 def self.process_instance_variables(deployment_id, process_instance_id) JSON.parse(RestClient.get(BpmManager.uri('/runtime/' + deployment_id.to_s + '/withvars/process/instance/' + process_instance_id.to_s), :accept => :json))['variables'] 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
63 64 65 |
# File 'lib/bpm_manager/red_hat.rb', line 63 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
58 59 60 |
# File 'lib/bpm_manager/red_hat.rb', line 58 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
68 69 70 |
# File 'lib/bpm_manager/red_hat.rb', line 68 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
43 44 45 |
# File 'lib/bpm_manager/red_hat.rb', line 43 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
48 49 50 |
# File 'lib/bpm_manager/red_hat.rb', line 48 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
53 54 55 |
# File 'lib/bpm_manager/red_hat.rb', line 53 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 |