class GoodData::LCM2::CollectSegmentClients
Constants
- DESCRIPTION
- PARAMS
- RESULT_HEADER
Public Class Methods
call(params)
click to toggle source
# File lib/gooddata/lcm/actions/collect_segment_clients.rb, line 58 def call(params) client = params.gdc_gd_client results = [] synchronize_clients = params[:segments].map do |segment_hash| segment = segment_hash[:segment] segment_clients = segment.clients missing_project_clients = segment_clients.reject(&:project?).map(&:client_id) raise "Client(s) missing workspace: #{missing_project_clients.join(', ')}. Please make sure all clients have workspace." unless missing_project_clients.empty? domain_name = params.organization || params.domain fail "Either organisation or domain has to be specified in params" unless domain_name client.domain(domain_name) || fail("Invalid domain name specified - #{domain_name}") if params.ads_client latest_master = GoodData::LCM2::Helpers.latest_master_project_from_ads( params.release_table_name, params.ads_client, segment.segment_id ) else data_product = params.data_product data_product_id = data_product.data_product_id latest_master = GoodData::LCM2::Helpers.latest_master_project_from_nfs(domain_name, data_product_id, segment.segment_id) end raise 'Release table has no data' unless latest_master latest_master = client.projects(latest_master[:master_project_id]) # TODO: Check res.first.nil? || res.first[:master_project_id].nil? master_pid = latest_master.pid master_name = latest_master.title previous_master = segment_hash[:segment_master] if segment_hash[:segment_master] && segment_hash[:segment_master].pid != latest_master.pid sync_info = { segment_id: segment.segment_id, from: master_pid, previous_master: previous_master, to: segment_clients.map do |segment_client| client_project = segment_client.project to_pid = client_project.pid results << { segment: segment.segment_id, from_name: master_name, from_pid: master_pid, to_name: client_project.title, to_pid: to_pid, previous_master: previous_master } { pid: to_pid, client_id: segment_client.client_id } end } sync_info end results.flatten! # Return results { results: results, params: { synchronize: synchronize_clients } } end