import React from 'react'; import PropTypes from 'prop-types'; import { Text, View, InteractionManager } from 'react-native'; import { connect } from 'react-redux'; import { RectButton } from 'react-native-gesture-handler'; import { SafeAreaView } from 'react-navigation'; import { HeaderBackButton } from 'react-navigation-stack'; import { sanitizedRaw } from '@nozbe/watermelondb/RawRecord'; import moment from 'moment'; import * as Haptics from 'expo-haptics'; import { Q } from '@nozbe/watermelondb'; import isEqual from 'lodash/isEqual'; import { replyBroadcast as replyBroadcastAction } from '../../actions/messages'; import { List } from './List'; import database from '../../lib/database'; import RocketChat from '../../lib/rocketchat'; import Message from '../../containers/message'; import MessageActions from '../../containers/MessageActions'; import MessageErrorActions from '../../containers/MessageErrorActions'; import MessageBox from '../../containers/MessageBox'; import ReactionPicker from './ReactionPicker'; import UploadProgress from './UploadProgress'; import styles from './styles'; import log from '../../utils/log'; import EventEmitter from '../../utils/events'; import I18n from '../../i18n'; import RoomHeaderView, { RightButtons } from './Header'; import StatusBar from '../../containers/StatusBar'; import Separator from './Separator'; import { COLOR_WHITE, HEADER_BACK } from '../../constants/colors'; import debounce from '../../utils/debounce'; import FileModal from '../../containers/FileModal'; import ReactionsModal from '../../containers/ReactionsModal'; import { LISTENER } from '../../containers/Toast'; import { isReadOnly, isBlocked } from '../../utils/room'; import { isIOS } from '../../utils/deviceInfo'; import { showErrorAlert } from '../../utils/info'; const stateAttrsUpdate = [ 'joined', 'lastOpen', 'photoModalVisible', 'reactionsModalVisible', 'canAutoTranslate', 'showActions', 'showErrorActions', 'loading', 'editing', 'replying', 'reacting' ]; const roomAttrsUpdate = ['f', 'ro', 'blocked', 'blocker', 'archived', 'muted', 'jitsiTimeout']; class RoomView extends React.Component { static navigationOptions = ({ navigation }) => { const rid = navigation.getParam('rid'); const prid = navigation.getParam('prid'); const title = navigation.getParam('name'); const t = navigation.getParam('t'); const tmid = navigation.getParam('tmid'); const room = navigation.getParam('room'); const toggleFollowThread = navigation.getParam('toggleFollowThread', () => {}); const unreadsCount = navigation.getParam('unreadsCount', null); return { headerTitle: ( ), headerRight: ( ), headerLeft: ( 999 ? '+999' : unreadsCount || ' '} backTitleVisible={isIOS} onPress={() => navigation.goBack()} tintColor={HEADER_BACK} /> ) }; } static propTypes = { navigation: PropTypes.object, user: PropTypes.shape({ id: PropTypes.string.isRequired, username: PropTypes.string.isRequired, token: PropTypes.string.isRequired }), appState: PropTypes.string, useRealName: PropTypes.bool, isAuthenticated: PropTypes.bool, Message_GroupingPeriod: PropTypes.number, Message_TimeFormat: PropTypes.string, Message_Read_Receipt_Enabled: PropTypes.bool, baseUrl: PropTypes.string, customEmojis: PropTypes.object, useMarkdown: PropTypes.bool, replyBroadcast: PropTypes.func }; constructor(props) { super(props); console.time(`${ this.constructor.name } init`); console.time(`${ this.constructor.name } mount`); this.rid = props.navigation.getParam('rid'); this.t = props.navigation.getParam('t'); this.tmid = props.navigation.getParam('tmid', null); const room = props.navigation.getParam('room'); const selectedMessage = props.navigation.getParam('message'); this.state = { joined: true, room: room || { rid: this.rid, t: this.t }, roomUpdate: {}, lastOpen: null, photoModalVisible: false, reactionsModalVisible: false, selectedAttachment: {}, selectedMessage: selectedMessage || {}, canAutoTranslate: false, loading: true, showActions: false, showErrorActions: false, editing: false, replying: !!selectedMessage, replyWithMention: false, reacting: false }; if (room && room.observe) { this.observeRoom(room); } else { this.findAndObserveRoom(this.rid); } this.beginAnimating = false; this.didFocusListener = props.navigation.addListener('didFocus', () => this.beginAnimating = true); this.messagebox = React.createRef(); this.willBlurListener = props.navigation.addListener('willBlur', () => this.mounted = false); this.mounted = false; console.timeEnd(`${ this.constructor.name } init`); } componentDidMount() { this.mounted = true; this.didMountInteraction = InteractionManager.runAfterInteractions(() => { const { room } = this.state; const { navigation, isAuthenticated } = this.props; if (room.id && !this.tmid) { navigation.setParams({ name: this.getRoomTitle(room), t: room.t }); } if (this.tmid) { navigation.setParams({ toggleFollowThread: this.toggleFollowThread }); } if (isAuthenticated) { this.init(); } else { EventEmitter.addEventListener('connected', this.handleConnected); } if (isIOS) { this.updateUnreadCount(); } }); console.timeEnd(`${ this.constructor.name } mount`); } shouldComponentUpdate(nextProps, nextState) { const { state } = this; const { roomUpdate } = state; const { appState } = this.props; if (appState !== nextProps.appState) { return true; } const stateUpdated = stateAttrsUpdate.some(key => nextState[key] !== state[key]); if (stateUpdated) { return true; } return roomAttrsUpdate.some(key => !isEqual(nextState.roomUpdate[key], roomUpdate[key])); } componentDidUpdate(prevProps) { const { appState } = this.props; if (appState === 'foreground' && appState !== prevProps.appState) { this.onForegroundInteraction = InteractionManager.runAfterInteractions(() => { this.init(); }); } } async componentWillUnmount() { const { editing, room } = this.state; const db = database.active; this.mounted = false; if (!editing && this.messagebox && this.messagebox.current) { const { text } = this.messagebox.current; let obj; if (this.tmid) { try { const threadsCollection = db.collections.get('threads'); obj = await threadsCollection.find(this.tmid); } catch (e) { // Do nothing } } else { obj = room; } if (obj) { try { await db.action(async() => { await obj.update((r) => { r.draftMessage = text; }); }); } catch (error) { // Do nothing } } } if (this.sub && this.sub.stop) { this.sub.stop(); } if (this.didFocusListener && this.didFocusListener.remove) { this.didFocusListener.remove(); } if (this.didMountInteraction && this.didMountInteraction.cancel) { this.didMountInteraction.cancel(); } if (this.onForegroundInteraction && this.onForegroundInteraction.cancel) { this.onForegroundInteraction.cancel(); } if (this.initInteraction && this.initInteraction.cancel) { this.initInteraction.cancel(); } if (this.willBlurListener && this.willBlurListener.remove) { this.willBlurListener.remove(); } if (this.subSubscription && this.subSubscription.unsubscribe) { this.subSubscription.unsubscribe(); } if (this.queryUnreads && this.queryUnreads.unsubscribe) { this.queryUnreads.unsubscribe(); } EventEmitter.removeListener('connected', this.handleConnected); console.countReset(`${ this.constructor.name }.render calls`); } // eslint-disable-next-line react/sort-comp init = () => { try { this.setState({ loading: true }); this.initInteraction = InteractionManager.runAfterInteractions(async() => { const { room, joined } = this.state; if (this.tmid) { await this.getThreadMessages(); } else { const newLastOpen = new Date(); await this.getMessages(room); // if room is joined if (joined) { if (room.alert || room.unread || room.userMentions) { this.setLastOpen(room.ls); } else { this.setLastOpen(null); } RocketChat.readMessages(room.rid, newLastOpen).catch(e => console.log(e)); this.sub = await RocketChat.subscribeRoom(room); } } // We run `canAutoTranslate` again in order to refetch auto translate permission // in case of a missing connection or poor connection on room open const canAutoTranslate = await RocketChat.canAutoTranslate(); this.setState({ canAutoTranslate, loading: false }); }); } catch (e) { this.setState({ loading: false }); log(e); } } findAndObserveRoom = async(rid) => { try { const db = database.active; const { navigation } = this.props; const subCollection = await db.collections.get('subscriptions'); const room = await subCollection.find(rid); this.setState({ room }); navigation.setParams({ room }); this.observeRoom(room); } catch (error) { if (this.t !== 'd') { console.log('Room not found'); this.internalSetState({ joined: false }); } else { // We navigate to RoomView before the DM is inserted to the local db // So we retry just to make sure we have the right content this.retryFindCount = this.retryFindCount + 1 || 1; if (this.retryFindCount <= 3) { this.retryFindTimeout = setTimeout(() => { this.findAndObserveRoom(rid); this.init(); }, 300); } } } } observeRoom = (room) => { const observable = room.observe(); this.subSubscription = observable .subscribe((changes) => { const roomUpdate = roomAttrsUpdate.reduce((ret, attr) => { ret[attr] = changes[attr]; return ret; }, {}); if (this.mounted) { this.internalSetState({ room: changes, roomUpdate }); } else { this.state.room = changes; this.state.roomUpdate = roomUpdate; } }); } errorActionsShow = (message) => { this.setState({ selectedMessage: message, showErrorActions: true }); } onActionsHide = () => { const { editing, replying, reacting } = this.state; if (editing || replying || reacting) { return; } this.setState({ selectedMessage: {}, showActions: false }); } onErrorActionsHide = () => { this.setState({ selectedMessage: {}, showErrorActions: false }); } onEditInit = (message) => { this.setState({ selectedMessage: message, editing: true, showActions: false }); } onEditCancel = () => { this.setState({ selectedMessage: {}, editing: false }); } onEditRequest = async(message) => { this.setState({ selectedMessage: {}, editing: false }); try { await RocketChat.editMessage(message); } catch (e) { log(e); } } onReplyInit = (message, mention) => { this.setState({ selectedMessage: message, replying: true, showActions: false, replyWithMention: mention }); } onReplyCancel = () => { this.setState({ selectedMessage: {}, replying: false }); } onReactionInit = (message) => { this.setState({ selectedMessage: message, reacting: true, showActions: false }); } onReactionClose = () => { this.setState({ selectedMessage: {}, reacting: false }); } onMessageLongPress = (message) => { this.setState({ selectedMessage: message, showActions: true }); } onOpenFileModal = (attachment) => { this.setState({ selectedAttachment: attachment, photoModalVisible: true }); } onCloseFileModal = () => { this.setState({ selectedAttachment: {}, photoModalVisible: false }); } onReactionPress = async(shortname, messageId) => { try { await RocketChat.setReaction(shortname, messageId); this.onReactionClose(); } catch (e) { log(e); } }; onReactionLongPress = (message) => { this.setState({ selectedMessage: message, reactionsModalVisible: true }); Haptics.impactAsync(Haptics.ImpactFeedbackStyle.Light); } onCloseReactionsModal = () => { this.setState({ selectedMessage: {}, reactionsModalVisible: false }); } onDiscussionPress = debounce((item) => { const { navigation } = this.props; navigation.push('RoomView', { rid: item.drid, prid: item.rid, name: item.msg, t: 'p' }); }, 1000, true) // eslint-disable-next-line react/sort-comp updateUnreadCount = async() => { const db = database.active; const observable = await db.collections .get('subscriptions') .query( Q.where('archived', false), Q.where('open', true), Q.where('rid', Q.notEq(this.rid)) ) .observeWithColumns(['unread']); this.queryUnreads = observable.subscribe((data) => { const { navigation } = this.props; const unreadsCount = data.filter(s => s.unread > 0).reduce((a, b) => a + (b.unread || 0), 0); if (unreadsCount !== navigation.getParam('unreadsCount')) { navigation.setParams({ unreadsCount }); } }); }; onThreadPress = debounce(async(item) => { const { navigation } = this.props; if (item.tmid) { if (!item.tmsg) { await this.fetchThreadName(item.tmid, item.id); } navigation.push('RoomView', { rid: item.subscription.id, tmid: item.tmid, name: item.tmsg, t: 'thread' }); } else if (item.tlm) { navigation.push('RoomView', { rid: item.subscription.id, tmid: item.id, name: item.msg, t: 'thread' }); } }, 1000, true) replyBroadcast = (message) => { const { replyBroadcast } = this.props; replyBroadcast(message); } handleConnected = () => { this.init(); EventEmitter.removeListener('connected', this.handleConnected); } internalSetState = (...args) => { if (!this.mounted) { return; } this.setState(...args); } sendMessage = (message, tmid) => { const { user } = this.props; RocketChat.sendMessage(this.rid, message, this.tmid || tmid, user).then(() => { this.setLastOpen(null); }); }; getRoomTitle = (room) => { const { useRealName } = this.props; return ((room.prid || useRealName) && room.fname) || room.name; } getMessages = async() => { const { room } = this.state; try { if (room.lastOpen) { await RocketChat.loadMissedMessages(room); } else { await RocketChat.loadMessagesForRoom(room); } return Promise.resolve(); } catch (e) { log(e); } } getThreadMessages = () => { try { return RocketChat.loadThreadMessages({ tmid: this.tmid, rid: this.rid }); } catch (e) { log(e); } } getCustomEmoji = (name) => { const { customEmojis } = this.props; const emoji = customEmojis[name]; if (emoji) { return emoji; } return null; } setLastOpen = lastOpen => this.setState({ lastOpen }); joinRoom = async() => { try { await RocketChat.joinRoom(this.rid, this.t); this.internalSetState({ joined: true }); } catch (e) { log(e); } } // eslint-disable-next-line react/sort-comp fetchThreadName = async(tmid, messageId) => { try { const { room } = this.state; const db = database.active; const threadCollection = db.collections.get('threads'); const messageCollection = db.collections.get('messages'); const messageRecord = await messageCollection.find(messageId); let threadRecord; try { threadRecord = await threadCollection.find(tmid); } catch (error) { console.log('Thread not found. We have to search for it.'); } if (threadRecord) { await db.action(async() => { await messageRecord.update((m) => { m.tmsg = threadRecord.msg || (threadRecord.attachments && threadRecord.attachments.length && threadRecord.attachments[0].title); }); }); } else { const thread = await RocketChat.getSingleMessage(tmid); await db.action(async() => { await db.batch( threadCollection.prepareCreate((t) => { t._raw = sanitizedRaw({ id: thread._id }, threadCollection.schema); t.subscription.set(room); Object.assign(t, thread); }), messageRecord.prepareUpdate((m) => { m.tmsg = thread.msg || (thread.attachments && thread.attachments.length && thread.attachments[0].title); }) ); }); } } catch (e) { log(e); } } toggleFollowThread = async(isFollowingThread) => { try { await RocketChat.toggleFollowMessage(this.tmid, !isFollowingThread); EventEmitter.emit(LISTENER, { message: isFollowingThread ? 'Unfollowed thread' : 'Following thread' }); } catch (e) { log(e); } } navToRoomInfo = (navParam) => { const { navigation, user } = this.props; if (navParam.rid === user.id) { return; } navigation.navigate('RoomInfoView', navParam); } callJitsi = () => { const { room } = this.state; const { jitsiTimeout } = room; if (jitsiTimeout < Date.now()) { showErrorAlert(I18n.t('Call_already_ended')); } else { RocketChat.callJitsi(this.rid, {}); } }; get isReadOnly() { const { room } = this.state; const { user } = this.props; return isReadOnly(room, user); } renderItem = (item, previousItem) => { const { room, lastOpen, canAutoTranslate } = this.state; const { user, Message_GroupingPeriod, Message_TimeFormat, useRealName, baseUrl, useMarkdown, Message_Read_Receipt_Enabled } = this.props; let dateSeparator = null; let showUnreadSeparator = false; if (!previousItem) { dateSeparator = item.ts; showUnreadSeparator = moment(item.ts).isAfter(lastOpen); } else { showUnreadSeparator = lastOpen && moment(item.ts).isAfter(lastOpen) && moment(previousItem.ts).isBefore(lastOpen); if (!moment(item.ts).isSame(previousItem.ts, 'day')) { dateSeparator = item.ts; } } const message = ( ); if (showUnreadSeparator || dateSeparator) { return ( {message} ); } return message; } renderFooter = () => { const { joined, room, selectedMessage, editing, replying, replyWithMention } = this.state; const { navigation } = this.props; if (!joined && !this.tmid) { return ( {I18n.t('You_are_in_preview_mode')} {I18n.t('Join')} ); } if (this.isReadOnly) { return ( {I18n.t('This_room_is_read_only')} ); } if (isBlocked(room)) { return ( {I18n.t('This_room_is_blocked')} ); } return ( ); }; renderActions = () => { const { room, selectedMessage, showActions, showErrorActions, joined } = this.state; const { user, navigation } = this.props; if (!navigation.isFocused()) { return null; } return ( <> {joined && showActions ? ( ) : null } {showErrorActions ? ( ) : null} ); } render() { console.count(`${ this.constructor.name }.render calls`); const { room, photoModalVisible, reactionsModalVisible, selectedAttachment, selectedMessage, loading, reacting } = this.state; const { user, baseUrl } = this.props; const { rid, t } = room; return ( {this.renderFooter()} {this.renderActions()} ); } } const mapStateToProps = state => ({ 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 }, appState: state.app.ready && state.app.foreground ? 'foreground' : 'background', useRealName: state.settings.UI_Use_Real_Name, isAuthenticated: state.login.isAuthenticated, Message_GroupingPeriod: state.settings.Message_GroupingPeriod, Message_TimeFormat: state.settings.Message_TimeFormat, useMarkdown: state.markdown.useMarkdown, customEmojis: state.customEmojis, baseUrl: state.settings.baseUrl || state.server ? state.server.server : '', Message_Read_Receipt_Enabled: state.settings.Message_Read_Receipt_Enabled }); const mapDispatchToProps = dispatch => ({ replyBroadcast: message => dispatch(replyBroadcastAction(message)) }); export default connect(mapStateToProps, mapDispatchToProps)(RoomView);