Class: GoodData::LCM2::ProvisionClients
- Inherits:
-
BaseAction
- Object
- BaseAction
- GoodData::LCM2::ProvisionClients
- Defined in:
- lib/gooddata/lcm/actions/provision_clients.rb
Constant Summary collapse
- DESCRIPTION =
'Provisions LCM Clients'
- PARAMS =
define_params(self) do description 'Client Used for Connecting to GD' param :gdc_gd_client, instance_of(Type::GdClientType), required: true description 'Organization Name' param :organization, instance_of(Type::StringType), required: false description 'Domain' param :domain, instance_of(Type::StringType), required: false description 'Segments to manage' param :segments, array_of(instance_of(Type::SegmentType)), required: true description 'DataProduct to manage' param :data_product, instance_of(Type::GDDataProductType), required: false description 'Logger' param :gdc_logger, instance_of(Type::GdLogger), required: true end
- RESULT_HEADER =
[ :id, :status, :project_uri, :error, :type ]
Constants included from Dsl::Dsl
Dsl::Dsl::DEFAULT_OPTS, Dsl::Dsl::TYPES
Class Method Summary collapse
Methods inherited from BaseAction
Methods included from Dsl::Dsl
#define_params, #define_type, #process
Class Method Details
.call(params) ⇒ Object
44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 |
# File 'lib/gooddata/lcm/actions/provision_clients.rb', line 44 def call(params) synchronize_projects = [] data_product = params.data_product client = params.gdc_gd_client 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}") = nil invalid_client_ids = [] begin results = params.segments.map do |segment| 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] = "There was error during provisioning clients: #{entry[:error]}" unless invalid_client_ids << entry[:id] next end { pid: entry[:project_uri].split('/').last, client_id: entry[:id] } end.compact } synchronize_projects << synchronize_project unless synchronize_project[:to].empty? end if params.gdc_logger.debug "#{}. 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(', ')}" raise unless ['TooManyProjectsCreatedException'] || ['Max number registered projects'] break tmp end tmp end rescue => e params.gdc_logger.error "Problem occurs when provisioning clients." raise e end results.flatten! if results # Return results { results: results, params: { synchronize: synchronize_projects } } end |