module Eco module API class MicroCases # Helper to obtain all the elements of `people` anew from the _People Manager_. # @note # 1. This helper is normally used to run consecutive usecases, where data needs refresh. # 2. It only includes new people if they are not dirty (they do not have pending updates) # - This contingency wouldn't be necessary if the server worked perfectly. # @param people [Eco::API::Organization::People] the people that needs refresh. # @param include_created [Boolean] include people created during this session? (will check `:create` batch jobs). # @return [Eco::API::Organization::People] the `People` object with the data. def people_refresh(people:, include_created: true) # rubocop:disable Metrics/AbcSize people = people.newFrom people.select do |person| !person.new? || !person.dirty? end ini = people.length if include_created session.job_groups.find_jobs(type: :create).map do |job| to_add = job.people.reject(&:dirty?) people = people.merge(to_add) end end created = people.length - ini msg = "Going to refresh #{people.length} people with server data" msg << " (including #{created} that were created)" if created.positive? log(:info) { msg } start = Time.now entries = session.batch.get_people(people, silent: true) secs = (Time.now - start).round(3) cnt = entries.count per_sec = (cnt.to_f / secs).round(2) log(:info) { "Re-loaded #{cnt} people (out of #{people.length}) in #{secs} seconds (#{per_sec} people/sec)" } missing = people.length - entries.length if missing.positive? log(:error) { "Missed to obtain #{missing} people during the refresh" } end Eco::API::Organization::People.new(entries) end end end end