fix: read receipts not turning blue when all active users have read (#39246)

abhinavkrin · sampaiodiego · web-flow · commit 12c44d2db65a · 2026-04-17T18:31:57.000Z
Signed-off-by: Abhinav Kumar &lt;abhinav@avitechlab.com&gt;
Co-authored-by: Diego Sampaio &lt;chinello@gmail.com&gt;
diff --git a/.changeset/hot-lies-divide.md b/.changeset/hot-lies-divide.md
@@ -0,0 +1,7 @@
+---
+'@rocket.chat/model-typings': patch
+'@rocket.chat/models': patch
+'@rocket.chat/meteor': patch
+---
+
+Fixes an issue where messages appeared as unread even when all active users had read them. Read receipts now correctly ignore deactivated users.
diff --git a/apps/meteor/app/lib/server/functions/setUserActiveStatus.ts b/apps/meteor/app/lib/server/functions/setUserActiveStatus.ts
@@ -113,7 +113,7 @@ export async function setUserActiveStatus(
 	}
 
 	if (user.username) {
-		const { modifiedCount } = await Subscriptions.setArchivedByUsername(user.username, !active);
+		const { modifiedCount } = await Subscriptions.setArchivedForDMsWithUsername(user.username, !active);
 		if (modifiedCount) {
 			void notifyOnSubscriptionChangedByNameAndRoomType({ t: 'd', name: user.username });
 		}
diff --git a/apps/meteor/app/lib/server/functions/unarchiveRoom.ts b/apps/meteor/app/lib/server/functions/unarchiveRoom.ts
@@ -1,14 +1,40 @@
 import { Message } from '@rocket.chat/core-services';
 import type { IMessage } from '@rocket.chat/core-typings';
-import { Rooms, Subscriptions } from '@rocket.chat/models';
+import { Rooms, Subscriptions, Users } from '@rocket.chat/models';
 
 import { notifyOnRoomChangedById, notifyOnSubscriptionChangedByRoomId } from '../lib/notifyListener';
 
+const BATCH_SIZE = 100_000;
+
+async function getActiveUserIds(userIds: string[]): Promise<Set<string>> {
+	const activeUserIds = new Set<string>();
+
+	for (let i = 0; i < userIds.length; i += BATCH_SIZE) {
+		const batch = await Users.findActiveByIds(userIds.slice(i, i + BATCH_SIZE), { projection: { _id: 1 } }).toArray();
+		for (const u of batch) {
+			activeUserIds.add(u._id);
+		}
+	}
+
+	return activeUserIds;
+}
+
+async function unarchiveSubscriptionsByIds(ids: string[]): Promise<void> {
+	for (let i = 0; i < ids.length; i += BATCH_SIZE) {
+		await Subscriptions.unarchiveByIds(ids.slice(i, i + BATCH_SIZE));
+	}
+}
+
 export const unarchiveRoom = async function (rid: string, user: IMessage['u']): Promise<void> {
 	await Rooms.unarchiveById(rid);
 
-	const unarchiveResponse = await Subscriptions.unarchiveByRoomId(rid);
-	if (unarchiveResponse.modifiedCount) {
+	const archivedSubs = await Subscriptions.findArchivedByRoomId(rid, { projection: { 'u._id': 1 } }).toArray();
+
+	if (archivedSubs.length > 0) {
+		const activeUserIds = await getActiveUserIds(archivedSubs.map((s) => s.u._id));
+		const idsToUnarchive = archivedSubs.filter((s) => activeUserIds.has(s.u._id)).map((s) => s._id);
+
+		await unarchiveSubscriptionsByIds(idsToUnarchive);
 		void notifyOnSubscriptionChangedByRoomId(rid);
 	}
 
diff --git a/apps/meteor/app/lib/server/functions/unarchiveUserSubscriptions.ts b/apps/meteor/app/lib/server/functions/unarchiveUserSubscriptions.ts
@@ -0,0 +1,40 @@
+import { Rooms, Subscriptions } from '@rocket.chat/models';
+
+const BATCH_SIZE = 100_000;
+
+async function getArchivedRoomIds(rids: string[]): Promise<Set<string>> {
+	const archivedRoomIds = new Set<string>();
+
+	for (let i = 0; i < rids.length; i += BATCH_SIZE) {
+		const batch = await Rooms.findManyArchivedByRoomIds(rids.slice(i, i + BATCH_SIZE), { projection: { _id: 1 } }).toArray();
+		for (const r of batch) {
+			archivedRoomIds.add(r._id);
+		}
+	}
+
+	return archivedRoomIds;
+}
+
+async function unarchiveSubscriptionsByIds(ids: string[]): Promise<void> {
+	for (let i = 0; i < ids.length; i += BATCH_SIZE) {
+		await Subscriptions.unarchiveByIds(ids.slice(i, i + BATCH_SIZE));
+	}
+}
+
+export const unarchiveUserSubscriptions = async (userId: string): Promise<boolean> => {
+	const archivedSubs = await Subscriptions.findArchivedByUserId(userId, { projection: { rid: 1 } }).toArray();
+
+	if (!archivedSubs.length) {
+		return false;
+	}
+
+	const archivedRoomIds = await getArchivedRoomIds(archivedSubs.map((s) => s.rid));
+	const idsToUnarchive = archivedSubs.filter((s) => !archivedRoomIds.has(s.rid)).map((s) => s._id);
+
+	if (!idsToUnarchive.length) {
+		return false;
+	}
+
+	await unarchiveSubscriptionsByIds(idsToUnarchive);
+	return true;
+};
diff --git a/apps/meteor/app/lib/server/lib/afterUserActions.ts b/apps/meteor/app/lib/server/lib/afterUserActions.ts
@@ -0,0 +1,24 @@
+import type { IUser } from '@rocket.chat/core-typings';
+import { Subscriptions } from '@rocket.chat/models';
+
+import { notifyOnSubscriptionChangedByUserId } from './notifyListener';
+import { callbacks } from '../../../../server/lib/callbacks';
+import { unarchiveUserSubscriptions } from '../functions/unarchiveUserSubscriptions';
+
+const handleDeactivateUser = async (user: IUser): Promise<void> => {
+	const { modifiedCount } = await Subscriptions.setArchivedByUserId(user._id, true);
+	if (modifiedCount) {
+		void notifyOnSubscriptionChangedByUserId(user._id);
+	}
+};
+
+const handleActivateUser = async (user: IUser): Promise<void> => {
+	const unarchived = await unarchiveUserSubscriptions(user._id);
+	if (unarchived) {
+		void notifyOnSubscriptionChangedByUserId(user._id);
+	}
+};
+
+callbacks.add('afterDeactivateUser', handleDeactivateUser, callbacks.priority.LOW, 'subscription-archive-on-deactivate');
+
+callbacks.add('afterActivateUser', handleActivateUser, callbacks.priority.LOW, 'subscription-unarchive-on-activate');
diff --git a/apps/meteor/app/lib/server/lib/index.ts b/apps/meteor/app/lib/server/lib/index.ts
@@ -5,6 +5,7 @@
 	for the *server* pieces of code which does include the shared
 	library files.
 */
+import './afterUserActions';
 import './notifyUsersOnMessage';
 
 export { sendNotification } from './sendNotificationsOnMessage';
diff --git a/apps/meteor/ee/server/lib/message-read-receipt/ReadReceipt.ts b/apps/meteor/ee/server/lib/message-read-receipt/ReadReceipt.ts
@@ -72,7 +72,7 @@ class ReadReceiptClass {
 		}
 
 		// mark message as read if the sender is the only one in the room
-		const isUserAlone = (await Subscriptions.countByRoomIdAndNotUserId(roomId, userId)) === 0;
+		const isUserAlone = (await Subscriptions.countUnarchivedByRoomIdAndNotUserId(roomId, userId)) === 0;
 		if (isUserAlone) {
 			const result = await Messages.setAsReadById(message._id);
 			if (result.modifiedCount > 0) {
diff --git a/apps/meteor/tests/e2e/read-receipts-deactivated-users.spec.ts b/apps/meteor/tests/e2e/read-receipts-deactivated-users.spec.ts
@@ -0,0 +1,119 @@
+import type { Page } from '@playwright/test';
+
+import { IS_EE } from './config/constants';
+import { createAuxContext } from './fixtures/createAuxContext';
+import type { IUserState } from './fixtures/userStates';
+import { Users } from './fixtures/userStates';
+import { HomeChannel } from './page-objects';
+import { createTargetChannel, deleteChannel, setSettingValueById } from './utils';
+import { expect, test } from './utils/test';
+import type { ITestUser } from './utils/user-helpers';
+import { createTestUser, loginTestUser } from './utils/user-helpers';
+
+test.use({ storageState: Users.admin.state });
+
+test.describe.serial('read-receipts-deactivated-users', () => {
+	let poHomeChannel: HomeChannel;
+	let targetChannel: string;
+	let user1Context: { page: Page; poHomeChannel: HomeChannel } | undefined;
+	let user2Context: { page: Page; poHomeChannel: HomeChannel } | undefined;
+	let testUser1: ITestUser;
+	let testUser2: ITestUser;
+	let testUser1State: IUserState;
+	let testUser2State: IUserState;
+
+	test.skip(!IS_EE, 'Enterprise Only');
+
+	test.beforeAll(async ({ api }) => {
+		[testUser1, testUser2] = await Promise.all([createTestUser(api), createTestUser(api)]);
+
+		[testUser1State, testUser2State] = await Promise.all([loginTestUser(api, testUser1), loginTestUser(api, testUser2)]);
+
+		targetChannel = await createTargetChannel(api, { members: [testUser1.data.username, testUser2.data.username] });
+		await Promise.all([
+			setSettingValueById(api, 'Message_Read_Receipt_Enabled', true),
+			setSettingValueById(api, 'Message_Read_Receipt_Store_Users', true),
+		]);
+	});
+
+	test.afterAll(async ({ api }) => {
+		await Promise.all([
+			setSettingValueById(api, 'Message_Read_Receipt_Enabled', false),
+			setSettingValueById(api, 'Message_Read_Receipt_Store_Users', false),
+		]);
+
+		await deleteChannel(api, targetChannel);
+		await Promise.all([testUser1?.delete(), testUser2?.delete()]);
+	});
+
+	test.beforeEach(async ({ page }) => {
+		poHomeChannel = new HomeChannel(page);
+		await page.goto('/home');
+	});
+
+	test.afterEach(async () => {
+		await Promise.all([user1Context?.page.close(), user2Context?.page.close()]);
+		user1Context = undefined;
+		user2Context = undefined;
+	});
+
+	test('should correctly handle read receipts as users are deactivated', async ({ browser, api, page }) => {
+		const { page: page1 } = await createAuxContext(browser, testUser1State);
+		const user1Ctx = { page: page1, poHomeChannel: new HomeChannel(page1) };
+		user1Context = user1Ctx;
+
+		const { page: page2 } = await createAuxContext(browser, testUser2State);
+		const user2Ctx = { page: page2, poHomeChannel: new HomeChannel(page2) };
+		user2Context = user2Ctx;
+
+		await Promise.all([
+			poHomeChannel.navbar.openChat(targetChannel),
+			user1Ctx.poHomeChannel.navbar.openChat(targetChannel),
+			user2Ctx.poHomeChannel.navbar.openChat(targetChannel),
+		]);
+
+		await test.step('when all users are active', async () => {
+			await poHomeChannel.content.sendMessage('Message 1: All three users active');
+
+			await Promise.all([
+				expect(user1Ctx.poHomeChannel.content.lastUserMessage).toBeVisible(),
+				expect(user2Ctx.poHomeChannel.content.lastUserMessage).toBeVisible(),
+			]);
+
+			await expect(poHomeChannel.content.lastUserMessage.getByRole('status', { name: 'Message viewed' })).toBeVisible();
+
+			await poHomeChannel.content.openLastMessageMenu();
+			await page.locator('role=menuitem[name="Read receipts"]').click();
+			await expect(page.getByRole('dialog').getByRole('listitem')).toHaveCount(3);
+			await page.getByRole('button', { name: 'Close' }).click();
+		});
+
+		await test.step('when some users are deactivated', async () => {
+			await api.post('/users.setActiveStatus', { userId: testUser1.data._id, activeStatus: false });
+
+			await poHomeChannel.content.sendMessage('Message 2: User1 deactivated, two active users');
+
+			await expect(user2Ctx.poHomeChannel.content.lastUserMessage).toBeVisible();
+
+			await expect(poHomeChannel.content.lastUserMessage.getByRole('status', { name: 'Message viewed' })).toBeVisible();
+
+			await poHomeChannel.content.openLastMessageMenu();
+			await page.locator('role=menuitem[name="Read receipts"]').click();
+			await expect(page.getByRole('dialog').getByRole('listitem')).toHaveCount(2);
+			await page.getByRole('button', { name: 'Close' }).click();
+		});
+
+		await test.step('when only one user remains active (user alone in room)', async () => {
+			await api.post('/users.setActiveStatus', { userId: testUser2.data._id, activeStatus: false });
+
+			await poHomeChannel.content.sendMessage('Message 3: Only admin active');
+
+			await expect(poHomeChannel.content.lastUserMessage.getByRole('status', { name: 'Message viewed' })).toBeVisible();
+
+			await poHomeChannel.content.openLastMessageMenu();
+			await page.locator('role=menuitem[name="Read receipts"]').click();
+			await expect(page.getByRole('dialog').getByRole('listitem')).toHaveCount(1);
+			await page.getByRole('button', { name: 'Close' }).click();
+		});
+	});
+});
diff --git a/apps/meteor/tests/e2e/read-receipts.spec.ts b/apps/meteor/tests/e2e/read-receipts.spec.ts
@@ -30,7 +30,7 @@ test.describe.serial('read-receipts', () => {
 			await poHomeChannel.navbar.openChat(targetChannel);
 			await poHomeChannel.content.sendMessage('hello world');
 			await poHomeChannel.content.openLastMessageMenu();
-			expect(page.locator('role=menuitem[name="Read receipts"]')).not.toBeVisible;
+			await expect(page.locator('role=menuitem[name="Read receipts"]')).not.toBeVisible();
 		});
 	});
 
diff --git a/apps/meteor/tests/e2e/utils/user-helpers.ts b/apps/meteor/tests/e2e/utils/user-helpers.ts
@@ -3,7 +3,8 @@ import type { APIResponse } from '@playwright/test';
 import type { IUser } from '@rocket.chat/core-typings';
 
 import type { BaseTest } from './test';
-import { DEFAULT_USER_CREDENTIALS } from '../config/constants';
+import { BASE_URL, DEFAULT_USER_CREDENTIALS } from '../config/constants';
+import type { IUserState } from '../fixtures/userStates';
 
 export interface ICreateUserOptions {
 	username?: string;
@@ -62,6 +63,63 @@ export async function createTestUser(api: BaseTest['api'], options: ICreateUserO
 	};
 }
 
+/**
+ * Logs in a test user via the REST API and returns an IUserState
+ * suitable for use with createAuxContext.
+ *
+ * Use this instead of the pre-baked Users.userN fixtures whenever the test
+ * will deactivate (or otherwise invalidate the session of) the user, so that
+ * shared fixture tokens are never corrupted.
+ */
+export async function loginTestUser(api: BaseTest['api'], user: ITestUser): Promise<IUserState> {
+	const response = await api.post('/login', {
+		username: user.data.username,
+		password: DEFAULT_USER_CREDENTIALS.password,
+	});
+	const {
+		data: { userId, authToken },
+	} = await response.json();
+
+	const expires = new Date();
+	expires.setFullYear(expires.getFullYear() + 1);
+
+	return {
+		data: {
+			_id: userId,
+			username: user.data.username,
+			loginToken: authToken,
+			loginExpire: expires,
+			hashedToken: '',
+		},
+		state: {
+			cookies: [
+				{ sameSite: 'Lax', name: 'rc_uid', value: userId, domain: 'localhost', path: '/', expires: -1, httpOnly: false, secure: false },
+				{
+					sameSite: 'Lax',
+					name: 'rc_token',
+					value: authToken,
+					domain: 'localhost',
+					path: '/',
+					expires: -1,
+					httpOnly: false,
+					secure: false,
+				},
+			],
+			origins: [
+				{
+					origin: BASE_URL,
+					localStorage: [
+						{ name: 'userLanguage', value: 'en-US' },
+						{ name: 'Meteor.loginToken', value: authToken },
+						{ name: 'Meteor.loginTokenExpires', value: expires.toISOString() },
+						{ name: 'Meteor.userId', value: userId },
+					],
+				},
+			],
+		},
+	};
+}
+
 /**
  * Creates multiple test users at once
  */
diff --git a/packages/model-typings/src/models/IRoomsModel.ts b/packages/model-typings/src/models/IRoomsModel.ts
@@ -53,6 +53,8 @@ export interface IRoomsModel extends IBaseModel<IRoom> {
 
 	findManyByRoomIds(roomIds: Array<IRoom['_id']>, options?: FindOptions<IRoom>): FindCursor<IRoom>;
 
+	findManyArchivedByRoomIds(roomIds: Array<IRoom['_id']>, options?: FindOptions<IRoom>): FindCursor<IRoom>;
+
 	findPaginatedByIds(
 		roomIds: Array<IRoom['_id']>,
 		options?: FindOptions<IRoom>,
diff --git a/packages/model-typings/src/models/ISubscriptionsModel.ts b/packages/model-typings/src/models/ISubscriptionsModel.ts
@@ -38,6 +38,8 @@ export interface ISubscriptionsModel extends IBaseModel<ISubscription> {
 
 	countUnarchivedByRoomId(rid: string): Promise<number>;
 
+	countUnarchivedByRoomIdAndNotUserId(rid: string, uid: string): Promise<number>;
+
 	isUserInRole(uid: IUser['_id'], roleId: IRole['_id'], rid?: IRoom['_id']): Promise<boolean>;
 
 	setAsReadByRoomIdAndUserId(
@@ -240,7 +242,9 @@ export interface ISubscriptionsModel extends IBaseModel<ISubscription> {
 	findUnreadByUserId(userId: string): FindCursor<ISubscription>;
 
 	archiveByRoomId(roomId: string): Promise<UpdateResult | Document>;
-	unarchiveByRoomId(roomId: string): Promise<UpdateResult | Document>;
+	findArchivedByRoomId(roomId: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription>;
+	findArchivedByUserId(userId: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription>;
+	unarchiveByIds(ids: string[]): Promise<UpdateResult | Document>;
 	updateNameAndAlertByRoomId(roomId: string, name: string, fname: string): Promise<UpdateResult | Document>;
 	findByRoomIdWhenUsernameExists(rid: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription>;
 	setCustomFieldsDirectMessagesByUserId(userId: string, fields: Record<string, any>): Promise<UpdateResult | Document>;
@@ -282,7 +286,8 @@ export interface ISubscriptionsModel extends IBaseModel<ISubscription> {
 
 	removeRoleById(_id: string, role: string): Promise<UpdateResult>;
 	updateDirectFNameByName(name: string, fname: string): Promise<UpdateResult | Document>;
-	setArchivedByUsername(username: string, archived: boolean): Promise<UpdateResult | Document>;
+	setArchivedByUserId(userId: string, archived: boolean): Promise<UpdateResult | Document>;
+	setArchivedForDMsWithUsername(username: string, archived: boolean): Promise<UpdateResult | Document>;
 	updateUserHighlights(userId: string, userHighlights: any): Promise<UpdateResult | Document>;
 	updateNotificationUserPreferences(
 		userId: string,
@@ -331,7 +336,6 @@ export interface ISubscriptionsModel extends IBaseModel<ISubscription> {
 	countByRoomId(roomId: string, options?: CountDocumentsOptions): Promise<number>;
 	countByUserIdExceptType(userId: string, typeException: ISubscription['t']): Promise<number>;
 	openByRoomIdAndUserId(roomId: string, userId: string): Promise<UpdateResult>;
-	countByRoomIdAndNotUserId(rid: string, uid: string): Promise<number>;
 	countByRoomIdWhenUsernameExists(rid: string): Promise<number>;
 	setE2EKeyByUserIdAndRoomId(userId: string, rid: string, key: string): Promise<null | WithId<ISubscription>>;
 	countUsersInRoles(roles: IRole['_id'][], rid: IRoom['_id'] | undefined): Promise<number>;
diff --git a/packages/models/src/models/Rooms.ts b/packages/models/src/models/Rooms.ts
diff --git a/packages/models/src/models/Subscriptions.ts b/packages/models/src/models/Subscriptions.ts

Original file line number	Diff line number	Diff line change
`@@ -113,7 +113,7 @@ export async function setUserActiveStatus(`
`113`	`113`	`}`
`114`	`114`
`115`	`115`	`if (user.username) {`
`116`		`- const { modifiedCount } = await Subscriptions.setArchivedByUsername(user.username, !active);`
	`116`	`+ const { modifiedCount } = await Subscriptions.setArchivedForDMsWithUsername(user.username, !active);`
`117`	`117`	`if (modifiedCount) {`
`118`	`118`	`void notifyOnSubscriptionChangedByNameAndRoomType({ t: 'd', name: user.username });`
`119`	`119`	`}`
Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ class ReadReceiptClass {`
`72`	`72`	`}`
`73`	`73`
`74`	`74`	`// mark message as read if the sender is the only one in the room`
`75`		`- const isUserAlone = (await Subscriptions.countByRoomIdAndNotUserId(roomId, userId)) === 0;`
	`75`	`+ const isUserAlone = (await Subscriptions.countUnarchivedByRoomIdAndNotUserId(roomId, userId)) === 0;`
`76`	`76`	`if (isUserAlone) {`
`77`	`77`	`const result = await Messages.setAsReadById(message._id);`
`78`	`78`	`if (result.modifiedCount > 0) {`