xmpp.chapril.org-conversejs/src/plugins/mam-views/utils.js
2021-09-29 11:20:14 +02:00

45 lines
1.8 KiB
JavaScript

import MAMPlaceholderMessage from '@converse/headless/plugins/mam/placeholder.js';
import log from '@converse/headless/log.js';
import { _converse, api } from '@converse/headless/core';
import { fetchArchivedMessages } from '@converse/headless/plugins/mam/utils';
import { html } from 'lit/html.js';
export function getPlaceholderTemplate (message, tpl) {
if (message instanceof MAMPlaceholderMessage) {
return html`<converse-mam-placeholder .model=${message}></converse-mam-placeholder>`;
} else {
return tpl;
}
}
export async function fetchMessagesOnScrollUp (view) {
if (view.model.ui.get('chat-content-spinner-top')) {
return;
}
if (view.model.messages.length) {
const is_groupchat = view.model.get('type') === _converse.CHATROOMS_TYPE;
const oldest_message = view.model.getOldestMessage();
if (oldest_message) {
const by_jid = is_groupchat ? view.model.get('jid') : _converse.bare_jid;
const stanza_id = oldest_message && oldest_message.get(`stanza_id ${by_jid}`);
view.model.ui.set('chat-content-spinner-top', true);
try {
if (stanza_id) {
await fetchArchivedMessages(view.model, { 'before': stanza_id });
} else {
await fetchArchivedMessages(view.model, { 'end': oldest_message.get('time') });
}
} catch (e) {
log.error(e);
view.model.ui.set('chat-content-spinner-top', false);
return;
}
if (api.settings.get('allow_url_history_change')) {
_converse.router.history.navigate(`#${oldest_message.get('msgid')}`);
}
setTimeout(() => view.model.ui.set('chat-content-spinner-top', false), 250);
}
}
}