Skip to content

Commit

Permalink
Test removal of doubled service child retirement call
Browse files Browse the repository at this point in the history
  • Loading branch information
d-m-u committed Sep 17, 2018
1 parent bda5c54 commit 3cb9175
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 7 deletions.
11 changes: 6 additions & 5 deletions app/models/service_retire_task.rb
Original file line number Diff line number Diff line change
Expand Up @@ -29,18 +29,18 @@ def after_request_task_create
create_retire_subtasks(parent_svc, self)
end

def create_retire_subtasks(parent_service, task)
def create_retire_subtasks(parent_service, parent_task)
parent_service.service_resources.collect do |svc_rsc|
next unless svc_rsc.resource.try(:retireable?)
# TODO: the next line deals with the filtering for provisioning
# (https://github.com/ManageIQ/manageiq/blob/3921e87915b5a69937b9d4a70bb24ab71b97c165/app/models/service_template/filter.rb#L5)
# which should be extended to retirement as part of later work
# svc_rsc.resource_type != "ServiceTemplate" || self.class.include_service_template?(self, srr.id, parent_service)
nh = attributes.except("id", "created_on", "updated_on", "type", "state", "status", "message")
nh = attributes.except("id", "created_on", "updated_on", "type", "state", "status", "message", *self.class.virtual_attribute_names)
nh['options'] = options.except(:child_tasks)
# Initial Options[:dialog] to an empty hash so we do not pass down dialog values to child services tasks
nh['options'][:dialog] = {}
new_task = create_task(svc_rsc, parent_service, nh)
new_task = create_task(svc_rsc, parent_service, nh, parent_task)
create_retire_subtasks(svc_rsc.resource, new_task) if svc_rsc.resource.kind_of?(Service)
new_task.after_request_task_create
miq_request.miq_request_tasks << new_task
Expand All @@ -49,15 +49,16 @@ def create_retire_subtasks(parent_service, task)
end.compact!
end

def create_task(svc_rsc, parent_service, nh)
def create_task(svc_rsc, parent_service, nh, parent_task)
new_task = (svc_rsc.resource.type.demodulize + "RetireTask").constantize.new(nh)
new_task.options.merge!(
:src_id => svc_rsc.resource.id,
:service_resource_id => svc_rsc.id,
:parent_service_id => parent_service.id,
:parent_task_id => id,
:parent_task_id => parent_task.id,
)
new_task.source = svc_rsc.resource
parent_task.miq_request_tasks << new_task
new_task.request_type = svc_rsc.resource.type.demodulize.downcase + "_retire"
new_task.save!
new_task
Expand Down
4 changes: 2 additions & 2 deletions spec/models/service_retire_task_spec.rb
Original file line number Diff line number Diff line change
Expand Up @@ -89,8 +89,8 @@
service.service_resources << FactoryGirl.create(:service_resource, :resource_type => "Service", :service_id => service_c1.id, :resource_id => service_c1.id)

@service_retire_task.after_request_task_create
expect(VmRetireTask.count).to eq(4)
expect(VmRetireTask.all.pluck(:message)).to eq(["Automation Starting", "Automation Starting", "Automation Starting", "Automation Starting"])
expect(VmRetireTask.count).to eq(2)
expect(VmRetireTask.all.pluck(:message)).to eq(["Automation Starting", "Automation Starting"])
expect(ServiceRetireTask.count).to eq(1)
expect(ServiceRetireRequest.count).to eq(1)
end
Expand Down

0 comments on commit 3cb9175

Please sign in to comment.