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