Class: GoodData::LCM2::SynchronizeDataSetMapping

Inherits:
BaseAction show all
Defined in:
lib/gooddata/lcm/actions/synchronize_dataset_mappings.rb

Constant Summary collapse

DESCRIPTION = 
'Synchronize Dataset Mappings'
PARAMS = 
define_params(self) do
  description 'Client Used for Connecting to GD'
  param :gdc_gd_client, instance_of(Type::GdClientType), required: true

  description 'Client used to connecting to development domain'
  param :development_client, instance_of(Type::GdClientType), required: true

  description 'Synchronization Info'
  param :synchronize, array_of(instance_of(Type::SynchronizationInfoType)), required: true, generated: true

  description 'Logger'
  param :gdc_logger, instance_of(Type::GdLogger), required: true
end
RESULT_HEADER = 
%i[from to count status]

Constants included from Dsl::Dsl

Dsl::Dsl::DEFAULT_OPTS, Dsl::Dsl::TYPES

Class Method Summary collapse

Methods inherited from BaseAction

check_params, without_check

Methods included from Dsl::Dsl

#define_params, #define_type, #process

Class Method Details

.call(params) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
 
# File 'lib/gooddata/lcm/actions/synchronize_dataset_mappings.rb', line 32

def call(params)
  results = []

  client = params.gdc_gd_client
  development_client = params.development_client

  params.synchronize.peach do |info|
    from_project = info.from
    to_projects = info.to

    from = development_client.projects(from_project) || fail("Invalid 'from' project specified - '#{from_project}'")
    dataset_mapping = from.dataset_mapping
    if dataset_mapping&.dig('datasetMappings', 'items').nil? || dataset_mapping['datasetMappings']['items'].empty?
      params.gdc_logger.info "Project: '#{from.title}', PID: '#{from.pid}' has no model mapping, skip synchronizing model mapping."
    else
      to_projects.peach do |to|
        pid = to[:pid]
        to_project = client.projects(pid) || fail("Invalid 'to' project specified - '#{pid}'")

        params.gdc_logger.info "Transferring model mapping, from project: '#{from.title}', PID: '#{from.pid}', to project: '#{to_project.title}', PID: '#{to_project.pid}'"
        res = to_project.update_dataset_mapping(dataset_mapping)
        res[:from] = from.pid
        results << res
      end
    end
  end
  # Return results
  results.flatten
end