diff --git a/app/integrations/server/lib/triggerHandler.js b/app/integrations/server/lib/triggerHandler.js index a565fa0b4d945..8ba50fca9bd4a 100644 --- a/app/integrations/server/lib/triggerHandler.js +++ b/app/integrations/server/lib/triggerHandler.js @@ -841,91 +841,91 @@ export class RocketChatIntegrationHandler { this.updateHistory({ historyId, step: 'after-process-false-result', finished: true }); return; } + } - // if the result contained nothing or wasn't a successful statusCode - if (!content || !this.successResults.includes(res.status)) { - if (content) { - outgoingLogger.error({ - msg: `Error for the Integration "${trigger.name}" to ${url}`, - result: content, - }); + // if the result contained nothing or wasn't a successful statusCode + if (!content || !this.successResults.includes(res.status)) { + if (content) { + outgoingLogger.error({ + msg: `Error for the Integration "${trigger.name}" to ${url}`, + result: content, + }); - if (res.status === 410) { - this.updateHistory({ historyId, step: 'after-process-http-status-410', error: true }); - outgoingLogger.error(`Disabling the Integration "${trigger.name}" because the status code was 401 (Gone).`); - await Integrations.updateOne({ _id: trigger._id }, { $set: { enabled: false } }); - return; - } + if (res.status === 410) { + this.updateHistory({ historyId, step: 'after-process-http-status-410', error: true }); + outgoingLogger.error(`Disabling the Integration "${trigger.name}" because the status code was 401 (Gone).`); + await Integrations.updateOne({ _id: trigger._id }, { $set: { enabled: false } }); + return; + } - if (res.status === 500) { - this.updateHistory({ historyId, step: 'after-process-http-status-500', error: true }); - outgoingLogger.error({ - msg: `Error "500" for the Integration "${trigger.name}" to ${url}.`, - content, - }); - return; - } + if (res.status === 500) { + this.updateHistory({ historyId, step: 'after-process-http-status-500', error: true }); + outgoingLogger.error({ + msg: `Error "500" for the Integration "${trigger.name}" to ${url}.`, + content, + }); + return; } + } - if (trigger.retryFailedCalls) { - if (tries < trigger.retryCount && trigger.retryDelay) { - this.updateHistory({ historyId, error: true, step: `going-to-retry-${tries + 1}` }); - - let waitTime; - - switch (trigger.retryDelay) { - case 'powers-of-ten': - // Try again in 0.1s, 1s, 10s, 1m40s, 16m40s, 2h46m40s, 27h46m40s, etc - waitTime = Math.pow(10, tries + 2); - break; - case 'powers-of-two': - // 2 seconds, 4 seconds, 8 seconds - waitTime = Math.pow(2, tries + 1) * 1000; - break; - case 'increments-of-two': - // 2 second, 4 seconds, 6 seconds, etc - waitTime = (tries + 1) * 2 * 1000; - break; - default: - const er = new Error("The integration's retryDelay setting is invalid."); - this.updateHistory({ - historyId, - step: 'failed-and-retry-delay-is-invalid', - error: true, - errorStack: er.stack, - }); - return; - } - - outgoingLogger.info(`Trying the Integration ${trigger.name} to ${url} again in ${waitTime} milliseconds.`); - Meteor.setTimeout(() => { - this.executeTriggerUrl(url, trigger, { event, message, room, owner, user }, historyId, tries + 1); - }, waitTime); - } else { - this.updateHistory({ historyId, step: 'too-many-retries', error: true }); + if (trigger.retryFailedCalls) { + if (tries < trigger.retryCount && trigger.retryDelay) { + this.updateHistory({ historyId, error: true, step: `going-to-retry-${tries + 1}` }); + + let waitTime; + + switch (trigger.retryDelay) { + case 'powers-of-ten': + // Try again in 0.1s, 1s, 10s, 1m40s, 16m40s, 2h46m40s, 27h46m40s, etc + waitTime = Math.pow(10, tries + 2); + break; + case 'powers-of-two': + // 2 seconds, 4 seconds, 8 seconds + waitTime = Math.pow(2, tries + 1) * 1000; + break; + case 'increments-of-two': + // 2 second, 4 seconds, 6 seconds, etc + waitTime = (tries + 1) * 2 * 1000; + break; + default: + const er = new Error("The integration's retryDelay setting is invalid."); + this.updateHistory({ + historyId, + step: 'failed-and-retry-delay-is-invalid', + error: true, + errorStack: er.stack, + }); + return; } + + outgoingLogger.info(`Trying the Integration ${trigger.name} to ${url} again in ${waitTime} milliseconds.`); + Meteor.setTimeout(() => { + this.executeTriggerUrl(url, trigger, { event, message, room, owner, user }, historyId, tries + 1); + }, waitTime); } else { - this.updateHistory({ - historyId, - step: 'failed-and-not-configured-to-retry', - error: true, - }); + this.updateHistory({ historyId, step: 'too-many-retries', error: true }); } - - return; + } else { + this.updateHistory({ + historyId, + step: 'failed-and-not-configured-to-retry', + error: true, + }); } - // process outgoing webhook response as a new message - if (content && this.successResults.includes(res.status)) { - if (data?.text || data?.attachments) { - const resultMsg = this.sendMessage({ trigger, room, message: data, data }); - this.updateHistory({ - historyId, - step: 'url-response-sent-message', - resultMessage: resultMsg, - finished: true, - }); - } + return; + } + + // process outgoing webhook response as a new message + if (content && this.successResults.includes(res.status)) { + if (data?.text || data?.attachments) { + const resultMsg = this.sendMessage({ trigger, room, message: data, data }); + this.updateHistory({ + historyId, + step: 'url-response-sent-message', + resultMessage: resultMsg, + finished: true, + }); } } }) diff --git a/app/lib/server/methods/addOAuthService.js b/app/lib/server/methods/addOAuthService.ts similarity index 90% rename from app/lib/server/methods/addOAuthService.js rename to app/lib/server/methods/addOAuthService.ts index 36a4ba555ec26..57ce8265fc3a2 100644 --- a/app/lib/server/methods/addOAuthService.js +++ b/app/lib/server/methods/addOAuthService.ts @@ -1,7 +1,7 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { hasPermission } from '../../../authorization'; +import { hasPermission } from '../../../authorization/server'; import { addOAuthService } from '../functions/addOAuthService'; Meteor.methods({ diff --git a/app/lib/server/methods/addUserToRoom.js b/app/lib/server/methods/addUserToRoom.ts similarity index 100% rename from app/lib/server/methods/addUserToRoom.js rename to app/lib/server/methods/addUserToRoom.ts diff --git a/app/lib/server/methods/archiveRoom.js b/app/lib/server/methods/archiveRoom.ts similarity index 89% rename from app/lib/server/methods/archiveRoom.js rename to app/lib/server/methods/archiveRoom.ts index 4f101615b8416..7f55af28122b5 100644 --- a/app/lib/server/methods/archiveRoom.js +++ b/app/lib/server/methods/archiveRoom.ts @@ -1,8 +1,8 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { Rooms } from '../../../models'; -import { hasPermission } from '../../../authorization'; +import { Rooms } from '../../../models/server'; +import { hasPermission } from '../../../authorization/server'; import { archiveRoom } from '../functions'; import { roomTypes, RoomMemberActions } from '../../../utils/server'; diff --git a/app/lib/server/methods/blockUser.js b/app/lib/server/methods/blockUser.ts similarity index 91% rename from app/lib/server/methods/blockUser.js rename to app/lib/server/methods/blockUser.ts index f9e4bb4c54d22..7ca223e4ad00b 100644 --- a/app/lib/server/methods/blockUser.js +++ b/app/lib/server/methods/blockUser.ts @@ -1,9 +1,8 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { Subscriptions } from '../../../models'; import { roomTypes, RoomMemberActions } from '../../../utils/server'; -import { Rooms } from '../../../models/server'; +import { Rooms, Subscriptions } from '../../../models/server'; Meteor.methods({ blockUser({ rid, blocked }) { diff --git a/app/lib/server/methods/checkRegistrationSecretURL.js b/app/lib/server/methods/checkRegistrationSecretURL.ts similarity index 81% rename from app/lib/server/methods/checkRegistrationSecretURL.js rename to app/lib/server/methods/checkRegistrationSecretURL.ts index ab411be95d1a5..11a1d4ea42007 100644 --- a/app/lib/server/methods/checkRegistrationSecretURL.js +++ b/app/lib/server/methods/checkRegistrationSecretURL.ts @@ -1,7 +1,7 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { settings } from '../../../settings'; +import { settings } from '../../../settings/server'; Meteor.methods({ checkRegistrationSecretURL(hash) { diff --git a/app/lib/server/methods/checkUsernameAvailability.js b/app/lib/server/methods/checkUsernameAvailability.ts similarity index 80% rename from app/lib/server/methods/checkUsernameAvailability.js rename to app/lib/server/methods/checkUsernameAvailability.ts index 7bf9b7f9acdbd..2a9f34780f2a1 100644 --- a/app/lib/server/methods/checkUsernameAvailability.js +++ b/app/lib/server/methods/checkUsernameAvailability.ts @@ -1,7 +1,7 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { settings } from '../../../settings'; +import { settings } from '../../../settings/server'; import { checkUsernameAvailability } from '../functions'; import { RateLimiter } from '../lib'; @@ -15,11 +15,11 @@ Meteor.methods({ const user = Meteor.user(); - if (user.username && !settings.get('Accounts_AllowUsernameChange')) { + if (user?.username && !settings.get('Accounts_AllowUsernameChange')) { throw new Meteor.Error('error-not-allowed', 'Not allowed', { method: 'setUsername' }); } - if (user.username === username) { + if (user?.username === username) { return true; } return checkUsernameAvailability(username); diff --git a/app/lib/server/methods/createChannel.js b/app/lib/server/methods/createChannel.ts similarity index 79% rename from app/lib/server/methods/createChannel.js rename to app/lib/server/methods/createChannel.ts index 0201e985e74f7..364d31200d21c 100644 --- a/app/lib/server/methods/createChannel.js +++ b/app/lib/server/methods/createChannel.ts @@ -1,7 +1,7 @@ import { Meteor } from 'meteor/meteor'; import { Match, check } from 'meteor/check'; -import { hasPermission } from '../../../authorization'; +import { hasPermission } from '../../../authorization/server'; import { createRoom } from '../functions'; Meteor.methods({ @@ -16,7 +16,7 @@ Meteor.methods({ if (!hasPermission(Meteor.userId(), 'create-c')) { throw new Meteor.Error('error-not-allowed', 'Not allowed', { method: 'createChannel' }); } - return createRoom('c', name, Meteor.user() && Meteor.user().username, members, readOnly, { + return createRoom('c', name, Meteor.user() && Meteor.user()?.username, members, readOnly, { customFields, ...extraData, }); diff --git a/app/lib/server/methods/createToken.js b/app/lib/server/methods/createToken.ts similarity index 78% rename from app/lib/server/methods/createToken.js rename to app/lib/server/methods/createToken.ts index 47713c0fc44ee..d05df8d95562f 100644 --- a/app/lib/server/methods/createToken.js +++ b/app/lib/server/methods/createToken.ts @@ -1,12 +1,12 @@ import { Meteor } from 'meteor/meteor'; import { Accounts } from 'meteor/accounts-base'; -import { hasPermission } from '../../../authorization'; +import { hasPermission } from '../../../authorization/server'; Meteor.methods({ createToken(userId) { if ( - !['yes', 'true'].includes(process.env.CREATE_TOKENS_FOR_USERS) || + !['yes', 'true'].includes(String(process.env.CREATE_TOKENS_FOR_USERS)) || (Meteor.userId() !== userId && !hasPermission(Meteor.userId(), 'user-generate-access-token')) ) { throw new Meteor.Error('error-not-authorized', 'Not authorized', { method: 'createToken' }); diff --git a/app/lib/server/methods/deleteMessage.js b/app/lib/server/methods/deleteMessage.ts similarity index 83% rename from app/lib/server/methods/deleteMessage.js rename to app/lib/server/methods/deleteMessage.ts index 47d54f4e940e3..d8c1b97034dbc 100644 --- a/app/lib/server/methods/deleteMessage.js +++ b/app/lib/server/methods/deleteMessage.ts @@ -2,8 +2,9 @@ import { Meteor } from 'meteor/meteor'; import { Match, check } from 'meteor/check'; import { canDeleteMessage } from '../../../authorization/server/functions/canDeleteMessage'; -import { Messages } from '../../../models'; +import { Messages } from '../../../models/server'; import { deleteMessage } from '../functions'; +import { IUser } from '../../../../definition/IUser'; Meteor.methods({ async deleteMessage(message) { @@ -38,6 +39,6 @@ Meteor.methods({ }); } - return deleteMessage(originalMessage, Meteor.user()); + return deleteMessage(originalMessage, Meteor.user() as IUser); }, }); diff --git a/app/lib/server/methods/deleteUserOwnAccount.js b/app/lib/server/methods/deleteUserOwnAccount.ts similarity index 93% rename from app/lib/server/methods/deleteUserOwnAccount.js rename to app/lib/server/methods/deleteUserOwnAccount.ts index f6dda0888febd..2ce0a3df79fa3 100644 --- a/app/lib/server/methods/deleteUserOwnAccount.js +++ b/app/lib/server/methods/deleteUserOwnAccount.ts @@ -4,8 +4,8 @@ import { Accounts } from 'meteor/accounts-base'; import { SHA256 } from 'meteor/sha'; import s from 'underscore.string'; -import { settings } from '../../../settings'; -import { Users } from '../../../models'; +import { settings } from '../../../settings/server'; +import { Users } from '../../../models/server'; import { deleteUser } from '../functions'; Meteor.methods({ diff --git a/app/lib/server/methods/executeSlashCommandPreview.js b/app/lib/server/methods/executeSlashCommandPreview.ts similarity index 94% rename from app/lib/server/methods/executeSlashCommandPreview.js rename to app/lib/server/methods/executeSlashCommandPreview.ts index 52f2c18527a5c..8df013402607a 100644 --- a/app/lib/server/methods/executeSlashCommandPreview.js +++ b/app/lib/server/methods/executeSlashCommandPreview.ts @@ -1,6 +1,6 @@ import { Meteor } from 'meteor/meteor'; -import { slashCommands } from '../../../utils'; +import { slashCommands } from '../../../utils/server'; Meteor.methods({ executeSlashCommandPreview(command, preview) { diff --git a/app/lib/server/methods/getChannelHistory.js b/app/lib/server/methods/getChannelHistory.ts similarity index 96% rename from app/lib/server/methods/getChannelHistory.js rename to app/lib/server/methods/getChannelHistory.ts index d39499a845245..939889eff2fea 100644 --- a/app/lib/server/methods/getChannelHistory.js +++ b/app/lib/server/methods/getChannelHistory.ts @@ -16,7 +16,7 @@ Meteor.methods({ throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'getChannelHistory' }); } - const fromUserId = Meteor.userId(); + const fromUserId = Meteor.userId() || undefined; const room = Rooms.findOneById(rid); if (!room) { return false; @@ -47,7 +47,7 @@ Meteor.methods({ const hiddenMessageTypes = getHiddenSystemMessages(room); - const options = { + const options: Record = { sort: { ts: -1, }, diff --git a/app/lib/server/methods/getMessages.js b/app/lib/server/methods/getMessages.ts similarity index 62% rename from app/lib/server/methods/getMessages.js rename to app/lib/server/methods/getMessages.ts index f8ccbbbb6f740..57b5d50483fb6 100644 --- a/app/lib/server/methods/getMessages.js +++ b/app/lib/server/methods/getMessages.ts @@ -3,16 +3,23 @@ import { check } from 'meteor/check'; import { canAccessRoom } from '../../../authorization/server'; import { Messages } from '../../../models/server'; +import { IMessage } from '../../../../definition/IMessage'; Meteor.methods({ getMessages(messages) { check(messages, [String]); + const uid = Meteor.userId(); - const msgs = Messages.findVisibleByIds(messages).fetch(); + if (!uid) { + throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'getMessages' }); + } + + const msgs = Messages.findVisibleByIds(messages).fetch() as IMessage[]; - const user = { _id: Meteor.userId() }; + const user = { _id: uid }; const rids = [...new Set(msgs.map((m) => m.rid))]; + if (!rids.every((_id) => canAccessRoom({ _id }, user))) { throw new Meteor.Error('error-not-allowed', 'Not allowed', { method: 'getSingleMessage' }); } diff --git a/app/lib/server/methods/getRoomJoinCode.js b/app/lib/server/methods/getRoomJoinCode.ts similarity index 77% rename from app/lib/server/methods/getRoomJoinCode.js rename to app/lib/server/methods/getRoomJoinCode.ts index da58b6b86e834..0776787a0a285 100644 --- a/app/lib/server/methods/getRoomJoinCode.js +++ b/app/lib/server/methods/getRoomJoinCode.ts @@ -1,8 +1,8 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { hasPermission } from '../../../authorization'; -import { Rooms } from '../../../models'; +import { hasPermission } from '../../../authorization/server'; +import { Rooms } from '../../../models/server'; Meteor.methods({ getRoomJoinCode(rid) { @@ -18,6 +18,6 @@ Meteor.methods({ const [room] = Rooms.findById(rid).fetch(); - return room && room.joinCode; + return room?.joinCode; }, }); diff --git a/app/lib/server/methods/getRoomRoles.js b/app/lib/server/methods/getRoomRoles.ts similarity index 89% rename from app/lib/server/methods/getRoomRoles.js rename to app/lib/server/methods/getRoomRoles.ts index 33b6ef34edad3..5b20c92849236 100644 --- a/app/lib/server/methods/getRoomRoles.js +++ b/app/lib/server/methods/getRoomRoles.ts @@ -1,7 +1,7 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { settings } from '../../../settings'; +import { settings } from '../../../settings/server'; import { getRoomRoles } from '../lib/getRoomRoles'; Meteor.methods({ diff --git a/app/lib/server/methods/getSingleMessage.js b/app/lib/server/methods/getSingleMessage.ts similarity index 70% rename from app/lib/server/methods/getSingleMessage.js rename to app/lib/server/methods/getSingleMessage.ts index 604ac2f1b4f70..ff5457a06657a 100644 --- a/app/lib/server/methods/getSingleMessage.js +++ b/app/lib/server/methods/getSingleMessage.ts @@ -8,13 +8,19 @@ Meteor.methods({ getSingleMessage(msgId) { check(msgId, String); + const uid = Meteor.userId(); + + if (!uid) { + throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'getSingleMessage' }); + } + const msg = Messages.findOneById(msgId); if (!msg || !msg.rid) { return undefined; } - if (!canAccessRoom({ _id: msg.rid }, { _id: Meteor.userId() })) { + if (!canAccessRoom({ _id: msg.rid }, { _id: uid })) { throw new Meteor.Error('error-not-allowed', 'Not allowed', { method: 'getSingleMessage' }); } diff --git a/app/lib/server/methods/getSlashCommandPreviews.js b/app/lib/server/methods/getSlashCommandPreviews.ts similarity index 93% rename from app/lib/server/methods/getSlashCommandPreviews.js rename to app/lib/server/methods/getSlashCommandPreviews.ts index a643593217354..2d8b7ce179b5f 100644 --- a/app/lib/server/methods/getSlashCommandPreviews.js +++ b/app/lib/server/methods/getSlashCommandPreviews.ts @@ -1,6 +1,6 @@ import { Meteor } from 'meteor/meteor'; -import { slashCommands } from '../../../utils'; +import { slashCommands } from '../../../utils/server'; Meteor.methods({ getSlashCommandPreviews(command) { diff --git a/app/lib/server/methods/joinDefaultChannels.js b/app/lib/server/methods/joinDefaultChannels.ts similarity index 100% rename from app/lib/server/methods/joinDefaultChannels.js rename to app/lib/server/methods/joinDefaultChannels.ts diff --git a/app/lib/server/methods/joinRoom.js b/app/lib/server/methods/joinRoom.ts similarity index 89% rename from app/lib/server/methods/joinRoom.js rename to app/lib/server/methods/joinRoom.ts index 9460f68cf6729..c4de0456dd393 100644 --- a/app/lib/server/methods/joinRoom.js +++ b/app/lib/server/methods/joinRoom.ts @@ -1,8 +1,8 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { hasPermission, canAccessRoom } from '../../../authorization'; -import { Rooms } from '../../../models'; +import { hasPermission, canAccessRoom } from '../../../authorization/server'; +import { Rooms } from '../../../models/server'; import { Tokenpass, updateUserTokenpassBalances } from '../../../tokenpass/server'; import { addUserToRoom } from '../functions'; import { roomTypes, RoomMemberActions } from '../../../utils/server'; @@ -11,7 +11,9 @@ Meteor.methods({ joinRoom(rid, code) { check(rid, String); - if (!Meteor.userId()) { + const user = Meteor.user(); + + if (!user) { throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'joinRoom' }); } @@ -26,7 +28,7 @@ Meteor.methods({ } // TODO we should have a 'beforeJoinRoom' call back so external services can do their own validations - const user = Meteor.user(); + if (room.tokenpass && user && user.services && user.services.tokenpass) { const balances = updateUserTokenpassBalances(user); @@ -34,10 +36,10 @@ Meteor.methods({ throw new Meteor.Error('error-not-allowed', 'Token required', { method: 'joinRoom' }); } } else { - if (!canAccessRoom(room, Meteor.user())) { + if (!canAccessRoom(room, user)) { throw new Meteor.Error('error-not-allowed', 'Not allowed', { method: 'joinRoom' }); } - if (room.joinCodeRequired === true && code !== room.joinCode && !hasPermission(Meteor.userId(), 'join-without-join-code')) { + if (room.joinCodeRequired === true && code !== room.joinCode && !hasPermission(user._id, 'join-without-join-code')) { throw new Meteor.Error('error-code-invalid', 'Invalid Room Password', { method: 'joinRoom', }); diff --git a/app/lib/server/methods/restartServer.js b/app/lib/server/methods/restartServer.ts similarity index 73% rename from app/lib/server/methods/restartServer.js rename to app/lib/server/methods/restartServer.ts index d694b833f746f..c530ee1b7afa2 100644 --- a/app/lib/server/methods/restartServer.js +++ b/app/lib/server/methods/restartServer.ts @@ -1,14 +1,17 @@ import { Meteor } from 'meteor/meteor'; -import { hasRole } from '../../../authorization'; +import { hasRole } from '../../../authorization/server'; Meteor.methods({ + // eslint-disable-next-line @typescript-eslint/camelcase restart_server() { - if (!Meteor.userId()) { + const uid = Meteor.userId(); + + if (!uid) { throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'restart_server' }); } - if (hasRole(Meteor.userId(), 'admin') !== true) { + if (hasRole(uid, 'admin') !== true) { throw new Meteor.Error('error-not-allowed', 'Not allowed', { method: 'restart_server' }); } diff --git a/app/lib/server/methods/setAdminStatus.js b/app/lib/server/methods/setAdminStatus.ts similarity index 76% rename from app/lib/server/methods/setAdminStatus.js rename to app/lib/server/methods/setAdminStatus.ts index 9ea6d5259d315..2f416fe8e6d77 100644 --- a/app/lib/server/methods/setAdminStatus.js +++ b/app/lib/server/methods/setAdminStatus.ts @@ -1,26 +1,28 @@ import { Meteor } from 'meteor/meteor'; import { Match, check } from 'meteor/check'; -import { hasPermission } from '../../../authorization'; +import { hasPermission } from '../../../authorization/server'; Meteor.methods({ setAdminStatus(userId, admin) { check(userId, String); check(admin, Match.Optional(Boolean)); - if (!Meteor.userId()) { + const uid = Meteor.userId(); + + if (!uid) { throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'setAdminStatus' }); } - if (hasPermission(Meteor.userId(), 'assign-admin-role') !== true) { + if (hasPermission(uid, 'assign-admin-role') !== true) { throw new Meteor.Error('error-not-allowed', 'Not allowed', { method: 'setAdminStatus' }); } const user = Meteor.users.findOne({ _id: userId }, { fields: { username: 1 } }); if (admin) { - return Meteor.call('authorization:addUserToRole', 'admin', user.username); + return Meteor.call('authorization:addUserToRole', 'admin', user?.username); } - return Meteor.call('authorization:removeUserFromRole', 'admin', user.username); + return Meteor.call('authorization:removeUserFromRole', 'admin', user?.username); }, }); diff --git a/app/lib/server/methods/setEmail.js b/app/lib/server/methods/setEmail.ts similarity index 92% rename from app/lib/server/methods/setEmail.js rename to app/lib/server/methods/setEmail.ts index 027e6418145c1..682f936defc7f 100644 --- a/app/lib/server/methods/setEmail.js +++ b/app/lib/server/methods/setEmail.ts @@ -1,7 +1,7 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { settings } from '../../../settings'; +import { settings } from '../../../settings/server'; import { setEmail } from '../functions'; import { RateLimiter } from '../lib'; @@ -9,12 +9,12 @@ Meteor.methods({ setEmail(email) { check(email, String); - if (!Meteor.userId()) { + const user = Meteor.user(); + + if (!user) { throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'setEmail' }); } - const user = Meteor.user(); - if (!settings.get('Accounts_AllowEmailChange')) { throw new Meteor.Error('error-action-not-allowed', 'Changing email is not allowed', { method: 'setEmail', diff --git a/app/lib/server/methods/setRealName.js b/app/lib/server/methods/setRealName.ts similarity index 93% rename from app/lib/server/methods/setRealName.js rename to app/lib/server/methods/setRealName.ts index 5f8301667a344..0ebc9ebb76bf8 100644 --- a/app/lib/server/methods/setRealName.js +++ b/app/lib/server/methods/setRealName.ts @@ -1,7 +1,7 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { settings } from '../../../settings'; +import { settings } from '../../../settings/server'; import { setRealName } from '../functions'; import { RateLimiter } from '../lib'; diff --git a/app/lib/server/methods/setUsername.js b/app/lib/server/methods/setUsername.ts similarity index 92% rename from app/lib/server/methods/setUsername.js rename to app/lib/server/methods/setUsername.ts index 91e1d60d6d86c..83ffee0bf2f96 100644 --- a/app/lib/server/methods/setUsername.js +++ b/app/lib/server/methods/setUsername.ts @@ -2,8 +2,8 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; import _ from 'underscore'; -import { settings } from '../../../settings'; -import { Users } from '../../../models'; +import { settings } from '../../../settings/server'; +import { Users } from '../../../models/server'; import { callbacks } from '../../../../lib/callbacks'; import { checkUsernameAvailability } from '../functions'; import { RateLimiter } from '../lib'; @@ -14,12 +14,12 @@ Meteor.methods({ const { joinDefaultChannelsSilenced } = param; check(username, String); - if (!Meteor.userId()) { + const user = Meteor.user(); + + if (!user) { throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'setUsername' }); } - const user = Meteor.user(); - if (user.username && !settings.get('Accounts_AllowUsernameChange')) { throw new Meteor.Error('error-not-allowed', 'Not allowed', { method: 'setUsername' }); } @@ -49,7 +49,7 @@ Meteor.methods({ }); } - if (!saveUserIdentity({ _id: user._id, username })) { + if (!saveUserIdentity({ _id: user?._id, username })) { throw new Meteor.Error('error-could-not-change-username', 'Could not change username', { method: 'setUsername', }); diff --git a/app/lib/server/methods/unarchiveRoom.js b/app/lib/server/methods/unarchiveRoom.ts similarity index 85% rename from app/lib/server/methods/unarchiveRoom.js rename to app/lib/server/methods/unarchiveRoom.ts index e584ce1044d3c..f0313b7a24cc5 100644 --- a/app/lib/server/methods/unarchiveRoom.js +++ b/app/lib/server/methods/unarchiveRoom.ts @@ -1,8 +1,8 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { hasPermission } from '../../../authorization'; -import { Rooms } from '../../../models'; +import { hasPermission } from '../../../authorization/server'; +import { Rooms } from '../../../models/server'; import { unarchiveRoom } from '../functions'; Meteor.methods({ diff --git a/app/lib/server/methods/unblockUser.js b/app/lib/server/methods/unblockUser.ts similarity index 92% rename from app/lib/server/methods/unblockUser.js rename to app/lib/server/methods/unblockUser.ts index 3b3522feebd89..4a4650e6fd40c 100644 --- a/app/lib/server/methods/unblockUser.js +++ b/app/lib/server/methods/unblockUser.ts @@ -1,7 +1,7 @@ import { Meteor } from 'meteor/meteor'; import { check } from 'meteor/check'; -import { Subscriptions } from '../../../models'; +import { Subscriptions } from '../../../models/server'; Meteor.methods({ unblockUser({ rid, blocked }) { diff --git a/app/ui-login/client/login/form.html b/app/ui-login/client/login/form.html index ef639ddc1719f..4c4a253104d93 100644 --- a/app/ui-login/client/login/form.html +++ b/app/ui-login/client/login/form.html @@ -126,7 +126,7 @@

