Add tests for actions/websocket/event (#8470)
This commit is contained in:
Joram Wilander
GitHub
parent
e6c19637b9
commit
cdbb9ebfd7
1 changed files with 524 additions and 0 deletions
524
app/actions/websocket/event.test.ts
Normal file
524
app/actions/websocket/event.test.ts
Normal file
|
|
@ -0,0 +1,524 @@
|
|||
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
||||
// See LICENSE.txt for license information.
|
||||
|
||||
import * as bookmark from '@actions/local/channel_bookmark';
|
||||
import * as calls from '@calls/connection/websocket_event_handlers';
|
||||
import {WebsocketEvents} from '@constants';
|
||||
|
||||
import * as category from './category';
|
||||
import * as channel from './channel';
|
||||
import {handleWebSocketEvent} from './event';
|
||||
import * as group from './group';
|
||||
import {handleOpenDialogEvent} from './integrations';
|
||||
import * as posts from './posts';
|
||||
import * as preferences from './preferences';
|
||||
import * as reactions from './reactions';
|
||||
import * as roles from './roles';
|
||||
import * as system from './system';
|
||||
import * as teams from './teams';
|
||||
import * as threads from './threads';
|
||||
import * as users from './users';
|
||||
|
||||
jest.mock('./posts');
|
||||
jest.mock('./category');
|
||||
jest.mock('./integrations');
|
||||
jest.mock('./teams');
|
||||
jest.mock('./channel');
|
||||
jest.mock('./preferences');
|
||||
jest.mock('./reactions');
|
||||
jest.mock('./roles');
|
||||
jest.mock('./system');
|
||||
jest.mock('./users');
|
||||
jest.mock('./threads');
|
||||
jest.mock('@calls/connection/websocket_event_handlers');
|
||||
jest.mock('./group');
|
||||
jest.mock('@actions/local/channel_bookmark');
|
||||
|
||||
describe('handleWebSocketEvent', () => {
|
||||
const serverUrl = 'https://example.com';
|
||||
const msg = {event: '', data: {}} as WebSocketMessage;
|
||||
|
||||
beforeEach(() => {
|
||||
jest.clearAllMocks();
|
||||
});
|
||||
|
||||
it('should handle POSTED event', async () => {
|
||||
msg.event = WebsocketEvents.POSTED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(posts.handleNewPostEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle POST_EDITED event', async () => {
|
||||
msg.event = WebsocketEvents.POST_EDITED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(posts.handlePostEdited).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle POST_DELETED event', async () => {
|
||||
msg.event = WebsocketEvents.POST_DELETED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(posts.handlePostDeleted).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle POST_UNREAD event', async () => {
|
||||
msg.event = WebsocketEvents.POST_UNREAD;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(posts.handlePostUnread).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle POST_ACKNOWLEDGEMENT_ADDED event', async () => {
|
||||
msg.event = WebsocketEvents.POST_ACKNOWLEDGEMENT_ADDED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(posts.handlePostAcknowledgementAdded).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle POST_ACKNOWLEDGEMENT_REMOVED event', async () => {
|
||||
msg.event = WebsocketEvents.POST_ACKNOWLEDGEMENT_REMOVED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(posts.handlePostAcknowledgementRemoved).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle LEAVE_TEAM event', async () => {
|
||||
msg.event = WebsocketEvents.LEAVE_TEAM;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(teams.handleLeaveTeamEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle UPDATE_TEAM event', async () => {
|
||||
msg.event = WebsocketEvents.UPDATE_TEAM;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(teams.handleUpdateTeamEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle ADDED_TO_TEAM event', async () => {
|
||||
msg.event = WebsocketEvents.ADDED_TO_TEAM;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(teams.handleUserAddedToTeamEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle DELETE_TEAM event', async () => {
|
||||
msg.event = WebsocketEvents.DELETE_TEAM;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(teams.handleTeamArchived).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle RESTORE_TEAM event', async () => {
|
||||
msg.event = WebsocketEvents.RESTORE_TEAM;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(teams.handleTeamRestored).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle USER_ADDED event', async () => {
|
||||
msg.event = WebsocketEvents.USER_ADDED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleUserAddedToChannelEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle USER_REMOVED event', async () => {
|
||||
msg.event = WebsocketEvents.USER_REMOVED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleUserRemovedFromChannelEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle USER_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.USER_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(users.handleUserUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle ROLE_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.ROLE_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(roles.handleRoleUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle USER_ROLE_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.USER_ROLE_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(roles.handleUserRoleUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle MEMBERROLE_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.MEMBERROLE_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(roles.handleTeamMemberRoleUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CATEGORY_CREATED event', async () => {
|
||||
msg.event = WebsocketEvents.CATEGORY_CREATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(category.handleCategoryCreatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CATEGORY_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.CATEGORY_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(category.handleCategoryUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CATEGORY_ORDER_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.CATEGORY_ORDER_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(category.handleCategoryOrderUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CATEGORY_DELETED event', async () => {
|
||||
msg.event = WebsocketEvents.CATEGORY_DELETED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(category.handleCategoryDeletedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_CREATED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_CREATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleChannelCreatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_DELETED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_DELETED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleChannelDeletedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_UNARCHIVED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_UNARCHIVED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleChannelUnarchiveEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleChannelUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_CONVERTED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_CONVERTED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleChannelConvertedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_VIEWED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_VIEWED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleChannelViewedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle MULTIPLE_CHANNELS_VIEWED event', async () => {
|
||||
msg.event = WebsocketEvents.MULTIPLE_CHANNELS_VIEWED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleMultipleChannelsViewedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_MEMBER_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_MEMBER_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleChannelMemberUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle DIRECT_ADDED event', async () => {
|
||||
msg.event = WebsocketEvents.DIRECT_ADDED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleDirectAddedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle GROUP_ADDED event', async () => {
|
||||
msg.event = WebsocketEvents.GROUP_ADDED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(channel.handleDirectAddedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle PREFERENCE_CHANGED event', async () => {
|
||||
msg.event = WebsocketEvents.PREFERENCE_CHANGED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(preferences.handlePreferenceChangedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle PREFERENCES_CHANGED event', async () => {
|
||||
msg.event = WebsocketEvents.PREFERENCES_CHANGED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(preferences.handlePreferencesChangedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle PREFERENCES_DELETED event', async () => {
|
||||
msg.event = WebsocketEvents.PREFERENCES_DELETED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(preferences.handlePreferencesDeletedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle STATUS_CHANGED event', async () => {
|
||||
msg.event = WebsocketEvents.STATUS_CHANGED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(users.handleStatusChangedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle TYPING event', async () => {
|
||||
msg.event = WebsocketEvents.TYPING;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(users.handleUserTypingEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle REACTION_ADDED event', async () => {
|
||||
msg.event = WebsocketEvents.REACTION_ADDED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(reactions.handleReactionAddedToPostEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle REACTION_REMOVED event', async () => {
|
||||
msg.event = WebsocketEvents.REACTION_REMOVED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(reactions.handleReactionRemovedFromPostEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle EMOJI_ADDED event', async () => {
|
||||
msg.event = WebsocketEvents.EMOJI_ADDED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(reactions.handleAddCustomEmoji).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle LICENSE_CHANGED event', async () => {
|
||||
msg.event = WebsocketEvents.LICENSE_CHANGED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(system.handleLicenseChangedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CONFIG_CHANGED event', async () => {
|
||||
msg.event = WebsocketEvents.CONFIG_CHANGED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(system.handleConfigChangedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle OPEN_DIALOG event', async () => {
|
||||
msg.event = WebsocketEvents.OPEN_DIALOG;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(handleOpenDialogEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle THREAD_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.THREAD_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(threads.handleThreadUpdatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle THREAD_READ_CHANGED event', async () => {
|
||||
msg.event = WebsocketEvents.THREAD_READ_CHANGED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(threads.handleThreadReadChangedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle THREAD_FOLLOW_CHANGED event', async () => {
|
||||
msg.event = WebsocketEvents.THREAD_FOLLOW_CHANGED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(threads.handleThreadFollowChangedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_CHANNEL_ENABLED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_CHANNEL_ENABLED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallChannelEnabled).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_CHANNEL_DISABLED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_CHANNEL_DISABLED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallChannelDisabled).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_CONNECTED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_CONNECTED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserConnected).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_DISCONNECTED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_DISCONNECTED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserDisconnected).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_JOINED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_JOINED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserJoined).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_LEFT event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_LEFT;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserLeft).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_MUTED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_MUTED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserMuted).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_UNMUTED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_UNMUTED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserUnmuted).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_VOICE_ON event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_VOICE_ON;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserVoiceOn).toHaveBeenCalledWith(msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_VOICE_OFF event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_VOICE_OFF;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserVoiceOff).toHaveBeenCalledWith(msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_CALL_START event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_CALL_START;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallStarted).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_SCREEN_ON event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_SCREEN_ON;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallScreenOn).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_SCREEN_OFF event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_SCREEN_OFF;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallScreenOff).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_RAISE_HAND event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_RAISE_HAND;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserRaiseHand).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_UNRAISE_HAND event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_UNRAISE_HAND;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserUnraiseHand).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_CALL_END event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_CALL_END;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallEnded).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_REACTED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_REACTED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallUserReacted).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_RECORDING_STATE event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_RECORDING_STATE;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallRecordingState).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_JOB_STATE event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_JOB_STATE;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallJobState).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_HOST_CHANGED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_HOST_CHANGED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallHostChanged).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_USER_DISMISSED_NOTIFICATION event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_USER_DISMISSED_NOTIFICATION;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleUserDismissedNotification).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_CAPTION event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_CAPTION;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallCaption).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_HOST_MUTE event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_HOST_MUTE;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleHostMute).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_HOST_LOWER_HAND event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_HOST_LOWER_HAND;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleHostLowerHand).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_HOST_REMOVED event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_HOST_REMOVED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleHostRemoved).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CALLS_CALL_STATE event', async () => {
|
||||
msg.event = WebsocketEvents.CALLS_CALL_STATE;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(calls.handleCallState).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle GROUP_RECEIVED event', async () => {
|
||||
msg.event = WebsocketEvents.GROUP_RECEIVED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(group.handleGroupReceivedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle GROUP_MEMBER_ADD event', async () => {
|
||||
msg.event = WebsocketEvents.GROUP_MEMBER_ADD;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(group.handleGroupMemberAddEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle GROUP_MEMBER_DELETE event', async () => {
|
||||
msg.event = WebsocketEvents.GROUP_MEMBER_DELETE;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(group.handleGroupMemberDeleteEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle GROUP_ASSOCIATED_TO_TEAM event', async () => {
|
||||
msg.event = WebsocketEvents.GROUP_ASSOCIATED_TO_TEAM;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(group.handleGroupTeamAssociatedEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle GROUP_DISSOCIATED_TO_TEAM event', async () => {
|
||||
msg.event = WebsocketEvents.GROUP_DISSOCIATED_TO_TEAM;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(group.handleGroupTeamDissociateEvent).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_BOOKMARK_CREATED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_BOOKMARK_CREATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(bookmark.handleBookmarkAddedOrDeleted).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_BOOKMARK_DELETED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_BOOKMARK_DELETED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(bookmark.handleBookmarkAddedOrDeleted).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_BOOKMARK_UPDATED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_BOOKMARK_UPDATED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(bookmark.handleBookmarkEdited).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
|
||||
it('should handle CHANNEL_BOOKMARK_SORTED event', async () => {
|
||||
msg.event = WebsocketEvents.CHANNEL_BOOKMARK_SORTED;
|
||||
await handleWebSocketEvent(serverUrl, msg);
|
||||
expect(bookmark.handleBookmarkSorted).toHaveBeenCalledWith(serverUrl, msg);
|
||||
});
|
||||
});
|
||||
Loading…
Reference in a new issue