class GoodData::LCM2::ProvisionClients

Constants

DESCRIPTION
PARAMS
RESULT_HEADER

Public Class Methods

call(params) click to toggle source
# File lib/gooddata/lcm/actions/provision_clients.rb, line 53
def call(params)
  synchronize_projects = []
  data_product = params.data_product
  client = params.gdc_gd_client
  collect_synced_status = collect_synced_status(params)
  continue_on_error = continue_on_error(params)
  domain_name = params.organization || params.domain
  fail "Either organisation or domain has to be specified in params" unless domain_name
  domain = client.domain(domain_name) || fail("Invalid domain name specified - #{domain_name}")
  error_message = nil
  invalid_client_ids = []
  begin
    results = params.segments.map do |segment|
      next if sync_failed_segment(segment.segment_id, params)

      segment_object = domain.segments(segment.segment_id, data_product)
      tmp = segment_object.provision_client_projects.map do |m|
        Hash[m.each_pair.to_a].merge(type: :provision_result)
      end

      unless tmp.empty?
        synchronize_project = {
          segment_id: segment.segment_id,
          from: segment.development_pid,
          to: tmp.map do |entry|
            unless entry[:project_uri]
              error_message = "There was error during provisioning clients: #{entry[:error]}" unless error_message
              invalid_client_ids << entry[:id]
              if collect_synced_status
                failed_message = "Failed to provision client #{entry[:id]} in segment #{segment.segment_id}. Error: #{entry[:error]}"
                add_failed_client(entry[:id], failed_message, short_name, params)
              end
              next
            end

            project_id = entry[:project_uri].split('/').last
            if collect_synced_status && entry[:status] == 'CREATED' && entry[:id]
              # Update project client mappings when there are create new clients during provision clients of the segment
              add_new_clients_to_project_client_mapping(project_id, entry[:id], segment.segment_id, params)
            end

            {
              pid: project_id,
              client_id: entry[:id]
            }
          end.compact
        }

        synchronize_projects << synchronize_project unless synchronize_project[:to].empty?
      end

      if error_message
        params.gdc_logger.debug "#{error_message}. Purge all invalid clients now ..."
        deleted_client_ids = []

        segment_object.clients.map do |segment_client|
          project = segment_client.project
          if (project.nil? || project.deleted?)
            client_id =  segment_client.client_id
            if invalid_client_ids.include?(client_id)
              segment_client.delete
              deleted_client_ids << client_id
            end
          end
        end

        params.gdc_logger.debug "Deleted clients: #{deleted_client_ids.join(', ')}"
        unless error_message['TooManyProjectsCreatedException'] || error_message['Max number registered projects']
          raise error_message unless continue_on_error

          next
        end

        break tmp
      end

      tmp
    end
  rescue => e
    params.gdc_logger.error "Problem occurs when provisioning clients. Error: #{e}"
    raise e unless continue_on_error
  end

  results.flatten! if results

  # Return results
  {
    results: results,
    params: {
      synchronize: synchronize_projects
    }
  }
end