docbrown/app/javascript/chat/chat.jsx
Sarthak Sharma 75608e3e55 Feature🚀: Ability to mention anyone in open chats and notify them (#5460) [deploy]
* Feature 🚀 : Ability to delete messages in chat channels

- Sending message ID to frontend
- Deleting Message
- Use pusher to delete message realtime

* Minor Bug 🐞: Show message action only for current user

- User can delete or edit their own messages

* Test cases added

* Bug 🐞: Update message id for receiver

Message id was not sent to receiver by pusher

* Refactoring🛠: Message controller refactoring

* Test Cases📝 : Specs for Delete message added

* Feature 🚀 : Ability to edit messages

* Test Cases📝 : Specs for Edit message added

* Feature 🚀 : Ability to mention member in Group [Frontend]

* Test Cases📝 : Test Cases added

* Feature 🚀 : Ability to mention member in Group [Backend]

* Bug Fix 🐞: Making messages realtime for open channels

* Feature 🚀 and Bug Fix 🐞: Ability to get notification if mentioned in open messages and increasing message number count

* Feature 🚀 : Ability to remove message count on channel open

* Bug Fix 🐞: Making Notification more reliable by checking if the new message is notified to user or not

* Feature 🚀 : Ability to metion @all and notify them

* Bug Fix 🐞: Minor fixes

* Fews tweaks in code

* Bug Fix 🐞: Feature was not present for Invite only Section

* Bug Fix 🐞: In open channels one can't mention all

* Bug Fix 🐞: Markdown conversion for all only in case of invite only

* Specs added

* Delete schema.rb

* Schema file updated

* Code refactoring

* Further Code refactoring backend

* Further Code refactoring backend

* Bug Fix 🐞: Mention List error problem in switching tabs

* Test Snapshots added

* Feature 🚀 : Ability to mention member in Group [Frontend]

* Test Cases📝 : Test Cases added

* Feature 🚀 : Ability to mention member in Group [Backend]

* Bug Fix 🐞: Making messages realtime for open channels

* Feature 🚀 and Bug Fix 🐞: Ability to get notification if mentioned in open messages and increasing message number count

* Feature 🚀 : Ability to remove message count on channel open

* Bug Fix 🐞: Making Notification more reliable by checking if the new message is notified to user or not

* Feature 🚀 : Ability to metion @all and notify them

* Bug Fix 🐞: Minor fixes

* Fews tweaks in code

* Bug Fix 🐞: Feature was not present for Invite only Section

* Bug Fix 🐞: In open channels one can't mention all

* Bug Fix 🐞: Markdown conversion for all only in case of invite only

* Specs added

* Code refactoring

* Further Code refactoring backend

* Further Code refactoring backend

* Bug Fix 🐞: Mention List error problem in switching tabs

* Test Snapshots added

* Feature 🚀: Ability to navigate through user list with keyboard only

* Bug Fix 🐞: Changing color of group avatars in dark themes

* Bug Fix 🐞: Setup pusher channel for open channels also
2020-01-23 18:06:35 -05:00

1576 lines
45 KiB
JavaScript

import { h, Component } from 'preact';
import PropTypes from 'prop-types';
import ConfigImage from '../../assets/images/three-dots.svg';
import {
conductModeration,
getAllMessages,
sendMessage,
sendOpen,
getChannels,
getUnopenedChannelIds,
getContent,
getChannelInvites,
sendChannelInviteAction,
deleteMessage,
editMessage,
} from './actions';
import { hideMessages, scrollToBottom, setupObserver } from './util';
import Alert from './alert';
import Channels from './channels';
import Compose from './compose';
import Message from './message';
import Content from './content';
import Video from './video';
import View from './view';
import setupPusher from '../src/utils/pusher';
export default class Chat extends Component {
static propTypes = {
pusherKey: PropTypes.number.isRequired,
chatChannels: PropTypes.string.isRequired,
chatOptions: PropTypes.string.isRequired,
githubToken: PropTypes.string.isRequired,
};
constructor(props) {
super(props);
const chatChannels = JSON.parse(props.chatChannels);
const chatOptions = JSON.parse(props.chatOptions);
this.state = {
messages: [],
scrolled: false,
showAlert: false,
chatChannels,
unopenedChannelIds: [],
filterQuery: '',
channelTypeFilter: 'all',
channelsLoaded: false,
channelPaginationNum: 0,
fetchingPaginatedChannels: false,
activeChannelId: chatOptions.activeChannelId,
activeChannel: null,
showChannelsList: chatOptions.showChannelsList,
showTimestamp: chatOptions.showTimestamp,
currentUserId: chatOptions.currentUserId,
notificationsPermission: null,
activeContent: {},
expanded: window.innerWidth > 600,
isMobileDevice: typeof window.orientation !== 'undefined',
subscribedPusherChannels: [],
activeVideoChannelId: null,
incomingVideoCallChannelIds: [],
videoCallParticipants: [],
nonChatView: null,
inviteChannels: [],
soundOn: true,
videoOn: true,
messageOffset: 0,
showDeleteModal: false,
messageDeleteId: null,
allMessagesLoaded: false,
currentMessageLocation: 0,
startEditing: false,
activeEditMessage: {},
markdownEdited: false,
channelUsers: [],
showMemberlist: false,
memberFilterQuery: null,
};
}
componentDidMount() {
const {
chatChannels,
activeChannelId,
showChannelsList,
channelTypeFilter,
isMobileDevice,
channelPaginationNum,
currentUserId,
} = this.state;
this.setupChannels(chatChannels);
const channelsForPusherSub = chatChannels.filter(
this.channelTypeFilterFn('open'),
);
this.subscribeChannelsToPusher(
channelsForPusherSub,
channel => `open-channel-${channel.chat_channel_id}`,
);
setupObserver(this.observerCallback);
this.subscribePusher(`private-message-notifications-${currentUserId}`);
if (activeChannelId) {
sendOpen(activeChannelId, this.handleChannelOpenSuccess, null);
}
if (showChannelsList) {
const filters =
channelTypeFilter === 'all'
? {}
: { filters: `channel_type:${channelTypeFilter}` };
getChannels(
'',
activeChannelId,
this.props,
channelPaginationNum,
filters,
this.loadChannels,
);
getUnopenedChannelIds(this.markUnopenedChannelIds);
}
if (!isMobileDevice) {
document.getElementById('messageform').focus();
}
if (document.getElementById('chatchannels__channelslist')) {
document
.getElementById('chatchannels__channelslist')
.addEventListener('scroll', this.handleChannelScroll);
}
getChannelInvites(this.handleChannelInvites, null);
}
componentDidUpdate() {
const { scrolled, currentMessageLocation } = this.state;
const messageList = document.getElementById('messagelist');
if (messageList) {
if (!scrolled) {
scrollToBottom();
}
}
if (currentMessageLocation && messageList.scrollTop === 0) {
messageList.scrollTop =
messageList.scrollHeight - (currentMessageLocation + 30);
}
}
liveCoding = e => {
const { activeContent, activeChannelId } = this.state;
if (activeContent !== { type_of: 'code_editor' }) {
activeContent[activeChannelId] = { type_of: 'code_editor' };
this.setState({ activeContent });
}
if (document.querySelector('.CodeMirror')) {
const cm = document.querySelector('.CodeMirror').CodeMirror;
if (cm && e.context === 'initializing-live-code-channel') {
window.pusher.channel(e.channel).trigger('client-livecode', {
value: cm.getValue(),
cursorPos: cm.getCursor(),
});
} else if ((cm && e.keyPressed === true) || e.value.length > 0) {
const cursorCoords = e.cursorPos;
const cursorElement = document.createElement('span');
cursorElement.classList.add('cursorelement');
cursorElement.style.height = `${cursorCoords.bottom -
cursorCoords.top}px`;
cm.setValue(e.value);
cm.setBookmark(e.cursorPos, { widget: cursorElement });
}
}
};
filterForActiveChannel = (channels, id) =>
channels.filter(channel => channel.chat_channel_id === parseInt(id, 10))[0];
subscribePusher = channelName => {
const { subscribedPusherChannels } = this.state;
const { pusherKey } = this.props;
if (!subscribedPusherChannels.includes(channelName)) {
setupPusher(pusherKey, {
channelId: channelName,
messageCreated: this.receiveNewMessage,
messageDeleted: this.removeMessage,
messageEdited: this.updateMessage,
channelCleared: this.clearChannel,
redactUserMessages: this.redactUserMessages,
channelError: this.channelError,
liveCoding: this.liveCoding,
videoCallInitiated: this.receiveVideoCall,
videoCallEnded: this.receiveVideoCallHangup,
mentioned: this.mentioned,
messageOpened: this.messageOpened,
});
const subscriptions = subscribedPusherChannels;
subscriptions.push(channelName);
this.setState({ subscribedPusherChannels: subscriptions });
}
};
mentioned = () => {};
messageOpened = () => {};
loadChannels = (channels, query) => {
const { activeChannelId, activeChannel } = this.state;
if (activeChannelId && query.length === 0) {
this.setState({
chatChannels: channels,
scrolled: false,
channelsLoaded: true,
channelPaginationNum: 0,
filterQuery: '',
activeChannel:
activeChannel ||
this.filterForActiveChannel(channels, activeChannelId),
});
this.setupChannel(activeChannelId);
} else if (activeChannelId) {
this.setState({
scrolled: false,
chatChannels: channels,
channelsLoaded: true,
channelPaginationNum: 0,
filterQuery: query,
activeChannel:
activeChannel ||
this.filterForActiveChannel(channels, activeChannelId),
});
this.setupChannel(activeChannelId);
} else if (channels.length > 0) {
this.setState({
chatChannels: channels,
channelsLoaded: true,
channelPaginationNum: 0,
filterQuery: query || '',
scrolled: false,
});
const channel = channels[0];
this.triggerSwitchChannel(
channel.chat_channel_id,
channel.channel_modified_slug,
);
} else {
this.setState({ channelsLoaded: true });
}
this.subscribeChannelsToPusher(
channels.filter(this.channelTypeFilterFn('open')),
channel => `open-channel-${channel.chat_channel_id}`,
);
this.subscribeChannelsToPusher(
channels.filter(this.channelTypeFilterFn('invite_only')),
channel => `presence-channel-${channel.chat_channel_id}`,
);
document.getElementById('chatchannels__channelslist').scrollTop = 0;
};
markUnopenedChannelIds = ids => {
this.setState({ unopenedChannelIds: ids });
};
subscribeChannelsToPusher = (channels, channelNameFn) => {
channels.forEach(channel => {
this.subscribePusher(channelNameFn(channel));
});
};
channelTypeFilterFn = type => channel => {
return channel.channel_type === type;
};
setupChannels = channels => {
channels.forEach((channel, index) => {
if (index < 3) {
this.setupChannel(channel.chat_channel_id);
}
});
};
loadPaginatedChannels = channels => {
const { state } = this.state;
const currentChannels = state.chatChannels;
const currentChannelIds = currentChannels.map(channel => channel.id);
const newChannels = currentChannels;
channels.forEach(channel => {
if (!currentChannelIds.includes(channel.id)) {
newChannels.push(channel);
}
});
if (
currentChannels.length === newChannels.length &&
state.channelPaginationNum > 3
) {
return;
}
this.setState({
chatChannels: newChannels,
fetchingPaginatedChannels: false,
channelPaginationNum: state.channelPaginationNum + 1,
});
};
setupChannel = channelId => {
const {
messages,
messageOffset,
activeChannel,
activeChannelId,
} = this.state;
if (
!messages[channelId] ||
messages[channelId].length === 0 ||
messages[channelId][0].reception_method === 'pushed'
) {
getAllMessages(channelId, messageOffset, this.receiveAllMessages);
}
if (activeChannel && activeChannel.channel_type !== 'direct') {
getContent(
`/api/chat_channels/${activeChannelId}`,
this.setOpenChannelUsers,
null,
);
if (activeChannel.channel_type === 'open')
this.subscribePusher(`open-channel-${channelId}`);
}
this.subscribePusher(`presence-channel-${channelId}`);
};
setOpenChannelUsers = res => {
const { activeChannelId, activeChannel } = this.state;
Object.filter = (obj, predicate) =>
Object.fromEntries(Object.entries(obj).filter(predicate));
const leftUser = Object.filter(
res.channel_users,
([username]) => username !== window.currentUser.username,
);
if (activeChannel.channel_type === 'open') {
this.setState({
channelUsers: {
[activeChannelId]: leftUser,
},
});
} else {
this.setState({
channelUsers: {
[activeChannelId]: {
all: { username: 'all', name: 'To notify everyone here' },
...leftUser,
},
},
});
}
};
observerCallback = entries => {
entries.forEach(entry => {
if (entry.isIntersecting) {
this.setState({ scrolled: false, showAlert: false });
} else {
this.setState({ scrolled: true });
}
});
};
channelError = _error => {
this.setState({
subscribedPusherChannels: [],
});
};
receiveAllMessages = res => {
const { chatChannelId, messages } = res;
this.setState(prevState => ({
messages: { ...prevState.messages, [chatChannelId]: messages },
scrolled: false,
}));
};
removeMessage = message => {
const { activeChannelId } = this.state;
this.setState(prevState => ({
messages: {
[activeChannelId]: [
...prevState.messages[activeChannelId].filter(
oldmessage => oldmessage.id !== message.id,
),
],
},
}));
};
updateMessage = message => {
const { activeChannelId } = this.state;
if (message.chat_channel_id === activeChannelId) {
this.setState(({ messages }) => {
const newMessages = messages;
const foundIndex = messages[activeChannelId].findIndex(
oldMessage => oldMessage.id === message.id,
);
newMessages[activeChannelId][foundIndex] = message;
return { messages: newMessages };
});
}
};
receiveNewMessage = message => {
const {
messages,
activeChannelId,
scrolled,
chatChannels,
unopenedChannelIds,
} = this.state;
const receivedChatChannelId = message.chat_channel_id;
let newMessages = [];
if (
message.temp_id &&
messages[activeChannelId].findIndex(
oldmessage => oldmessage.temp_id === message.temp_id,
) > -1
) {
return;
}
if (messages[receivedChatChannelId]) {
newMessages = messages[receivedChatChannelId].slice();
newMessages.push(message);
if (newMessages.length > 150) {
newMessages.shift();
}
}
const newShowAlert =
activeChannelId === receivedChatChannelId ? { showAlert: scrolled } : {};
let newMessageChannelIndex = 0;
let newMessageChannel = null;
const newChannelsObj = chatChannels.map((channel, index) => {
if (receivedChatChannelId === channel.chat_channel_id) {
newMessageChannelIndex = index;
newMessageChannel = channel;
return { ...channel, channel_last_message_at: new Date() };
}
return channel;
});
if (newMessageChannelIndex > 0) {
newChannelsObj.splice(newMessageChannelIndex, 1);
newChannelsObj.unshift(newMessageChannel);
}
if (receivedChatChannelId === activeChannelId) {
sendOpen(receivedChatChannelId, this.handleChannelOpenSuccess, null);
} else {
const newUnopenedChannels = unopenedChannelIds;
if (!unopenedChannelIds.includes(receivedChatChannelId)) {
newUnopenedChannels.push(receivedChatChannelId);
}
this.setState({
unopenedChannelIds: newUnopenedChannels,
});
}
this.setState(prevState => ({
...newShowAlert,
chatChannels: newChannelsObj,
messages: {
...prevState.messages,
[receivedChatChannelId]: newMessages,
},
}));
};
receiveVideoCall = callObj => {
this.setState(prevState => ({
incomingVideoCallChannelIds: [...prevState, callObj.channelId],
}));
};
receiveVideoCallHangup = () => {
const { videoCallParticipants } = this.state;
if (videoCallParticipants.size < 1) {
this.setState({ activeVideoChannelId: null });
}
};
redactUserMessages = res => {
const { messages } = this.state;
const newMessages = hideMessages(messages, res.userId);
this.setState({ messages: newMessages });
};
clearChannel = res => {
this.setState(prevState => ({
messages: { ...prevState.messages, [res.chat_channel_id]: [] },
}));
};
handleChannelScroll = e => {
const {
fetchingPaginatedChannels,
chatChannels,
channelTypeFilter,
filterQuery,
activeChannelId,
channelPaginationNum,
} = this.state;
if (fetchingPaginatedChannels || chatChannels.length < 30) {
return;
}
const { target } = e;
if (target.scrollTop + target.offsetHeight + 1800 > target.scrollHeight) {
this.setState({ fetchingPaginatedChannels: true });
const filters =
channelTypeFilter === 'all'
? {}
: { filters: `channel_type:${channelTypeFilter}` };
getChannels(
filterQuery,
activeChannelId,
this.props,
channelPaginationNum,
filters,
this.loadPaginatedChannels,
);
}
};
handleChannelInvites = response => {
this.setState({ inviteChannels: response });
};
handleKeyDown = e => {
const { showMemberlist } = this.state;
const enterPressed = e.keyCode === 13;
const targetValue = e.target.value;
const messageIsEmpty = targetValue.length === 0;
const shiftPressed = e.shiftKey;
if (enterPressed) {
if (showMemberlist) {
e.preventDefault();
const selectedUser = document.querySelector('.active__message__list');
this.addUserName({ target: selectedUser });
} else if (messageIsEmpty) {
e.preventDefault();
} else if (!messageIsEmpty && !shiftPressed) {
e.preventDefault();
this.handleMessageSubmit(e.target.value);
e.target.value = '';
}
}
if (e.target.value.includes('@')) {
if (e.keyCode === 40 || e.keyCode === 38) {
e.preventDefault();
}
}
};
handleKeyDownEdit = e => {
const enterPressed = e.keyCode === 13;
const targetValue = e.target.value;
const messageIsEmpty = targetValue.length === 0;
const shiftPressed = e.shiftKey;
if (enterPressed) {
if (messageIsEmpty) {
e.preventDefault();
} else if (!messageIsEmpty && !shiftPressed) {
e.preventDefault();
this.handleMessageSubmitEdit(e.target.value);
e.target.value = '';
}
}
};
handleMessageSubmitEdit = message => {
const { activeChannelId, activeEditMessage } = this.state;
const editedMessage = {
activeChannelId,
id: activeEditMessage.id,
message,
};
editMessage(editedMessage, this.handleSuccess, this.handleFailure);
this.handleEditMessageClose();
};
handleMessageSubmit = message => {
const { activeChannelId } = this.state;
// should check if user has the privilege
if (message.startsWith('/code')) {
this.setActiveContentState(activeChannelId, { type_of: 'code_editor' });
} else if (message.startsWith('/call')) {
this.setState({ activeVideoChannelId: activeChannelId });
window.pusher
.channel(`presence-channel-${activeChannelId}`)
.trigger('client-initiatevideocall', {
channelId: activeChannelId,
});
} else if (message.startsWith('/new')) {
this.setActiveContentState(activeChannelId, {
type_of: 'loading-post',
});
this.setActiveContent({
path: '/new',
type_of: 'article',
});
} else if (message.startsWith('/github')) {
const args = message.split('/github ')[1].trim();
this.setActiveContentState(activeChannelId, { type_of: 'github', args });
} else if (message[0] === '/') {
conductModeration(
activeChannelId,
message,
this.handleSuccess,
this.handleFailure,
);
} else {
const messageObject = {
activeChannelId,
message,
mentionedUsersId: this.getMentionedUsers(message),
};
sendMessage(messageObject, this.handleSuccess, this.handleFailure);
}
};
handleSwitchChannel = e => {
e.preventDefault();
let { target } = e;
if (!target.dataset.channelId) {
target = target.parentElement;
}
this.triggerSwitchChannel(
parseInt(target.dataset.channelId, 10),
target.dataset.channelSlug,
);
};
answerVideoCall = () => {
const { activeChannelId } = this.state;
this.setState({
activeVideoChannelId: activeChannelId,
incomingVideoCallChannelIds: [],
});
};
hangupVideoCall = () => {
const { activeVideoChannelId } = this.state;
window.pusher
.channel(`presence-channel-${activeVideoChannelId}`)
.trigger('client-endvideocall', {});
this.setState({
activeVideoChannelId: null,
});
};
handleVideoParticipantChange = participants => {
this.setState({ videoCallParticipants: participants });
};
toggleVideoSound = () => {
this.setState(prevState => ({ soundOn: !prevState.soundOn }));
};
toggleVideoVideo = () => {
this.setState(prevState => ({ videoOn: !prevState.videoOn }));
};
triggerSwitchChannel = (id, slug) => {
const { chatChannels, isMobileDevice, unopenedChannelIds } = this.state;
const newUnopenedChannelIds = unopenedChannelIds;
const index = newUnopenedChannelIds.indexOf(id);
if (index > -1) {
newUnopenedChannelIds.splice(index, 1);
}
this.setState({
activeChannel: this.filterForActiveChannel(chatChannels, id),
activeChannelId: parseInt(id, 10),
scrolled: false,
showAlert: false,
unopenedChannelIds: unopenedChannelIds.filter(
unopenedId => unopenedId !== id,
),
});
this.setupChannel(id);
window.history.replaceState(null, null, `/connect/${slug}`);
if (!isMobileDevice) {
document.getElementById('messageform').focus();
}
if (window.ga && ga.create) {
ga('send', 'pageview', window.location.pathname + window.location.search);
}
sendOpen(id, this.handleChannelOpenSuccess, null);
};
handleSubmitOnClick = e => {
e.preventDefault();
const message = document.getElementById('messageform').value;
if (message.length > 0) {
this.handleMessageSubmit(message);
document.getElementById('messageform').value = '';
}
};
handleSubmitOnClickEdit = e => {
e.preventDefault();
const message = document.getElementById('messageform').value;
if (message.length > 0) {
this.handleMessageSubmitEdit(message);
document.getElementById('messageform').value = '';
}
};
triggerDeleteMessage = e => {
this.setState({ messageDeleteId: e.target.dataset.content });
this.setState({ showDeleteModal: true });
};
triggerEditMessage = e => {
const { messages, activeChannelId } = this.state;
this.setState({
activeEditMessage: messages[activeChannelId].filter(
message => message.id === parseInt(e.target.dataset.content, 10),
)[0],
});
this.setState({ startEditing: true });
};
handleSuccess = response => {
const { activeChannelId } = this.state;
if (response.status === 'success') {
if (response.message.temp_id) {
this.setState(({ messages }) => {
const newMessages = messages;
const foundIndex = messages[activeChannelId].findIndex(
message => message.temp_id === response.message.temp_id,
);
if (foundIndex > 0) {
newMessages[activeChannelId][foundIndex].id = response.message.id;
}
return { messages: newMessages };
});
}
} else if (response.status === 'error') {
this.receiveNewMessage(response.message);
}
};
triggerActiveContent = e => {
if (
// Trying to open in new tab
e.ctrlKey ||
e.shiftKey ||
e.metaKey || // apple
(e.button && e.button === 1) // middle click, >IE9 + everyone else
) {
return false;
}
const { target } = e;
const content =
target.dataset.content || target.parentElement.dataset.content;
if (content) {
e.preventDefault();
e.stopPropagation();
const { activeChannelId } = this.state;
if (target.dataset.content.startsWith('chat_channels/')) {
this.setActiveContentState(activeChannelId, {
type_of: 'loading-user',
});
getContent(
`/api/${target.dataset.content}`,
this.setActiveContent,
null,
);
} else if (
content.startsWith('sidecar') ||
content.startsWith('article')
) {
// article is legacy which can be removed shortly
this.setActiveContentState(activeChannelId, {
type_of: 'loading-post',
});
this.setActiveContent({
path: target.href || target.parentElement.href,
type_of: 'article',
});
} else if (target.dataset.content === 'exit') {
this.setActiveContentState(activeChannelId, null);
}
}
return false;
};
setActiveContentState = (channelId, state) => {
this.setState(prevState => ({
activeContent: {
...prevState.activeContent,
[channelId]: state,
},
}));
};
setActiveContent = response => {
const { activeChannelId } = this.state;
this.setActiveContentState(activeChannelId, response);
setTimeout(() => {
document.getElementById('chat_activecontent').scrollTop = 0;
document.getElementById('chat').scrollLeft = 1000;
}, 3);
setTimeout(() => {
document.getElementById('chat_activecontent').scrollTop = 0;
document.getElementById('chat').scrollLeft = 1000;
}, 10);
};
handleChannelOpenSuccess = response => {
this.setState(({ chatChannels }) => {
const newChannelsObj = chatChannels.map(channel => {
if (parseInt(response.channel, 10) === channel.chat_channel_id) {
return { ...channel, last_opened_at: new Date() };
}
return channel;
});
return { chatChannels: newChannelsObj };
});
};
handleInvitationAccept = e => {
const id = e.target.dataset.content;
sendChannelInviteAction(id, 'accept', this.handleChannelInviteResult, null);
};
handleInvitationDecline = e => {
const id = e.target.dataset.content;
sendChannelInviteAction(
id,
'decline',
this.handleChannelInviteResult,
null,
);
};
handleChannelInviteResult = response => {
this.setState({ inviteChannels: response });
};
triggerChannelTypeFilter = e => {
const { filterQuery } = this.state;
const type = e.target.dataset.channelType;
this.setState({
channelTypeFilter: type,
fetchingPaginatedChannels: false,
});
const filters = type === 'all' ? {} : { filters: `channel_type:${type}` };
getChannels(filterQuery, null, this.props, 0, filters, this.loadChannels);
};
triggerNonChatView = e => {
this.setState({ nonChatView: e.target.dataset.content });
};
triggerExitView = () => {
this.setState({ nonChatView: null });
};
handleFailure = err => {
// eslint-disable-next-line no-console
console.error(err);
};
renderMessages = () => {
const {
activeChannelId,
messages,
showTimestamp,
activeChannel,
currentUserId,
} = this.state;
if (!messages[activeChannelId]) {
return '';
}
if (messages[activeChannelId].length === 0 && activeChannel) {
if (activeChannel.channel_type === 'direct') {
return (
<div className="chatmessage" style={{ color: 'grey' }}>
<div className="chatmessage__body">
You and
{' '}
<a href={`/${activeChannel.channel_modified_slug}`}>
{activeChannel.channel_modified_slug}
</a>
{' '}
are connected because you both follow each other. All interactions
{' '}
<em>
<b>must</b>
</em>
{' '}
abide by the
{' '}
<a href="/code-of-conduct">code of conduct</a>
.
</div>
</div>
);
}
if (activeChannel.channel_type === 'open') {
return (
<div className="chatmessage" style={{ color: 'grey' }}>
<div className="chatmessage__body">
You have joined
{' '}
{activeChannel.channel_name}
! All interactions
{' '}
<em>
<b>must</b>
</em>
{' '}
abide by the
{' '}
<a href="/code-of-conduct">code of conduct</a>
.
</div>
</div>
);
}
}
return messages[activeChannelId].map(message => (
<Message
currentUserId={currentUserId}
id={message.id}
user={message.username}
userID={message.user_id}
profileImageUrl={message.profile_image_url}
message={message.message}
timestamp={showTimestamp ? message.timestamp : null}
editedAt={message.edited_at}
color={message.color}
type={message.type}
onContentTrigger={this.triggerActiveContent}
onDeleteMessageTrigger={this.triggerDeleteMessage}
onEditMessageTrigger={this.triggerEditMessage}
/>
));
};
triggerChannelFilter = e => {
const { channelTypeFilter } = this.state;
const filters =
channelTypeFilter === 'all'
? {}
: { filters: `channel_type:${channelTypeFilter}` };
getChannels(
e.target.value,
null,
this.props,
0,
filters,
this.loadChannels,
);
};
toggleExpand = () => {
this.setState(prevState => ({ expanded: !prevState.expanded }));
};
renderChannelFilterButton = (type, name, active) => (
<button
data-channel-type={type}
onClick={this.triggerChannelTypeFilter}
className={`chat__channeltypefilterbutton chat__channeltypefilterbutton--${
type === active ? 'active' : 'inactive'
}`}
type="button"
>
{name}
</button>
);
renderChatChannels = () => {
const { state } = this;
if (state.showChannelsList) {
const { notificationsPermission } = state;
const notificationsButton = '';
let notificationsState = '';
let invitesButton = '';
if (notificationsPermission === 'granted') {
notificationsState = (
<div className="chat_chatconfig chat_chatconfig--on">
Notifications On
</div>
);
} else if (notificationsPermission === 'denied') {
notificationsState = (
<div className="chat_chatconfig chat_chatconfig--off">
Notifications Off
</div>
);
}
if (state.inviteChannels.length > 0) {
invitesButton = (
<div className="chat__channelinvitationsindicator">
<button
onClick={this.triggerNonChatView}
data-content="invitations"
type="button"
>
New Invitations!
</button>
</div>
);
}
if (state.expanded) {
return (
<div className="chat__channels chat__channels--expanded">
{notificationsButton}
<button
className="chat__channelstogglebutt"
onClick={this.toggleExpand}
type="button"
>
{'<'}
</button>
<input placeholder="Filter" onKeyUp={this.triggerChannelFilter} />
{invitesButton}
<div className="chat__channeltypefilter">
{this.renderChannelFilterButton(
'all',
'all',
state.channelTypeFilter,
)}
{this.renderChannelFilterButton(
'direct',
'direct',
state.channelTypeFilter,
)}
{this.renderChannelFilterButton(
'invite_only',
'group',
state.channelTypeFilter,
)}
</div>
<Channels
activeChannelId={state.activeChannelId}
chatChannels={state.chatChannels}
unopenedChannelIds={state.unopenedChannelIds}
handleSwitchChannel={this.handleSwitchChannel}
channelsLoaded={state.channelsLoaded}
filterQuery={state.filterQuery}
expanded={state.expanded}
incomingVideoCallChannelIds={state.incomingVideoCallChannelIds}
/>
{notificationsState}
</div>
);
}
return (
<div className="chat__channels">
{notificationsButton}
<button
className="chat__channelstogglebutt"
onClick={this.toggleExpand}
style={{ width: '100%' }}
type="button"
>
{'>'}
</button>
<Channels
incomingVideoCallChannelIds={state.incomingVideoCallChannelIds}
activeChannelId={state.activeChannelId}
chatChannels={state.chatChannels}
unopenedChannelIds={state.unopenedChannelIds}
handleSwitchChannel={this.handleSwitchChannel}
expanded={state.expanded}
/>
{notificationsState}
</div>
);
}
return '';
};
handleMessageScroll = () => {
const {
allMessagesLoaded,
messages,
activeChannelId,
messageOffset,
} = this.state;
if (!messages[activeChannelId]) {
return;
}
const jumpbackButton = document.getElementById('jumpback_button');
if (this.scroller) {
const scrolledRatio =
(this.scroller.scrollTop + this.scroller.clientHeight) /
this.scroller.scrollHeight;
if (scrolledRatio < 0.7) {
jumpbackButton.classList.remove('chatchanneljumpback__hide');
} else if (scrolledRatio > 0.8) {
jumpbackButton.classList.add('chatchanneljumpback__hide');
}
if (this.scroller.scrollTop === 0 && !allMessagesLoaded) {
getAllMessages(
activeChannelId,
messageOffset + messages[activeChannelId].length,
this.addMoreMessages,
);
const curretPosition = this.scroller.scrollHeight;
this.setState({ currentMessageLocation: curretPosition });
}
}
};
addMoreMessages = res => {
const { chatChannelId, messages } = res;
if (messages.length > 0) {
this.setState(prevState => ({
messages: {
[chatChannelId]: [...messages, ...prevState.messages[chatChannelId]],
},
}));
} else {
this.setState({ allMessagesLoaded: true });
}
};
jumpBacktoBottom = () => {
scrollToBottom();
document
.getElementById('jumpback_button')
.classList.remove('chatchanneljumpback__hide');
};
renderActiveChatChannel = (channelHeader, incomingCall) => {
const { state, props } = this;
return (
<div className="activechatchannel">
<div className="activechatchannel__conversation">
{channelHeader}
<div
className="activechatchannel__messages"
onScroll={this.handleMessageScroll}
ref={scroller => {
this.scroller = scroller;
}}
id="messagelist"
>
{this.renderMessages()}
{incomingCall}
<div className="messagelist__sentinel" id="messagelist__sentinel" />
</div>
<div
className="chatchanneljumpback chatchanneljumpback__hide"
id="jumpback_button"
>
<div
role="button"
className="chatchanneljumpback__messages"
onClick={this.jumpBacktoBottom}
tabIndex="0"
onKeyUp={e => {
if (e.keyCode === 13) this.jumpBacktoBottom();
}}
>
Scroll to Bottom
</div>
</div>
{this.renderDeleteModal()}
<div className="activechatchannel__alerts">
<Alert showAlert={state.showAlert} />
</div>
{this.renderChannelMembersList()}
<div className="activechatchannel__form">
<Compose
handleSubmitOnClick={this.handleSubmitOnClick}
handleKeyDown={this.handleKeyDown}
handleSubmitOnClickEdit={this.handleSubmitOnClickEdit}
handleMention={this.handleMention}
handleKeyUp={this.handleKeyUp}
handleKeyDownEdit={this.handleKeyDownEdit}
activeChannelId={state.activeChannelId}
startEditing={state.startEditing}
markdownEdited={state.markdownEdited}
editMessageHtml={state.activeEditMessage.message}
editMessageMarkdown={state.activeEditMessage.markdown}
handleEditMessageClose={this.handleEditMessageClose}
/>
</div>
</div>
<Content
onTriggerContent={this.triggerActiveContent}
resource={state.activeContent[state.activeChannelId]}
activeChannelId={state.activeChannelId}
activeChannel={state.activeChannel}
pusherKey={props.pusherKey}
githubToken={props.githubToken}
/>
</div>
);
};
handleMention = e => {
const { activeChannel } = this.state;
const mention = e.keyCode === 64;
if (mention && activeChannel.channel_type !== 'direct') {
this.setState({ showMemberlist: true });
}
};
handleKeyUp = e => {
const { startEditing, activeChannel, showMemberlist } = this.state;
const enterPressed = e.keyCode === 13;
if (enterPressed && showMemberlist)
this.setState({ showMemberlist: false });
if (activeChannel.channel_type !== 'direct') {
if (startEditing) {
this.setState({ markdownEdited: true });
}
if (!e.target.value.includes('@')) {
this.setState({ showMemberlist: false });
} else {
this.setQuery(e.target);
this.listHighlightManager(e.keyCode);
}
}
};
setQuery = e => {
const { showMemberlist } = this.state;
if (showMemberlist) {
const before = e.value.substring(0, e.selectionStart);
const query = before.substring(
before.lastIndexOf('@') + 1,
e.selectionStart,
);
if (query.includes(' ') || before.lastIndexOf('@') < 0)
this.setState({ showMemberlist: false });
else {
this.setState({ showMemberlist: true });
this.setState({ memberFilterQuery: query });
}
}
};
addUserName = e => {
const name =
e.target.dataset.content || e.target.parentElement.dataset.content;
const el = document.getElementById('messageform');
const start = el.selectionStart;
const end = el.selectionEnd;
const text = el.value;
let before = text.substring(0, start);
before = text.substring(0, before.lastIndexOf('@') + 1);
const after = text.substring(end, text.length);
el.value = before + name + after;
el.selectionStart = start + name.length;
el.selectionEnd = start + name.length;
el.focus();
this.setState({ showMemberlist: false });
};
listHighlightManager = keyCode => {
const mentionList = document.getElementById('mentionList');
const activeElement = document.querySelector('.active__message__list');
if (mentionList.children.length > 0) {
if (keyCode === 40 && activeElement) {
if (activeElement.nextElementSibling) {
activeElement.classList.remove('active__message__list');
activeElement.nextElementSibling.classList.add(
'active__message__list',
);
}
} else if (keyCode === 38 && activeElement) {
if (activeElement.previousElementSibling) {
activeElement.classList.remove('active__message__list');
activeElement.previousElementSibling.classList.add(
'active__message__list',
);
}
} else {
mentionList.children[0].classList.add('active__message__list');
}
}
};
getMentionedUsers = message => {
const { channelUsers, activeChannelId, activeChannel } = this.state;
if (channelUsers[activeChannelId]) {
if (message.includes('@all') && activeChannel.channel_type !== 'open') {
return Array.from(
Object.values(channelUsers[activeChannelId]).filter(user => user.id),
user => user.id,
);
}
return Array.from(
Object.values(channelUsers[activeChannelId]).filter(user =>
message.includes(user.username),
),
user => user.id,
);
}
return null;
};
renderChannelMembersList = () => {
const {
showMemberlist,
activeChannelId,
channelUsers,
memberFilterQuery,
} = this.state;
const filterRegx = new RegExp(memberFilterQuery, 'gi');
return (
<div
className={
showMemberlist ? 'mention__list mention__visible' : 'mention__list'
}
id="mentionList"
>
{showMemberlist
? Object.values(channelUsers[activeChannelId])
.filter(user => user.username.match(filterRegx))
.map(user => (
<div
className="mention__user"
role="button"
onClick={this.addUserName}
tabIndex="0"
data-content={user.username}
onKeyUp={e => {
if (e.keyCode === 13) this.addUserName();
}}
>
<img
className="mention__user__image"
src={user.profile_image}
alt={user.name}
style={!user.profile_image ? { display: 'none' } : ' '}
/>
<span
style={{
padding: '3px 0px',
'font-size': '16px',
}}
>
{'@'}
{user.username}
<p>{user.name}</p>
</span>
</div>
))
: ' '}
</div>
);
};
handleEditMessageClose = () => {
const textarea = document.getElementById('messageform');
this.setState({
startEditing: false,
markdownEdited: false,
activeEditMessage: { message: '', markdown: '' },
});
textarea.value = '';
};
renderDeleteModal = () => {
const { showDeleteModal } = this.state;
return (
<div
id="message"
className={
showDeleteModal
? 'message__delete__modal'
: 'message__delete__modal message__delete__modal__hide'
}
>
<div className="modal__content">
<h3> Are you sure, you want to delete this message ?</h3>
<div className="delete__action__buttons">
<div
role="button"
className="message__cancel__button"
onClick={this.handleCloseDeleteModal}
tabIndex="0"
onKeyUp={e => {
if (e.keyCode === 13) this.handleCloseDeleteModal();
}}
>
{' '}
Cancel
</div>
<div
role="button"
className="message__delete__button"
onClick={this.handleMessageDelete}
tabIndex="0"
onKeyUp={e => {
if (e.keyCode === 13) this.handleMessageDelete();
}}
>
{' '}
Delete
</div>
</div>
</div>
</div>
);
};
handleCloseDeleteModal = () => {
this.setState({ showDeleteModal: false, messageDeleteId: null });
};
handleMessageDelete = () => {
const { messageDeleteId } = this.state;
deleteMessage(messageDeleteId);
this.setState({ showDeleteModal: false });
};
renderChannelHeaderInner = () => {
const { activeChannel, activeChannelId } = this.state;
if (activeChannel.channel_type === 'direct') {
return (
<a
href={`/${activeChannel.channel_username}`}
onClick={this.triggerActiveContent}
data-content="sidecar-user"
>
{activeChannel.channel_modified_slug}
</a>
);
}
return (
<a
href={`/connect/${activeChannel.channel_modified_slug}`}
onClick={this.triggerActiveContent}
data-content={`chat_channels/${activeChannelId}`}
>
{activeChannel.channel_name}
</a>
);
};
renderChannelConfigImage = () => {
const { activeContent, activeChannel, activeChannelId } = this.state;
if (
activeContent[activeChannelId] &&
activeContent[activeChannelId].type_of
) {
return '';
}
const dataContent =
activeChannel.channel_type === 'direct'
? 'sidecar-user'
: `chat_channels/${activeChannelId}`;
return (
<a
className="activechatchannel__channelconfig"
onClick={this.triggerActiveContent}
onKeyUp={e => {
if (e.keyCode === 13) this.triggerActiveContent(e);
}}
tabIndex="0"
href={`/${activeChannel.channel_username}`}
data-content={dataContent}
>
<img
src={ConfigImage}
alt="channel config"
data-content={dataContent}
/>
</a>
);
};
render() {
const { state } = this;
const detectIOSSafariClass =
navigator.userAgent.match(/iPhone/i) &&
!navigator.userAgent.match('CriOS')
? ' chat--iossafari'
: '';
let channelHeader = <div className="activechatchannel__header">&nbsp;</div>;
if (state.activeChannel) {
channelHeader = (
<div className="activechatchannel__header">
{this.renderChannelHeaderInner()}
{this.renderChannelConfigImage()}
</div>
);
}
let vid = '';
let incomingCall = '';
if (state.activeVideoChannelId) {
vid = (
<Video
activeChannelId={state.activeChannelId}
onToggleSound={this.toggleVideoSound}
onToggleVideo={this.toggleVideoVideo}
soundOn={state.soundOn}
videoOn={state.videoOn}
onExit={this.hangupVideoCall}
onParticipantChange={this.handleVideoParticipantChange}
/>
);
} else if (
state.incomingVideoCallChannelIds.includes(state.activeChannelId)
) {
incomingCall = (
<div
className="activechatchannel__incomingcall"
onClick={this.answerVideoCall}
onKeyUp={e => {
if (e.keyCode === 13) this.answerVideoCall();
}}
role="button"
tabIndex="0"
>
<span role="img" aria-label="waving">
👋
</span>
{' '}
Incoming Video Call
{' '}
</div>
);
}
let nonChatView = '';
if (state.nonChatView) {
nonChatView = (
<View
channels={state.inviteChannels}
onViewExit={this.triggerExitView}
onAcceptInvitation={this.handleInvitationAccept}
onDeclineInvitation={this.handleInvitationDecline}
/>
);
}
return (
<div
className={`chat chat--${
state.expanded ? 'expanded' : 'contracted'
}${detectIOSSafariClass}`}
data-no-instant
>
{this.renderChatChannels()}
<div className="chat__activechat">
{vid}
{nonChatView}
{this.renderActiveChatChannel(channelHeader, incomingCall)}
</div>
</div>
);
}
}