import React, { Component } from 'react'; import PropTypes from 'prop-types'; import { View, TextInput, FlatList, Text, TouchableOpacity, Alert } from 'react-native'; import { connect } from 'react-redux'; import { emojify } from 'react-emojione'; import { KeyboardAccessoryView } from 'react-native-keyboard-input'; import ImagePicker from 'react-native-image-crop-picker'; import { BorderlessButton } from 'react-native-gesture-handler'; import equal from 'deep-equal'; import { userTyping as userTypingAction } from '../../actions/room'; import { editRequest as editRequestAction, editCancel as editCancelAction, replyCancel as replyCancelAction } from '../../actions/messages'; import RocketChat from '../../lib/rocketchat'; import styles from './styles'; import database from '../../lib/realm'; import Avatar from '../Avatar'; import CustomEmoji from '../EmojiPicker/CustomEmoji'; import { emojis } from '../../emojis'; import Recording from './Recording'; import FilesActions from './FilesActions'; import UploadModal from './UploadModal'; import './EmojiKeyboard'; import log from '../../utils/log'; import I18n from '../../i18n'; import ReplyPreview from './ReplyPreview'; import { CustomIcon } from '../../lib/Icons'; import debounce from '../../utils/debounce'; import { COLOR_PRIMARY, COLOR_TEXT_DESCRIPTION } from '../../constants/colors'; const MENTIONS_TRACKING_TYPE_USERS = '@'; const MENTIONS_TRACKING_TYPE_EMOJIS = ':'; const onlyUnique = function onlyUnique(value, index, self) { return self.indexOf(({ _id }) => value._id === _id) === index; }; const imagePickerConfig = { cropping: true, compressImageQuality: 0.8, avoidEmptySpaceAroundImage: false, cropperChooseText: I18n.t('Choose'), cropperCancelText: I18n.t('Cancel') }; class MessageBox extends Component { static propTypes = { rid: PropTypes.string.isRequired, baseUrl: PropTypes.string.isRequired, message: PropTypes.object, replyMessage: PropTypes.object, replying: PropTypes.bool, editing: PropTypes.bool, threadsEnabled: PropTypes.bool, isFocused: PropTypes.bool, user: PropTypes.shape({ id: PropTypes.string, username: PropTypes.string, token: PropTypes.string }), roomType: PropTypes.string, tmid: PropTypes.string, editCancel: PropTypes.func.isRequired, editRequest: PropTypes.func.isRequired, onSubmit: PropTypes.func.isRequired, typing: PropTypes.func, closeReply: PropTypes.func } constructor(props) { super(props); this.state = { mentions: [], showEmojiKeyboard: false, showFilesAction: false, showSend: false, recording: false, trackingType: '', file: { isVisible: false } }; this.users = []; this.rooms = []; this.emojis = []; this.customEmojis = []; this.onEmojiSelected = this.onEmojiSelected.bind(this); this.text = ''; } componentDidMount() { const { rid, tmid } = this.props; let msg; if (tmid) { const thread = database.objectForPrimaryKey('threads', tmid); if (thread) { msg = thread.draftMessage; } } else { const [room] = database.objects('subscriptions').filtered('rid = $0', rid); if (room) { msg = room.draftMessage; } } if (msg) { this.setInput(msg); this.setShowSend(true); } } componentWillReceiveProps(nextProps) { const { message, replyMessage, isFocused } = this.props; if (!isFocused) { return; } if (!equal(message, nextProps.message) && nextProps.message.msg) { this.setInput(nextProps.message.msg); if (this.text) { this.setShowSend(true); } this.focus(); } else if (!equal(replyMessage, nextProps.replyMessage)) { this.focus(); } else if (!nextProps.message) { this.clearInput(); } } shouldComponentUpdate(nextProps, nextState) { const { showEmojiKeyboard, showFilesAction, showSend, recording, mentions, file } = this.state; const { roomType, replying, editing, isFocused } = this.props; if (!isFocused) { return false; } if (nextProps.roomType !== roomType) { return true; } if (nextProps.replying !== replying) { return true; } if (nextProps.editing !== editing) { return true; } if (nextState.showEmojiKeyboard !== showEmojiKeyboard) { return true; } if (nextState.showFilesAction !== showFilesAction) { return true; } if (nextState.showSend !== showSend) { return true; } if (nextState.recording !== recording) { return true; } if (!equal(nextState.mentions, mentions)) { return true; } if (!equal(nextState.file, file)) { return true; } return false; } onChangeText = (text) => { const isTextEmpty = text.length === 0; this.setShowSend(!isTextEmpty); this.handleTyping(!isTextEmpty); this.debouncedOnChangeText(text); } // eslint-disable-next-line react/sort-comp debouncedOnChangeText = debounce((text) => { this.setInput(text); if (this.component) { requestAnimationFrame(() => { const { start, end } = this.component._lastNativeSelection; const cursor = Math.max(start, end); const lastNativeText = this.component._lastNativeText; const regexp = /(#|@|:)([a-z0-9._-]+)$/im; const result = lastNativeText.substr(0, cursor).match(regexp); if (!result) { return this.stopTrackingMention(); } const [, lastChar, name] = result; this.identifyMentionKeyword(name, lastChar); }); } }, 100); onKeyboardResigned = () => { this.closeEmoji(); } onPressMention = (item) => { if (!this.component) { return; } const { trackingType } = this.state; const msg = this.text; const { start, end } = this.component._lastNativeSelection; const cursor = Math.max(start, end); const regexp = /([a-z0-9._-]+)$/im; const result = msg.substr(0, cursor).replace(regexp, ''); const mentionName = trackingType === MENTIONS_TRACKING_TYPE_EMOJIS ? `${ item.name || item }:` : (item.username || item.name); const text = `${ result }${ mentionName } ${ msg.slice(cursor) }`; this.setInput(text); this.focus(); requestAnimationFrame(() => this.stopTrackingMention()); } onEmojiSelected = (keyboardId, params) => { const { text } = this; const { emoji } = params; let newText = ''; // if messagebox has an active cursor if (this.component && this.component._lastNativeSelection) { const { start, end } = this.component._lastNativeSelection; const cursor = Math.max(start, end); newText = `${ text.substr(0, cursor) }${ emoji }${ text.substr(cursor) }`; } else { // if messagebox doesn't have a cursor, just append selected emoji newText = `${ text }${ emoji }`; } this.setInput(newText); this.setShowSend(true); } get leftButtons() { const { showEmojiKeyboard } = this.state; const { editing } = this.props; if (editing) { return ( ); } return !showEmojiKeyboard ? ( ) : ( ); } get rightButtons() { const { showSend } = this.state; const icons = []; if (showSend) { icons.push( ); return icons; } icons.push( ); icons.push( ); return icons; } getPermalink = async(message) => { try { return await RocketChat.getPermalink(message); } catch (error) { return null; } } getFixedMentions = (keyword) => { if ('all'.indexOf(keyword) !== -1) { this.users = [{ _id: -1, username: 'all' }, ...this.users]; } if ('here'.indexOf(keyword) !== -1) { this.users = [{ _id: -2, username: 'here' }, ...this.users]; } } getUsers = async(keyword) => { this.users = database.objects('users'); if (keyword) { this.users = this.users.filtered('username CONTAINS[c] $0', keyword); } this.getFixedMentions(keyword); this.setState({ mentions: this.users.slice() }); const usernames = []; if (keyword && this.users.length > 7) { return; } this.users.forEach(user => usernames.push(user.username)); if (this.oldPromise) { this.oldPromise(); } try { const results = await Promise.race([ RocketChat.spotlight(keyword, usernames, { users: true }), new Promise((resolve, reject) => (this.oldPromise = reject)) ]); if (results.users && results.users.length) { database.write(() => { results.users.forEach((user) => { try { database.create('users', user, true); } catch (e) { log('create users', e); } }); }); } } catch (e) { console.warn('spotlight canceled'); } finally { delete this.oldPromise; this.users = database.objects('users').filtered('username CONTAINS[c] $0', keyword).slice(); this.getFixedMentions(keyword); this.setState({ mentions: this.users }); } } getRooms = async(keyword = '') => { this.roomsCache = this.roomsCache || []; this.rooms = database.objects('subscriptions') .filtered('t != $0', 'd'); if (keyword) { this.rooms = this.rooms.filtered('name CONTAINS[c] $0', keyword); } const rooms = []; this.rooms.forEach(room => rooms.push(room)); this.roomsCache.forEach((room) => { if (room.name && room.name.toUpperCase().indexOf(keyword.toUpperCase()) !== -1) { rooms.push(room); } }); if (rooms.length > 3) { this.setState({ mentions: rooms }); return; } if (this.oldPromise) { this.oldPromise(); } try { const results = await Promise.race([ RocketChat.spotlight(keyword, [...rooms, ...this.roomsCache].map(r => r.name), { rooms: true }), new Promise((resolve, reject) => (this.oldPromise = reject)) ]); if (results.rooms && results.rooms.length) { this.roomsCache = [...this.roomsCache, ...results.rooms].filter(onlyUnique); } this.setState({ mentions: [...rooms.slice(), ...results.rooms] }); } catch (e) { console.warn('spotlight canceled'); } finally { delete this.oldPromise; } } getEmojis = (keyword) => { if (keyword) { this.customEmojis = database.objects('customEmojis').filtered('name CONTAINS[c] $0', keyword).slice(0, 4); this.emojis = emojis.filter(emoji => emoji.indexOf(keyword) !== -1).slice(0, 4); const mergedEmojis = [...this.customEmojis, ...this.emojis]; this.setState({ mentions: mergedEmojis }); } } focus = () => { if (this.component && this.component.focus) { this.component.focus(); } } handleTyping = (isTyping) => { const { typing, rid } = this.props; if (!isTyping) { if (this.typingTimeout) { clearTimeout(this.typingTimeout); this.typingTimeout = false; } typing(rid, false); return; } if (this.typingTimeout) { return; } this.typingTimeout = setTimeout(() => { typing(rid, true); this.typingTimeout = false; }, 1000); } setInput = (text) => { this.text = text; if (this.component && this.component.setNativeProps) { this.component.setNativeProps({ text }); } } setShowSend = (showSend) => { this.setState({ showSend }); } clearInput = () => { this.setInput(''); this.setShowSend(false); } toggleFilesActions = () => { this.setState(prevState => ({ showFilesAction: !prevState.showFilesAction })); } sendImageMessage = async(file) => { const { rid, tmid } = this.props; this.setState({ file: { isVisible: false } }); const fileInfo = { name: file.name, description: file.description, size: file.size, type: file.mime, store: 'Uploads', path: file.path }; try { await RocketChat.sendFileMessage(rid, fileInfo, tmid); } catch (e) { log('sendImageMessage', e); } } takePhoto = async() => { try { const image = await ImagePicker.openCamera(imagePickerConfig); this.showUploadModal(image); } catch (e) { log('takePhoto', e); } } chooseFromLibrary = async() => { try { const image = await ImagePicker.openPicker(imagePickerConfig); this.showUploadModal(image); } catch (e) { log('chooseFromLibrary', e); } } showUploadModal = (file) => { this.setState({ file: { ...file, isVisible: true } }); } editCancel = () => { const { editCancel } = this.props; editCancel(); this.clearInput(); } openEmoji = async() => { await this.setState({ showEmojiKeyboard: true }); } recordAudioMessage = async() => { const recording = await Recording.permission(); this.setState({ recording }); } finishAudioMessage = async(fileInfo) => { const { rid, tmid } = this.props; this.setState({ recording: false }); if (fileInfo) { try { await RocketChat.sendFileMessage(rid, fileInfo, tmid); } catch (e) { if (e && e.error === 'error-file-too-large') { return Alert.alert(I18n.t(e.error)); } log('finishAudioMessage', e); } } } closeEmoji = () => { this.setState({ showEmojiKeyboard: false }); } submit = async() => { const { message: editingMessage, editRequest, onSubmit } = this.props; const message = this.text; this.closeEmoji(); this.stopTrackingMention(); this.handleTyping(false); if (message.trim() === '') { return; } const { editing, replying } = this.props; // Edit if (editing) { const { _id, rid } = editingMessage; editRequest({ _id, msg: message, rid }); // Reply } else if (replying) { const { replyMessage, closeReply, threadsEnabled } = this.props; // Thread if (threadsEnabled) { onSubmit(message, replyMessage._id); // Legacy reply } else { const { user, roomType } = this.props; const permalink = await this.getPermalink(replyMessage); let msg = `[ ](${ permalink }) `; // if original message wasn't sent by current user and neither from a direct room if (user.username !== replyMessage.u.username && roomType !== 'd' && replyMessage.mention) { msg += `@${ replyMessage.u.username } `; } msg = `${ msg } ${ message }`; onSubmit(msg); } closeReply(); // Normal message } else { onSubmit(message); } this.clearInput(); } updateMentions = (keyword, type) => { if (type === MENTIONS_TRACKING_TYPE_USERS) { this.getUsers(keyword); } else if (type === MENTIONS_TRACKING_TYPE_EMOJIS) { this.getEmojis(keyword); } else { this.getRooms(keyword); } } identifyMentionKeyword = (keyword, type) => { this.setState({ showEmojiKeyboard: false, trackingType: type }); this.updateMentions(keyword, type); } stopTrackingMention = () => { const { trackingType } = this.state; if (!trackingType) { return; } this.setState({ mentions: [], trackingType: '' }); this.users = []; this.rooms = []; this.customEmojis = []; this.emojis = []; } renderFixedMentionItem = item => ( this.onPressMention(item)} > {item.username} {item.username === 'here' ? I18n.t('Notify_active_in_this_room') : I18n.t('Notify_all_in_this_room')} ) renderMentionEmoji = (item) => { const { baseUrl } = this.props; if (item.name) { return ( ); } return ( {emojify(`:${ item }:`, { output: 'unicode' })} ); } renderMentionItem = (item) => { const { trackingType } = this.state; const { baseUrl, user } = this.props; if (item.username === 'all' || item.username === 'here') { return this.renderFixedMentionItem(item); } return ( this.onPressMention(item)} testID={`mention-item-${ trackingType === MENTIONS_TRACKING_TYPE_EMOJIS ? item.name || item : item.username || item.name }`} > {trackingType === MENTIONS_TRACKING_TYPE_EMOJIS ? [ this.renderMentionEmoji(item), :{ item.name || item }: ] : [ , { item.username || item.name } ] } ); } renderMentions = () => { const { mentions, trackingType } = this.state; if (!trackingType) { return null; } return ( this.renderMentionItem(item)} keyExtractor={item => item._id || item.username || item} keyboardShouldPersistTaps='always' /> ); }; renderReplyPreview = () => { const { replyMessage, replying, closeReply, user } = this.props; if (!replying) { return null; } return ; }; renderFilesActions = () => { const { showFilesAction } = this.state; if (!showFilesAction) { return null; } return ( ); } renderContent = () => { const { recording } = this.state; const { editing } = this.props; if (recording) { return (); } return ( [ this.renderMentions(), {this.renderReplyPreview()} {this.leftButtons} this.component = component} style={styles.textBoxInput} returnKeyType='default' keyboardType='twitter' blurOnSubmit={false} placeholder={I18n.t('New_Message')} onChangeText={this.onChangeText} underlineColorAndroid='transparent' defaultValue='' multiline placeholderTextColor={COLOR_TEXT_DESCRIPTION} testID='messagebox-input' /> {this.rightButtons} ] ); } render() { const { showEmojiKeyboard, file } = this.state; return ( [ , this.renderFilesActions(), this.setState({ file: {} })} submit={this.sendImageMessage} /> ] ); } } const mapStateToProps = state => ({ message: state.messages.message, replyMessage: state.messages.replyMessage, replying: state.messages.replying, editing: state.messages.editing, baseUrl: state.settings.Site_Url || state.server ? state.server.server : '', threadsEnabled: state.settings.Threads_enabled, user: { id: state.login.user && state.login.user.id, username: state.login.user && state.login.user.username, token: state.login.user && state.login.user.token } }); const dispatchToProps = ({ editCancel: () => editCancelAction(), editRequest: message => editRequestAction(message), typing: (rid, status) => userTypingAction(rid, status), closeReply: () => replyCancelAction() }); export default connect(mapStateToProps, dispatchToProps, null, { forwardRef: true })(MessageBox);