Rocket.Chat.ReactNative/app/lib/rocketchat/services/restApi.ts

891 lines
23 KiB
TypeScript
Raw Normal View History

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 { getBundleId, isIOS } from '../../../utils/deviceInfo';
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<boolean> =>
// 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<ISpotlight> =>
// 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<boolean>;
}
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 } });
2022-03-05 03:08:26 +00:00
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 });
};
2022-03-05 03:17:24 +00:00
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 });
};
2022-03-05 03:40:41 +00:00
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<INotificationPreferences>) =>
// 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 });
2022-03-05 03:28:36 +00:00
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<boolean> =>
// 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<boolean> => {
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 });
2022-03-07 15:23:28 +00:00
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;
2022-03-07 15:40:38 +00:00
}) => {
const type = t as SubscriptionType.CHANNEL;
if (isOwner) {
// RC 0.49.4
2022-03-07 15:40:38 +00:00
return sdk.post(`${roomTypeToApiType(type)}.addOwner`, { roomId, userId });
}
// RC 0.49.4
2022-03-07 15:40:38 +00:00
return sdk.post(`${roomTypeToApiType(type)}.removeOwner`, { roomId, userId });
};
export const toggleRoomLeader = ({
roomId,
t,
userId,
isLeader
}: {
roomId: string;
t: SubscriptionType;
userId: string;
isLeader: boolean;
2022-03-07 15:52:22 +00:00
}) => {
const type = t as SubscriptionType.CHANNEL;
if (isLeader) {
// RC 0.58.0
2022-03-07 15:52:22 +00:00
return sdk.post(`${roomTypeToApiType(type)}.addLeader`, { roomId, userId });
}
// RC 0.58.0
2022-03-07 15:52:22 +00:00
return sdk.post(`${roomTypeToApiType(type)}.removeLeader`, { roomId, userId });
};
export const toggleRoomModerator = ({
roomId,
t,
userId,
isModerator
}: {
roomId: string;
t: SubscriptionType;
userId: string;
isModerator: boolean;
2022-03-07 14:47:06 +00:00
}) => {
const type = t as SubscriptionType.CHANNEL;
if (isModerator) {
// RC 0.49.4
2022-03-07 14:47:06 +00:00
return sdk.post(`${roomTypeToApiType(type)}.addModerator`, { roomId, userId });
}
// RC 0.49.4
2022-03-07 14:47:06 +00:00
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 });
2022-03-07 14:08:45 +00:00
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<IParams, 'username'>, customFields?: { [key: string | number]: string }) =>
// RC 0.62.2
sdk.post('users.updateOwnBasicInfo', { data, customFields });
2022-03-09 16:49:52 +00:00
export const saveUserPreferences = (data: Partial<INotificationPreferences>) =>
// RC 0.62.0
sdk.post('users.setPreferences', { data });
2022-03-09 17:04:25 +00:00
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<IAvatarSuggestion> =>
// 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<void> =>
// 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<void> => {
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<boolean> => {
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<boolean | {}> {
// {} 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 registerPushToken = () =>
new Promise<void>(async resolve => {
const token = getDeviceToken();
if (token) {
const type = isIOS ? 'apn' : 'gcm';
const data = {
value: token,
type,
appName: getBundleId
};
try {
// RC 0.60.0
await sdk.post('push.token', data);
} catch (error) {
console.log(error);
}
}
return resolve();
});
export const removePushToken = (): Promise<boolean | void> => {
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;
}
};