1 files changed, 63 insertions, 0 deletions
diff --git a/app/services/bulk_import_service.rb b/app/services/bulk_import_service.rb
new file mode 100644
index 00000000000..bebf9153ce7
--- /dev/null
+++ b/app/services/bulk_import_service.rb
@@ -0,0 +1,63 @@
+# frozen_string_literal: true
+
+# Entry point of the BulkImport feature.
+# This service receives a Gitlab Instance connection params
+# and a list of groups to be imported.
+#
+# Process topography:
+#
+#       sync      |   async
+#                 |
+#  User +--> P1 +----> Pn +---+
+#                 |     ^     | Enqueue new job
+#                 |     +-----+
+#
+# P1 (sync)
+#
+# - Create a BulkImport record
+# - Create a BulkImport::Entity for each group to be imported
+# - Enqueue a BulkImportWorker job (P2) to import the given groups (entities)
+#
+# Pn (async)
+#
+# - For each group to be imported (BulkImport::Entity.with_status(:created))
+#   - Import the group data
+#   - Create entities for each subgroup of the imported group
+#   - Enqueue a BulkImportService job (Pn) to import the new entities (subgroups)
+#
+class BulkImportService
+  attr_reader :current_user, :params, :credentials
+
+  def initialize(current_user, params, credentials)
+    @current_user = current_user
+    @params = params
+    @credentials = credentials
+  end
+
+  def execute
+    bulk_import = create_bulk_import
+
+    BulkImportWorker.perform_async(bulk_import.id)
+  end
+
+  private
+
+  def create_bulk_import
+    BulkImport.transaction do
+      bulk_import = BulkImport.create!(user: current_user, source_type: 'gitlab')
+      bulk_import.create_configuration!(credentials.slice(:url, :access_token))
+
+      params.each do |entity|
+        BulkImports::Entity.create!(
+          bulk_import: bulk_import,
+          source_type: entity[:source_type],
+          source_full_path: entity[:source_full_path],
+          destination_name: entity[:destination_name],
+          destination_namespace: entity[:destination_namespace]
+        )
+      end
+
+      bulk_import
+    end
+  end
+end