import ko from 'ko'; import { addObservablesTo, addComputablesTo, addSubscribablesTo } from 'External/ko'; import { Scope } from 'Common/Enums'; import { ComposeType, ClientSideKeyNameMessageHeaderFullInfo, ClientSideKeyNameMessageAttachmentControls, FolderType, MessageSetAction } from 'Common/EnumsUser'; import { elementById, leftPanelDisabled, keyScopeReal, Settings, SettingsCapa, fireEvent, addShortcut, registerShortcut } from 'Common/Globals'; import { arrayLength } from 'Common/Utils'; import { download, mailToHelper, showMessageComposer, moveAction } from 'Common/UtilsUser'; import { isFullscreen, exitFullscreen, toggleFullscreen } from 'Common/Fullscreen'; import { SMAudio } from 'Common/Audio'; import { i18n } from 'Common/Translator'; import { attachmentDownload } from 'Common/Links'; import { MessageFlagsCache } from 'Common/Cache'; import { AppUserStore } from 'Stores/User/App'; import { SettingsUserStore } from 'Stores/User/Settings'; import { AccountUserStore } from 'Stores/User/Account'; import { FolderUserStore, isAllowedKeyword } from 'Stores/User/Folder'; import { MessageUserStore } from 'Stores/User/Message'; import { MessagelistUserStore } from 'Stores/User/Messagelist'; import { ThemeStore } from 'Stores/Theme'; import * as Local from 'Storage/Client'; import Remote from 'Remote/User/Fetch'; import { decorateKoCommands } from 'Knoin/Knoin'; import { AbstractViewRight } from 'Knoin/AbstractViews'; import { PgpUserStore } from 'Stores/User/Pgp'; import { MimeToMessage } from 'Mime/Utils'; import { MessageModel } from 'Model/Message'; import { showScreenPopup } from 'Knoin/Knoin'; import { OpenPgpImportPopupView } from 'View/Popup/OpenPgpImport'; import { GnuPGUserStore } from 'Stores/User/GnuPG'; import { OpenPGPUserStore } from 'Stores/User/OpenPGP'; const oMessageScrollerDom = () => elementById('messageItem') || {}, currentMessage = MessageUserStore.message, fetchRaw = url => rl.fetch(url).then(response => response.ok && response.text()); export class MailMessageView extends AbstractViewRight { constructor() { super(); const /** * @param {Function} fExecute * @param {Function} fCanExecute = true * @returns {Function} */ createCommand = (fExecute, fCanExecute) => { let fResult = () => { fCanExecute() && fExecute.call(null); return false; }; fResult.canExecute = fCanExecute; return fResult; }, createCommandReplyHelper = type => createCommand(() => this.replyOrforward(type), this.canBeRepliedOrForwarded), createCommandActionHelper = (folderType, bDelete) => createCommand(() => { const message = currentMessage(); if (message) { currentMessage(null); rl.app.moveMessagesToFolderType(folderType, message.folder, [message.uid], bDelete); } }, this.messageVisibility); this.msgDefaultAction = SettingsUserStore.msgDefaultAction; this.simpleAttachmentsList = SettingsUserStore.simpleAttachmentsList; addObservablesTo(this, { showAttachmentControls: !!Local.get(ClientSideKeyNameMessageAttachmentControls), downloadAsZipLoading: false, showFullInfo: '1' === Local.get(ClientSideKeyNameMessageHeaderFullInfo), moreDropdownTrigger: false, // viewer viewFromShort: '', viewFromDkimData: ['none', ''], viewToShort: '' }); this.moveAction = moveAction; this.allowMessageActions = SettingsCapa('MessageActions'); const attachmentsActions = Settings.app('attachmentsActions'); this.attachmentsActions = ko.observableArray(arrayLength(attachmentsActions) ? attachmentsActions : []); this.hasCheckedMessages = MessagelistUserStore.hasChecked; this.archiveAllowed = MessagelistUserStore.archiveAllowed; this.canMarkAsSpam = MessagelistUserStore.canMarkAsSpam; this.isDraftFolder = MessagelistUserStore.isDraftFolder; this.isSpamFolder = MessagelistUserStore.isSpamFolder; this.message = MessageUserStore.message; this.messageLoadingThrottle = MessageUserStore.loading; this.messagesBodiesDom = MessageUserStore.bodiesDom; this.messageError = MessageUserStore.error; this.fullScreenMode = isFullscreen; this.toggleFullScreen = toggleFullscreen; this.downloadAsZipError = ko.observable(false).extend({ falseTimeout: 7000 }); this.messageDomFocused = ko.observable(false).extend({ rateLimit: 0 }); // viewer this.viewHash = ''; addComputablesTo(this, { allowAttachmentControls: () => arrayLength(attachmentsActions) && SettingsCapa('AttachmentsActions'), downloadAsZipAllowed: () => this.attachmentsActions.includes('zip') && (currentMessage()?.attachments || []) .filter(item => item?.download /*&& !item?.isLinked()*/ && item?.checked()) .length, tagsAllowed: () => FolderUserStore.currentFolder()?.tagsAllowed(), messageVisibility: () => !MessageUserStore.loading() && !!currentMessage(), canBeRepliedOrForwarded: () => !MessagelistUserStore.isDraftFolder() && this.messageVisibility(), viewFromDkimVisibility: () => 'none' !== this.viewFromDkimData()[0], viewFromDkimStatusIconClass:() => { switch (this.viewFromDkimData()[0]) { case 'none': return ''; case 'pass': return 'icon-ok iconcolor-green'; // ✔️ default: return 'icon-cross iconcolor-red'; // ✖ ❌ } }, viewFromDkimStatusTitle:() => { const status = this.viewFromDkimData(); if (arrayLength(status) && status[0]) { return status[1] || 'DKIM: ' + status[0]; } return ''; }, pgpSupported: () => currentMessage() && PgpUserStore.isSupported(), messageListOrViewLoading: () => MessagelistUserStore.isLoading() | MessageUserStore.loading() }); addSubscribablesTo(this, { message: message => { if (message) { if (this.viewHash !== message.hash) { this.scrollMessageToTop(); } this.viewHash = message.hash; // TODO: make first param a user setting #683 this.viewFromShort(message.fromToLine(false, true)); this.viewFromDkimData(message.fromDkimData()); this.viewToShort(message.toToLine(true, true)); } else { MessagelistUserStore.selectedMessage(null); this.viewHash = ''; this.scrollMessageToTop(); } }, showFullInfo: value => Local.set(ClientSideKeyNameMessageHeaderFullInfo, value ? '1' : '0') }); // commands this.replyCommand = createCommandReplyHelper(ComposeType.Reply); this.replyAllCommand = createCommandReplyHelper(ComposeType.ReplyAll); this.forwardCommand = createCommandReplyHelper(ComposeType.Forward); this.forwardAsAttachmentCommand = createCommandReplyHelper(ComposeType.ForwardAsAttachment); this.editAsNewCommand = createCommandReplyHelper(ComposeType.EditAsNew); this.deleteCommand = createCommandActionHelper(FolderType.Trash); this.deleteWithoutMoveCommand = createCommandActionHelper(FolderType.Trash, true); this.archiveCommand = createCommandActionHelper(FolderType.Archive); this.spamCommand = createCommandActionHelper(FolderType.Spam); this.notSpamCommand = createCommandActionHelper(FolderType.NotSpam); decorateKoCommands(this, { messageEditCommand: self => self.messageVisibility(), goUpCommand: self => !self.messageListOrViewLoading(), goDownCommand: self => !self.messageListOrViewLoading() }); } closeMessage() { currentMessage(null); } messageEditCommand() { currentMessage() && showMessageComposer([ComposeType.Draft, currentMessage()]); } goUpCommand() { fireEvent('mailbox.message-list.selector.go-up', !!currentMessage() // bForceSelect ); } goDownCommand() { fireEvent('mailbox.message-list.selector.go-down', !!currentMessage() // bForceSelect ); } /** * @param {string} sType * @returns {void} */ replyOrforward(sType) { showMessageComposer([sType, currentMessage()]); } onBuild(dom) { const eqs = (ev, s) => ev.target.closestWithin(s, dom); dom.addEventListener('click', event => { ThemeStore.isMobile() && leftPanelDisabled(true); let el = eqs(event, 'a'); if (el && 0 === event.button && mailToHelper(el.href)) { event.preventDefault(); event.stopPropagation(); return; } if (eqs(event, '.attachmentsPlace .showPreview')) { event.stopPropagation(); return; } el = eqs(event, '.attachmentsPlace .showPreplay'); if (el) { event.stopPropagation(); const attachment = ko.dataFor(el); if (attachment && SMAudio.supported) { switch (true) { case SMAudio.supportedMp3 && attachment.isMp3(): SMAudio.playMp3(attachment.linkDownload(), attachment.fileName); break; case SMAudio.supportedOgg && attachment.isOgg(): SMAudio.playOgg(attachment.linkDownload(), attachment.fileName); break; case SMAudio.supportedWav && attachment.isWav(): SMAudio.playWav(attachment.linkDownload(), attachment.fileName); break; // no default } } return; } el = eqs(event, '.attachmentItem'); if (el) { const attachment = ko.dataFor(el), url = attachment?.linkDownload(); if (url) { if ('application/pgp-keys' == attachment.mimeType && (OpenPGPUserStore.isSupported() || GnuPGUserStore.isSupported())) { fetchRaw(url).then(text => showScreenPopup(OpenPgpImportPopupView, [text]) ); } else if ('message/rfc822' == attachment.mimeType) { // TODO fetchRaw(url).then(text => { const oMessage = new MessageModel(); MimeToMessage(text, oMessage); // cleanHTML oMessage.viewPopupMessage(); }); } else { download(url, attachment.fileName); } } } if (eqs(event, '.messageItemHeader .subjectParent .flagParent')) { const message = currentMessage(); message && MessagelistUserStore.setAction( message.folder, message.isFlagged() ? MessageSetAction.UnsetFlag : MessageSetAction.SetFlag, [message] ); } }); AppUserStore.focusedState.subscribe(value => { if (Scope.MessageView !== value) { this.scrollMessageToTop(); this.scrollMessageToLeft(); } }); keyScopeReal.subscribe(value => this.messageDomFocused(Scope.MessageView === value)); // initShortcuts // exit fullscreen, back addShortcut('escape', '', Scope.MessageView, () => { if (!this.viewModelDom.hidden && currentMessage()) { const preview = SettingsUserStore.usePreviewPane(); if (isFullscreen()) { exitFullscreen(); if (preview) { AppUserStore.focusedState(Scope.MessageList); } } else if (!preview) { currentMessage(null); } else { AppUserStore.focusedState(Scope.MessageList); } return false; } }); // fullscreen addShortcut('enter,open', '', Scope.MessageView, () => { isFullscreen() || toggleFullscreen(); return false; }); // reply registerShortcut('r,mailreply', '', [Scope.MessageList, Scope.MessageView], () => { if (currentMessage()) { this.replyCommand(); return false; } return true; }); // replyAll registerShortcut('a', '', [Scope.MessageList, Scope.MessageView], () => { if (currentMessage()) { this.replyAllCommand(); return false; } }); registerShortcut('mailreply', 'shift', [Scope.MessageList, Scope.MessageView], () => { if (currentMessage()) { this.replyAllCommand(); return false; } }); // forward registerShortcut('f,mailforward', '', [Scope.MessageList, Scope.MessageView], () => { if (currentMessage()) { this.forwardCommand(); return false; } }); // message information registerShortcut('i', 'meta', [Scope.MessageList, Scope.MessageView], () => { if (currentMessage()) { this.showFullInfo(!this.showFullInfo()); } return false; }); // toggle message blockquotes registerShortcut('b', '', [Scope.MessageList, Scope.MessageView], () => { const message = currentMessage(); if (message?.body) { message.body.querySelectorAll('.sm-bq-switcher > summary').forEach(node => node.click()); return false; } }); addShortcut('arrowup,arrowleft', 'meta', [Scope.MessageList, Scope.MessageView], () => { this.goUpCommand(); return false; }); addShortcut('arrowdown,arrowright', 'meta', [Scope.MessageList, Scope.MessageView], () => { this.goDownCommand(); return false; }); // delete addShortcut('delete', '', Scope.MessageView, () => { this.deleteCommand(); return false; }); addShortcut('delete', 'shift', Scope.MessageView, () => { this.deleteWithoutMoveCommand(); return false; }); // change focused state addShortcut('arrowleft', '', Scope.MessageView, () => { if (!isFullscreen() && currentMessage() && SettingsUserStore.usePreviewPane() && !oMessageScrollerDom().scrollLeft) { AppUserStore.focusedState(Scope.MessageList); return false; } }); addShortcut('tab', 'shift', Scope.MessageView, () => { if (!isFullscreen() && currentMessage() && SettingsUserStore.usePreviewPane()) { AppUserStore.focusedState(Scope.MessageList); } return false; }); } /** * @returns {boolean} */ isDraftOrSentFolder() { return MessagelistUserStore.isDraftFolder() || MessagelistUserStore.isSentFolder(); } scrollMessageToTop() { oMessageScrollerDom().scrollTop = (50 < oMessageScrollerDom().scrollTop) ? 50 : 0; } scrollMessageToLeft() { oMessageScrollerDom().scrollLeft = 0; } toggleAttachmentControls() { const b = !this.showAttachmentControls(); this.showAttachmentControls(b); Local.set(ClientSideKeyNameMessageAttachmentControls, b); } downloadAsZip() { const hashes = (currentMessage()?.attachments || []) .map(item => item?.checked() /*&& !item?.isLinked()*/ ? item.download : '') .filter(v => v); if (hashes.length) { Remote.post('AttachmentsActions', this.downloadAsZipLoading, { Do: 'Zip', Hashes: hashes }) .then(result => { let hash = result?.Result?.FileHash; if (hash) { download(attachmentDownload(hash), hash+'.zip'); } else { this.downloadAsZipError(true); } }) .catch(() => this.downloadAsZipError(true)); } } /** * @param {MessageModel} oMessage * @returns {void} */ showImages() { currentMessage().showExternalImages(); } /** * @returns {string} */ printableCheckedMessageCount() { const cnt = MessagelistUserStore.listCheckedOrSelectedUidsWithSubMails().size; return 0 < cnt ? (100 > cnt ? cnt : '99+') : ''; } /** * @param {MessageModel} oMessage * @returns {void} */ readReceipt() { let oMessage = currentMessage() if (oMessage.readReceipt()) { Remote.request('SendReadReceiptMessage', iError => { if (!iError) { oMessage.flags.push('$mdnsent'); // oMessage.flags.valueHasMutated(); MessageFlagsCache.store(oMessage); MessagelistUserStore.reloadFlagsAndCachedMessage(); } }, { MessageFolder: oMessage.folder, MessageUid: oMessage.uid, ReadReceipt: oMessage.readReceipt(), subject: i18n('READ_RECEIPT/SUBJECT', { SUBJECT: oMessage.subject() }), Text: i18n('READ_RECEIPT/BODY', { 'READ-RECEIPT': AccountUserStore.email() }) }); } } newTag() { let message = currentMessage(); if (message) { let keyword = prompt(i18n('MESSAGE/NEW_TAG'), '')?.replace(/[\s\\]+/g, ''); if (keyword.length && isAllowedKeyword(keyword)) { message.toggleTag(keyword); FolderUserStore.currentFolder().permanentFlags.push(keyword); } } } pgpDecrypt() { const oMessage = currentMessage(); PgpUserStore.decrypt(oMessage).then(result => { if (result) { oMessage.pgpDecrypted(true); if (result.data) { MimeToMessage(result.data, oMessage); oMessage.html() ? oMessage.viewHtml() : oMessage.viewPlain(); if (result.signatures?.length) { oMessage.pgpSigned(true); oMessage.pgpVerified({ signatures: result.signatures, success: !!result.signatures.length }); } } } else { // TODO: translate alert('Decryption failed, canceled or not possible'); } }) .catch(e => console.error(e)); } pgpVerify(/*self, event*/) { const oMessage = currentMessage()/*, ctrl = event.target.closest('.openpgp-control')*/; PgpUserStore.verify(oMessage).then(result => { if (result) { oMessage.pgpVerified(result); } else { alert('Verification failed or no valid public key found'); } /* if (result?.success) { i18n('OPENPGP/GOOD_SIGNATURE', { USER: validKey.user + ' (' + validKey.id + ')' }); message.getText() } else { const keyIds = arrayLength(signingKeyIds) ? signingKeyIds : null, additional = keyIds ? keyIds.map(item => item?.toHex?.()).filter(v => v).join(', ') : ''; i18n('OPENPGP/ERROR', { ERROR: 'message' }) + (additional ? ' (' + additional + ')' : ''); } */ }); } }