BigW Consortium Gitlab

member.rb 6.95 KB
Newer Older
1
class Member < ActiveRecord::Base
2
  include Sortable
3
  include Importable
4
  include Expirable
5 6
  include Gitlab::Access

7 8
  attr_accessor :raw_invite_token

9
  belongs_to :created_by, class_name: "User"
10 11 12
  belongs_to :user
  belongs_to :source, polymorphic: true

13
  validates :user, presence: true, unless: :invite?
14
  validates :source, presence: true
15
  validates :user_id, uniqueness: { scope: [:source_type, :source_id],
16 17
                                    message: "already exists in source",
                                    allow_nil: true }
18
  validates :access_level, inclusion: { in: Gitlab::Access.all_values }, presence: true
Douwe Maan committed
19 20 21 22
  validates :invite_email,
    presence: {
      if: :invite?
    },
23
    email: {
Douwe Maan committed
24 25 26 27 28 29
      allow_nil: true
    },
    uniqueness: {
      scope: [:source_type, :source_id],
      allow_nil: true
    }
30

31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46
  # This scope encapsulates (most of) the conditions a row in the member table
  # must satisfy if it is a valid permission. Of particular note:
  #
  #   * Access requests must be excluded
  #   * Blocked users must be excluded
  #   * Invitations take effect immediately
  #   * expires_at is not implemented. A background worker purges expired rows
  scope :active, -> do
    is_external_invite = arel_table[:user_id].eq(nil).and(arel_table[:invite_token].not_eq(nil))
    user_is_active = User.arel_table[:state].eq(:active)

    includes(:user).references(:users)
      .where(is_external_invite.or(user_is_active))
      .where(requested_at: nil)
  end

47
  scope :invite, -> { where.not(invite_token: nil) }
48
  scope :non_invite, -> { where(invite_token: nil) }
49
  scope :request, -> { where.not(requested_at: nil) }
50 51 52 53 54 55 56 57 58

  scope :has_access, -> { active.where('access_level > 0') }

  scope :guests, -> { active.where(access_level: GUEST) }
  scope :reporters, -> { active.where(access_level: REPORTER) }
  scope :developers, -> { active.where(access_level: DEVELOPER) }
  scope :masters,  -> { active.where(access_level: MASTER) }
  scope :owners,  -> { active.where(access_level: OWNER) }
  scope :owners_and_masters,  -> { active.where(access_level: [OWNER, MASTER]) }
59

60
  before_validation :generate_invite_token, on: :create, if: -> (member) { member.invite_email.present? }
61

62
  after_create :send_invite, if: :invite?, unless: :importing?
James Lopez committed
63 64 65 66
  after_create :send_request, if: :request?, unless: :importing?
  after_create :create_notification_setting, unless: [:pending?, :importing?]
  after_create :post_create_hook, unless: [:pending?, :importing?]
  after_update :post_update_hook, unless: [:pending?, :importing?]
67
  after_destroy :post_destroy_hook, unless: :pending?
68

69
  delegate :name, :username, :email, to: :user, prefix: true
70

71 72
  default_value_for :notification_level, NotificationSetting.levels[:global]

73
  class << self
Stan Hu committed
74
    def access_for_user_ids(user_ids)
Adam Niedzielski committed
75
      where(user_id: user_ids).has_access.pluck(:user_id, :access_level).to_h
Stan Hu committed
76 77
    end

78 79 80 81 82
    def find_by_invite_token(invite_token)
      invite_token = Devise.token_generator.digest(self, :invite_token, invite_token)
      find_by(invite_token: invite_token)
    end

83 84 85
    def add_user(source, user, access_level, current_user: nil, expires_at: nil)
      user = retrieve_user(user)
      access_level = retrieve_access_level(access_level)
86

87
      # `user` can be either a User object or an email to be invited
