import { IMessage, INotificationPreferences, IPreviewItem, IRoom, IRoomNotifications, SubscriptionType, IUser, TRocketChat } from '../../../definitions'; import { IAvatarSuggestion, IParams } from '../../../definitions/IProfileViewInterfaces'; import { ISpotlight } from '../../../definitions/ISpotlight'; import { TEAM_TYPE } from '../../../definitions/ITeam'; import { Encryption } from '../../encryption'; import { TParams } from '../../../definitions/ILivechatEditView'; import { store as reduxStore } from '../../auxStore'; import { getDeviceToken } from '../../../notifications/push'; import { compareServerVersion } from '../../utils'; import roomTypeToApiType, { RoomTypes } from '../methods/roomTypeToApiType'; import sdk from './sdk'; export const createChannel = ({ name, users, type, readOnly, broadcast, encrypted, teamId }: { name: string; users: string[]; type: boolean; readOnly: boolean; broadcast: boolean; encrypted: boolean; teamId: string; }) => { const params = { name, members: users, readOnly, extraData: { broadcast, encrypted, ...(teamId && { teamId }) } }; return sdk.post(type ? 'groups.create' : 'channels.create', params); }; export const e2eSetUserPublicAndPrivateKeys = (public_key: string, private_key: string) => // RC 2.2.0 sdk.post('e2e.setUserPublicAndPrivateKeys', { public_key, private_key }); export const e2eRequestSubscriptionKeys = (): Promise => // RC 0.72.0 sdk.methodCallWrapper('e2e.requestSubscriptionKeys'); export const e2eGetUsersOfRoomWithoutKey = (rid: string) => // RC 0.70.0 sdk.get('e2e.getUsersOfRoomWithoutKey', { rid }); export const e2eSetRoomKeyID = (rid: string, keyID: string) => // RC 0.70.0 sdk.post('e2e.setRoomKeyID', { rid, keyID }); export const e2eUpdateGroupKey = (uid: string, rid: string, key: string): any => // RC 0.70.0 sdk.post('e2e.updateGroupKey', { uid, rid, key }); export const e2eRequestRoomKey = (rid: string, e2eKeyId: string): Promise<{ message: { msg?: string }; success: boolean }> => // RC 0.70.0 sdk.methodCallWrapper('stream-notify-room-users', `${rid}/e2ekeyRequest`, rid, e2eKeyId); export const updateJitsiTimeout = (roomId: string) => // RC 0.74.0 sdk.post('video-conference/jitsi.update-timeout', { roomId }); export const register = (credentials: { name: string; email: string; pass: string; username: string }) => // RC 0.50.0 sdk.post('users.register', credentials); export const forgotPassword = (email: string) => // RC 0.64.0 sdk.post('users.forgotPassword', { email }); export const sendConfirmationEmail = (email: string): Promise<{ message: string; success: boolean }> => sdk.methodCallWrapper('sendConfirmationEmail', email); export const spotlight = (search: string, usernames: string[], type: { users: boolean; rooms: boolean }): Promise => // RC 0.51.0 sdk.methodCallWrapper('spotlight', search, usernames, type); export const createDirectMessage = (username: string) => // RC 0.59.0 sdk.post('im.create', { username }); export const createDiscussion = ({ prid, pmid, t_name, reply, users, encrypted }: { prid: string; pmid?: string; t_name: string; reply?: string; users?: string[]; encrypted?: boolean; }) => // RC 1.0.0 sdk.post('rooms.createDiscussion', { prid, pmid, t_name, reply, users, encrypted }); export const getDiscussions = ({ roomId, offset, count, text }: { roomId: string; text?: string | undefined; offset: number; count: number; }) => { const params = { roomId, offset, count, ...(text && { text }) }; // RC 2.4.0 return sdk.get('chat.getDiscussions', params); }; export const createTeam = ({ name, users, type, readOnly, broadcast, encrypted }: { name: string; users: string[]; type: boolean; readOnly: boolean; broadcast: boolean; encrypted: boolean; }) => { const params = { name, users, type: type ? TEAM_TYPE.PRIVATE : TEAM_TYPE.PUBLIC, room: { readOnly, extraData: { broadcast, encrypted } } }; // RC 3.13.0 return sdk.post('teams.create', params); }; export const addRoomsToTeam = ({ teamId, rooms }: { teamId: string; rooms: string[] }) => // RC 3.13.0 sdk.post('teams.addRooms', { teamId, rooms }); export const removeTeamRoom = ({ roomId, teamId }: { roomId: string; teamId: string }) => // RC 3.13.0 sdk.post('teams.removeRoom', { roomId, teamId }); export const leaveTeam = ({ teamId, rooms }: { teamId: string; rooms: string[] }): any => // RC 3.13.0 // TODO: missing definitions from server // @ts-ignore sdk.post('teams.leave', { teamId, // RC 4.2.0 ...(rooms?.length && { rooms }) }); export const removeTeamMember = ({ teamId, userId, rooms }: { teamId: string; userId: string; rooms: string[] }) => // RC 3.13.0 sdk.post('teams.removeMember', { teamId, userId, // RC 4.2.0 ...(rooms?.length && { rooms }) }); export const updateTeamRoom = ({ roomId, isDefault }: { roomId: string; isDefault: boolean }) => // RC 3.13.0 sdk.post('teams.updateRoom', { roomId, isDefault }); export const deleteTeam = ({ teamId, roomsToRemove }: { teamId: string; roomsToRemove: string[] }): any => // RC 3.13.0 // TODO: missing definitions from server // @ts-ignore sdk.post('teams.delete', { teamId, roomsToRemove }); export const teamListRoomsOfUser = ({ teamId, userId }: { teamId: string; userId: string }) => // RC 3.13.0 sdk.get('teams.listRoomsOfUser', { teamId, userId }); export const convertChannelToTeam = ({ rid, name, type }: { rid: string; name: string; type: 'c' | 'p' }) => { const params = { ...(type === 'c' ? { channelId: rid, channelName: name } : { roomId: rid, roomName: name }) }; return sdk.post(type === 'c' ? 'channels.convertToTeam' : 'groups.convertToTeam', params); }; export const convertTeamToChannel = ({ teamId, selected }: { teamId: string; selected: string[] }) => { const params = { teamId, ...(selected.length && { roomsToRemove: selected }) }; return sdk.post('teams.convertToChannel', params); }; export const joinRoom = (roomId: string, joinCode: string | null, type: 'c' | 'p') => { // RC 0.48.0 if (type === 'p') { return sdk.methodCallWrapper('joinRoom', roomId) as Promise; } return sdk.post('channels.join', { roomId, joinCode }); }; export const deleteMessage = (messageId: string, rid: string) => // RC 0.48.0 sdk.post('chat.delete', { msgId: messageId, roomId: rid }); export const markAsUnread = ({ messageId }: { messageId: string }) => // RC 0.65.0 sdk.post('subscriptions.unread', { firstUnreadMessage: { _id: messageId } }); export const toggleStarMessage = (messageId: string, starred: boolean) => { if (starred) { // RC 0.59.0 return sdk.post('chat.unStarMessage', { messageId }); } // RC 0.59.0 return sdk.post('chat.starMessage', { messageId }); }; export const togglePinMessage = (messageId: string, pinned: boolean) => { if (pinned) { // RC 0.59.0 return sdk.post('chat.unPinMessage', { messageId }); } // RC 0.59.0 return sdk.post('chat.pinMessage', { messageId }); }; export const reportMessage = (messageId: string) => // RC 0.64.0 sdk.post('chat.reportMessage', { messageId, description: 'Message reported by user' }); export const setUserPreferences = (userId: string, data: Partial) => // RC 0.62.0 sdk.post('users.setPreferences', { userId, data }); export const setUserStatus = (status: string, message: string) => // RC 1.2.0 sdk.post('users.setStatus', { status, message }); export const setReaction = (emoji: string, messageId: string) => // RC 0.62.2 sdk.post('chat.react', { emoji, messageId }); export const toggleRead = (read: boolean, roomId: string) => { if (read) { return sdk.post('subscriptions.unread', { roomId }); } return sdk.post('subscriptions.read', { rid: roomId }); }; export const getRoomCounters = ( roomId: string, t: SubscriptionType.CHANNEL | SubscriptionType.GROUP | SubscriptionType.OMNICHANNEL ) => // RC 0.65.0 sdk.get(`${roomTypeToApiType(t)}.counters`, { roomId }); export const getChannelInfo = (roomId: string) => // RC 0.48.0 sdk.get('channels.info', { roomId }); export const getUserPreferences = (userId: string) => // RC 0.62.0 sdk.get('users.getPreferences', { userId }); export const getRoomInfo = (roomId: string) => // RC 0.72.0 sdk.get('rooms.info', { roomId }); export const getVisitorInfo = (visitorId: string) => // RC 2.3.0 sdk.get('livechat/visitors.info', { visitorId }); export const setUserPresenceAway = () => sdk.methodCall('UserPresence:away'); export const setUserPresenceOnline = () => sdk.methodCall('UserPresence:online'); export const getTeamListRoom = ({ teamId, count, offset, type, filter }: { teamId: string; count: number; offset: number; type: string; filter: any; }) => { const params: any = { teamId, count, offset, type }; if (filter) { params.filter = filter; } // RC 3.13.0 return sdk.get('teams.listRooms', params); }; export const closeLivechat = (rid: string, comment: string) => // RC 0.29.0 sdk.methodCallWrapper('livechat:closeRoom', rid, comment, { clientAction: true }); export const editLivechat = (userData: TParams, roomData: TParams): Promise<{ error?: string }> => // RC 0.55.0 sdk.methodCallWrapper('livechat:saveInfo', userData, roomData); export const returnLivechat = (rid: string): Promise => // RC 0.72.0 sdk.methodCallWrapper('livechat:returnAsInquiry', rid); export const forwardLivechat = (transferData: any) => // RC 0.36.0 sdk.methodCallWrapper('livechat:transfer', transferData); export const getDepartmentInfo = (departmentId: string) => // RC 2.2.0 sdk.get(`livechat/department/${departmentId}?includeAgents=false`); export const getDepartments = (args?: { count: number; offset: number; text: string }) => { let params; if (args) { params = { text: args.text, count: args.count, offset: args.offset }; } // RC 2.2.0 return sdk.get('livechat/department', params); }; export const usersAutoComplete = (selector: any) => // RC 2.4.0 sdk.get('users.autocomplete', { selector }); export const getRoutingConfig = (): Promise<{ previewRoom: boolean; showConnecting: boolean; showQueue: boolean; showQueueLink: boolean; returnQueue: boolean; enableTriggerAction: boolean; autoAssignAgent: boolean; }> => // RC 2.0.0 sdk.methodCallWrapper('livechat:getRoutingConfig'); export const getTagsList = (): Promise< { _id: string; name: string; departments: string[]; }[] > => // RC 2.0.0 sdk.methodCallWrapper('livechat:getTagsList'); export const getAgentDepartments = (uid: string) => // RC 2.4.0 sdk.get(`livechat/agents/${uid}/departments?enabledDepartmentsOnly=true`); export const getCustomFields = () => // RC 2.2.0 sdk.get('livechat/custom-fields'); export const getListCannedResponse = ({ scope = '', departmentId = '', offset = 0, count = 25, text = '' }) => { const params = { offset, count, ...(departmentId && { departmentId }), ...(text && { text }), ...(scope && { scope }) }; // RC 3.17.0 return sdk.get('canned-responses', params); }; export const toggleBlockUser = (rid: string, blocked: string, block: boolean): Promise => { if (block) { // RC 0.49.0 return sdk.methodCallWrapper('blockUser', { rid, blocked }); } // RC 0.49.0 return sdk.methodCallWrapper('unblockUser', { rid, blocked }); }; export const leaveRoom = (roomId: string, t: RoomTypes) => // RC 0.48.0 sdk.post(`${roomTypeToApiType(t)}.leave`, { roomId }); export const deleteRoom = (roomId: string, t: RoomTypes) => // RC 0.49.0 sdk.post(`${roomTypeToApiType(t)}.delete`, { roomId }); export const toggleMuteUserInRoom = ( rid: string, username: string, mute: boolean ): Promise<{ message: { msg: string; result: boolean }; success: boolean }> => { if (mute) { // RC 0.51.0 return sdk.methodCallWrapper('muteUserInRoom', { rid, username }); } // RC 0.51.0 return sdk.methodCallWrapper('unmuteUserInRoom', { rid, username }); }; export const toggleRoomOwner = ({ roomId, t, userId, isOwner }: { roomId: string; t: SubscriptionType; userId: string; isOwner: boolean; }) => { const type = t as SubscriptionType.CHANNEL; if (isOwner) { // RC 0.49.4 return sdk.post(`${roomTypeToApiType(type)}.addOwner`, { roomId, userId }); } // RC 0.49.4 return sdk.post(`${roomTypeToApiType(type)}.removeOwner`, { roomId, userId }); }; export const toggleRoomLeader = ({ roomId, t, userId, isLeader }: { roomId: string; t: SubscriptionType; userId: string; isLeader: boolean; }) => { const type = t as SubscriptionType.CHANNEL; if (isLeader) { // RC 0.58.0 return sdk.post(`${roomTypeToApiType(type)}.addLeader`, { roomId, userId }); } // RC 0.58.0 return sdk.post(`${roomTypeToApiType(type)}.removeLeader`, { roomId, userId }); }; export const toggleRoomModerator = ({ roomId, t, userId, isModerator }: { roomId: string; t: SubscriptionType; userId: string; isModerator: boolean; }) => { const type = t as SubscriptionType.CHANNEL; if (isModerator) { // RC 0.49.4 return sdk.post(`${roomTypeToApiType(type)}.addModerator`, { roomId, userId }); } // RC 0.49.4 return sdk.post(`${roomTypeToApiType(type)}.removeModerator`, { roomId, userId }); }; export const removeUserFromRoom = ({ roomId, t, userId }: { roomId: string; t: RoomTypes; userId: string }) => // RC 0.48.0 sdk.post(`${roomTypeToApiType(t)}.kick`, { roomId, userId }); export const ignoreUser = ({ rid, userId, ignore }: { rid: string; userId: string; ignore: boolean }) => // RC 0.64.0 sdk.get('chat.ignoreUser', { rid, userId, ignore }); export const toggleArchiveRoom = (roomId: string, t: SubscriptionType, archive: boolean) => { const type = t as SubscriptionType.CHANNEL | SubscriptionType.GROUP; if (archive) { // RC 0.48.0 return sdk.post(`${roomTypeToApiType(type)}.archive`, { roomId }); } // RC 0.48.0 return sdk.post(`${roomTypeToApiType(type)}.unarchive`, { roomId }); }; export const hideRoom = (roomId: string, t: RoomTypes) => // RC 0.48.0 sdk.post(`${roomTypeToApiType(t)}.close`, { roomId }); export const saveRoomSettings = ( rid: string, params: { roomName?: string; roomAvatar?: string; roomDescription?: string; roomTopic?: string; roomAnnouncement?: string; roomType?: SubscriptionType; readOnly?: boolean; reactWhenReadOnly?: boolean; systemMessages?: string[]; joinCode?: string; encrypted?: boolean; } ): Promise<{ result: boolean; rid: string }> => // RC 0.55.0 sdk.methodCallWrapper('saveRoomSettings', rid, params); export const saveUserProfile = (data: IParams | Pick, customFields?: { [key: string | number]: string }) => // RC 0.62.2 sdk.post('users.updateOwnBasicInfo', { data, customFields }); export const saveUserPreferences = (data: Partial) => // RC 0.62.0 sdk.post('users.setPreferences', { data }); export const saveNotificationSettings = (roomId: string, notifications: IRoomNotifications) => // RC 0.63.0 sdk.post('rooms.saveNotification', { roomId, notifications }); export const getSingleMessage = (msgId: string) => // RC 0.47.0 sdk.get('chat.getMessage', { msgId }); export const getRoomRoles = ( roomId: string, type: SubscriptionType.CHANNEL | SubscriptionType.GROUP | SubscriptionType.OMNICHANNEL ) => // RC 0.65.0 sdk.get(`${roomTypeToApiType(type)}.roles`, { roomId }); export const getAvatarSuggestion = (): Promise => // RC 0.51.0 sdk.methodCallWrapper('getAvatarSuggestion'); export const resetAvatar = (userId: string) => // RC 0.55.0 sdk.post('users.resetAvatar', { userId }); export const setAvatarFromService = ({ data, contentType = '', service = null }: { data: any; contentType?: string; service?: string | null; }): Promise => // RC 0.51.0 sdk.methodCallWrapper('setAvatarFromService', data, contentType, service); export const getUsernameSuggestion = () => // RC 0.65.0 sdk.get('users.getUsernameSuggestion'); export const getFiles = (roomId: string, type: SubscriptionType, offset: number) => { const t = type as SubscriptionType.DIRECT | SubscriptionType.CHANNEL | SubscriptionType.GROUP; // RC 0.59.0 return sdk.get(`${roomTypeToApiType(t)}.files`, { roomId, offset, sort: { uploadedAt: -1 } }); }; export const getMessages = ( roomId: string, type: SubscriptionType, query: { 'mentions._id': { $in: string[] } } | { 'starred._id': { $in: string[] } } | { pinned: boolean }, offset: number ) => { const t = type as SubscriptionType.DIRECT | SubscriptionType.CHANNEL | SubscriptionType.GROUP; // RC 0.59.0 return sdk.get(`${roomTypeToApiType(t)}.messages`, { roomId, query, offset, sort: { ts: -1 } }); }; export const getReadReceipts = (messageId: string) => // RC 0.63.0 sdk.get('chat.getMessageReadReceipts', { messageId }); export const searchMessages = (roomId: string, searchText: string, count: number, offset: number) => // RC 0.60.0 sdk.get('chat.search', { roomId, searchText, count, offset }); export const toggleFollowMessage = (mid: string, follow: boolean) => { // RC 1.0 if (follow) { return sdk.post('chat.followMessage', { mid }); } return sdk.post('chat.unfollowMessage', { mid }); }; export const getThreadsList = ({ rid, count, offset, text }: { rid: string; count: number; offset: number; text?: string }) => { const params: any = { rid, count, offset, sort: { ts: -1 } }; if (text) { params.text = text; } // RC 1.0 return sdk.get('chat.getThreadsList', params); }; export const getSyncThreadsList = ({ rid, updatedSince }: { rid: string; updatedSince: string }) => // RC 1.0 sdk.get('chat.syncThreadsList', { rid, updatedSince }); export const runSlashCommand = (command: string, roomId: string, params: string, triggerId?: string, tmid?: string) => // RC 0.60.2 sdk.post('commands.run', { command, roomId, params, triggerId, tmid }); export const getCommandPreview = (command: string, roomId: string, params: string) => // RC 0.65.0 sdk.get('commands.preview', { command, roomId, params }); export const executeCommandPreview = ( command: string, params: string, roomId: string, previewItem: IPreviewItem, triggerId: string, tmid?: string ) => // RC 0.65.0 sdk.post('commands.preview', { command, params, roomId, previewItem, triggerId, tmid }); export const getDirectory = ({ query, count, offset, sort }: { query: { [key: string]: string }; count: number; offset: number; sort: { [key: string]: number }; }) => // RC 1.0 sdk.get('directory', { query, count, offset, sort }); export const saveAutoTranslate = ({ rid, field, value, options }: { rid: string; field: string; value: string; options?: { defaultLanguage: string }; }) => sdk.methodCallWrapper('autoTranslate.saveSettings', rid, field, value, options ?? null); export const getSupportedLanguagesAutoTranslate = () => sdk.methodCallWrapper('autoTranslate.getSupportedLanguages', 'en'); export const translateMessage = (message: any, targetLanguage: string) => sdk.methodCallWrapper('autoTranslate.translateMessage', message, targetLanguage); export const findOrCreateInvite = ({ rid, days, maxUses }: { rid: string; days: number; maxUses: number }): any => // RC 2.4.0 // TODO: missing definitions from server // @ts-ignore sdk.post('findOrCreateInvite', { rid, days, maxUses }); export const validateInviteToken = (token: string): any => // RC 2.4.0 // TODO: missing definitions from server // @ts-ignore sdk.post('validateInviteToken', { token }); export const useInviteToken = (token: string): any => // RC 2.4.0 // TODO: missing definitions from server // @ts-ignore sdk.post('useInviteToken', { token }); export const readThreads = (tmid: string): Promise => { const serverVersion = reduxStore.getState().server.version; if (compareServerVersion(serverVersion, 'greaterThanOrEqualTo', '3.4.0')) { // RC 3.4.0 return sdk.methodCallWrapper('readThreads', tmid); } return Promise.resolve(); }; export const createGroupChat = () => { const { users } = reduxStore.getState().selectedUsers; const usernames = users.map(u => u.name).join(','); // RC 3.1.0 return sdk.post('im.create', { usernames }); }; export const addUsersToRoom = (rid: string): Promise => { const { users: selectedUsers } = reduxStore.getState().selectedUsers; const users = selectedUsers.map(u => u.name); // RC 0.51.0 return sdk.methodCallWrapper('addUsersToRoom', { rid, users }); }; export const emitTyping = (room: IRoom, typing = true) => { const { login, settings } = reduxStore.getState(); const { UI_Use_Real_Name } = settings; const { user } = login; const name = UI_Use_Real_Name ? user.name : user.username; return sdk.methodCall('stream-notify-room', `${room}/typing`, name, typing); }; export function e2eResetOwnKey(this: TRocketChat): Promise { // {} when TOTP is enabled // TODO: remove this this.unsubscribeRooms(); // RC 0.72.0 return sdk.methodCallWrapper('e2e.resetOwnE2EKey'); } export const editMessage = async (message: IMessage) => { const { rid, msg } = await Encryption.encryptMessage(message); // RC 0.49.0 return sdk.post('chat.update', { roomId: rid, msgId: message.id, text: msg }); }; export const removePushToken = (): Promise => { const token = getDeviceToken(); if (token) { // RC 0.60.0 return sdk.current.del('push.token', { token }); } return Promise.resolve(); }; export const sendEmailCode = () => { const { username } = reduxStore.getState().login.user as IUser; // RC 3.1.0 return sdk.post('users.2fa.sendEmailCode', { emailOrUsername: username }); }; export const getRoomMembers = async ({ rid, allUsers, roomType, type, filter, skip = 0, limit = 10 }: { rid: string; allUsers: boolean; type: 'all' | 'online'; roomType: SubscriptionType; filter: boolean; skip: number; limit: number; }) => { const t = roomType as SubscriptionType.CHANNEL | SubscriptionType.GROUP | SubscriptionType.DIRECT; const serverVersion = reduxStore.getState().server.version; if (compareServerVersion(serverVersion, 'greaterThanOrEqualTo', '3.16.0')) { const params = { roomId: rid, offset: skip, count: limit, ...(type !== 'all' && { 'status[]': type }), ...(filter && { filter }) }; // RC 3.16.0 const result = await sdk.get(`${roomTypeToApiType(t)}.members`, params); if (result.success) { return result?.members; } } // RC 0.42.0 const result = await sdk.methodCallWrapper('getUsersOfRoom', rid, allUsers, { skip, limit }); if (result.success) { return result?.records; } };