Merge branch 'develop' into feat/mentionBot

.changeset/beige-coats-wait.md

@@ -0,0 +1,56 @@
+---
+'@rocket.chat/ui-kit': minor
+'@rocket.chat/server-cloud-communication': patch
+'@rocket.chat/omnichannel-services': patch
+'rocketchat-services': patch
+'@rocket.chat/omnichannel-transcript': patch
+'@rocket.chat/authorization-service': patch
+'@rocket.chat/web-ui-registration': patch
+'@rocket.chat/stream-hub-service': patch
+'@rocket.chat/password-policies': patch
+'@rocket.chat/uikit-playground': patch
+'@rocket.chat/presence-service': patch
+'@rocket.chat/fuselage-ui-kit': patch
+'@rocket.chat/instance-status': patch
+'@rocket.chat/account-service': patch
+'@rocket.chat/mock-providers': patch
+'@rocket.chat/release-action': patch
+'@rocket.chat/api-client': patch
+'@rocket.chat/ddp-client': patch
+'@rocket.chat/pdf-worker': patch
+'@rocket.chat/ui-theming': patch
+'@rocket.chat/account-utils': patch
+'@rocket.chat/core-services': patch
+'@rocket.chat/eslint-config': patch
+'@rocket.chat/model-typings': patch
+'@rocket.chat/ui-video-conf': patch
+'@rocket.chat/cas-validate': patch
+'@rocket.chat/core-typings': patch
+'@rocket.chat/rest-typings': patch
+'@rocket.chat/server-fetch': patch
+'@rocket.chat/ddp-streamer': patch
+'@rocket.chat/queue-worker': patch
+'@rocket.chat/presence': patch
+'@rocket.chat/poplib': patch
+'@rocket.chat/ui-composer': patch
+'@rocket.chat/ui-contexts': patch
+'@rocket.chat/license': patch
+'@rocket.chat/log-format': patch
+'@rocket.chat/gazzodown': patch
+'@rocket.chat/ui-client': patch
+'@rocket.chat/livechat': patch
+'@rocket.chat/favicon': patch
+'@rocket.chat/agenda': patch
+'@rocket.chat/base64': patch
+'@rocket.chat/logger': patch
+'@rocket.chat/models': patch
+'@rocket.chat/random': patch
+'@rocket.chat/sha256': patch
+'@rocket.chat/tools': patch
+'@rocket.chat/cron': patch
+'@rocket.chat/i18n': patch
+'@rocket.chat/jwt': patch
+'@rocket.chat/meteor': patch
+---
+
+feat(uikit): Move `@rocket.chat/ui-kit` package to the main monorepo

.changeset/fifty-maps-deny.md

@@ -0,0 +1,6 @@
+---
+"@rocket.chat/meteor": minor
+"@rocket.chat/rest-typings": minor
+---
+
+Added `push.info` endpoint to enable users to retrieve info about the workspace's push gateway

.changeset/fresh-radios-whisper.md

@@ -0,0 +1,5 @@
+---
+"@rocket.chat/meteor": patch
+---
+
+Fixed issue with the new `custom-roles` license module not being checked throughout the application

.changeset/kind-beers-share.md

@@ -0,0 +1,7 @@
+---
+"@rocket.chat/meteor": minor
+"@rocket.chat/ui-client": minor
+"@rocket.chat/web-ui-registration": minor
+---
+
+feat: Skip to main content shortcut and useDocumentTitle

.changeset/nasty-islands-trade.md

@@ -0,0 +1,6 @@
+---
+'@rocket.chat/rest-typings': minor
+'@rocket.chat/meteor': minor
+---
+
+fix Federation Regression, builds service correctly

.yarnrc.yml

@@ -14,4 +14,4 @@ plugins:
   - path: .yarn/plugins/@yarnpkg/plugin-typescript.cjs
     spec: "@yarnpkg/plugin-typescript"
 
-yarnPath: .yarn/releases/yarn-3.2.2.cjs
+yarnPath: .yarn/releases/yarn-3.5.0.cjs

apps/meteor/app/api/server/v1/import.ts

@@ -10,10 +10,13 @@ import {
 	isDownloadPendingFilesParamsPOST,
 	isDownloadPendingAvatarsParamsPOST,
 	isGetCurrentImportOperationParamsGET,
+	isImportersListParamsGET,
 	isImportAddUsersParamsPOST,
 } from '@rocket.chat/rest-typings';
 import { Meteor } from 'meteor/meteor';
 
