2017-06-23 21:19:08 +08:00
|
|
|
class MyModuleGroup < ApplicationRecord
|
2016-02-12 23:52:43 +08:00
|
|
|
include SearchableModel
|
|
|
|
|
2016-09-21 21:35:23 +08:00
|
|
|
auto_strip_attributes :name, nullify: false
|
2016-10-05 23:45:20 +08:00
|
|
|
validates :name,
|
|
|
|
presence: true,
|
|
|
|
length: { maximum: Constants::NAME_MAX_LENGTH }
|
2016-07-22 16:43:55 +08:00
|
|
|
validates :experiment, presence: true
|
2016-02-12 23:52:43 +08:00
|
|
|
|
2017-06-28 21:21:32 +08:00
|
|
|
belongs_to :experiment, inverse_of: :my_module_groups, optional: true
|
|
|
|
belongs_to :created_by,
|
|
|
|
foreign_key: 'created_by_id',
|
|
|
|
class_name: 'User',
|
|
|
|
optional: true
|
2016-09-21 21:54:12 +08:00
|
|
|
has_many :my_modules, inverse_of: :my_module_group, dependent: :nullify
|
2016-02-12 23:52:43 +08:00
|
|
|
|
2017-05-05 22:41:23 +08:00
|
|
|
def self.search(user,
|
|
|
|
include_archived,
|
|
|
|
query = nil,
|
|
|
|
page = 1,
|
|
|
|
_current_team = nil,
|
|
|
|
options = {})
|
2016-07-25 22:30:59 +08:00
|
|
|
exp_ids =
|
|
|
|
Experiment
|
2016-10-05 23:45:20 +08:00
|
|
|
.search(user, include_archived, nil, Constants::SEARCH_NO_LIMIT)
|
2017-04-11 20:55:44 +08:00
|
|
|
.pluck(:id)
|
2016-02-12 23:52:43 +08:00
|
|
|
|
|
|
|
new_query = MyModuleGroup
|
2017-05-05 22:41:23 +08:00
|
|
|
.distinct
|
|
|
|
.where('my_module_groups.experiment_id IN (?)', exp_ids)
|
|
|
|
.where_attributes_like('my_module_groups.name', query, options)
|
2016-02-12 23:52:43 +08:00
|
|
|
|
|
|
|
# Show all results if needed
|
2016-10-05 23:45:20 +08:00
|
|
|
if page == Constants::SEARCH_NO_LIMIT
|
2016-02-12 23:52:43 +08:00
|
|
|
new_query
|
|
|
|
else
|
|
|
|
new_query
|
2016-10-05 23:45:20 +08:00
|
|
|
.limit(Constants::SEARCH_LIMIT)
|
|
|
|
.offset((page - 1) * Constants::SEARCH_LIMIT)
|
2016-02-12 23:52:43 +08:00
|
|
|
end
|
|
|
|
end
|
2016-07-21 19:11:15 +08:00
|
|
|
|
|
|
|
def ordered_modules
|
|
|
|
my_modules.order(workflow_order: :asc)
|
|
|
|
end
|
2016-08-11 21:13:36 +08:00
|
|
|
|
|
|
|
def deep_clone_to_experiment(current_user, experiment)
|
|
|
|
clone = MyModuleGroup.new(
|
|
|
|
name: name,
|
|
|
|
created_by: created_by,
|
|
|
|
experiment: experiment
|
|
|
|
)
|
|
|
|
|
|
|
|
# Get clones of modules from this group, save them as hash
|
|
|
|
cloned_modules = ordered_modules.each_with_object({}) do |m, hash|
|
|
|
|
hash[m.id] = m.deep_clone_to_experiment(current_user, experiment)
|
|
|
|
hash
|
|
|
|
end
|
|
|
|
|
|
|
|
ordered_modules.each do |m|
|
|
|
|
# Copy connections
|
|
|
|
m.inputs.each do |inp|
|
|
|
|
Connection.create(
|
|
|
|
input_id: cloned_modules[inp[:input_id]].id,
|
|
|
|
output_id: cloned_modules[inp[:output_id]].id
|
|
|
|
)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Copy remaining variables
|
|
|
|
cloned_module = cloned_modules[m.id]
|
|
|
|
cloned_module.my_module_group = self
|
|
|
|
cloned_module.created_by = m.created_by
|
|
|
|
cloned_module.workflow_order = m.workflow_order
|
|
|
|
end
|
|
|
|
|
|
|
|
clone.my_modules << cloned_modules.values
|
|
|
|
clone.save
|
|
|
|
clone
|
|
|
|
end
|
2016-02-12 23:52:43 +08:00
|
|
|
end
|