/* Copyright 2020 Bruno Windels 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 {SimpleTile} from "./SimpleTile.js"; import {ReactionsViewModel} from "../ReactionsViewModel.js"; import {getIdentifierColorNumber, avatarInitials, getAvatarHttpUrl} from "../../../../avatar.js"; export class BaseMessageTile extends SimpleTile { constructor(options) { super(options); this._date = this._entry.timestamp ? new Date(this._entry.timestamp) : null; this._isContinuation = false; this._reactions = null; if (this._entry.annotations || this._entry.pendingAnnotations) { this._updateReactions(); } } get _mediaRepository() { return this._room.mediaRepository; } get displayName() { return this._entry.displayName || this.sender; } get sender() { return this._entry.sender; } get memberPanelLink() { return `${this.urlCreator.urlUntilSegment("room")}/member/${this.sender}`; } // Avatar view model contract get avatarColorNumber() { return getIdentifierColorNumber(this._entry.sender); } avatarUrl(size) { return getAvatarHttpUrl(this._entry.avatarUrl, size, this.platform, this._mediaRepository); } get avatarLetter() { return avatarInitials(this.sender); } get avatarTitle() { return this.displayName; } get date() { return this._date && this._date.toLocaleDateString({}, {month: "numeric", day: "numeric"}); } get time() { return this._date && this._date.toLocaleTimeString({}, {hour: "numeric", minute: "2-digit"}); } get isOwn() { return this._entry.sender === this._ownMember.userId; } get isContinuation() { return this._isContinuation; } get isUnverified() { return this._entry.isUnverified; } _getContent() { return this._entry.content; } updatePreviousSibling(prev) { super.updatePreviousSibling(prev); let isContinuation = false; if (prev && prev instanceof BaseMessageTile && prev.sender === this.sender) { // timestamp is null for pending events const myTimestamp = this._entry.timestamp; const otherTimestamp = prev._entry.timestamp; // other message was sent less than 5min ago isContinuation = (myTimestamp - otherTimestamp) < (5 * 60 * 1000); } if (isContinuation !== this._isContinuation) { this._isContinuation = isContinuation; this.emitChange("isContinuation"); } } updateEntry(entry, param) { const action = super.updateEntry(entry, param); if (action.shouldUpdate) { this._updateReactions(); } return action; } startReply() { this._roomVM.startReply(this._entry); } reply(msgtype, body, log = null) { return this._room.sendEvent("m.room.message", this._entry.reply(msgtype, body), null, log); } redact(reason, log) { return this._room.sendRedaction(this._entry.id, reason, log); } get canRedact() { return this._powerLevels.canRedactFromSender(this._entry.sender); } get reactions() { if (this.shape !== "redacted") { return this._reactions; } return null; } get canReact() { return this._powerLevels.canSendType("m.reaction"); } react(key, log = null) { return this.logger.wrapOrRun(log, "react", async log => { if (!this.canReact) { log.set("powerlevel_lacking", true); return; } if (this._entry.haveAnnotation(key)) { log.set("already_reacted", true); return; } const redaction = this._entry.pendingAnnotations?.get(key)?.redactionEntry; if (redaction && !redaction.pendingEvent.hasStartedSending) { log.set("abort_redaction", true); await redaction.pendingEvent.abort(); } else { await this._room.sendEvent("m.reaction", this._entry.annotate(key), null, log); } }); } redactReaction(key, log = null) { return this.logger.wrapOrRun(log, "redactReaction", async log => { if (!this._powerLevels.canRedactFromSender(this._ownMember.userId)) { log.set("powerlevel_lacking", true); return; } if (!this._entry.haveAnnotation(key)) { log.set("not_yet_reacted", true); return; } let entry = this._entry.pendingAnnotations?.get(key)?.annotationEntry; if (!entry) { entry = await this._timeline.getOwnAnnotationEntry(this._entry.id, key); } if (entry) { await this._room.sendRedaction(entry.id, null, log); } else { log.set("no_reaction", true); } }); } toggleReaction(key, log = null) { return this.logger.wrapOrRun(log, "toggleReaction", async log => { if (this._entry.haveAnnotation(key)) { await this.redactReaction(key, log); } else { await this.react(key, log); } }); } _updateReactions() { const {annotations, pendingAnnotations} = this._entry; if (!annotations && !pendingAnnotations) { if (this._reactions) { this._reactions = null; } } else { if (!this._reactions) { this._reactions = new ReactionsViewModel(this); } this._reactions.update(annotations, pendingAnnotations); } } }