issuable_base_service.rb 4.4 KB
Newer Older
1 2 3 4
class IssuableBaseService < BaseService
  private

  def create_assignee_note(issuable)
5
    SystemNoteService.change_assignee(
6 7 8 9
      issuable, issuable.project, current_user, issuable.assignee)
  end

  def create_milestone_note(issuable)
10
    SystemNoteService.change_milestone(
11 12
      issuable, issuable.project, current_user, issuable.milestone)
  end
N
Nikita Verkhovin 已提交
13

14 15 16 17
  def create_labels_note(issuable, old_labels)
    added_labels = issuable.labels - old_labels
    removed_labels = old_labels - issuable.labels

18
    SystemNoteService.change_label(
N
Nikita Verkhovin 已提交
19 20
      issuable, issuable.project, current_user, added_labels, removed_labels)
  end
21 22 23 24 25

  def create_title_change_note(issuable, old_title)
    SystemNoteService.change_title(
      issuable, issuable.project, current_user, old_title)
  end
26 27 28 29 30 31

  def create_branch_change_note(issuable, branch_type, old_branch, new_branch)
    SystemNoteService.change_branch(
      issuable, issuable.project, current_user, branch_type,
      old_branch, new_branch)
  end
32

33 34 35 36 37 38
  def create_task_status_note(issuable)
    issuable.updated_tasks.each do |task|
      SystemNoteService.change_task_status(issuable, issuable.project, current_user, task)
    end
  end

39
  def filter_params(issuable_ability_name = :issue)
40 41 42
    filter_assignee
    filter_milestone
    filter_labels
43

44 45 46
    ability = :"admin_#{issuable_ability_name}"

    unless can?(current_user, ability, project)
47
      params.delete(:milestone_id)
48 49
      params.delete(:add_label_ids)
      params.delete(:remove_label_ids)
50 51 52 53
      params.delete(:label_ids)
      params.delete(:assignee_id)
    end
  end
54

55 56 57 58 59 60 61
  def filter_assignee
    if params[:assignee_id] == IssuableFinder::NONE
      params[:assignee_id] = ''
    end
  end

  def filter_milestone
62 63
    milestone_id = params[:milestone_id]
    return unless milestone_id
64

65 66
    if milestone_id == IssuableFinder::NONE ||
        project.milestones.find_by(id: milestone_id).nil?
67 68 69 70 71
      params[:milestone_id] = ''
    end
  end

  def filter_labels
72 73 74
    if params[:add_label_ids].present? || params[:remove_label_ids].present?
      params.delete(:label_ids)

75 76
      filter_labels_in_param(:add_label_ids)
      filter_labels_in_param(:remove_label_ids)
77
    else
78
      filter_labels_in_param(:label_ids)
79 80 81
    end
  end

82 83
  def filter_labels_in_param(key)
    return if params[key].to_a.empty?
84

85
    params[key] = project.labels.where(id: params[key]).pluck(:id)
86 87 88 89 90 91
  end

  def update_issuable(issuable, attributes)
    issuable.with_transaction_returning_status do
      add_label_ids = attributes.delete(:add_label_ids)
      remove_label_ids = attributes.delete(:remove_label_ids)
92

93 94 95
      issuable.label_ids |= add_label_ids if add_label_ids
      issuable.label_ids -= remove_label_ids if remove_label_ids

96
      issuable.assign_attributes(attributes.merge(updated_by: current_user))
97 98 99

      issuable.save
    end
100 101
  end

102 103
  def update(issuable)
    change_state(issuable)
104
    change_subscription(issuable)
105 106 107
    filter_params
    old_labels = issuable.labels.to_a

108
    if params.present? && update_issuable(issuable, params)
109
      issuable.reset_events_cache
110
      handle_common_system_notes(issuable, old_labels: old_labels)
111
      handle_changes(issuable, old_labels: old_labels)
112 113 114 115 116 117 118 119 120 121 122 123 124 125 126
      issuable.create_new_cross_references!(current_user)
      execute_hooks(issuable, 'update')
    end

    issuable
  end

  def change_state(issuable)
    case params.delete(:state_event)
    when 'reopen'
      reopen_service.new(project, current_user, {}).execute(issuable)
    when 'close'
      close_service.new(project, current_user, {}).execute(issuable)
    end
  end
127

128 129 130 131 132 133 134 135 136
  def change_subscription(issuable)
    case params.delete(:subscription_event)
    when 'subscribe'
      issuable.subscribe(current_user)
    when 'unsubscribe'
      issuable.unsubscribe(current_user)
    end
  end

137
  def has_changes?(issuable, old_labels: [])
138 139 140 141 142 143
    valid_attrs = [:title, :description, :assignee_id, :milestone_id, :target_branch]

    attrs_changed = valid_attrs.any? do |attr|
      issuable.previous_changes.include?(attr.to_s)
    end

144
    labels_changed = issuable.labels != old_labels
145 146 147 148

    attrs_changed || labels_changed
  end

149
  def handle_common_system_notes(issuable, old_labels: [])
150 151 152 153 154 155 156
    if issuable.previous_changes.include?('title')
      create_title_change_note(issuable, issuable.previous_changes['title'].first)
    end

    if issuable.previous_changes.include?('description') && issuable.tasks?
      create_task_status_note(issuable)
    end
157

158
    create_labels_note(issuable, old_labels) if issuable.labels != old_labels
159
  end
160
end