summaryrefslogtreecommitdiff
path: root/app/services/bulk_create_integration_service.rb
diff options
context:
space:
mode:
authorGitLab Bot <gitlab-bot@gitlab.com>2022-06-20 11:10:13 +0000
committerGitLab Bot <gitlab-bot@gitlab.com>2022-06-20 11:10:13 +0000
commit0ea3fcec397b69815975647f5e2aa5fe944a8486 (patch)
tree7979381b89d26011bcf9bdc989a40fcc2f1ed4ff /app/services/bulk_create_integration_service.rb
parent72123183a20411a36d607d70b12d57c484394c8e (diff)
downloadgitlab-ce-0ea3fcec397b69815975647f5e2aa5fe944a8486.tar.gz
Add latest changes from gitlab-org/gitlab@15-1-stable-eev15.1.0-rc42
Diffstat (limited to 'app/services/bulk_create_integration_service.rb')
-rw-r--r--app/services/bulk_create_integration_service.rb14
1 files changed, 4 insertions, 10 deletions
diff --git a/app/services/bulk_create_integration_service.rb b/app/services/bulk_create_integration_service.rb
index 3a214122ed3..8fbb7f4f347 100644
--- a/app/services/bulk_create_integration_service.rb
+++ b/app/services/bulk_create_integration_service.rb
@@ -1,6 +1,8 @@
# frozen_string_literal: true
class BulkCreateIntegrationService
+ include Integrations::BulkOperationHashes
+
def initialize(integration, batch, association)
@integration = integration
@batch = batch
@@ -8,13 +10,13 @@ class BulkCreateIntegrationService
end
def execute
- service_list = ServiceList.new(batch, integration_hash, association).to_array
+ service_list = ServiceList.new(batch, integration_hash(:create), association).to_array
Integration.transaction do
results = bulk_insert(*service_list)
if integration.data_fields_present?
- data_list = DataList.new(results, data_fields_hash, integration.data_fields.class).to_array
+ data_list = DataList.new(results, data_fields_hash(:create), integration.data_fields.class).to_array
bulk_insert(*data_list)
end
@@ -30,12 +32,4 @@ class BulkCreateIntegrationService
klass.insert_all(items_to_insert, returning: [:id])
end
-
- def integration_hash
- integration.to_integration_hash.tap { |json| json['inherit_from_id'] = integration.inherit_from_id || integration.id }
- end
-
- def data_fields_hash
- integration.to_data_fields_hash
- end
end