Chapril/xmpp.chapril.org-conversejs
Chapril/xmpp.chapril.org-conversejs
25
0
Fork 0
Code Issues Pull Requests Projects Releases Activity

converse-mam: Light refactoring and cleanup

Browse Source
This commit is contained in:
JC Brand 2019-08-03 14:16:46 +02:00
parent c2db667321
commit c038794fb5
1 changed files with 30 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
src/headless/converse-mam.js
View File

@ -11,10 +11,11 @@
*/
import "./converse-disco";
import "./converse-rsm";
import { intersection, pick } from 'lodash'
import converse from "./converse-core";
import sizzle from "sizzle";
const { Strophe, $iq, $build, _, dayjs } = converse.env;
const { Strophe, $iq, $build, dayjs } = converse.env;
const u = converse.env.utils;
// XEP-0313 Message Archive Management
@ -64,16 +65,17 @@ converse.plugins.add('converse-mam', {
const MAMEnabledChat = {
fetchNewestMessages () {
/* Fetches messages that might have been archived *after*
/**
* Fetches messages that might have been archived *after*
* the last archived message in our local cache.
*/
fetchNewestMessages () {
if (this.disable_mam) {
return;
}
const most_recent_msg = u.getMostRecentMessage(this);
if (_.isNil(most_recent_msg)) {
if (!most_recent_msg) {
this.fetchArchivedMessages();
} else {
const stanza_id = most_recent_msg.get(`stanza_id ${this.get('jid')}`);
@ -100,24 +102,14 @@ converse.plugins.add('converse-mam', {
} else {
message_handler = _converse.chatboxes.onMessage.bind(_converse.chatboxes)
}
let result = {};
try {
result = await _converse.api.archive.query(
const result = await _converse.api.archive.query(
Object.assign({
'groupchat': is_groupchat,
'before': '', // Page backwards from the most recent message
'max': _converse.archived_messages_page_size,
'with': this.get('jid'),
}, options));
} catch (e) {
_converse.log(
"Error or timeout while trying to fetch "+
"archived messages", Strophe.LogLevel.ERROR);
_converse.log(e, Strophe.LogLevel.ERROR);
}
if (result.messages) {
result.messages.forEach(message_handler);
}
},
async findDuplicateFromArchiveID (stanza) {
@ -165,7 +157,7 @@ converse.plugins.add('converse-mam', {
}
};
_converse.onMAMPreferences = function (feature, iq) {
_converse.onMAMPreferences = function (iq, feature) {
/* Handle returned IQ stanza containing Message Archive
* Management (XEP-0313) preferences.
*
@ -184,7 +176,7 @@ converse.plugins.add('converse-mam', {
'xmlns':Strophe.NS.MAM,
'default':_converse.message_archiving
});
_.each(preference.children, child => stanza.cnode(child).up());
Array.from(preference.children).forEach(child => stanza.cnode(child).up());
// XXX: Strictly speaking, the server should respond with the updated prefs
// (see example 18: https://xmpp.org/extensions/xep-0313.html#config)
@ -205,7 +197,7 @@ converse.plugins.add('converse-mam', {
}
if (prefs['default'] !== _converse.message_archiving) {
_converse.api.sendIQ($iq({'type': 'get'}).c('prefs', {'xmlns': Strophe.NS.MAM}))
.then(_.partial(_converse.onMAMPreferences, feature))
.then(iq => _converse.onMAMPreferences(iq, feature))
.catch(_converse.onMAMError);
}
}
@ -418,7 +410,7 @@ converse.plugins.add('converse-mam', {
* result.messages.forEach(m => this.showMessage(m));
*
*/
'query': async function (options) {
async query (options) {
if (!_converse.api.connection.connected()) {
throw new Error('Can\'t call `api.archive.query` before having established an XMPP session');
}
@ -474,30 +466,29 @@ converse.plugins.add('converse-mam', {
return true;
}
const result = message.querySelector('result');
if (!_.isNull(result) && result.getAttribute('queryid') === queryid) {
if (result !== null && result.getAttribute('queryid') === queryid) {
messages.push(message);
}
return true;
}, Strophe.NS.MAM);
let iq;
let iq_result, rsm;
try {
iq = await _converse.api.sendIQ(stanza, _converse.message_archiving_timeout)
iq_result = await _converse.api.sendIQ(stanza, _converse.message_archiving_timeout)
} catch (e) {
_converse.connection.deleteHandler(message_handler);
throw(e);
_converse.log(
"Error or timeout while trying to fetch "+
"archived messages", Strophe.LogLevel.ERROR);
_converse.log(e, Strophe.LogLevel.ERROR);
}
_converse.connection.deleteHandler(message_handler);
const set = iq.querySelector('set');
let rsm;
if (!_.isNull(set)) {
const set = iq_result ? iq_result.querySelector('set') : null;
if (set !== null) {
rsm = new _converse.RSM({'xml': set});
Object.assign(rsm, _.pick(options, _.concat(MAM_ATTRIBUTES, ['max'])));
}
return {
messages,
rsm
}
return { messages, rsm }
}
}
});