Sha256: d4ccfc05da00b356792d144a814749d19d9af6d4c30d9a0e094b1b98367b586a
Contents?: true
Size: 1.91 KB
Versions: 12
Compression:
Stored size: 1.91 KB
Contents
module Eco
module API
class UseCases
class DefaultCases
class CreateDetailsWithSupervisorCase < DefaultCase
def process
# good candidate to do @cases.case("create-details").use.chain(@cases.case("set-supervisor").use)
@cases.define("create-details-with-supervisor", type: :sync) do |entries, people, session, options, usecase|
creation = session.job_group("main").new("create", usecase: usecase, type: :create, sets: [:core, :details])
supers = session.job_group("post").new("supers", usecase: usecase, type: :update, sets: :core)
strict_search = session.config.people.strict_search? && (!options[:search]&.key?(:strict) || options.dig(:search, :strict))
entries.each.with_index do |entry, i|
if person = people.find(entry, strict: strict_search)
session.logger.error("This person (id: '#{person.id}') already exists: #{entry.to_s(:identify)}")
else
person = session.new_person
entry.set_core(person, exclude: "supervisor_id")
entry.set_details(person)
creation.add(person)
# set supervisor
if !(sup_id = entry.supervisor_id)
person.supervisor_id = nil
else
if supervisor = people.person(id: sup_id, external_id: sup_id, email: sup_id)
person.supervisor_id = supervisor.id
else
# delay setting supervisor if does not exit
supers.add(person) do |person|
person.supervisor_id = sup_id
end
end
end
end
end
end
end
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems