Adds attention request count to navigation dropdown

Updates the merge request navigation count to use the
attention requests count.

Closes https://gitlab.com/gitlab-org/gitlab/-/issues/343328/

app/assets/javascripts/commons/nav/user_merge_requests.js

@@ -23,7 +23,18 @@ function updateReviewerMergeRequestCounts(newCount) {
 function updateMergeRequestCounts(newCount) {
   const mergeRequestsCountEl = document.querySelector('.js-merge-requests-count');
   mergeRequestsCountEl.textContent = newCount.toLocaleString();
-  mergeRequestsCountEl.classList.toggle('hidden', Number(newCount) === 0);
+  mergeRequestsCountEl.classList.toggle('gl-display-none', Number(newCount) === 0);
+}
+
+function updateAttentionRequestsCount(count) {
+  const attentionCountEl = document.querySelector('.js-attention-count');
+  attentionCountEl.textContent = count.toLocaleString();
+
+  if (Number(count) === 0) {
+    attentionCountEl.classList.replace('badge-warning', 'badge-neutral');
+  } else {
+    attentionCountEl.classList.replace('badge-neutral', 'badge-warning');
+  }
 }
 
 /**
@@ -32,14 +43,22 @@ function updateMergeRequestCounts(newCount) {
 export function refreshUserMergeRequestCounts() {
   return getUserCounts()
     .then(({ data }) => {
+      const attentionRequestsEnabled = window.gon?.features?.mrAttentionRequests;
       const assignedMergeRequests = data.assigned_merge_requests;
       const reviewerMergeRequests = data.review_requested_merge_requests;
-      const fullCount = assignedMergeRequests + reviewerMergeRequests;
+      const attentionRequests = data.attention_requests;
+      const fullCount = attentionRequestsEnabled
+        ? attentionRequests
+        : assignedMergeRequests + reviewerMergeRequests;
 
       updateUserMergeRequestCounts(assignedMergeRequests);
       updateReviewerMergeRequestCounts(reviewerMergeRequests);
       updateMergeRequestCounts(fullCount);
       broadcastCount(fullCount);
+
+      if (attentionRequestsEnabled) {
+        updateAttentionRequestsCount(attentionRequests);
+      }
     })
     .catch((ex) => {
       console.error(ex); // eslint-disable-line no-console

app/assets/javascripts/sidebar/mount_sidebar.js

@@ -27,6 +27,7 @@ import { DropdownVariant } from '~/vue_shared/components/sidebar/labels_select_v
 import LabelsSelectWidget from '~/vue_shared/components/sidebar/labels_select_widget/labels_select_root.vue';
 import { LabelType } from '~/vue_shared/components/sidebar/labels_select_widget/constants';
 import eventHub from '~/sidebar/event_hub';
+import { refreshUserMergeRequestCounts } from '~/commons/nav/user_merge_requests';
 import Translate from '../vue_shared/translate';
 import SidebarAssignees from './components/assignees/sidebar_assignees.vue';
 import CopyEmailToClipboard from './components/copy_email_to_clipboard.vue';
@@ -619,9 +620,10 @@ export function mountSidebar(mediator, store) {
   mountSeverityComponent();
 
   if (window.gon?.features?.mrAttentionRequests) {
-    eventHub.$on('removeCurrentUserAttentionRequested', () =>
-      mediator.removeCurrentUserAttentionRequested(),
-    );
+    eventHub.$on('removeCurrentUserAttentionRequested', () => {
+      mediator.removeCurrentUserAttentionRequested();
+      refreshUserMergeRequestCounts();
+    });
   }
 }
 

app/assets/javascripts/sidebar/sidebar_mediator.js

@@ -2,6 +2,7 @@ import Store from '~/sidebar/stores/sidebar_store';
 import createFlash from '~/flash';
 import { __, sprintf } from '~/locale';
 import toast from '~/vue_shared/plugins/global_toast';
+import { refreshUserMergeRequestCounts } from '~/commons/nav/user_merge_requests';
 import { visitUrl } from '../lib/utils/url_utility';
 import Service from './services/sidebar_service';
 
@@ -125,6 +126,7 @@ export default class SidebarMediator {
       this.store.updateReviewer(user.id, 'attention_requested');
       this.store.updateAssignee(user.id, 'attention_requested');
 
+      refreshUserMergeRequestCounts();
       callback();
     } catch (error) {
       callback();

app/helpers/dashboard_helper.rb

@@ -15,6 +15,10 @@ module DashboardHelper
     merge_requests_dashboard_path(reviewer_username: current_user.username)
   end
 
+  def attention_requested_mrs_dashboard_path
+    merge_requests_dashboard_path(attention: current_user.username)
+  end
+
   def dashboard_nav_links
     @dashboard_nav_links ||= get_dashboard_nav_links
   end

app/helpers/merge_requests_helper.rb

@@ -150,11 +150,20 @@ module MergeRequestsHelper
       review_requested_count = review_requested_merge_requests_count
       total_count = assigned_count + review_requested_count
 
-      {
+      counts = {
         assigned: assigned_count,
         review_requested: review_requested_count,
         total: total_count
       }
+
+      if Feature.enabled?(:mr_attention_requests, default_enabled: :yaml)
+        attention_requested_count = attention_requested_merge_requests_count
+
+        counts[:attention_requested_count] = attention_requested_count
+        counts[:total] = attention_requested_count
+      end
+
+      counts
     end
   end
 
@@ -205,6 +214,10 @@ module MergeRequestsHelper
     current_user.review_requested_open_merge_requests_count
   end
 
+  def attention_requested_merge_requests_count
+    current_user.attention_requested_open_merge_requests_count
+  end
+
   def default_suggestion_commit_message
     @project.suggestion_commit_message.presence || Gitlab::Suggestions::CommitMessage::DEFAULT_SUGGESTION_COMMIT_MESSAGE
   end

app/models/user.rb

@@ -1692,6 +1692,12 @@ class User < ApplicationRecord
     end
   end
 
+  def attention_requested_open_merge_requests_count(force: false)
+    Rails.cache.fetch(attention_request_cache_key, force: force, expires_in: COUNT_CACHE_VALIDITY_PERIOD) do
+      MergeRequestsFinder.new(self, attention: self.username, state: 'opened', non_archived: true).execute.count
+    end
+  end
+
   def assigned_open_issues_count(force: false)
     Rails.cache.fetch(['users', id, 'assigned_open_issues_count'], force: force, expires_in: COUNT_CACHE_VALIDITY_PERIOD) do
       IssuesFinder.new(self, assignee_id: self.id, state: 'opened', non_archived: true).execute.count
@@ -1735,6 +1741,11 @@ class User < ApplicationRecord
   def invalidate_merge_request_cache_counts
     Rails.cache.delete(['users', id, 'assigned_open_merge_requests_count'])
     Rails.cache.delete(['users', id, 'review_requested_open_merge_requests_count'])
+    invalidate_attention_requested_count
+  end
+
+  def invalidate_attention_requested_count
+    Rails.cache.delete(attention_request_cache_key)
   end
 
   def invalidate_todos_cache_counts
@@ -1746,6 +1757,10 @@ class User < ApplicationRecord
     Rails.cache.delete(['users', id, 'personal_projects_count'])
   end
 
+  def attention_request_cache_key
+    ['users', id, 'attention_requested_open_merge_requests_count']
+  end
+
   # This is copied from Devise::Models::Lockable#valid_for_authentication?, as our auth
   # flow means we don't call that automatically (and can't conveniently do so).
   #

app/services/merge_requests/approval_service.rb

@@ -14,7 +14,7 @@ module MergeRequests
       create_approval_note(merge_request)
       mark_pending_todos_as_done(merge_request)
       execute_approval_hooks(merge_request, current_user)
-      remove_attention_requested(merge_request, current_user)
+      remove_attention_requested(merge_request)
       merge_request_activity_counter.track_approve_mr_action(user: current_user)
 
       success

app/services/merge_requests/base_service.rb

@@ -60,7 +60,7 @@ module MergeRequests
       merge_request_activity_counter.track_reviewers_changed_action(user: current_user)
 
       unless new_reviewers.include?(current_user)
-        remove_attention_requested(merge_request, current_user)
+        remove_attention_requested(merge_request)
 
         merge_request.merge_request_reviewers_with(new_reviewers).update_all(updated_state_by_user_id: current_user.id)
       end
@@ -253,10 +253,10 @@ module MergeRequests
       ::MergeRequests::BulkRemoveAttentionRequestedService.new(project: merge_request.project, current_user: current_user, merge_request: merge_request, users: users.uniq).execute
     end
 
-    def remove_attention_requested(merge_request, user)
+    def remove_attention_requested(merge_request)
       return unless merge_request.attention_requested_enabled?
 
-      ::MergeRequests::RemoveAttentionRequestedService.new(project: merge_request.project, current_user: current_user, merge_request: merge_request, user: user).execute
+      ::MergeRequests::RemoveAttentionRequestedService.new(project: merge_request.project, current_user: current_user, merge_request: merge_request).execute
     end
   end
 end

app/services/merge_requests/bulk_remove_attention_requested_service.rb

@@ -19,6 +19,8 @@ module MergeRequests
       merge_request.merge_request_assignees.where(user_id: users).update_all(state: :reviewed)
       merge_request.merge_request_reviewers.where(user_id: users).update_all(state: :reviewed)
 
+      users.each { |user| user.invalidate_attention_requested_count }
+
       success
     end
     # rubocop: enable CodeReuse/ActiveRecord

app/services/merge_requests/handle_assignees_change_service.rb

@@ -26,7 +26,7 @@ module MergeRequests
       execute_assignees_hooks(merge_request, old_assignees) if options[:execute_hooks]
 
       unless new_assignees.include?(current_user)
-        remove_attention_requested(merge_request, current_user)
+        remove_attention_requested(merge_request)
       end
     end
 

app/services/merge_requests/remove_approval_service.rb

@@ -17,7 +17,7 @@ module MergeRequests
         reset_approvals_cache(merge_request)
         create_note(merge_request)
         merge_request_activity_counter.track_unapprove_mr_action(user: current_user)
-        remove_attention_requested(merge_request, current_user)
+        remove_attention_requested(merge_request)
       end
 
       success

app/services/merge_requests/remove_attention_requested_service.rb

@@ -2,13 +2,12 @@
 
 module MergeRequests
   class RemoveAttentionRequestedService < MergeRequests::BaseService
-    attr_accessor :merge_request, :user
+    attr_accessor :merge_request
 
-    def initialize(project:, current_user:, merge_request:, user:)
+    def initialize(project:, current_user:, merge_request:)
       super(project: project, current_user: current_user)
 
       @merge_request = merge_request
-      @user = user
     end
 
     def execute
@@ -18,6 +17,8 @@ module MergeRequests
         update_state(reviewer)
         update_state(assignee)
 
+        current_user.invalidate_attention_requested_count
+
         success
       else
         error("User is not a reviewer or assignee of the merge request")
@@ -27,11 +28,11 @@ module MergeRequests
     private
 
     def assignee
-      merge_request.find_assignee(user)
+      merge_request.find_assignee(current_user)
     end
 
     def reviewer
-      merge_request.find_reviewer(user)
+      merge_request.find_reviewer(current_user)
     end
 
     def update_state(reviewer_or_assignee)

app/services/merge_requests/reopen_service.rb

@@ -6,6 +6,8 @@ module MergeRequests
       return merge_request unless can?(current_user, :reopen_merge_request, merge_request)
 
       if merge_request.reopen
+        users = merge_request.assignees | merge_request.reviewers
+
         create_event(merge_request)
         create_note(merge_request, 'reopened')
         merge_request_activity_counter.track_reopen_mr_action(user: current_user)
@@ -13,11 +15,13 @@ module MergeRequests
         execute_hooks(merge_request, 'reopen')
         merge_request.reload_diff(current_user)
         merge_request.mark_as_unchecked
-        invalidate_cache_counts(merge_request, users: merge_request.assignees | merge_request.reviewers)
+        invalidate_cache_counts(merge_request, users: users)
         merge_request.update_project_counter_caches
         merge_request.cache_merge_request_closes_issues!(current_user)
         merge_request.cleanup_schedule&.destroy
         merge_request.update_column(:merge_ref_sha, nil)
+
+        users.each { |user| user.invalidate_attention_requested_count }
       end
 
       merge_request

app/services/merge_requests/toggle_attention_requested_service.rb

@@ -18,12 +18,14 @@ module MergeRequests
         update_state(reviewer)
         update_state(assignee)
 
+        user.invalidate_attention_requested_count
+
         if reviewer&.attention_requested? || assignee&.attention_requested?
           create_attention_request_note
           notity_user
 
           if current_user.id != user.id
-            remove_attention_requested(merge_request, current_user)
+            remove_attention_requested(merge_request)
           end
         else
           create_remove_attention_request_note

app/views/layouts/header/_default.html.haml

@@ -68,7 +68,8 @@
                   = number_with_delimiter(issues_count)
           - if header_link?(:merge_requests)
             = nav_link(path: 'dashboard#merge_requests', html_options: { class: "user-counter dropdown" }) do
-              = link_to assigned_mrs_dashboard_path, class: 'dashboard-shortcuts-merge_requests', title: _('Merge requests'), aria: { label: _('Merge requests') },
+              - top_level_link = Feature.enabled?(:mr_attention_requests, default_enabled: :yaml) ? attention_requested_mrs_dashboard_path : assigned_mrs_dashboard_path
+              = link_to top_level_link, class: 'dashboard-shortcuts-merge_requests', title: _('Merge requests'), aria: { label: _('Merge requests') },
                 data: { qa_selector: 'merge_requests_shortcut_button',
                 toggle: "dropdown",
                 placement: 'bottom',
@@ -84,6 +85,12 @@
                 %ul
                   %li.dropdown-header
                     = _('Merge requests')
+                  - if Feature.enabled?(:mr_attention_requests, default_enabled: :yaml)
+                    %li
+                      = link_to attention_requested_mrs_dashboard_path, class: 'gl-display-flex! gl-align-items-center js-prefetch-document' do
+                        = _('Need your attention')
+                        = gl_badge_tag user_merge_requests_counts[:attention_requested_count], { size: :sm, variant: user_merge_requests_counts[:attention_requested_count] == 0 ? :neutral : :warning }, { class: 'merge-request-badge gl-ml-auto js-attention-count' }
+                    %li.divider
                   %li
                     = link_to assigned_mrs_dashboard_path, class: 'gl-display-flex! gl-align-items-center js-prefetch-document' do
                       = _('Assigned to you')

lib/api/user_counts.rb

@@ -11,13 +11,19 @@ module API
       get do
         unauthorized! unless current_user
 
-        {
+        counts = {
           merge_requests: current_user.assigned_open_merge_requests_count, # @deprecated
           assigned_issues: current_user.assigned_open_issues_count,
           assigned_merge_requests: current_user.assigned_open_merge_requests_count,
           review_requested_merge_requests: current_user.review_requested_open_merge_requests_count,
           todos: current_user.todos_pending_count
         }
+
+        if Feature.enabled?(:mr_attention_requests, default_enabled: :yaml)
+          counts[:attention_requests] = current_user.attention_requested_open_merge_requests_count
+        end
+
+        counts
       end
     end
   end

locale/gitlab.pot

@@ -24103,6 +24103,9 @@ msgstr ""
 msgid "Need help?"
 msgstr ""
 
+msgid "Need your attention"
+msgstr ""
+
 msgid "Needs"
 msgstr ""
 

spec/features/dashboard/issuables_counter_spec.rb

@@ -8,7 +8,10 @@ RSpec.describe 'Navigation bar counter', :use_clean_rails_memory_store_caching d
   let(:issue) { create(:issue, project: project) }
   let(:merge_request) { create(:merge_request, source_project: project) }
 
+  describe 'feature flag mr_attention_requests is disabled' do
     before do
+      stub_feature_flags(mr_attention_requests: false)
+
       issue.assignees = [user]
       merge_request.update!(assignees: [user])
       sign_in(user)
@@ -30,7 +33,7 @@ RSpec.describe 'Navigation bar counter', :use_clean_rails_memory_store_caching d
       end
     end
 
-  it 'reflects dashboard merge requests count' do
+    it 'reflects dashboard merge requests count', :js do
       visit merge_requests_path
 
       expect_counters('merge_requests', '1', n_("%d merge request", "%d merge requests", 1) % 1)
@@ -45,6 +48,30 @@ RSpec.describe 'Navigation bar counter', :use_clean_rails_memory_store_caching d
         expect_counters('merge_requests', '0', n_("%d merge request", "%d merge requests", 0) % 0)
       end
     end
+  end
+
+  describe 'feature flag mr_attention_requests is enabled' do
+    before do
+      merge_request.update!(assignees: [user])
+      sign_in(user)
+    end
+
+    it 'reflects dashboard merge requests count', :js do
+      visit merge_requests_attention_path
+
+      expect_counters('merge_requests', '1', n_("%d merge request", "%d merge requests", 1) % 1)
+
+      merge_request.find_assignee(user).update!(state: :reviewed)
+
+      user.invalidate_attention_requested_count
+
+      travel_to(3.minutes.from_now) do
+        visit merge_requests_attention_path
+
+        expect_counters('merge_requests', '0', n_("%d merge request", "%d merge requests", 0) % 0)
+      end
+    end
+  end
 
   def issues_path
     issues_dashboard_path(assignee_username: user.username)
@@ -54,14 +81,15 @@ RSpec.describe 'Navigation bar counter', :use_clean_rails_memory_store_caching d
     merge_requests_dashboard_path(assignee_username: user.username)
   end
 
+  def merge_requests_attention_path
+    merge_requests_dashboard_path(attention: user.username)
+  end
+
   def expect_counters(issuable_type, count, badge_label)
     dashboard_count = find('.gl-tabs-nav li a.active')
-    nav_count = find(".dashboard-shortcuts-#{issuable_type}")
 
     expect(dashboard_count).to have_content(count)
-    expect(nav_count).to have_content(count)
-    within("span[aria-label='#{badge_label}']") do
-      expect(page).to have_content(count)
-    end
+    expect(page).to have_css(".dashboard-shortcuts-#{issuable_type}", visible: :all, text: count)
+    expect(page).to have_css("span[aria-label='#{badge_label}']", visible: :all, text: count)
   end
 end

spec/frontend/sidebar/sidebar_mediator_spec.js

@@ -5,9 +5,11 @@ import SidebarService, { gqClient } from '~/sidebar/services/sidebar_service';
 import SidebarMediator from '~/sidebar/sidebar_mediator';
 import SidebarStore from '~/sidebar/stores/sidebar_store';
 import toast from '~/vue_shared/plugins/global_toast';
+import { refreshUserMergeRequestCounts } from '~/commons/nav/user_merge_requests';
 import Mock from './mock_data';
 
 jest.mock('~/vue_shared/plugins/global_toast');
+jest.mock('~/commons/nav/user_merge_requests');
 
 describe('Sidebar mediator', () => {
   const { mediator: mediatorMockData } = Mock;
@@ -137,6 +139,7 @@ describe('Sidebar mediator', () => {
       });
 
       expect(attentionRequiredService).toHaveBeenCalledWith(1);
+      expect(refreshUserMergeRequestCounts).toHaveBeenCalled();
     });
 
     it.each`

spec/helpers/merge_requests_helper_spec.rb

@@ -72,7 +72,8 @@ RSpec.describe MergeRequestsHelper do
     let(:user) do
       double(
         assigned_open_merge_requests_count: 1,
-        review_requested_open_merge_requests_count: 2
+        review_requested_open_merge_requests_count: 2,
+        attention_requested_open_merge_requests_count: 3
       )
     end
 
@@ -82,6 +83,11 @@ RSpec.describe MergeRequestsHelper do
       allow(helper).to receive(:current_user).and_return(user)
     end
 
+    describe 'mr_attention_requests disabled' do
+      before do
+        stub_feature_flags(mr_attention_requests: false)
+      end
+
       it "returns assigned, review requested and total merge request counts" do
         expect(subject).to eq(
           assigned: user.assigned_open_merge_requests_count,
@@ -91,6 +97,18 @@ RSpec.describe MergeRequestsHelper do
       end
     end
 
+    describe 'mr_attention_requests enabled' do
+      it "returns assigned, review requested, attention requests and total merge request counts" do
+        expect(subject).to eq(
+          assigned: user.assigned_open_merge_requests_count,
+          review_requested: user.review_requested_open_merge_requests_count,
+          attention_requested_count: user.attention_requested_open_merge_requests_count,
+          total: user.attention_requested_open_merge_requests_count
+        )
+      end
+    end
+  end
+
   describe '#reviewers_label' do
     let(:merge_request) { build_stubbed(:merge_request) }
     let(:reviewer1) { build_stubbed(:user, name: 'Jane Doe') }

spec/models/user_spec.rb

@@ -4712,6 +4712,7 @@ RSpec.describe User do
 
       expect(cache_mock).to receive(:delete).with(['users', user.id, 'assigned_open_merge_requests_count'])
       expect(cache_mock).to receive(:delete).with(['users', user.id, 'review_requested_open_merge_requests_count'])
+      expect(cache_mock).to receive(:delete).with(['users', user.id, 'attention_requested_open_merge_requests_count'])
 
       allow(Rails).to receive(:cache).and_return(cache_mock)
 
@@ -4719,6 +4720,20 @@ RSpec.describe User do
     end
   end
 
+  describe '#invalidate_attention_requested_count' do
+    let(:user) { build_stubbed(:user) }
+
+    it 'invalidates cache for issue counter' do
+      cache_mock = double
+
+      expect(cache_mock).to receive(:delete).with(['users', user.id, 'attention_requested_open_merge_requests_count'])
+
+      allow(Rails).to receive(:cache).and_return(cache_mock)
+
+      user.invalidate_attention_requested_count
+    end
+  end
+
   describe '#invalidate_personal_projects_count' do
     let(:user) { build_stubbed(:user) }
 
@@ -4805,6 +4820,20 @@ RSpec.describe User do
     end
   end
 
+  describe '#attention_requested_open_merge_requests_count' do
+    it 'returns number of open merge requests from non-archived projects' do
+      user    = create(:user)
+      project = create(:project, :public)
+      archived_project = create(:project, :public, :archived)
+
+      create(:merge_request, source_project: project, author: user, reviewers: [user])
+      create(:merge_request, :closed, source_project: project, author: user, reviewers: [user])
+      create(:merge_request, source_project: archived_project, author: user, reviewers: [user])
+
+      expect(user.attention_requested_open_merge_requests_count(force: true)).to eq 1
+    end
+  end
+
   describe '#assigned_open_issues_count' do
     it 'returns number of open issues from non-archived projects' do
       user    = create(:user)

spec/requests/api/user_counts_spec.rb

@@ -43,6 +43,21 @@ RSpec.describe API::UserCounts do
           expect(response).to have_gitlab_http_status(:ok)
           expect(json_response).to be_a Hash
           expect(json_response['merge_requests']).to eq(2)
+          expect(json_response['attention_requests']).to eq(2)
+        end
+
+        describe 'mr_attention_requests is disabled' do
+          before do
+            stub_feature_flags(mr_attention_requests: false)
+          end
+
+          it 'does not include attention_requests count' do
+            create(:merge_request, source_project: project, author: user, assignees: [user])
+
+            get api('/user_counts', user)
+
+            expect(json_response.key?('attention_requests')).to be(false)
+          end
         end
       end
 

spec/services/merge_requests/approval_service_spec.rb

@@ -61,7 +61,7 @@ RSpec.describe MergeRequests::ApprovalService do
 
       it 'removes attention requested state' do
         expect(MergeRequests::RemoveAttentionRequestedService).to receive(:new)
-          .with(project: project, current_user: user, merge_request: merge_request, user: user)
+          .with(project: project, current_user: user, merge_request: merge_request)
           .and_call_original
 
         service.execute(merge_request)

spec/services/merge_requests/bulk_remove_attention_requested_service_spec.rb

@@ -40,6 +40,10 @@ RSpec.describe MergeRequests::BulkRemoveAttentionRequestedService do
         expect(reviewer.state).to eq 'reviewed'
         expect(assignee.state).to eq 'reviewed'
       end
+
+      it_behaves_like 'invalidates attention request cache' do
+        let(:users) { [assignee_user, user] }
+      end
     end
   end
 end

spec/services/merge_requests/handle_assignees_change_service_spec.rb

@@ -89,7 +89,7 @@ RSpec.describe MergeRequests::HandleAssigneesChangeService do
 
     it 'removes attention requested state' do
       expect(MergeRequests::RemoveAttentionRequestedService).to receive(:new)
-        .with(project: project, current_user: user, merge_request: merge_request, user: user)
+        .with(project: project, current_user: user, merge_request: merge_request)
         .and_call_original
 
       execute

spec/services/merge_requests/remove_attention_requested_service_spec.rb

@@ -4,23 +4,20 @@ require 'spec_helper'
 
 RSpec.describe MergeRequests::RemoveAttentionRequestedService do
   let(:current_user) { create(:user) }
-  let(:user) { create(:user) }
-  let(:assignee_user) { create(:user) }
-  let(:merge_request) { create(:merge_request, reviewers: [user], assignees: [assignee_user]) }
-  let(:reviewer) { merge_request.find_reviewer(user) }
-  let(:assignee) { merge_request.find_assignee(assignee_user) }
+  let(:merge_request) { create(:merge_request, reviewers: [current_user], assignees: [current_user]) }
+  let(:reviewer) { merge_request.find_reviewer(current_user) }
+  let(:assignee) { merge_request.find_assignee(current_user) }
   let(:project) { merge_request.project }
-  let(:service) { described_class.new(project: project, current_user: current_user, merge_request: merge_request, user: user) }
+  let(:service) { described_class.new(project: project, current_user: current_user, merge_request: merge_request) }
   let(:result) { service.execute }
 
   before do
     project.add_developer(current_user)
-    project.add_developer(user)
   end
 
   describe '#execute' do
     context 'invalid permissions' do
-      let(:service) { described_class.new(project: project, current_user: create(:user), merge_request: merge_request, user: user) }
+      let(:service) { described_class.new(project: project, current_user: create(:user), merge_request: merge_request) }
 
       it 'returns an error' do
         expect(result[:status]).to eq :error
@@ -28,7 +25,7 @@ RSpec.describe MergeRequests::RemoveAttentionRequestedService do
     end
 
     context 'reviewer does not exist' do
-      let(:service) { described_class.new(project: project, current_user: current_user, merge_request: merge_request, user: create(:user)) }
+      let(:service) { described_class.new(project: project, current_user: create(:user), merge_request: merge_request) }
 
       it 'returns an error' do
         expect(result[:status]).to eq :error
@@ -46,10 +43,14 @@ RSpec.describe MergeRequests::RemoveAttentionRequestedService do
 
         expect(reviewer.state).to eq 'reviewed'
       end
+
+      it_behaves_like 'invalidates attention request cache' do
+        let(:users) { [current_user] }
+      end
     end
 
     context 'assignee exists' do
-      let(:service) { described_class.new(project: project, current_user: current_user, merge_request: merge_request, user: assignee_user) }
+      let(:service) { described_class.new(project: project, current_user: current_user, merge_request: merge_request) }
 
       before do
         assignee.update!(state: :reviewed)
@@ -65,12 +66,16 @@ RSpec.describe MergeRequests::RemoveAttentionRequestedService do
 
         expect(assignee.state).to eq 'reviewed'
       end
+
+      it_behaves_like 'invalidates attention request cache' do
+        let(:users) { [current_user] }
+      end
     end
 
     context 'assignee is the same as reviewer' do
-      let(:merge_request) { create(:merge_request, reviewers: [user], assignees: [user]) }
-      let(:service) { described_class.new(project: project, current_user: current_user, merge_request: merge_request, user: user) }
-      let(:assignee) { merge_request.find_assignee(user) }
+      let(:merge_request) { create(:merge_request, reviewers: [current_user], assignees: [current_user]) }
+      let(:service) { described_class.new(project: project, current_user: current_user, merge_request: merge_request) }
+      let(:assignee) { merge_request.find_assignee(current_user) }
 
       it 'updates reviewers and assignees state' do
         service.execute

spec/services/merge_requests/toggle_attention_requested_service_spec.rb

@@ -80,11 +80,21 @@ RSpec.describe MergeRequests::ToggleAttentionRequestedService do
 
       it 'removes attention requested state' do
         expect(MergeRequests::RemoveAttentionRequestedService).to receive(:new)
-          .with(project: project, current_user: current_user, merge_request: merge_request, user: current_user)
+          .with(project: project, current_user: current_user, merge_request: merge_request)
           .and_call_original
 
         service.execute
       end
+
+      it 'invalidates cache' do
+        cache_mock = double
+
+        expect(cache_mock).to receive(:delete).with(['users', user.id, 'attention_requested_open_merge_requests_count'])
+
+        allow(Rails).to receive(:cache).and_return(cache_mock)
+
+        service.execute
+      end
     end
 
     context 'assignee exists' do
@@ -119,11 +129,15 @@ RSpec.describe MergeRequests::ToggleAttentionRequestedService do
 
       it 'removes attention requested state' do
         expect(MergeRequests::RemoveAttentionRequestedService).to receive(:new)
-          .with(project: project, current_user: current_user, merge_request: merge_request, user: current_user)
+          .with(project: project, current_user: current_user, merge_request: merge_request)
           .and_call_original
 
         service.execute
       end
+
+      it_behaves_like 'invalidates attention request cache' do
+        let(:users) { [assignee_user] }
+      end
     end
 
     context 'assignee is the same as reviewer' do

spec/support/shared_examples/attention_request_cache_invalidation_examples.rb

+# frozen_string_literal: true
+
+RSpec.shared_examples 'invalidates attention request cache' do
+  it 'invalidates the merge requests requiring attention count' do
+    cache_mock = double
+
+    users.each do |user|
+      expect(cache_mock).to receive(:delete).with(['users', user.id, 'attention_requested_open_merge_requests_count'])
+    end
+
+    allow(Rails).to receive(:cache).and_return(cache_mock)
+
+    service.execute
+  end
+end