1 files changed, 82 insertions, 0 deletions
diff --git a/spec/lib/bulk_imports/groups/pipelines/subgroup_entities_pipeline_spec.rb b/spec/lib/bulk_imports/groups/pipelines/subgroup_entities_pipeline_spec.rb
new file mode 100644
index 00000000000..60a4a796682
--- /dev/null
+++ b/spec/lib/bulk_imports/groups/pipelines/subgroup_entities_pipeline_spec.rb
@@ -0,0 +1,82 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+
+RSpec.describe BulkImports::Groups::Pipelines::SubgroupEntitiesPipeline do
+  describe '#run' do
+    let_it_be(:user) { create(:user) }
+    let(:parent) { create(:group, name: 'imported-group', path: 'imported-group') }
+    let!(:parent_entity) do
+      create(
+        :bulk_import_entity,
+        destination_namespace: parent.full_path,
+        group: parent
+      )
+    end
+
+    let(:context) do
+      instance_double(
+        BulkImports::Pipeline::Context,
+        current_user: user,
+        entity: parent_entity
+      )
+    end
+
+    let(:subgroup_data) do
+      [
+        {
+          "name" => "subgroup",
+          "full_path" => "parent/subgroup"
+        }
+      ]
+    end
+
+    subject { described_class.new }
+
+    before do
+      allow_next_instance_of(BulkImports::Groups::Extractors::SubgroupsExtractor) do |extractor|
+        allow(extractor).to receive(:extract).and_return(subgroup_data)
+      end
+
+      parent.add_owner(user)
+    end
+
+    it 'creates entities for the subgroups' do
+      expect { subject.run(context) }.to change(BulkImports::Entity, :count).by(1)
+
+      subgroup_entity = BulkImports::Entity.last
+
+      expect(subgroup_entity.source_full_path).to eq 'parent/subgroup'
+      expect(subgroup_entity.destination_namespace).to eq 'imported-group'
+      expect(subgroup_entity.destination_name).to eq 'subgroup'
+      expect(subgroup_entity.parent_id).to eq parent_entity.id
+    end
+  end
+
+  describe 'pipeline parts' do
+    it { expect(described_class).to include_module(BulkImports::Pipeline) }
+    it { expect(described_class).to include_module(BulkImports::Pipeline::Attributes) }
+    it { expect(described_class).to include_module(BulkImports::Pipeline::Runner) }
+
+    it 'has extractors' do
+      expect(described_class.extractors).to contain_exactly(
+        klass: BulkImports::Groups::Extractors::SubgroupsExtractor,
+        options: nil
+      )
+    end
+
+    it 'has transformers' do
+      expect(described_class.transformers).to contain_exactly(
+        klass: BulkImports::Groups::Transformers::SubgroupToEntityTransformer,
+        options: nil
+      )
+    end
+
+    it 'has loaders' do
+      expect(described_class.loaders).to contain_exactly(
+        klass: BulkImports::Common::Loaders::EntityLoader,
+        options: nil
+      )
+    end
+  end
+end