Welcome to mirror list, hosted at ThFree Co, Russian Federation.

group_loader.rb « loaders « groups « bulk_imports « lib - gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
blob: 85d85f0f703f2121ad9de2448856b4289aae43d3 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
# frozen_string_literal: true

module BulkImports
  module Groups
    module Loaders
      class GroupLoader
        TWO_FACTOR_KEY = 'require_two_factor_authentication'

        GroupCreationError = Class.new(StandardError)

        def load(context, data)
          path = data['path']
          current_user = context.current_user
          destination_namespace = context.entity.destination_namespace

          raise(GroupCreationError, 'Path is missing') unless path.present?
          raise(GroupCreationError, 'Destination is not a group') if user_namespace_destination?(destination_namespace)
          raise(GroupCreationError, 'User not allowed to create group') unless user_can_create_group?(current_user, data)
          raise(GroupCreationError, 'Group exists') if group_exists?(destination_namespace, path)

          unless two_factor_requirements_met?(current_user, data)
            raise(GroupCreationError, 'User requires Two-Factor Authentication')
          end

          group = ::Groups::CreateService.new(current_user, data).execute

          raise(GroupCreationError, group.errors.full_messages.to_sentence) if group.errors.any?

          context.entity.update!(group: group)

          group
        end

        private

        def user_can_create_group?(current_user, data)
          if data['parent_id']
            parent = Namespace.find_by_id(data['parent_id'])

            Ability.allowed?(current_user, :create_subgroup, parent)
          else
            Ability.allowed?(current_user, :create_group)
          end
        end

        def two_factor_requirements_met?(current_user, data)
          return true unless data.has_key?(TWO_FACTOR_KEY) && data[TWO_FACTOR_KEY]

          current_user.two_factor_enabled?
        end

        def group_exists?(destination_namespace, path)
          full_path = destination_namespace.present? ? File.join(destination_namespace, path) : path

          Group.find_by_full_path(full_path).present?
        end

        def user_namespace_destination?(destination_namespace)
          return false unless destination_namespace.present?

          Namespace.find_by_full_path(destination_namespace)&.user_namespace?
        end
      end
    end
  end
end