+import { PendingAvatarImporter } from '../../../importer-pending-avatars/server/PendingAvatarImporter';
+import { PendingFileImporter } from '../../../importer-pending-files/server/PendingFileImporter';
 import { Importers } from '../../../importer/server';
 import {
 	executeUploadImportFile,
@@ -136,9 +139,8 @@ API.v1.addRoute(
 			}
 
 			const operation = await Import.newOperation(this.userId, importer.name, importer.key);
-
-			importer.instance = new importer.importer(importer, operation); // eslint-disable-line new-cap
-			const count = await importer.instance.prepareFileCount();
+			const instance = new PendingFileImporter(importer, operation);
+			const count = await instance.prepareFileCount();
 
 			return API.v1.success({
 				count,
@@ -162,8 +164,8 @@ API.v1.addRoute(
 			}
 
 			const operation = await Import.newOperation(this.userId, importer.name, importer.key);
-			importer.instance = new importer.importer(importer, operation); // eslint-disable-line new-cap
-			const count = await importer.instance.prepareFileCount();
+			const instance = new PendingAvatarImporter(importer, operation);
+			const count = await instance.prepareFileCount();
 
 			return API.v1.success({
 				count,
@@ -189,6 +191,22 @@ API.v1.addRoute(
 	},
 );
 
+API.v1.addRoute(
+	'importers.list',
+	{
+		authRequired: true,
+		validateParams: isImportersListParamsGET,
+		permissionsRequired: ['run-import'],
+	},
+	{
+		async get() {
+			const importers = Importers.getAllVisible().map(({ key, name }) => ({ key, name }));
+
+			return API.v1.success(importers);
+		},
+	},
+);
+
 API.v1.addRoute(
 	'import.clear',
 	{

apps/meteor/app/api/server/v1/push.ts

@@ -1,10 +1,11 @@
-import { Messages, AppsTokens, Users, Rooms } from '@rocket.chat/models';
+import { Messages, AppsTokens, Users, Rooms, Settings } from '@rocket.chat/models';
 import { Random } from '@rocket.chat/random';
 import { Match, check } from 'meteor/check';
 import { Meteor } from 'meteor/meteor';
 
 import { canAccessRoomAsync } from '../../../authorization/server/functions/canAccessRoom';
 import PushNotification from '../../../push-notifications/server/lib/PushNotification';
+import { settings } from '../../../settings/server';
 import { API } from '../api';
 
 API.v1.addRoute(
@@ -110,3 +111,18 @@ API.v1.addRoute(
 		},
 	},
 );
+
+API.v1.addRoute(
+	'push.info',
+	{ authRequired: true },
+	{
+		async get() {
+			const defaultGateway = (await Settings.findOneById('Push_gateway', { projection: { packageValue: 1 } }))?.packageValue;
+			const defaultPushGateway = settings.get('Push_gateway') === defaultGateway;
+			return API.v1.success({
+				pushGatewayEnabled: settings.get('Push_enable'),
+				defaultPushGateway,
+			});
+		},
+	},
+);

apps/meteor/app/apps/server/bridges/uiInteraction.ts

@@ -2,7 +2,7 @@ import type { IUIKitInteraction } from '@rocket.chat/apps-engine/definition/uiki
 import type { IUser } from '@rocket.chat/apps-engine/definition/users';
 import { UiInteractionBridge as AppsEngineUiInteractionBridge } from '@rocket.chat/apps-engine/server/bridges/UiInteractionBridge';
 import { api } from '@rocket.chat/core-services';
-import type { UiKit } from '@rocket.chat/core-typings';
+import type * as UiKit from '@rocket.chat/ui-kit';
 
 import type { AppServerOrchestrator } from '../../../../ee/server/apps/orchestrator';
 

apps/meteor/app/autotranslate/server/autotranslate.ts

@@ -1,3 +1,4 @@
+import { api } from '@rocket.chat/core-services';
 import type {
 	IMessage,
 	IRoom,
@@ -15,6 +16,7 @@ import _ from 'underscore';
 
 import { callbacks } from '../../../lib/callbacks';
 import { isTruthy } from '../../../lib/isTruthy';
+import { broadcastMessageSentEvent } from '../../../server/modules/watchers/lib/messages';
 import { Markdown } from '../../markdown/server';
 import { settings } from '../../settings/server';
 
@@ -305,6 +307,7 @@ export abstract class AutoTranslate {
 				const translations = await this._translateMessage(targetMessage, targetLanguages);
 				if (!_.isEmpty(translations)) {
 					await Messages.addTranslations(message._id, translations, TranslationProviderRegistry[Provider] || '');
+					this.notifyTranslatedMessage(message._id);
 				}
 			});
 		}
@@ -320,6 +323,7 @@ export abstract class AutoTranslate {
 
 						if (!_.isEmpty(translations)) {
 							await Messages.addAttachmentTranslations(message._id, String(index), translations);
+							this.notifyTranslatedMessage(message._id);
 						}
 					}
 				}
@@ -328,6 +332,13 @@ export abstract class AutoTranslate {
 		return Messages.findOneById(message._id);
 	}
 
+	private notifyTranslatedMessage(messageId: string): void {
+		void broadcastMessageSentEvent({
+			id: messageId,
+			broadcastCallback: (message) => api.broadcast('message.sent', message),
+		});
+	}
+
 	/**
 	 * Returns metadata information about the service provider which is used by
 	 * the generic implementation

apps/meteor/app/federation/server/endpoints/dispatch.js

@@ -3,6 +3,7 @@ import { eventTypes } from '@rocket.chat/core-typings';
 import { FederationServers, FederationRoomEvents, Rooms, Messages, Subscriptions, Users, ReadReceipts } from '@rocket.chat/models';
 import EJSON from 'ejson';
 
+import { broadcastMessageSentEvent } from '../../../../server/modules/watchers/lib/messages';
 import { API } from '../../../api/server';
 import { FileUpload } from '../../../file-upload/server';
 import { deleteRoom } from '../../../lib/server/functions/deleteRoom';
@@ -214,11 +215,13 @@ const eventHandlers = {
 
 			// Check if message exists
 			const persistedMessage = await Messages.findOne({ _id: message._id });
+			let messageForNotification;
 
 			if (persistedMessage) {
 				// Update the federation
 				if (!persistedMessage.federation) {
 					await Messages.updateOne({ _id: persistedMessage._id }, { $set: { federation: message.federation } });
+					messageForNotification = { ...persistedMessage, federation: message.federation };
 				}
 			} else {
 				// Load the room
@@ -275,10 +278,18 @@ const eventHandlers = {
 					// Notify users
 					await notifyUsersOnMessage(denormalizedMessage, room);
 					sendAllNotifications(denormalizedMessage, room);
+					messageForNotification = denormalizedMessage;
 				} catch (err) {
 					serverLogger.debug(`Error on creating message: ${message._id}`);
 				}
 			}
+			if (messageForNotification) {
+				void broadcastMessageSentEvent({
+					id: messageForNotification._id,
+					data: messageForNotification,
+					broadcastCallback: (message) => api.broadcast('message.sent', message),
+				});
+			}
 		}
 
 		return eventResult;
@@ -305,6 +316,15 @@ const eventHandlers = {
 			} else {
 				// Update the message
 				await Messages.updateOne({ _id: persistedMessage._id }, { $set: { msg: message.msg, federation: message.federation } });
+				void broadcastMessageSentEvent({
+					id: persistedMessage._id,
+					data: {
+						...persistedMessage,
+						msg: message.msg,
+						federation: message.federation,
+					},
+					broadcastCallback: (message) => api.broadcast('message.sent', message),
+				});
 			}
 		}
 
@@ -367,6 +387,17 @@ const eventHandlers = {
 
 			// Update the property
 			await Messages.updateOne({ _id: messageId }, { $set: { [`reactions.${reaction}`]: reactionObj } });
+			void broadcastMessageSentEvent({
+				id: persistedMessage._id,
+				data: {
+					...persistedMessage,
+					reactions: {
+						...persistedMessage.reactions,
+						[reaction]: reactionObj,
+					},
+				},
+				broadcastCallback: (message) => api.broadcast('message.sent', message),
+			});
 		}
 
 		return eventResult;
@@ -415,6 +446,17 @@ const eventHandlers = {
 				// Otherwise, update the property
 				await Messages.updateOne({ _id: messageId }, { $set: { [`reactions.${reaction}`]: reactionObj } });
 			}
+			void broadcastMessageSentEvent({
+				id: persistedMessage._id,
+				data: {
+					...persistedMessage,
+					reactions: {
+						...persistedMessage.reactions,
+						[reaction]: reactionObj,
+					},
+				},
+				broadcastCallback: (message) => api.broadcast('message.sent', message),
+			});
 		}
 
 		return eventResult;