+ include PipelineComponentsHelper
+
+ def copy
+ template = PipelineTemplate.find?(@object.pipeline_template_uuid)
+
+ source = @object
+ @object = PipelineInstance.new
+ @object.pipeline_template_uuid = source.pipeline_template_uuid
+
+ if params['components'] == 'use_latest' and template
+ @object.components = template.components.deep_dup
+ @object.components.each do |cname, component|
+ # Go through the script parameters of each component
+ # that are marked as user input and copy them over.
+ # Skip any components that are not present in the
+ # source instance (there's nothing to copy)
+ if source.components.include? cname
+ component[:script_parameters].each do |pname, val|
+ if val.is_a? Hash and val[:dataclass]
+ # this is user-inputtable, so check the value from the source pipeline
+ srcvalue = source.components[cname][:script_parameters][pname]
+ if not srcvalue.nil?
+ component[:script_parameters][pname] = srcvalue
+ end
+ end
+ end
+ end
+ end
+ else
+ @object.components = source.components.deep_dup
+ end
+
+ if params['script'] == 'use_same'
+ # Go through each component and copy the script_version from each job.
+ @object.components.each do |cname, component|
+ if source.components.include? cname and source.components[cname][:job]
+ component[:script_version] = source.components[cname][:job][:script_version]
+ end
+ end
+ end
+
+ @object.components.each do |cname, component|
+ component.delete :job
+ end
+ @object.state = 'New'
+
+ # set owner_uuid to that of source, provided it is a project and wriable by current user
+ current_project = Group.find(source.owner_uuid) rescue nil
+ if (current_project && current_project.writable_by.andand.include?(current_user.uuid))
+ @object.owner_uuid = source.owner_uuid
+ end
+
+ super
+ end
+
+ def update
+ @updates ||= params[@object.class.to_s.underscore.singularize.to_sym]
+ if (components = @updates[:components])
+ components.each do |cname, component|
+ if component[:script_parameters]
+ component[:script_parameters].each do |param, value_info|
+ if value_info.is_a? Hash
+ value_info_partitioned = value_info[:value].partition('/') if value_info[:value].andand.class.eql?(String)
+ value_info_value = value_info_partitioned ? value_info_partitioned[0] : value_info[:value]
+ value_info_class = resource_class_for_uuid value_info_value
+ if value_info_class == Link
+ # Use the link target, not the link itself, as script
+ # parameter; but keep the link info around as well.
+ link = Link.find value_info[:value]
+ value_info[:value] = link.head_uuid
+ value_info[:link_uuid] = link.uuid
+ value_info[:link_name] = link.name
+ else
+ # Delete stale link_uuid and link_name data.
+ value_info[:link_uuid] = nil
+ value_info[:link_name] = nil
+ end
+ if value_info_class == Collection
+ # to ensure reproducibility, the script_parameter for a
+ # collection should be the portable_data_hash
+ # keep the collection name and uuid for human-readability
+ obj = Collection.find value_info_value
+ if value_info_partitioned
+ value_info[:value] = obj.portable_data_hash + value_info_partitioned[1] + value_info_partitioned[2]
+ value_info[:selection_name] = obj.name ? obj.name + value_info_partitioned[1] + value_info_partitioned[2] : obj.name
+ else
+ value_info[:value] = obj.portable_data_hash
+ value_info[:selection_name] = obj.name
+ end
+ value_info[:selection_uuid] = obj.uuid
+ end
+ end
+ end
+ end
+ end
+ end
+ super
+ end