/* Copyright 2015-2021 The Matrix.org Foundation C.I.C. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ import React from 'react'; import { _t, _td } from '../../languageHandler'; import { MatrixClientPeg } from '../../MatrixClientPeg'; import Resend from '../../Resend'; import dis from '../../dispatcher/dispatcher'; import { messageForResourceLimitError } from '../../utils/ErrorUtils'; import { Action } from "../../dispatcher/actions"; import { replaceableComponent } from "../../utils/replaceableComponent"; import { EventStatus, MatrixEvent } from "matrix-js-sdk/src/models/event"; import NotificationBadge from "../views/rooms/NotificationBadge"; import { StaticNotificationState } from "../../stores/notifications/StaticNotificationState"; import AccessibleButton from "../views/elements/AccessibleButton"; import InlineSpinner from "../views/elements/InlineSpinner"; import { SyncState } from "matrix-js-sdk/src/sync.api"; import { ISyncStateData } from "matrix-js-sdk/src/sync"; import { Room } from "matrix-js-sdk/src/models/room"; const STATUS_BAR_HIDDEN = 0; const STATUS_BAR_EXPANDED = 1; const STATUS_BAR_EXPANDED_LARGE = 2; export function getUnsentMessages(room: Room): MatrixEvent[] { if (!room) { return []; } return room.getPendingEvents().filter(function(ev) { return ev.status === EventStatus.NOT_SENT; }); } interface IProps { // the room this statusbar is representing. room: Room; // true if the room is being peeked at. This affects components that shouldn't // logically be shown when peeking, such as a prompt to invite people to a room. isPeeking?: boolean; // callback for when the user clicks on the 'resend all' button in the // 'unsent messages' bar onResendAllClick?: () => void; // callback for when the user clicks on the 'cancel all' button in the // 'unsent messages' bar onCancelAllClick?: () => void; // callback for when the user clicks on the 'invite others' button in the // 'you are alone' bar onInviteClick?: () => void; // callback for when we do something that changes the size of the // status bar. This is used to trigger a re-layout in the parent // component. onResize?: () => void; // callback for when the status bar can be hidden from view, as it is // not displaying anything onHidden?: () => void; // callback for when the status bar is displaying something and should // be visible onVisible?: () => void; } interface IState { syncState: SyncState; syncStateData: ISyncStateData; unsentMessages: MatrixEvent[]; isResending: boolean; } @replaceableComponent("structures.RoomStatusBar") export default class RoomStatusBar extends React.PureComponent { constructor(props: IProps) { super(props); this.state = { syncState: MatrixClientPeg.get().getSyncState(), syncStateData: MatrixClientPeg.get().getSyncStateData(), unsentMessages: getUnsentMessages(this.props.room), isResending: false, }; } public componentDidMount(): void { MatrixClientPeg.get().on("sync", this.onSyncStateChange); MatrixClientPeg.get().on("Room.localEchoUpdated", this.onRoomLocalEchoUpdated); this.checkSize(); } public componentDidUpdate(): void { this.checkSize(); } public componentWillUnmount(): void { // we may have entirely lost our client as we're logging out before clicking login on the guest bar... const client = MatrixClientPeg.get(); if (client) { client.removeListener("sync", this.onSyncStateChange); client.removeListener("Room.localEchoUpdated", this.onRoomLocalEchoUpdated); } } private onSyncStateChange = (state: SyncState, prevState: SyncState, data: ISyncStateData): void => { if (state === "SYNCING" && prevState === "SYNCING") { return; } this.setState({ syncState: state, syncStateData: data, }); }; private onResendAllClick = (): void => { Resend.resendUnsentEvents(this.props.room).then(() => { this.setState({ isResending: false }); }); this.setState({ isResending: true }); dis.fire(Action.FocusSendMessageComposer); }; private onCancelAllClick = (): void => { Resend.cancelUnsentEvents(this.props.room); dis.fire(Action.FocusSendMessageComposer); }; private onRoomLocalEchoUpdated = (ev: MatrixEvent, room: Room) => { if (room.roomId !== this.props.room.roomId) return; const messages = getUnsentMessages(this.props.room); this.setState({ unsentMessages: messages, isResending: messages.length > 0 && this.state.isResending, }); }; // Check whether current size is greater than 0, if yes call props.onVisible private checkSize(): void { if (this.getSize()) { if (this.props.onVisible) this.props.onVisible(); } else { if (this.props.onHidden) this.props.onHidden(); } } // We don't need the actual height - just whether it is likely to have // changed - so we use '0' to indicate normal size, and other values to // indicate other sizes. private getSize(): number { if (this.shouldShowConnectionError()) { return STATUS_BAR_EXPANDED; } else if (this.state.unsentMessages.length > 0 || this.state.isResending) { return STATUS_BAR_EXPANDED_LARGE; } return STATUS_BAR_HIDDEN; } private shouldShowConnectionError(): boolean { // no conn bar trumps the "some not sent" msg since you can't resend without // a connection! // There's one situation in which we don't show this 'no connection' bar, and that's // if it's a resource limit exceeded error: those are shown in the top bar. const errorIsMauError = Boolean( this.state.syncStateData && this.state.syncStateData.error && this.state.syncStateData.error.name === 'M_RESOURCE_LIMIT_EXCEEDED', ); return this.state.syncState === "ERROR" && !errorIsMauError; } private getUnsentMessageContent(): JSX.Element { const unsentMessages = this.state.unsentMessages; let title; let consentError = null; let resourceLimitError = null; for (const m of unsentMessages) { if (m.error && m.error.errcode === 'M_CONSENT_NOT_GIVEN') { consentError = m.error; break; } else if (m.error && m.error.errcode === 'M_RESOURCE_LIMIT_EXCEEDED') { resourceLimitError = m.error; break; } } if (consentError) { title = _t( "You can't send any messages until you review and agree to " + "our terms and conditions.", {}, { 'consentLink': (sub) => { sub } , }, ); } else if (resourceLimitError) { title = messageForResourceLimitError( resourceLimitError.data.limit_type, resourceLimitError.data.admin_contact, { 'monthly_active_user': _td( "Your message wasn't sent because this homeserver has hit its Monthly Active User Limit. " + "Please contact your service administrator to continue using the service.", ), 'hs_disabled': _td( "Your message wasn't sent because this homeserver has been blocked by it's administrator. " + "Please contact your service administrator to continue using the service.", ), '': _td( "Your message wasn't sent because this homeserver has exceeded a resource limit. " + "Please contact your service administrator to continue using the service.", ), }, ); } else { title = _t('Some of your messages have not been sent'); } let buttonRow = <> { _t("Delete all") } { _t("Retry all") } ; if (this.state.isResending) { buttonRow = <> { /* span for css */ } { _t("Sending") } ; } return <>
{ title }
{ _t("You can select all or individual messages to retry or delete") }
{ buttonRow }
; } public render(): JSX.Element { if (this.shouldShowConnectionError()) { return (
/!\
{ _t('Connectivity to the server has been lost.') }
{ _t('Sent messages will be stored until your connection has returned.') }
); } if (this.state.unsentMessages.length > 0 || this.state.isResending) { return this.getUnsentMessageContent(); } return null; } }