88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105
      member =
        if user.is_a?(User)
          source.members.find_by(user_id: user.id) ||
          source.requesters.find_by(user_id: user.id) ||
          source.members.build(user_id: user.id)
        else
          source.members.build(invite_email: user)
        end

      return member unless can_update_member?(current_user, member)

      member.attributes = {
        created_by: member.created_by || current_user,
        access_level: access_level,
        expires_at: expires_at
      }

      if member.request?
106 107 108 109 110 111
        ::Members::ApproveAccessRequestService.new(
          source,
          current_user,
          id: member.id,
          access_level: access_level
        ).execute
112
      else
113
        member.save
114
      end
115

116 117
      member
    end
118

119 120
    def access_levels
      Gitlab::Access.sym_options
121
    end
122 123 124

    private

125 126 127 128 129 130 131 132 133 134 135 136
    # This method is used to find users that have been entered into the "Add members" field.
    # These can be the User objects directly, their IDs, their emails, or new emails to be invited.
    def retrieve_user(user)
      return user if user.is_a?(User)

      User.find_by(id: user) || User.find_by(email: user) || user
    end

    def retrieve_access_level(access_level)
      access_levels.fetch(access_level) { access_level.to_i }
    end

137
    def can_update_member?(current_user, member)
Douwe Maan committed
138
      # There is no current user for bulk actions, in which case anything is allowed
139
      !current_user || current_user.can?(:"update_#{member.type.underscore}", member)
140
    end
141

142 143 144 145 146 147 148 149 150 151
    def add_users_to_source(source, users, access_level, current_user: nil, expires_at: nil)
      users.each do |user|
        add_user(
          source,
          user,
          access_level,
          current_user: current_user,
          expires_at: expires_at
        )
      end
152
    end
Douwe Maan committed
153 154
  end

155 156 157 158
  def real_source_type
    source_type
  end

159 160 161 162
  def invite?
    self.invite_token.present?
  end

163
  def request?
164
    requested_at.present?
165 166
  end

167 168
  def pending?
    invite? || request?
169 170
  end

171
  def accept_request
172 173
    return false unless request?

174
    updated = self.update(requested_at: nil)
175
    after_accept_request if updated
176

177
    updated
178 179
  end

180
  def accept_invite!(new_user)
Douwe Maan committed
181
    return false unless invite?
182

183 184 185 186 187 188 189 190 191 192 193 194
    self.invite_token = nil
    self.invite_accepted_at = Time.now.utc

    self.user = new_user

    saved = self.save

    after_accept_invite if saved

    saved
  end

Douwe Maan committed
195 196 197 198 199 200 201 202 203 204
  def decline_invite!
    return false unless invite?

    destroyed = self.destroy

    after_decline_invite if destroyed

    destroyed
  end

205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222
  def generate_invite_token
    raw, enc = Devise.token_generator.generate(self.class, :invite_token)
    @raw_invite_token = raw
    self.invite_token = enc
  end

  def generate_invite_token!
    generate_invite_token && save(validate: false)
  end

  def resend_invite
    return unless invite?

    generate_invite_token! unless @raw_invite_token

    send_invite
  end

223
  def create_notification_setting
224
    user.notification_settings.find_or_create_for(source)
225 226
  end

227
  def notification_setting
228
    @notification_setting ||= user.notification_settings_for(source)
229 230
  end

231 232 233 234 235 236
  private

  def send_invite
    # override in subclass
  end

237
  def send_request
238
    notification_service.new_access_request(self)
239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256
  end

  def post_create_hook
    system_hook_service.execute_hooks_for(self, :create)
  end

  def post_update_hook
    # override in subclass
  end

  def post_destroy_hook
    system_hook_service.execute_hooks_for(self, :destroy)
  end

  def after_accept_invite
    post_create_hook
  end

Douwe Maan committed
257 258 259 260
  def after_decline_invite
    # override in subclass
  end

261
  def after_accept_request
262 263 264 265 266 267 268 269 270 271
    post_create_hook
  end

  def system_hook_service
    SystemHooksService.new
  end

  def notification_service
    NotificationService.new
  end
272
end