Class: BulkImports::Groups::Pipelines::ProjectEntitiesPipeline

Inherits:
Object
  • Object
show all
Includes:
Pipeline
Defined in:
lib/bulk_imports/groups/pipelines/project_entities_pipeline.rb

Constant Summary

Constants included from Pipeline

Pipeline::CACHE_KEY_EXPIRATION, Pipeline::EMPTY_EXPORT_STATUS_TIMEOUT, Pipeline::ExpiredError, Pipeline::FailedError, Pipeline::NDJSON_EXPORT_TIMEOUT, Pipeline::NotAllowedError

Constants included from Pipeline::Runner

Pipeline::Runner::MarkedAsFailedError

Instance Method Summary collapse

Methods included from Pipeline

#current_user, #import_export_config, #initialize, #portable, #tracker

Methods included from Pipeline::Runner

#run

Instance Method Details

#load(context, data) ⇒ Object 



23
24
25
 
# File 'lib/bulk_imports/groups/pipelines/project_entities_pipeline.rb', line 23

def load(context, data)
  context.bulk_import.entities.create!(data)
end

#transform(context, data) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
 
# File 'lib/bulk_imports/groups/pipelines/project_entities_pipeline.rb', line 12

def transform(context, data)
  {
    source_type: :project_entity,
    source_full_path: data['full_path'],
    destination_name: data['path'],
    destination_namespace: context.entity.group.full_path,
    parent_id: context.entity.id,
    source_xid: GlobalID.parse(data['id']).model_id
  }
end