418 lines
10 KiB
Ruby
418 lines
10 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Event < ApplicationRecord
|
|
include Sortable
|
|
include FromUnion
|
|
include Presentable
|
|
include DeleteWithLimit
|
|
include CreatedAtFilterable
|
|
include Gitlab::Utils::StrongMemoize
|
|
|
|
default_scope { reorder(nil) }
|
|
|
|
ACTIONS = HashWithIndifferentAccess.new(
|
|
created: 1,
|
|
updated: 2,
|
|
closed: 3,
|
|
reopened: 4,
|
|
pushed: 5,
|
|
commented: 6,
|
|
merged: 7,
|
|
joined: 8, # User joined project
|
|
left: 9, # User left project
|
|
destroyed: 10,
|
|
expired: 11, # User left project due to expiry
|
|
approved: 12
|
|
).freeze
|
|
|
|
private_constant :ACTIONS
|
|
|
|
WIKI_ACTIONS = [:created, :updated, :destroyed].freeze
|
|
|
|
TARGET_TYPES = HashWithIndifferentAccess.new(
|
|
issue: Issue,
|
|
milestone: Milestone,
|
|
merge_request: MergeRequest,
|
|
note: Note,
|
|
project: Project,
|
|
snippet: Snippet,
|
|
user: User,
|
|
wiki: WikiPage::Meta
|
|
).freeze
|
|
|
|
RESET_PROJECT_ACTIVITY_INTERVAL = 1.hour
|
|
REPOSITORY_UPDATED_AT_INTERVAL = 5.minutes
|
|
|
|
enum action: ACTIONS, _suffix: true
|
|
|
|
delegate :name, :email, :public_email, :username, to: :author, prefix: true, allow_nil: true
|
|
delegate :title, to: :issue, prefix: true, allow_nil: true
|
|
delegate :title, to: :merge_request, prefix: true, allow_nil: true
|
|
delegate :title, to: :note, prefix: true, allow_nil: true
|
|
|
|
belongs_to :author, class_name: "User"
|
|
belongs_to :project
|
|
belongs_to :group
|
|
|
|
belongs_to :target, -> {
|
|
# If the association for "target" defines an "author" association we want to
|
|
# eager-load this so Banzai & friends don't end up performing N+1 queries to
|
|
# get the authors of notes, issues, etc. (likewise for "noteable").
|
|
incs = %i(author noteable).select do |a|
|
|
reflections['events'].active_record.reflect_on_association(a)
|
|
end
|
|
|
|
incs.reduce(self) { |obj, a| obj.includes(a) }
|
|
}, polymorphic: true # rubocop:disable Cop/PolymorphicAssociations
|
|
|
|
has_one :push_event_payload
|
|
|
|
# Callbacks
|
|
after_create :reset_project_activity
|
|
after_create :set_last_repository_updated_at, if: :push_action?
|
|
after_create :track_user_interacted_projects
|
|
|
|
# Scopes
|
|
scope :recent, -> { reorder(id: :desc) }
|
|
scope :for_wiki_page, -> { where(target_type: 'WikiPage::Meta') }
|
|
|
|
# Needed to implement feature flag: can be removed when feature flag is removed
|
|
scope :not_wiki_page, -> { where('target_type IS NULL or target_type <> ?', 'WikiPage::Meta') }
|
|
|
|
scope :with_associations, -> do
|
|
# We're using preload for "push_event_payload" as otherwise the association
|
|
# is not always available (depending on the query being built).
|
|
includes(:author, :project, project: [:project_feature, :import_data, :namespace])
|
|
.preload(:target, :push_event_payload)
|
|
end
|
|
|
|
scope :for_milestone_id, ->(milestone_id) { where(target_type: "Milestone", target_id: milestone_id) }
|
|
scope :for_wiki_meta, ->(meta) { where(target_type: 'WikiPage::Meta', target_id: meta.id) }
|
|
scope :created_at, ->(time) { where(created_at: time) }
|
|
|
|
# Authors are required as they're used to display who pushed data.
|
|
#
|
|
# We're just validating the presence of the ID here as foreign key constraints
|
|
# should ensure the ID points to a valid user.
|
|
validates :author_id, presence: true
|
|
|
|
self.inheritance_column = 'action'
|
|
|
|
class << self
|
|
def model_name
|
|
ActiveModel::Name.new(self, nil, 'event')
|
|
end
|
|
|
|
def find_sti_class(action)
|
|
if actions.fetch(action, action) == actions[:pushed] # action can be integer or symbol
|
|
PushEvent
|
|
else
|
|
Event
|
|
end
|
|
end
|
|
|
|
# Update Gitlab::ContributionsCalendar#activity_dates if this changes
|
|
def contributions
|
|
where("action = ? OR (target_type IN (?) AND action IN (?)) OR (target_type = ? AND action = ?)",
|
|
actions[:pushed],
|
|
%w(MergeRequest Issue), [actions[:created], actions[:closed], actions[:merged]],
|
|
"Note", actions[:commented])
|
|
end
|
|
|
|
def limit_recent(limit = 20, offset = nil)
|
|
recent.limit(limit).offset(offset)
|
|
end
|
|
|
|
def target_types
|
|
TARGET_TYPES.keys
|
|
end
|
|
end
|
|
|
|
def present
|
|
super(presenter_class: ::EventPresenter)
|
|
end
|
|
|
|
def visible_to_user?(user = nil)
|
|
return false unless capability.present?
|
|
|
|
Ability.allowed?(user, capability, permission_object)
|
|
end
|
|
|
|
def resource_parent
|
|
project || group
|
|
end
|
|
|
|
def target_title
|
|
target.try(:title)
|
|
end
|
|
|
|
def push_action?
|
|
false
|
|
end
|
|
|
|
def membership_changed?
|
|
joined_action? || left_action? || expired_action?
|
|
end
|
|
|
|
def created_project_action?
|
|
created_action? && !target && target_type.nil?
|
|
end
|
|
|
|
def created_wiki_page?
|
|
wiki_page? && created_action?
|
|
end
|
|
|
|
def updated_wiki_page?
|
|
wiki_page? && updated_action?
|
|
end
|
|
|
|
def created_target?
|
|
created_action? && target
|
|
end
|
|
|
|
def milestone?
|
|
target_type == "Milestone"
|
|
end
|
|
|
|
def note?
|
|
target.is_a?(Note)
|
|
end
|
|
|
|
def issue?
|
|
target_type == "Issue"
|
|
end
|
|
|
|
def merge_request?
|
|
target_type == "MergeRequest"
|
|
end
|
|
|
|
def wiki_page?
|
|
target_type == 'WikiPage::Meta'
|
|
end
|
|
|
|
def milestone
|
|
target if milestone?
|
|
end
|
|
|
|
def issue
|
|
target if issue?
|
|
end
|
|
|
|
def merge_request
|
|
target if merge_request?
|
|
end
|
|
|
|
def wiki_page
|
|
strong_memoize(:wiki_page) do
|
|
next unless wiki_page?
|
|
|
|
ProjectWiki.new(project, author).find_page(target.canonical_slug)
|
|
end
|
|
end
|
|
|
|
def note
|
|
target if note?
|
|
end
|
|
|
|
def action_name
|
|
if push_action?
|
|
push_action_name
|
|
elsif closed_action?
|
|
"closed"
|
|
elsif merged_action?
|
|
"accepted"
|
|
elsif joined_action?
|
|
'joined'
|
|
elsif left_action?
|
|
'left'
|
|
elsif expired_action?
|
|
'removed due to membership expiration from'
|
|
elsif destroyed_action?
|
|
'destroyed'
|
|
elsif commented_action?
|
|
"commented on"
|
|
elsif created_wiki_page?
|
|
'created'
|
|
elsif updated_wiki_page?
|
|
'updated'
|
|
elsif created_project_action?
|
|
created_project_action_name
|
|
else
|
|
"opened"
|
|
end
|
|
end
|
|
|
|
def target_iid
|
|
target.respond_to?(:iid) ? target.iid : target_id
|
|
end
|
|
|
|
def commit_note?
|
|
note? && target && target.for_commit?
|
|
end
|
|
|
|
def issue_note?
|
|
note? && target && target.for_issue?
|
|
end
|
|
|
|
def merge_request_note?
|
|
note? && target && target.for_merge_request?
|
|
end
|
|
|
|
def project_snippet_note?
|
|
note? && target && target.for_snippet?
|
|
end
|
|
|
|
def personal_snippet_note?
|
|
note? && target && target.for_personal_snippet?
|
|
end
|
|
|
|
def design_note?
|
|
note? && note.for_design?
|
|
end
|
|
|
|
def note_target
|
|
target.noteable
|
|
end
|
|
|
|
def note_target_id
|
|
if commit_note?
|
|
target.commit_id
|
|
else
|
|
target.noteable_id.to_s
|
|
end
|
|
end
|
|
|
|
def note_target_reference
|
|
return unless note_target
|
|
|
|
# Commit#to_reference returns the full SHA, but we want the short one here
|
|
if commit_note?
|
|
note_target.short_id
|
|
else
|
|
note_target.to_reference
|
|
end
|
|
end
|
|
|
|
def note_target_type
|
|
if target.noteable_type.present?
|
|
target.noteable_type.titleize
|
|
else
|
|
"Wall"
|
|
end.downcase
|
|
end
|
|
|
|
def body?
|
|
if push_action?
|
|
push_with_commits?
|
|
elsif note?
|
|
true
|
|
else
|
|
target.respond_to? :title
|
|
end
|
|
end
|
|
|
|
def reset_project_activity
|
|
return unless project
|
|
|
|
# Don't bother updating if we know the project was updated recently.
|
|
return if recent_update?
|
|
|
|
# At this point it's possible for multiple threads/processes to try to
|
|
# update the project. Only one query should actually perform the update,
|
|
# hence we add the extra WHERE clause for last_activity_at.
|
|
Project.unscoped.where(id: project_id)
|
|
.where('last_activity_at <= ?', RESET_PROJECT_ACTIVITY_INTERVAL.ago)
|
|
.update_all(last_activity_at: created_at)
|
|
end
|
|
|
|
def authored_by?(user)
|
|
user ? author_id == user.id : false
|
|
end
|
|
|
|
def to_partial_path
|
|
# We are intentionally using `Event` rather than `self.class` so that
|
|
# subclasses also use the `Event` implementation.
|
|
Event._to_partial_path
|
|
end
|
|
|
|
protected
|
|
|
|
# rubocop:disable Metrics/CyclomaticComplexity
|
|
# rubocop:disable Metrics/PerceivedComplexity
|
|
#
|
|
# TODO Refactor this method so we no longer need to disable the above cops
|
|
# https://gitlab.com/gitlab-org/gitlab/-/issues/216879.
|
|
def capability
|
|
@capability ||= begin
|
|
if push_action? || commit_note?
|
|
:download_code
|
|
elsif membership_changed? || created_project_action?
|
|
:read_project
|
|
elsif issue? || issue_note?
|
|
:read_issue
|
|
elsif merge_request? || merge_request_note?
|
|
:read_merge_request
|
|
elsif personal_snippet_note? || project_snippet_note?
|
|
:read_snippet
|
|
elsif milestone?
|
|
:read_milestone
|
|
elsif wiki_page?
|
|
:read_wiki
|
|
elsif design_note?
|
|
:read_design
|
|
end
|
|
end
|
|
end
|
|
# rubocop:enable Metrics/CyclomaticComplexity
|
|
# rubocop:enable Metrics/PerceivedComplexity
|
|
|
|
private
|
|
|
|
def permission_object
|
|
if note?
|
|
note_target
|
|
elsif target_id.present?
|
|
target
|
|
else
|
|
project
|
|
end
|
|
end
|
|
|
|
def push_action_name
|
|
if new_ref?
|
|
"pushed new"
|
|
elsif rm_ref?
|
|
"deleted"
|
|
else
|
|
"pushed to"
|
|
end
|
|
end
|
|
|
|
def created_project_action_name
|
|
if project.external_import?
|
|
"imported"
|
|
else
|
|
"created"
|
|
end
|
|
end
|
|
|
|
def recent_update?
|
|
project.last_activity_at > RESET_PROJECT_ACTIVITY_INTERVAL.ago
|
|
end
|
|
|
|
def set_last_repository_updated_at
|
|
Project.unscoped.where(id: project_id)
|
|
.where("last_repository_updated_at < ? OR last_repository_updated_at IS NULL", REPOSITORY_UPDATED_AT_INTERVAL.ago)
|
|
.update_all(last_repository_updated_at: created_at)
|
|
end
|
|
|
|
def track_user_interacted_projects
|
|
# Note the call to .available? is due to earlier migrations
|
|
# that would otherwise conflict with the call to .track
|
|
# (because the table does not exist yet).
|
|
UserInteractedProject.track(self) if UserInteractedProject.available?
|
|
end
|
|
end
|
|
|
|
Event.prepend_if_ee('EE::Event')
|