{{{_ "Registration_Succeeded"}}}

{{/if}} {{#if registrationAllowed}} - + {{else}} {{#if linkReplacementText}}
diff --git a/app/ui-login/client/login/form.js b/app/ui-login/client/login/form.js index 5f9d4237d34e1..0bac266dc6b9d 100644 --- a/app/ui-login/client/login/form.js +++ b/app/ui-login/client/login/form.js @@ -35,7 +35,7 @@ Template.loginForm.helpers({ } switch (Template.instance().state.get()) { case 'register': - return t('Register'); + return t('Register_new_account'); case 'login': return t('Login'); case 'email-verification': diff --git a/app/utils/lib/slashCommand.d.ts b/app/utils/lib/slashCommand.d.ts index 43c9bbb11cde8..a21676baaf98f 100644 --- a/app/utils/lib/slashCommand.d.ts +++ b/app/utils/lib/slashCommand.d.ts @@ -10,6 +10,6 @@ export declare const slashCommands: { previewCallback: Function | undefined, ): void; run(command: string, params: string, message: object, triggerId: string | undefined): Function | void; - getPreviews(command: string, params: string, message: object, preview: unknown, triggerId: string | undefined): Function | void; + getPreviews(command: string, params: string, message: object, preview?: unknown, triggerId?: string | undefined): Function | void; executePreview(command: string, params: string, message: object, preview: unknown, triggerId: string | undefined): Function | void; }; diff --git a/app/utils/lib/slashCommand.js b/app/utils/lib/slashCommand.js index 67e72e36cf0ae..42d9dd5a53651 100644 --- a/app/utils/lib/slashCommand.js +++ b/app/utils/lib/slashCommand.js @@ -24,18 +24,25 @@ export const slashCommands = { return slashCommands.commands[command].callback(command, params, message, triggerId); } }, - getPreviews: function _executeSlashCommandPreview(command, params, message, preview, triggerId) { - if (slashCommands.commands[command] && typeof slashCommands.commands[command].previewCallback === 'function') { + getPreviews: function _gettingSlashCommandPreviews(command, params, message) { + if (slashCommands.commands[command] && typeof slashCommands.commands[command].previewer === 'function') { if (!message || !message.rid) { throw new Meteor.Error('invalid-command-usage', 'Executing a command requires at least a message with a room id.'); } - // { id, type, value } - if (!preview.id || !preview.type || !preview.value) { - throw new Meteor.Error('error-invalid-preview', 'Preview Item must have an id, type, and value.'); + // { i18nTitle, items: [{ id, type, value }] } + const previewInfo = slashCommands.commands[command].previewer(command, params, message); + + if (typeof previewInfo !== 'object' || !Array.isArray(previewInfo.items) || previewInfo.items.length === 0) { + return; } - return slashCommands.commands[command].previewCallback(command, params, message, preview, triggerId); + // A limit of ten results, to save time and bandwidth + if (previewInfo.items.length >= 10) { + previewInfo.items = previewInfo.items.slice(0, 10); + } + + return previewInfo; } }, executePreview: function _executeSlashCommandPreview(command, params, message, preview, triggerId) { diff --git a/client/components/Omnichannel/hooks/useAgentsList.ts b/client/components/Omnichannel/hooks/useAgentsList.ts index d280aa5a0df34..9e5dafad23976 100644 --- a/client/components/Omnichannel/hooks/useAgentsList.ts +++ b/client/components/Omnichannel/hooks/useAgentsList.ts @@ -1,6 +1,6 @@ import { useCallback, useState } from 'react'; -import { ILivechatAgentRecord } from '../../../../definition/ILivechatAgentRecord'; +import { ILivechatAgent } from '../../../../definition/ILivechatAgent'; import { useEndpoint } from '../../../contexts/ServerContext'; import { useTranslation } from '../../../contexts/TranslationContext'; import { useScrollableRecordList } from '../../../hooks/lists/useScrollableRecordList'; @@ -15,14 +15,14 @@ type AgentsListOptions = { export const useAgentsList = ( options: AgentsListOptions, ): { - itemsList: RecordList; + itemsList: RecordList; initialItemCount: number; reload: () => void; loadMoreItems: (start: number, end: number) => void; } => { const t = useTranslation(); - const [itemsList, setItemsList] = useState(() => new RecordList()); - const reload = useCallback(() => setItemsList(new RecordList()), []); + const [itemsList, setItemsList] = useState(() => new RecordList()); + const reload = useCallback(() => setItemsList(new RecordList()), []); const endpoint = 'livechat/users/agent'; const getAgents = useEndpoint('GET', endpoint); diff --git a/client/lib/oauthRedirectUri.ts b/client/lib/oauthRedirectUri.ts new file mode 100644 index 0000000000000..447340588891e --- /dev/null +++ b/client/lib/oauthRedirectUri.ts @@ -0,0 +1,16 @@ +import { OAuth } from 'meteor/oauth'; + +const { _redirectUri } = OAuth; + +OAuth._redirectUri = (serviceName: string, config: any, params: unknown, absoluteUrlOptions: unknown): string => { + const ret = _redirectUri(serviceName, config, params, absoluteUrlOptions); + + // DEPRECATED: Remove in v5.0.0 + // Meteor 2.3 removed ?close from redirect uri so we need to add it back to not break old oauth clients + // https://github.com/meteor/meteor/commit/b5b7306bedc3e8eb241e64efb1e281925aa75dd3#diff-59244f4e0176cb1beed2e287924e97dc7ae2c0cc51494ce121a85d8937d116a5L11 + if (!config?.loginStyle && !ret.includes('close')) { + return `${ret + (ret.includes('?') ? '&' : '?')}close`; + } + + return ret; +}; diff --git a/client/main.ts b/client/main.ts index e08f775af7dee..eae3b5ade5fae 100644 --- a/client/main.ts +++ b/client/main.ts @@ -1,6 +1,7 @@ import '../ee/client/ecdh'; import './polyfills'; +import './lib/oauthRedirectUri'; import './lib/meteorCallWrapper'; import './importPackages'; diff --git a/client/startup/oauth.ts b/client/startup/oauth.ts index 7be58ef055dfe..23f5ec8246b46 100644 --- a/client/startup/oauth.ts +++ b/client/startup/oauth.ts @@ -1,5 +1,4 @@ import { Meteor } from 'meteor/meteor'; -// @ts-ignore #ToDo: Add definitions for meteor/oauth import { OAuth } from 'meteor/oauth'; // OAuth._retrieveCredentialSecret is a meteor method modified to also check the global localStorage @@ -8,7 +7,7 @@ import { OAuth } from 'meteor/oauth'; Meteor.startup(() => { const meteorOAuthRetrieveCredentialSecret = OAuth._retrieveCredentialSecret; - OAuth._retrieveCredentialSecret = (credentialToken: string): string | undefined => { + OAuth._retrieveCredentialSecret = (credentialToken: string): string | null => { let secret = meteorOAuthRetrieveCredentialSecret.call(OAuth, credentialToken); if (!secret) { const localStorageKey = `${OAuth._storageTokenPrefix}${credentialToken}`; diff --git a/client/views/admin/apps/CloudLoginModal.tsx b/client/views/admin/apps/CloudLoginModal.tsx index d82f093f944f3..35a069e3a82d2 100644 --- a/client/views/admin/apps/CloudLoginModal.tsx +++ b/client/views/admin/apps/CloudLoginModal.tsx @@ -1,47 +1,35 @@ -import { Button, ButtonGroup, Icon, Modal } from '@rocket.chat/fuselage'; -import React from 'react'; +import React, { ReactElement } from 'react'; +import GenericModal from '../../../components/GenericModal'; import { useSetModal } from '../../../contexts/ModalContext'; import { useRoute } from '../../../contexts/RouterContext'; import { useTranslation } from '../../../contexts/TranslationContext'; -const CloudLoginModal = (): JSX.Element => { +const CloudLoginModal = (): ReactElement => { const t = useTranslation(); const setModal = useSetModal(); const cloudRoute = useRoute('cloud'); - const handleCloseButtonClick = (): void => { - setModal(null); + const handleCancel = (): void => { + setModal(undefined); }; - const handleCancelButtonClick = (): void => { - setModal(null); - }; - - const handleLoginButtonClick = (): void => { + const handleLogin = (): void => { cloudRoute.push(); - setModal(null); + setModal(undefined); }; return ( - - - - {t('Apps_Marketplace_Login_Required_Title')} - - - {t('Apps_Marketplace_Login_Required_Description')} - - - - - - - + + {t('Apps_Marketplace_Login_Required_Description')} + ); }; diff --git a/client/views/setupWizard/contexts/SetupWizardContext.tsx b/client/views/setupWizard/contexts/SetupWizardContext.tsx index 9d3ec4afcaee9..4ea9f9a704ffc 100644 --- a/client/views/setupWizard/contexts/SetupWizardContext.tsx +++ b/client/views/setupWizard/contexts/SetupWizardContext.tsx @@ -24,7 +24,7 @@ type SetupWizarContextValue = { settings: Array; currentStep: number; validateEmail: (email: string) => string | true; - canDeclineServerRegistration: boolean; + skipCloudRegistration: boolean; goToPreviousStep: () => void; goToNextStep: () => void; goToStep: (step: number) => void; @@ -32,6 +32,8 @@ type SetupWizarContextValue = { registerServer: (params: { email: string; resend?: boolean }) => Promise; saveWorkspaceData: () => Promise; saveOrganizationData: () => Promise; + completeSetupWizard: () => Promise; + maxSteps: number; }; export const SetupWizardContext = createContext({ @@ -56,7 +58,7 @@ export const SetupWizardContext = createContext({ setSetupWizardData: (data: {}) => data, loaded: false, settings: [], - canDeclineServerRegistration: false, + skipCloudRegistration: false, goToPreviousStep: () => undefined, goToNextStep: () => undefined, goToStep: () => undefined, @@ -66,6 +68,8 @@ export const SetupWizardContext = createContext({ saveOrganizationData: async () => undefined, validateEmail: () => true, currentStep: 1, + completeSetupWizard: async () => undefined, + maxSteps: 4, }); export const useSetupWizardContext = (): SetupWizarContextValue => useContext(SetupWizardContext); diff --git a/client/views/setupWizard/hooks/useParameters.ts b/client/views/setupWizard/hooks/useParameters.ts index dd5b462354fbc..bf13cb07a2369 100644 --- a/client/views/setupWizard/hooks/useParameters.ts +++ b/client/views/setupWizard/hooks/useParameters.ts @@ -6,30 +6,30 @@ import { useMethod } from '../../../contexts/ServerContext'; export const useParameters = (): { loaded: boolean; settings: Array; - canDeclineServerRegistration: boolean; + skipCloudRegistration: boolean; } => { const [loaded, setLoaded] = useState(false); const [settings, setSettings] = useState>([]); - const [canDeclineServerRegistration, setCapableOfDeclineServerRegistration] = useState(false); + const [skipCloudRegistration, setSkipCloudRegistration] = useState(false); const getSetupWizardParameters = useMethod('getSetupWizardParameters'); useEffect(() => { let mounted = true; const requestParameters = async (): Promise => { try { - const { settings = [], allowStandaloneServer = false } = (await getSetupWizardParameters()) || {}; + const { setupWizardSettings = [], serverAlreadyRegistered = false } = (await getSetupWizardParameters()) || {}; if (!mounted) { return; } setLoaded(true); - setSettings(settings); - setCapableOfDeclineServerRegistration(allowStandaloneServer); + setSettings(setupWizardSettings); + setSkipCloudRegistration(serverAlreadyRegistered); } catch (error) { setLoaded(false); setSettings([]); - setCapableOfDeclineServerRegistration(false); + setSkipCloudRegistration(false); } }; @@ -43,6 +43,6 @@ export const useParameters = (): { return { loaded, settings, - canDeclineServerRegistration, + skipCloudRegistration, }; }; diff --git a/client/views/setupWizard/providers/SetupWizardProvider.tsx b/client/views/setupWizard/providers/SetupWizardProvider.tsx index 477cad93cb0e7..1f9dd061216c7 100644 --- a/client/views/setupWizard/providers/SetupWizardProvider.tsx +++ b/client/views/setupWizard/providers/SetupWizardProvider.tsx @@ -6,7 +6,7 @@ import { callbacks } from '../../../../lib/callbacks'; import { validateEmail } from '../../../../lib/emailValidator'; import { useMethod, useEndpoint } from '../../../contexts/ServerContext'; import { useSessionDispatch } from '../../../contexts/SessionContext'; -import { useSettingSetValue, useSetting, useSettingsDispatch } from '../../../contexts/SettingsContext'; +import { useSettingSetValue, useSettingsDispatch } from '../../../contexts/SettingsContext'; import { useToastMessageDispatch } from '../../../contexts/ToastMessagesContext'; import { useTranslation } from '../../../contexts/TranslationContext'; import { useLoginWithPassword, useUserId } from '../../../contexts/UserContext'; @@ -36,36 +36,32 @@ const initialData: ContextType['setupWizardData'] = { type HandleRegisterServer = (params: { email: string; resend?: boolean }) => Promise; const SetupWizardProvider = ({ children }: { children: ReactElement }): ReactElement => { + const t = useTranslation(); + const userId = useUserId(); const [setupWizardData, setSetupWizardData] = useState['setupWizardData']>(initialData); const [currentStep, setCurrentStep] = useStepRouting(); - const { loaded, settings, canDeclineServerRegistration } = useParameters(); - + const { loaded, settings, skipCloudRegistration } = useParameters(); const dispatchToastMessage = useToastMessageDispatch(); const dispatchSettings = useSettingsDispatch(); - const setShowSetupWizard = useSettingSetValue('Show_Setup_Wizard'); - const cloudEmail = useSetting('Organization_mail') as string; - const t = useTranslation(); + const [maxSteps, setMaxSteps] = useState(4); + const setShowSetupWizard = useSettingSetValue('Show_Setup_Wizard'); const registerUser = useMethod('registerUser'); const defineUsername = useMethod('setUsername'); - - const userId = useUserId(); const loginWithPassword = useLoginWithPassword(); const setForceLogin = useSessionDispatch('forceLogin'); - const createRegistrationIntent = useEndpoint('POST', 'cloud.createRegistrationIntent'); - useEffect(() => { - setSetupWizardData((prev) => ({ - ...prev, - registrationData: { ...prev.registrationData, cloudEmail }, - })); - }, [cloudEmail]); - const goToPreviousStep = useCallback(() => setCurrentStep((currentStep) => currentStep - 1), [setCurrentStep]); const goToNextStep = useCallback(() => setCurrentStep((currentStep) => currentStep + 1), [setCurrentStep]); const goToStep = useCallback((step) => setCurrentStep(() => step), [setCurrentStep]); + useEffect(() => { + if (skipCloudRegistration) { + return setMaxSteps(2); + } + }, [skipCloudRegistration]); + const _validateEmail = useCallback( (email: string): true | string => { if (!validateEmail(email)) { @@ -191,6 +187,13 @@ const SetupWizardProvider = ({ children }: { children: ReactElement }): ReactEle } }); + const completeSetupWizard = useMutableCallback(async (): Promise => { + await registerAdminUser(); + await saveOrganizationData(); + dispatchToastMessage({ type: 'success', message: t('Your_workspace_is_ready') }); + return setShowSetupWizard('completed'); + }); + const value = useMemo( () => ({ setupWizardData, @@ -198,7 +201,7 @@ const SetupWizardProvider = ({ children }: { children: ReactElement }): ReactEle currentStep, loaded, settings, - canDeclineServerRegistration, + skipCloudRegistration, goToPreviousStep, goToNextStep, goToStep, @@ -207,6 +210,8 @@ const SetupWizardProvider = ({ children }: { children: ReactElement }): ReactEle registerServer, saveWorkspaceData, saveOrganizationData, + completeSetupWizard, + maxSteps, }), [ setupWizardData, @@ -215,7 +220,7 @@ const SetupWizardProvider = ({ children }: { children: ReactElement }): ReactEle loaded, registerAdminUser, settings, - canDeclineServerRegistration, + skipCloudRegistration, goToPreviousStep, goToNextStep, goToStep, @@ -223,6 +228,8 @@ const SetupWizardProvider = ({ children }: { children: ReactElement }): ReactEle registerServer, saveWorkspaceData, saveOrganizationData, + completeSetupWizard, + maxSteps, ], ); diff --git a/client/views/setupWizard/steps/AdminInfoStep.tsx b/client/views/setupWizard/steps/AdminInfoStep.tsx index 76cac6ce79c75..b6f10b56b0f0e 100644 --- a/client/views/setupWizard/steps/AdminInfoStep.tsx +++ b/client/views/setupWizard/steps/AdminInfoStep.tsx @@ -16,6 +16,7 @@ const AdminInfoStep = (): ReactElement => { goToNextStep, currentStep, validateEmail, + maxSteps, } = useSetupWizardContext(); // TODO: check if username exists @@ -40,7 +41,7 @@ const AdminInfoStep = (): ReactElement => { validateEmail={validateEmail} currentStep={currentStep} initialValues={adminData} - stepCount={4} + stepCount={maxSteps} onSubmit={handleSubmit} /> ); diff --git a/client/views/setupWizard/steps/OrganizationInfoStep.tsx b/client/views/setupWizard/steps/OrganizationInfoStep.tsx index 815f7ae3b8e43..6158f3a2c56a0 100644 --- a/client/views/setupWizard/steps/OrganizationInfoStep.tsx +++ b/client/views/setupWizard/steps/OrganizationInfoStep.tsx @@ -32,7 +32,10 @@ const OrganizationInfoStep = (): ReactElement => { settings, goToPreviousStep, goToNextStep, + completeSetupWizard, currentStep, + skipCloudRegistration, + maxSteps, } = useSetupWizardContext(); const countryOptions = getSettingOptions(settings, 'Country', t); @@ -41,6 +44,9 @@ const OrganizationInfoStep = (): ReactElement => { const organizationSizeOptions = getSettingOptions(settings, 'Size', t); const handleSubmit: ComponentProps['onSubmit'] = async (data) => { + if (skipCloudRegistration) { + return completeSetupWizard(); + } setSetupWizardData((prevState) => ({ ...prevState, organizationData: data })); goToNextStep(); }; @@ -51,11 +57,12 @@ const OrganizationInfoStep = (): ReactElement => { onSubmit={handleSubmit} onBackButtonClick={goToPreviousStep} currentStep={currentStep} - stepCount={4} + stepCount={maxSteps} organizationTypeOptions={organizationTypeOptions} organizationIndustryOptions={organizationIndustryOptions} organizationSizeOptions={organizationSizeOptions} countryOptions={countryOptions} + nextStep={skipCloudRegistration ? t('Register') : undefined} /> ); }; diff --git a/client/views/setupWizard/steps/RegisterServerStep.tsx b/client/views/setupWizard/steps/RegisterServerStep.tsx index 84971d64bb0a2..c866032078b61 100644 --- a/client/views/setupWizard/steps/RegisterServerStep.tsx +++ b/client/views/setupWizard/steps/RegisterServerStep.tsx @@ -11,6 +11,7 @@ const RegisterServerStep = (): ReactElement => { setSetupWizardData, setupWizardData: { adminData }, registerServer, + maxSteps, } = useSetupWizardContext(); const handleSubmit: ComponentProps['onSubmit'] = async (data) => { @@ -24,7 +25,7 @@ const RegisterServerStep = (): ReactElement => { { - const { goToPreviousStep, currentStep, registerAdminUser, saveOrganizationData } = useSetupWizardContext(); - const setShowSetupWizard = useSettingSetValue('Show_Setup_Wizard'); - const dispatchToastMessage = useToastMessageDispatch(); - const t = useTranslation(); + const { goToPreviousStep, currentStep, completeSetupWizard, maxSteps } = useSetupWizardContext(); const handleConfirmStandalone: ComponentProps['onSubmit'] = async ({ registerType }) => { if (registerType !== 'registered') { - await registerAdminUser(); - await saveOrganizationData(); - dispatchToastMessage({ type: 'success', message: t('Your_workspace_is_ready') }); - return setShowSetupWizard('completed'); + return completeSetupWizard(); } }; return ( - + ); }; diff --git a/definition/ILivechatAgent.ts b/definition/ILivechatAgent.ts index a6f6d24542601..f9ba0a4a33c26 100644 --- a/definition/ILivechatAgent.ts +++ b/definition/ILivechatAgent.ts @@ -1,8 +1,16 @@ -export interface ILivechatAgent { - _id: string; - emails: { adress: string; verified: boolean }; - status: string; - name: string; - username: string; - statusLivechat: string; +import { IUser } from './IUser'; + +export enum ILivechatAgentStatus { + AVAILABLE = 'available', + UNAVAILABLE = 'unavailable', +} + +export interface ILivechatAgent extends IUser { + statusLivechat: ILivechatAgentStatus; + livechat: { + maxNumberSimultaneousChat: number; + }; + livechatCount: number; + lastRoutingTime: Date; + livechatStatusSystemModified?: boolean; } diff --git a/definition/ILivechatAgentRecord.ts b/definition/ILivechatAgentRecord.ts deleted file mode 100644 index 897a2a90d878e..0000000000000 --- a/definition/ILivechatAgentRecord.ts +++ /dev/null @@ -1,16 +0,0 @@ -import { IRocketChatRecord } from './IRocketChatRecord'; - -export interface ILivechatAgentRecord extends IRocketChatRecord { - _id: string; - emails: { - address: string; - verified: boolean; - }[]; - status: string; - name: string; - username: string; - statusLivechat: string; - livechat: { - maxNumberSimultaneousChat: number; - }; -} diff --git a/definition/externals/meteor/accounts-base.d.ts b/definition/externals/meteor/accounts-base.d.ts index 885d0ba385730..8f625c007331e 100644 --- a/definition/externals/meteor/accounts-base.d.ts +++ b/definition/externals/meteor/accounts-base.d.ts @@ -8,6 +8,8 @@ declare module 'meteor/accounts-base' { function _generateStampedLoginToken(): { token: string; when: Date }; + function _insertLoginToken(userId: string, token: { token: string; when: Date }): void; + function _runLoginHandlers(methodInvocation: Function, loginRequest: Record): Record | undefined; export class ConfigError extends Error {} diff --git a/definition/externals/meteor/oauth.d.ts b/definition/externals/meteor/oauth.d.ts new file mode 100644 index 0000000000000..67780bcbdb350 --- /dev/null +++ b/definition/externals/meteor/oauth.d.ts @@ -0,0 +1,7 @@ +declare module 'meteor/oauth' { + namespace OAuth { + function _redirectUri(serviceName: string, config: any, params: any, absoluteUrlOptions: any): string; + function _retrieveCredentialSecret(credentialToken: string): string | null; + const _storageTokenPrefix: string; + } +} diff --git a/definition/rest/v1/omnichannel.ts b/definition/rest/v1/omnichannel.ts index 07d14ae8a71ae..075c531820bcc 100644 --- a/definition/rest/v1/omnichannel.ts +++ b/definition/rest/v1/omnichannel.ts @@ -92,6 +92,11 @@ export type OmnichannelEndpoints = { departments: ILivechatDepartment[]; }>; }; + + 'livechat/department.listByIds': { + GET: (params: { ids: string[]; fields?: Record }) => { departments: ILivechatDepartment[] }; + }; + 'livechat/custom-fields': { GET: (params: PaginatedRequest<{ text: string }>) => PaginatedResult<{ customFields: [ diff --git a/ee/client/audit/Result.js b/ee/client/audit/Result.js index 36d2a15906223..a71a27a4f55d7 100644 --- a/ee/client/audit/Result.js +++ b/ee/client/audit/Result.js @@ -39,4 +39,6 @@ const Result = memo(({ setDataRef }) => { return ; }); +Result.displayName = 'Result'; + export default Result; diff --git a/ee/client/hooks/useAgentsList.ts b/ee/client/hooks/useAgentsList.ts index 7a177f9e8747c..b120dc9489e7b 100644 --- a/ee/client/hooks/useAgentsList.ts +++ b/ee/client/hooks/useAgentsList.ts @@ -4,7 +4,7 @@ import { useEndpoint } from '../../../client/contexts/ServerContext'; import { useScrollableRecordList } from '../../../client/hooks/lists/useScrollableRecordList'; import { useComponentDidUpdate } from '../../../client/hooks/useComponentDidUpdate'; import { RecordList } from '../../../client/lib/lists/RecordList'; -import { ILivechatAgentRecord } from '../../../definition/ILivechatAgentRecord'; +import { ILivechatAgent } from '../../../definition/ILivechatAgent'; type AgentsListOptions = { filter: string; @@ -13,13 +13,13 @@ type AgentsListOptions = { export const useAgentsList = ( options: AgentsListOptions, ): { - itemsList: RecordList; + itemsList: RecordList; initialItemCount: number; reload: () => void; loadMoreItems: (start: number, end: number) => void; } => { - const [itemsList, setItemsList] = useState(() => new RecordList()); - const reload = useCallback(() => setItemsList(new RecordList()), []); + const [itemsList, setItemsList] = useState(() => new RecordList()); + const reload = useCallback(() => setItemsList(new RecordList()), []); const getAgents = useEndpoint('GET', 'livechat/users/agent'); diff --git a/ee/client/omnichannel/tags/TagEdit.js b/ee/client/omnichannel/tags/TagEdit.js index 48f900be01711..d8e7f50bd8b6a 100644 --- a/ee/client/omnichannel/tags/TagEdit.js +++ b/ee/client/omnichannel/tags/TagEdit.js @@ -10,7 +10,7 @@ import { useToastMessageDispatch } from '../../../../client/contexts/ToastMessag import { useTranslation } from '../../../../client/contexts/TranslationContext'; import { useForm } from '../../../../client/hooks/useForm'; -function TagEdit({ title, data, tagId, isNew, reload, currentDepartments, ...props }) { +function TagEdit({ title, data, tagId, reload, currentDepartments, ...props }) { const t = useTranslation(); const tagsRoute = useRoute('omnichannel-tags'); diff --git a/ee/client/omnichannel/tags/TagEditWithData.js b/ee/client/omnichannel/tags/TagEditWithData.js index edcf266e86ffa..516ba2f7265b8 100644 --- a/ee/client/omnichannel/tags/TagEditWithData.js +++ b/ee/client/omnichannel/tags/TagEditWithData.js @@ -8,7 +8,7 @@ import { useEndpointData } from '../../../../client/hooks/useEndpointData'; import TagEdit from './TagEdit'; import TagEditWithDepartmentData from './TagEditWithDepartmentData'; -function TagEditWithData({ tagId, reload }) { +function TagEditWithData({ tagId, reload, title }) { const query = useMemo(() => ({ tagId }), [tagId]); const { value: data, phase: state, error } = useEndpointData('livechat/tags.getOne', query); @@ -29,9 +29,9 @@ function TagEditWithData({ tagId, reload }) { return ( <> {data && data.departments && data.departments.length > 0 ? ( - + ) : ( - + )} ); diff --git a/ee/client/omnichannel/tags/TagEditWithDepartmentData.js b/ee/client/omnichannel/tags/TagEditWithDepartmentData.tsx similarity index 60% rename from ee/client/omnichannel/tags/TagEditWithDepartmentData.js rename to ee/client/omnichannel/tags/TagEditWithDepartmentData.tsx index a4d5731ace58b..138f6a986c839 100644 --- a/ee/client/omnichannel/tags/TagEditWithDepartmentData.js +++ b/ee/client/omnichannel/tags/TagEditWithDepartmentData.tsx @@ -1,13 +1,21 @@ import { Callout } from '@rocket.chat/fuselage'; -import React, { useMemo } from 'react'; +import React, { ReactElement, useMemo, ReactNode } from 'react'; import { FormSkeleton } from '../../../../client/components/Skeleton'; import { useTranslation } from '../../../../client/contexts/TranslationContext'; import { AsyncStatePhase } from '../../../../client/hooks/useAsyncState'; import { useEndpointData } from '../../../../client/hooks/useEndpointData'; +import { ILivechatTag } from '../../../../definition/ILivechatTag'; import TagEdit from './TagEdit'; -function TagEditWithDepartmentData({ data, ...props }) { +type TagEditWithDepartmentDataPropsType = { + data: ILivechatTag; + title: ReactNode; + tagId: ILivechatTag['_id']; + reload: () => void; +}; + +function TagEditWithDepartmentData({ data, title, ...props }: TagEditWithDepartmentDataPropsType): ReactElement { const t = useTranslation(); const { @@ -16,7 +24,7 @@ function TagEditWithDepartmentData({ data, ...props }) { error: currentDepartmentsError, } = useEndpointData( 'livechat/department.listByIds', - useMemo(() => ({ ids: data && data.departments ? data.departments : [] }), [data]), + useMemo(() => ({ ids: data?.departments ? data.departments : [] }), [data]), ); if ([currentDepartmentsState].includes(AsyncStatePhase.LOADING)) { @@ -31,7 +39,7 @@ function TagEditWithDepartmentData({ data, ...props }) { ); } - return ; + return ; } export default TagEditWithDepartmentData; diff --git a/packages/rocketchat-i18n/i18n/en.i18n.json b/packages/rocketchat-i18n/i18n/en.i18n.json index a21e027d8ffce..71357c49601dd 100644 --- a/packages/rocketchat-i18n/i18n/en.i18n.json +++ b/packages/rocketchat-i18n/i18n/en.i18n.json @@ -3480,7 +3480,8 @@ "Refresh_your_page_after_install_to_enable_screen_sharing": "Refresh your page after install to enable screen sharing", "Regenerate_codes": "Regenerate codes", "Regexp_validation": "Validation by regular expression", - "Register": "Register a new account", + "Register": "Register", + "Register_new_account": "Register a new account", "Register_Server": "Register Server", "Register_Server_Info": "Use the preconfigured gateways and proxies provided by Rocket.Chat Technologies Corp.", "Register_Server_Opt_In": "Product and Security Updates", diff --git a/server/methods/getSetupWizardParameters.js b/server/methods/getSetupWizardParameters.js index 22e018e8765c5..69993359c70a5 100644 --- a/server/methods/getSetupWizardParameters.js +++ b/server/methods/getSetupWizardParameters.js @@ -1,15 +1,16 @@ import { Meteor } from 'meteor/meteor'; import { Settings } from '../../app/models'; +import { settings } from '../../app/settings/server'; Meteor.methods({ getSetupWizardParameters() { - const settings = Settings.findSetupWizardSettings().fetch(); - const allowStandaloneServer = process.env.DEPLOY_PLATFORM !== 'rocket-cloud'; + const setupWizardSettings = Settings.findSetupWizardSettings().fetch(); + const serverAlreadyRegistered = !!settings.get('Cloud_Workspace_Client_Id') || process.env.DEPLOY_PLATFORM === 'rocket-cloud'; return { - settings, - allowStandaloneServer, + setupWizardSettings, + serverAlreadyRegistered, }; }, }); diff --git a/server/startup/migrations/index.ts b/server/startup/migrations/index.ts index 5be02fd851df6..f87385facdcda 100644 --- a/server/startup/migrations/index.ts +++ b/server/startup/migrations/index.ts @@ -77,4 +77,5 @@ import './v250'; import './v251'; import './v252'; import './v253'; +import './v254'; import './xrun'; diff --git a/server/startup/migrations/v254.ts b/server/startup/migrations/v254.ts new file mode 100644 index 0000000000000..c9abebd67ed47 --- /dev/null +++ b/server/startup/migrations/v254.ts @@ -0,0 +1,13 @@ +import { addMigration } from '../../lib/migrations'; +import { Users, Rooms } from '../../../app/models/server'; + +addMigration({ + version: 254, + up() { + Users.tryDropIndex({ bio: 1 }); + Users.tryEnsureIndex({ bio: 1 }, { unique: 1 }); + + Rooms.tryDropIndex({ prid: 1 }); + Rooms.tryEnsureIndex({ prid: 1 }, { sparse: true }); + }, +});