diff options
Diffstat (limited to 'app/models/bulk_imports')
-rw-r--r-- | app/models/bulk_imports/entity.rb | 6 | ||||
-rw-r--r-- | app/models/bulk_imports/export_status.rb | 2 | ||||
-rw-r--r-- | app/models/bulk_imports/file_transfer/base_config.rb | 6 | ||||
-rw-r--r-- | app/models/bulk_imports/file_transfer/group_config.rb | 4 | ||||
-rw-r--r-- | app/models/bulk_imports/file_transfer/project_config.rb | 4 |
5 files changed, 20 insertions, 2 deletions
diff --git a/app/models/bulk_imports/entity.rb b/app/models/bulk_imports/entity.rb index bb543b39a79..24f86b44841 100644 --- a/app/models/bulk_imports/entity.rb +++ b/app/models/bulk_imports/entity.rb @@ -48,6 +48,8 @@ class BulkImports::Entity < ApplicationRecord enum source_type: { group_entity: 0, project_entity: 1 } + scope :by_user_id, ->(user_id) { joins(:bulk_import).where(bulk_imports: { user_id: user_id }) } + state_machine :status, initial: :created do state :created, value: 0 state :started, value: 1 @@ -68,6 +70,10 @@ class BulkImports::Entity < ApplicationRecord end end + def self.all_human_statuses + state_machine.states.map(&:human_name) + end + def encoded_source_full_path ERB::Util.url_encode(source_full_path) end diff --git a/app/models/bulk_imports/export_status.rb b/app/models/bulk_imports/export_status.rb index 98804d18f27..ff165830cf1 100644 --- a/app/models/bulk_imports/export_status.rb +++ b/app/models/bulk_imports/export_status.rb @@ -9,7 +9,7 @@ module BulkImports @relation = relation @entity = @pipeline_tracker.entity @configuration = @entity.bulk_import.configuration - @client = Clients::HTTP.new(uri: @configuration.url, token: @configuration.access_token) + @client = Clients::HTTP.new(url: @configuration.url, token: @configuration.access_token) end def started? diff --git a/app/models/bulk_imports/file_transfer/base_config.rb b/app/models/bulk_imports/file_transfer/base_config.rb index 7396f9d3655..ddea7c3f64c 100644 --- a/app/models/bulk_imports/file_transfer/base_config.rb +++ b/app/models/bulk_imports/file_transfer/base_config.rb @@ -30,7 +30,7 @@ module BulkImports end def portable_relations - import_export_config.dig(:tree, portable_class_sym).keys.map(&:to_s) + import_export_config.dig(:tree, portable_class_sym).keys.map(&:to_s) - skipped_relations end private @@ -66,6 +66,10 @@ module BulkImports def base_export_path raise NotImplementedError end + + def skipped_relations + [] + end end end end diff --git a/app/models/bulk_imports/file_transfer/group_config.rb b/app/models/bulk_imports/file_transfer/group_config.rb index 1f845b387b8..2266cbb484f 100644 --- a/app/models/bulk_imports/file_transfer/group_config.rb +++ b/app/models/bulk_imports/file_transfer/group_config.rb @@ -10,6 +10,10 @@ module BulkImports def import_export_yaml ::Gitlab::ImportExport.group_config_file end + + def skipped_relations + @skipped_relations ||= %w(members) + end end end end diff --git a/app/models/bulk_imports/file_transfer/project_config.rb b/app/models/bulk_imports/file_transfer/project_config.rb index e42b5bfce3d..8a57f51c1c5 100644 --- a/app/models/bulk_imports/file_transfer/project_config.rb +++ b/app/models/bulk_imports/file_transfer/project_config.rb @@ -10,6 +10,10 @@ module BulkImports def import_export_yaml ::Gitlab::ImportExport.config_file end + + def skipped_relations + @skipped_relations ||= %w(project_members group_members) + end end end end |