import React from 'react'; import { Keyboard } from 'react-native'; import Message from './Message'; import MessageContext from './Context'; import debounce from '../../utils/debounce'; import { SYSTEM_MESSAGES, getMessageTranslation } from './utils'; import { E2E_MESSAGE_TYPE, E2E_STATUS } from '../../lib/encryption/constants'; import messagesStatus from '../../constants/messagesStatus'; import { withTheme } from '../../theme'; import openLink from '../../utils/openLink'; interface IMessageContainerProps { item: any; user: { id: string; username: string; token: string; }; rid: string; timeFormat: string; style: any; archived: boolean; broadcast: boolean; previousItem: { ts: any; u: any; groupable: any; id: any; tmid: any; status: any }; baseUrl: string; Message_GroupingPeriod: number; isReadReceiptEnabled: boolean; isThreadRoom: boolean; useRealName: boolean; autoTranslateRoom: boolean; autoTranslateLanguage: string; status: number; isIgnored: boolean; highlighted: boolean; getCustomEmoji(): void; onLongPress: Function; onReactionPress: Function; onEncryptedPress: Function; onDiscussionPress: Function; onThreadPress: Function; errorActionsShow: Function; replyBroadcast: Function; reactionInit: Function; fetchThreadName: Function; showAttachment: Function; onReactionLongPress: Function; navToRoomInfo: Function; callJitsi: Function; blockAction: Function; theme: string; threadBadgeColor: string; toggleFollowThread: Function; jumpToMessage: Function; onPress: Function; } class MessageContainer extends React.Component { static defaultProps = { getCustomEmoji: () => {}, onLongPress: () => {}, onReactionPress: () => {}, onEncryptedPress: () => {}, onDiscussionPress: () => {}, onThreadPress: () => {}, errorActionsShow: () => {}, replyBroadcast: () => {}, reactionInit: () => {}, fetchThreadName: () => {}, showAttachment: () => {}, onReactionLongPress: () => {}, navToRoomInfo: () => {}, callJitsi: () => {}, blockAction: () => {}, archived: false, broadcast: false, isIgnored: false, theme: 'light' } state = { isManualUnignored: false }; private subscription: any; componentDidMount() { const { item } = this.props; if (item && item.observe) { const observable = item.observe(); this.subscription = observable.subscribe(() => { this.forceUpdate(); }); } } shouldComponentUpdate(nextProps: any, nextState: any) { const { isManualUnignored } = this.state; const { theme, threadBadgeColor, isIgnored, highlighted } = this.props; if (nextProps.theme !== theme) { return true; } if (nextProps.highlighted !== highlighted) { return true; } if (nextProps.threadBadgeColor !== threadBadgeColor) { return true; } if (nextProps.isIgnored !== isIgnored) { return true; } if (nextState.isManualUnignored !== isManualUnignored) { return true; } return false; } componentWillUnmount() { if (this.subscription && this.subscription.unsubscribe) { this.subscription.unsubscribe(); } } onPress = debounce(() => { const { onPress } = this.props; if (this.isIgnored) { return this.onIgnoredMessagePress(); } if (onPress) { return onPress(); } const { item, isThreadRoom } = this.props; Keyboard.dismiss(); if (((item.tlm || item.tmid) && !isThreadRoom)) { this.onThreadPress(); } }, 300, true); onLongPress = () => { const { archived, onLongPress, item } = this.props; if (this.isInfo || this.hasError || this.isEncrypted || archived) { return; } if (onLongPress) { onLongPress(item); } } onErrorPress = () => { const { errorActionsShow, item } = this.props; if (errorActionsShow) { errorActionsShow(item); } } onReactionPress = (emoji: any) => { const { onReactionPress, item } = this.props; if (onReactionPress) { onReactionPress(emoji, item.id); } } onReactionLongPress = () => { const { onReactionLongPress, item } = this.props; if (onReactionLongPress) { onReactionLongPress(item); } } onEncryptedPress = () => { const { onEncryptedPress } = this.props; if (onEncryptedPress) { onEncryptedPress(); } } onDiscussionPress = () => { const { onDiscussionPress, item } = this.props; if (onDiscussionPress) { onDiscussionPress(item); } } onThreadPress = () => { const { onThreadPress, item } = this.props; if (onThreadPress) { onThreadPress(item); } } onIgnoredMessagePress = () => { this.setState({ isManualUnignored: true }); } get isHeader() { const { item, previousItem, broadcast, Message_GroupingPeriod } = this.props; if (this.hasError || (previousItem && previousItem.status === messagesStatus.ERROR)) { return true; } try { if (previousItem && ( (previousItem.ts.toDateString() === item.ts.toDateString()) && (previousItem.u.username === item.u.username) && !(previousItem.groupable === false || item.groupable === false || broadcast === true) && (item.ts - previousItem.ts < Message_GroupingPeriod * 1000) && (previousItem.tmid === item.tmid) )) { return false; } return true; } catch (error) { return true; } } get isThreadReply() { const { item, previousItem, isThreadRoom } = this.props; if (isThreadRoom) { return false; } if (previousItem && item.tmid && (previousItem.tmid !== item.tmid) && (previousItem.id !== item.tmid)) { return true; } return false; } get isThreadSequential() { const { item, isThreadRoom } = this.props; if (isThreadRoom) { return false; } return item.tmid; } get isEncrypted() { const { item } = this.props; const { t, e2e } = item; return t === E2E_MESSAGE_TYPE && e2e !== E2E_STATUS.DONE; } get isInfo() { const { item } = this.props; return SYSTEM_MESSAGES.includes(item.t); } get isTemp() { const { item } = this.props; return item.status === messagesStatus.TEMP || item.status === messagesStatus.ERROR; } get isIgnored() { const { isManualUnignored } = this.state; const { isIgnored } = this.props; return isManualUnignored ? false : isIgnored; } get hasError() { const { item } = this.props; return item.status === messagesStatus.ERROR; } reactionInit = () => { const { reactionInit, item } = this.props; if (reactionInit) { reactionInit(item); } } replyBroadcast = () => { const { replyBroadcast, item } = this.props; if (replyBroadcast) { replyBroadcast(item); } } onLinkPress = (link: any) => { const { item, theme, jumpToMessage } = this.props; const isMessageLink = item?.attachments?.findIndex((att: any) => att?.message_link === link) !== -1; if (isMessageLink) { return jumpToMessage(link); } openLink(link, theme); } render() { const { item, user, style, archived, baseUrl, useRealName, broadcast, fetchThreadName, showAttachment, timeFormat, isReadReceiptEnabled, autoTranslateRoom, autoTranslateLanguage, navToRoomInfo, getCustomEmoji, isThreadRoom, callJitsi, blockAction, rid, theme, threadBadgeColor, toggleFollowThread, jumpToMessage, highlighted } = this.props; const { id, msg, ts, attachments, urls, reactions, t, avatar, emoji, u, alias, editedBy, role, drid, dcount, dlm, tmid, tcount, tlm, tmsg, mentions, channels, unread, blocks, autoTranslate: autoTranslateMessage, replies } = item; let message = msg; // "autoTranslateRoom" and "autoTranslateLanguage" are properties from the subscription // "autoTranslateMessage" is a toggle between "View Original" and "Translate" state if (autoTranslateRoom && autoTranslateMessage) { message = getMessageTranslation(item, autoTranslateLanguage) || message; } return ( {/*@ts-ignore*/} ); } } export default withTheme(MessageContainer);