Class: GoodData::LCM2::CollectComputedAttributeMetrics

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

Constant Summary collapse

DESCRIPTION = 
'Collect all metrics which is used in computed attributes in development projects'
PARAMS = 
define_params(self) do
  description 'Client Used for Connecting to GD'
  param :gdc_gd_client, instance_of(Type::GdClientType), required: false

  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::AnyType)), required: true, generated: true
end

Constants inherited from BaseAction

BaseAction::FAILED_CLIENTS, BaseAction::FAILED_PROJECTS, BaseAction::FAILED_SEGMENTS, BaseAction::SYNC_FAILED_LIST

Constants included from Dsl::Dsl

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

Class Method Summary collapse

Methods inherited from BaseAction

add_failed_client, add_failed_project, add_failed_segment, add_new_clients_to_project_client_mapping, check_params, collect_synced_status, continue_on_error, print_result, process_failed_project, process_failed_projects, sync_failed_client, sync_failed_project, sync_failed_segment, without_check

Methods included from Dsl::Dsl

#define_params, #define_type, #process

Class Method Details

.call(params) ⇒ Object

[View source]

26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/gooddata/lcm/actions/collect_ca_metrics.rb', line 26

def call(params)
  results = []
  development_client = params.development_client

  synchronize = params.synchronize.pmap do |info|
    from = info.from
    from_project = development_client.projects(from) || fail("Invalid 'from' project specified - '#{from}'")

    metric_uris = from_project.computed_attributes.flat_map { |a| a.using('metric').map { |m| m['link'] } }

    info[:transfer_uris] ||= []
    info[:transfer_uris] += metric_uris

    results += metric_uris.map do |uri|
      {
        project: from,
        transfer_uri: uri
      }
    end

    info
  end

  {
    results: results,
    params: {
      synchronize: synchronize
    }
  }
end