Skip to content

Commit

Permalink
[MM-50623] Allow to run Calls slash commands from other plugins/produ…
Browse files Browse the repository at this point in the history 
…cts (#343)

* Allow to run Calls slash commands

* Simplify
  • Loading branch information
@streamer45
streamer45 committed Mar 2, 2023
1 parent 1c423ed commit 5a25ba6
Show file tree
Hide file tree
Showing 2 changed files with 231 additions and 184 deletions.
189 changes: 5 additions & 184 deletions webapp/src/index.tsx
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,8 @@ import {
displayGenericErrorModal,
} from 'src/actions';

import slashCommandsHandler from 'src/slash_commands';

import {PostTypeCloudTrialRequest} from 'src/components/custom_post_types/post_type_cloud_trial_request';
import RTCDServiceUrl from 'src/components/admin_console_settings/rtcd_service_url';
import EnableRecordings from 'src/components/admin_console_settings/recordings/enable_recordings';
Expand Down Expand Up @@ -238,190 +240,7 @@ export default class Plugin {
registry.registerGlobalComponent(EndCallModal);

registry.registerSlashCommandWillBePostedHook(async (message, args) => {
const fullCmd = message.trim();
const fields = fullCmd.split(/\s+/);
if (fields.length < 2) {
return {message, args};
}

const rootCmd = fields[0];
const subCmd = fields[1];

if (rootCmd !== '/call') {
return {message, args};
}

const connectedID = connectedChannelID(store.getState());

switch (subCmd) {
case 'join':
case 'start':
if (subCmd === 'start') {
if (voiceConnectedUsersInChannel(store.getState(), args.channel_id).length > 0) {
store.dispatch(displayGenericErrorModal(
defineMessage({defaultMessage: 'Unable to start call'}),
defineMessage({defaultMessage: 'A call is already ongoing in the channel.'}),
));
return {};
}
}
if (!connectedID) {
let title = '';
if (fields.length > 2) {
title = fields.slice(2).join(' ');
}
const team_id = args?.team_id || getChannel(store.getState(), args.channel_id).team_id;
try {
await joinCall(args.channel_id, team_id, title, args.root_id);
return {};
} catch (e) {
let msg = defineMessage({defaultMessage: 'An internal error occurred preventing you to join the call. Please try again.'});
if (e === DisabledCallsErr) {
msg = defineMessage({defaultMessage: 'Calls are disabled in this channel.'});
}
store.dispatch(displayGenericErrorModal(
defineMessage({defaultMessage: 'Unable to start or join call'}),
msg,
));
return {};
}
}

store.dispatch(displayGenericErrorModal(
defineMessage({defaultMessage: 'Unable to join call'}),
defineMessage({defaultMessage: 'You\'re already connected to a call in the current channel.'}),
));
return {};
case 'leave':
if (connectedID && args.channel_id === connectedID) {
if (window.callsClient) {
window.callsClient.disconnect();
return {};
} else if (shouldRenderDesktopWidget()) {
sendDesktopEvent('calls-leave-call', {callID: args.channel_id});
return {};
}
}
store.dispatch(displayGenericErrorModal(
defineMessage({defaultMessage: 'Unable to leave the call'}),
defineMessage({defaultMessage: 'You\'re not connected to a call in the current channel.'}),
));
return {};
case 'end':
if (voiceConnectedUsersInChannel(store.getState(), args.channel_id)?.length === 0) {
store.dispatch(displayGenericErrorModal(
defineMessage({defaultMessage: 'Unable to end the call'}),
defineMessage({defaultMessage: 'There\'s no ongoing call in the channel.'}),
));
return {};
}

if (!isCurrentUserSystemAdmin(store.getState()) &&
getCurrentUserId(store.getState()) !== voiceChannelCallOwnerID(store.getState(), args.channel_id)) {
store.dispatch(displayGenericErrorModal(
defineMessage({defaultMessage: 'Unable to end the call'}),
defineMessage({defaultMessage: 'You don\'t have permission to end the call. Please ask the call owner to end call.'}),
));
return {};
}

store.dispatch({
type: SHOW_END_CALL_MODAL,
data: {
targetID: args.channel_id,
},
});
return {};
case 'link':
break;
case 'experimental':
if (fields.length < 3) {
break;
}
if (fields[2] === 'on') {
window.localStorage.setItem('calls_experimental_features', 'on');
logDebug('experimental features enabled');
} else if (fields[2] === 'off') {
logDebug('experimental features disabled');
window.localStorage.removeItem('calls_experimental_features');
}
break;
case 'stats': {
if (window.callsClient) {
try {
const stats = await window.callsClient.getStats();
return {message: `/call stats ${btoa(JSON.stringify(stats))}`, args};
} catch (err) {
return {error: {message: err}};
}
}
const data = sessionStorage.getItem('calls_client_stats') || '{}';
return {message: `/call stats ${btoa(data)}`, args};
}
case 'recording': {
if (fields.length < 3 || (fields[2] !== 'start' && fields[2] !== 'stop')) {
break;
}

const startErrorTitle = defineMessage({defaultMessage: 'Unable to start recording'});
const stopErrorTitle = defineMessage({defaultMessage: 'Unable to stop recording'});

if (args.channel_id !== connectedID) {
store.dispatch(displayGenericErrorModal(
fields[2] === 'start' ? startErrorTitle : stopErrorTitle,
defineMessage({defaultMessage: 'You\'re not connected to a call in the current channel.'}),
));
return {};
}

const state = store.getState();
const isHost = voiceChannelCallHostID(state, connectedID) === getCurrentUserId(state);
const recording = callRecording(state, connectedID);

if (fields[2] === 'start') {
if (recording?.start_at > recording?.end_at) {
store.dispatch(displayGenericErrorModal(
startErrorTitle,
defineMessage({defaultMessage: 'A recording is already in progress.'}),
));
return {};
}

if (!isHost) {
store.dispatch(displayGenericErrorModal(
startErrorTitle,
defineMessage({defaultMessage: 'You don\'t have permissions to start a recording. Please ask the call host to start a recording.'}),
));
return {};
}

await store.dispatch(startCallRecording(connectedID));
}

if (fields[2] === 'stop') {
if (!recording || recording?.end_at > recording?.start_at) {
store.dispatch(displayGenericErrorModal(
stopErrorTitle,
defineMessage({defaultMessage: 'No recording is in progress.'}),
));
return {};
}

if (!isHost) {
store.dispatch(displayGenericErrorModal(
stopErrorTitle,
defineMessage({defaultMessage: 'You don\'t have permissions to stop the recording. Please ask the call host to stop the recording.'}),
));
return {};
}

await stopCallRecording(connectedID);
}
break;
}
}

return {message, args};
return slashCommandsHandler(store, joinCall, message, args);
});

const connectToCall = async (channelId: string, teamId: string, title?: string, rootId?: string) => {
Expand Down Expand Up @@ -604,6 +423,8 @@ export default class Plugin {
});
} else if (ev.data?.type === 'calls-error' && ev.data.message.err === 'client-error') {
store.dispatch(displayCallErrorModal(ev.data.message.callID, new Error(ev.data.message.errMsg)));
} else if (ev.data?.type === 'calls-run-slash-command') {
slashCommandsHandler(store, joinCall, ev.data.message, ev.data.args);
}
};
window.addEventListener('message', windowEventHandler);
Expand Down

0 comments on commit 5a25ba6

Please sign in to comment.