b5eea12d49
It's better to parse an incoming message stanza early, than to have all kinds of methods throughout the codebase that does querySelector etc. Firstly, it allows us to catch and report errors and malicious stanzas early on. It also simplifies programming because you don't need to try and remember how to properly parse a stanza, all the work is done upfront for you.
1148 lines
63 KiB
JavaScript
1148 lines
63 KiB
JavaScript
/*global mock */
|
|
|
|
const { Strophe, $iq } = converse.env;
|
|
const u = converse.env.utils;
|
|
|
|
|
|
async function sendAndThenRetractMessage (_converse, view) {
|
|
view.model.sendMessage('hello world');
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg__text').length === 1);
|
|
const msg_obj = view.model.messages.last();
|
|
const reflection_stanza = u.toStanza(`
|
|
<message xmlns="jabber:client"
|
|
from="${msg_obj.get('from')}"
|
|
to="${_converse.connection.jid}"
|
|
type="groupchat">
|
|
<msg_body>${msg_obj.get('message')}</msg_body>
|
|
<stanza-id xmlns="urn:xmpp:sid:0"
|
|
id="5f3dbc5e-e1d3-4077-a492-693f3769c7ad"
|
|
by="lounge@montague.lit"/>
|
|
<origin-id xmlns="urn:xmpp:sid:0" id="${msg_obj.get('origin_id')}"/>
|
|
</message>`);
|
|
await view.model.handleMessageStanza(reflection_stanza);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg__body.chat-msg__body--received').length, 500);
|
|
|
|
const retract_button = await u.waitUntil(() => view.el.querySelector('.chat-msg__content .chat-msg__action-retract'));
|
|
retract_button.click();
|
|
await u.waitUntil(() => u.isVisible(document.querySelector('#converse-modals .modal')));
|
|
const submit_button = document.querySelector('#converse-modals .modal button[type="submit"]');
|
|
submit_button.click();
|
|
const sent_stanzas = _converse.connection.sent_stanzas;
|
|
return u.waitUntil(() => sent_stanzas.filter(s => s.querySelector('message apply-to[xmlns="urn:xmpp:fasten:0"]')).pop());
|
|
}
|
|
|
|
|
|
describe("Message Retractions", function () {
|
|
|
|
describe("A groupchat message retraction", function () {
|
|
|
|
it("is not applied if it's not from the right author",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
|
|
const received_stanza = u.toStanza(`
|
|
<message to='${_converse.jid}' from='${muc_jid}/eve' type='groupchat' id='${_converse.connection.getUniqueId()}'>
|
|
<body>Hello world</body>
|
|
<stanza-id xmlns='urn:xmpp:sid:0' id='stanza-id-1' by='${muc_jid}'/>
|
|
</message>
|
|
`);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
await view.model.handleMessageStanza(received_stanza);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 1);
|
|
expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBeFalsy();
|
|
|
|
const retraction_stanza = u.toStanza(`
|
|
<message type="groupchat" id='retraction-id-1' from="${muc_jid}/mallory" to="${muc_jid}/romeo">
|
|
<apply-to id="stanza-id-1" xmlns="urn:xmpp:fasten:0">
|
|
<retract xmlns="urn:xmpp:message-retract:0" />
|
|
</apply-to>
|
|
</message>
|
|
`);
|
|
spyOn(view.model, 'handleRetraction').and.callThrough();
|
|
|
|
_converse.connection._dataRecv(mock.createRequest(retraction_stanza));
|
|
await u.waitUntil(() => view.model.handleRetraction.calls.count() === 1);
|
|
expect(await view.model.handleRetraction.calls.first().returnValue).toBe(true);
|
|
expect(view.el.querySelectorAll('.chat-msg').length).toBe(1);
|
|
expect(view.model.messages.length).toBe(2);
|
|
expect(view.model.messages.at(1).get('retracted')).toBeTruthy();
|
|
expect(view.model.messages.at(1).get('is_ephemeral')).toBeFalsy();
|
|
expect(view.model.messages.at(1).get('dangling_retraction')).toBe(true);
|
|
|
|
expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBeFalsy();
|
|
done();
|
|
}));
|
|
|
|
it("can be received before the message it pertains to",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const date = (new Date()).toISOString();
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
|
|
const retraction_stanza = u.toStanza(`
|
|
<message type="groupchat" id='retraction-id-1' from="${muc_jid}/eve" to="${muc_jid}/romeo">
|
|
<apply-to id="origin-id-1" xmlns="urn:xmpp:fasten:0">
|
|
<retract by="${muc_jid}/eve" xmlns="urn:xmpp:message-retract:0" />
|
|
</apply-to>
|
|
</message>
|
|
`);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
spyOn(converse.env.log, 'warn');
|
|
spyOn(view.model, 'handleRetraction').and.callThrough();
|
|
_converse.connection._dataRecv(mock.createRequest(retraction_stanza));
|
|
|
|
await u.waitUntil(() => view.model.handleRetraction.calls.count() === 1);
|
|
await u.waitUntil(() => view.model.messages.length === 1);
|
|
expect(await view.model.handleRetraction.calls.first().returnValue).toBe(true);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('retracted')).toBeTruthy();
|
|
expect(view.model.messages.at(0).get('dangling_retraction')).toBe(true);
|
|
|
|
const received_stanza = u.toStanza(`
|
|
<message to='${_converse.jid}' from='${muc_jid}/eve' type='groupchat' id='${_converse.connection.getUniqueId()}'>
|
|
<body>Hello world</body>
|
|
<delay xmlns='urn:xmpp:delay' stamp='${date}'/>
|
|
<stanza-id xmlns='urn:xmpp:sid:0' id='stanza-id-1' by='${muc_jid}'/>
|
|
<origin-id xmlns="urn:xmpp:sid:0" id="origin-id-1"/>
|
|
</message>
|
|
`);
|
|
_converse.connection._dataRecv(mock.createRequest(received_stanza));
|
|
await u.waitUntil(() => view.model.handleRetraction.calls.count() === 2);
|
|
|
|
expect(view.el.querySelectorAll('.chat-msg').length).toBe(0);
|
|
expect(view.model.messages.length).toBe(1);
|
|
|
|
const message = view.model.messages.at(0)
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('dangling_retraction')).toBe(false);
|
|
expect(message.get('origin_id')).toBe('origin-id-1');
|
|
expect(message.get(`stanza_id ${muc_jid}`)).toBe('stanza-id-1');
|
|
expect(message.get('time')).toBe(date);
|
|
expect(message.get('type')).toBe('groupchat');
|
|
expect(await view.model.handleRetraction.calls.all().pop().returnValue).toBe(true);
|
|
done();
|
|
}));
|
|
});
|
|
|
|
describe("A groupchat message moderator retraction", function () {
|
|
|
|
it("can be received before the message it pertains to",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const date = (new Date()).toISOString();
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const retraction_stanza = u.toStanza(`
|
|
<message xmlns="jabber:client" from="${muc_jid}" type="groupchat" id="retraction-id-1">
|
|
<apply-to xmlns="urn:xmpp:fasten:0" id="stanza-id-1">
|
|
<moderated xmlns="urn:xmpp:message-moderate:0" by="${muc_jid}/madison">
|
|
<retract xmlns="urn:xmpp:message-retract:0"/>
|
|
<reason>Insults</reason>
|
|
</moderated>
|
|
</apply-to>
|
|
</message>
|
|
`);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
spyOn(converse.env.log, 'warn');
|
|
spyOn(view.model, 'handleModeration').and.callThrough();
|
|
_converse.connection._dataRecv(mock.createRequest(retraction_stanza));
|
|
|
|
await u.waitUntil(() => view.model.handleModeration.calls.count() === 1);
|
|
await u.waitUntil(() => view.model.messages.length === 1);
|
|
expect(await view.model.handleModeration.calls.first().returnValue).toBe(true);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('moderated')).toBe('retracted');
|
|
expect(view.model.messages.at(0).get('dangling_moderation')).toBe(true);
|
|
|
|
const received_stanza = u.toStanza(`
|
|
<message to='${_converse.jid}' from='${muc_jid}/eve' type='groupchat' id='${_converse.connection.getUniqueId()}'>
|
|
<body>Hello world</body>
|
|
<delay xmlns='urn:xmpp:delay' stamp='${date}'/>
|
|
<stanza-id xmlns='urn:xmpp:sid:0' id='stanza-id-1' by='${muc_jid}'/>
|
|
</message>
|
|
|
|
`);
|
|
|
|
_converse.connection._dataRecv(mock.createRequest(received_stanza));
|
|
await u.waitUntil(() => view.model.handleModeration.calls.count() === 2);
|
|
|
|
expect(view.el.querySelectorAll('.chat-msg').length).toBe(1);
|
|
expect(view.model.messages.length).toBe(1);
|
|
|
|
const message = view.model.messages.at(0)
|
|
expect(message.get('moderated')).toBe('retracted');
|
|
expect(message.get('dangling_moderation')).toBe(false);
|
|
expect(message.get(`stanza_id ${muc_jid}`)).toBe('stanza-id-1');
|
|
expect(message.get('time')).toBe(date);
|
|
expect(message.get('type')).toBe('groupchat');
|
|
expect(await view.model.handleModeration.calls.all().pop().returnValue).toBe(true);
|
|
done();
|
|
}));
|
|
});
|
|
|
|
|
|
describe("A message retraction", function () {
|
|
|
|
it("can be received before the message it pertains to",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const date = (new Date()).toISOString();
|
|
await mock.waitForRoster(_converse, 'current', 1);
|
|
await mock.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, [], [Strophe.NS.SID]);
|
|
const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
|
|
const view = await mock.openChatBoxFor(_converse, contact_jid);
|
|
spyOn(view.model, 'handleRetraction').and.callThrough();
|
|
|
|
const retraction_stanza = u.toStanza(`
|
|
<message id="${u.getUniqueId()}"
|
|
to="${_converse.bare_jid}"
|
|
from="${contact_jid}"
|
|
type="chat"
|
|
xmlns="jabber:client">
|
|
<apply-to id="2e972ea0-0050-44b7-a830-f6638a2595b3" xmlns="urn:xmpp:fasten:0">
|
|
<retract xmlns="urn:xmpp:message-retract:0"/>
|
|
</apply-to>
|
|
</message>
|
|
`);
|
|
|
|
const promise = new Promise(resolve => _converse.api.listen.on('messageAdded', resolve));
|
|
_converse.connection._dataRecv(mock.createRequest(retraction_stanza));
|
|
await u.waitUntil(() => view.model.messages.length === 1);
|
|
await promise;
|
|
const message = view.model.messages.at(0);
|
|
expect(message.get('dangling_retraction')).toBe(true);
|
|
expect(message.get('is_ephemeral')).toBe(false);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(view.el.querySelectorAll('.chat-msg').length).toBe(0);
|
|
|
|
const stanza = u.toStanza(`
|
|
<message xmlns="jabber:client"
|
|
to="${_converse.bare_jid}"
|
|
type="chat"
|
|
id="2e972ea0-0050-44b7-a830-f6638a2595b3"
|
|
from="${contact_jid}">
|
|
<body>Hello world</body>
|
|
<delay xmlns='urn:xmpp:delay' stamp='${date}'/>
|
|
<markable xmlns="urn:xmpp:chat-markers:0"/>
|
|
<origin-id xmlns="urn:xmpp:sid:0" id="2e972ea0-0050-44b7-a830-f6638a2595b3"/>
|
|
<stanza-id xmlns="urn:xmpp:sid:0" id="IxVDLJ0RYbWcWvqC" by="${_converse.bare_jid}"/>
|
|
</message>`);
|
|
_converse.connection._dataRecv(mock.createRequest(stanza));
|
|
await u.waitUntil(() => view.model.handleRetraction.calls.count() === 2);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('dangling_retraction')).toBe(false);
|
|
expect(message.get('origin_id')).toBe('2e972ea0-0050-44b7-a830-f6638a2595b3');
|
|
expect(message.get('time')).toBe(date);
|
|
expect(message.get('type')).toBe('chat');
|
|
done();
|
|
}));
|
|
});
|
|
|
|
describe("A Received Chat Message", function () {
|
|
|
|
it("can be followed up by a retraction",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
await mock.waitForRoster(_converse, 'current', 1);
|
|
await mock.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, [], [Strophe.NS.SID]);
|
|
const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
|
|
const view = await mock.openChatBoxFor(_converse, contact_jid);
|
|
|
|
let stanza = u.toStanza(`
|
|
<message xmlns="jabber:client"
|
|
to="${_converse.bare_jid}"
|
|
type="chat"
|
|
id="29132ea0-0121-2897-b121-36638c259554"
|
|
from="${contact_jid}">
|
|
<body>😊</body>
|
|
<markable xmlns="urn:xmpp:chat-markers:0"/>
|
|
<origin-id xmlns="urn:xmpp:sid:0" id="29132ea0-0121-2897-b121-36638c259554"/>
|
|
<stanza-id xmlns="urn:xmpp:sid:0" id="kxViLhgbnNMcWv10" by="${_converse.bare_jid}"/>
|
|
</message>`);
|
|
|
|
_converse.connection._dataRecv(mock.createRequest(stanza));
|
|
await u.waitUntil(() => view.model.messages.length === 1);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 1);
|
|
|
|
stanza = u.toStanza(`
|
|
<message xmlns="jabber:client"
|
|
to="${_converse.bare_jid}"
|
|
type="chat"
|
|
id="2e972ea0-0050-44b7-a830-f6638a2595b3"
|
|
from="${contact_jid}">
|
|
<body>This message will be retracted</body>
|
|
<markable xmlns="urn:xmpp:chat-markers:0"/>
|
|
<origin-id xmlns="urn:xmpp:sid:0" id="2e972ea0-0050-44b7-a830-f6638a2595b3"/>
|
|
<stanza-id xmlns="urn:xmpp:sid:0" id="IxVDLJ0RYbWcWvqC" by="${_converse.bare_jid}"/>
|
|
</message>`);
|
|
|
|
_converse.connection._dataRecv(mock.createRequest(stanza));
|
|
await u.waitUntil(() => view.model.messages.length === 2);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 2);
|
|
|
|
const retraction_stanza = u.toStanza(`
|
|
<message id="${u.getUniqueId()}"
|
|
to="${_converse.bare_jid}"
|
|
from="${contact_jid}"
|
|
type="chat"
|
|
xmlns="jabber:client">
|
|
<apply-to id="2e972ea0-0050-44b7-a830-f6638a2595b3" xmlns="urn:xmpp:fasten:0">
|
|
<retract xmlns="urn:xmpp:message-retract:0"/>
|
|
</apply-to>
|
|
</message>
|
|
`);
|
|
_converse.connection._dataRecv(mock.createRequest(retraction_stanza));
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
|
|
expect(view.model.messages.length).toBe(2);
|
|
|
|
const message = view.model.messages.at(1);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
const msg_el = view.el.querySelector('.chat-msg--retracted .chat-msg__message');
|
|
expect(msg_el.textContent.trim()).toBe('Mercutio has removed this message');
|
|
expect(u.hasClass('chat-msg--followup', view.el.querySelector('.chat-msg--retracted'))).toBe(true);
|
|
done();
|
|
}));
|
|
});
|
|
|
|
describe("A Sent Chat Message", function () {
|
|
|
|
it("can be retracted by its author",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
await mock.waitForRoster(_converse, 'current', 1);
|
|
const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
|
|
const view = await mock.openChatBoxFor(_converse, contact_jid);
|
|
|
|
view.model.sendMessage('hello world');
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 1);
|
|
|
|
const message = view.model.messages.at(0);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(message.get('retracted')).toBeFalsy();
|
|
expect(message.get('editable')).toBeTruthy();
|
|
|
|
|
|
const retract_button = await u.waitUntil(() => view.el.querySelector('.chat-msg__content .chat-msg__action-retract'));
|
|
retract_button.click();
|
|
await u.waitUntil(() => u.isVisible(document.querySelector('#converse-modals .modal')));
|
|
const submit_button = document.querySelector('#converse-modals .modal button[type="submit"]');
|
|
submit_button.click();
|
|
|
|
const sent_stanzas = _converse.connection.sent_stanzas;
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
|
|
const msg_obj = view.model.messages.at(0);
|
|
const retraction_stanza = await u.waitUntil(() => sent_stanzas.filter(s => s.querySelector('message apply-to[xmlns="urn:xmpp:fasten:0"]')).pop());
|
|
expect(Strophe.serialize(retraction_stanza)).toBe(
|
|
`<message id="${retraction_stanza.getAttribute('id')}" to="${contact_jid}" type="chat" xmlns="jabber:client">`+
|
|
`<store xmlns="urn:xmpp:hints"/>`+
|
|
`<apply-to id="${msg_obj.get('origin_id')}" xmlns="urn:xmpp:fasten:0">`+
|
|
`<retract xmlns="urn:xmpp:message-retract:0"/>`+
|
|
`</apply-to>`+
|
|
`</message>`);
|
|
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('editable')).toBeFalsy();
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message');
|
|
expect(el.textContent.trim()).toBe('Romeo Montague has removed this message');
|
|
done();
|
|
}));
|
|
});
|
|
|
|
|
|
describe("A Received Groupchat Message", function () {
|
|
|
|
it("can be followed up by a retraction by the author",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
|
|
const received_stanza = u.toStanza(`
|
|
<message to='${_converse.jid}' from='${muc_jid}/eve' type='groupchat' id='${_converse.connection.getUniqueId()}'>
|
|
<body>Hello world</body>
|
|
<stanza-id xmlns='urn:xmpp:sid:0' id='stanza-id-1' by='${muc_jid}'/>
|
|
<origin-id xmlns='urn:xmpp:sid:0' id='origin-id-1' by='${muc_jid}'/>
|
|
</message>
|
|
`);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
await view.model.handleMessageStanza(received_stanza);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 1);
|
|
expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBeFalsy();
|
|
|
|
const retraction_stanza = u.toStanza(`
|
|
<message type="groupchat" id='retraction-id-1' from="${muc_jid}/eve" to="${muc_jid}/romeo">
|
|
<apply-to id="origin-id-1" xmlns="urn:xmpp:fasten:0">
|
|
<retract by="${muc_jid}/eve" xmlns="urn:xmpp:message-retract:0" />
|
|
</apply-to>
|
|
</message>
|
|
`);
|
|
_converse.connection._dataRecv(mock.createRequest(retraction_stanza));
|
|
|
|
// We opportunistically save the message as retracted, even before receiving the retraction message
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('retracted')).toBeTruthy();
|
|
expect(view.model.messages.at(0).get('editable')).toBe(false);
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
const msg_el = view.el.querySelector('.chat-msg--retracted .chat-msg__message');
|
|
expect(msg_el.textContent.trim()).toBe('eve has removed this message');
|
|
expect(msg_el.querySelector('.chat-msg--retracted q')).toBe(null);
|
|
done();
|
|
}));
|
|
|
|
|
|
it("can be retracted by a moderator, with the IQ response received before the retraction message",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
const occupant = view.model.getOwnOccupant();
|
|
expect(occupant.get('role')).toBe('moderator');
|
|
|
|
const received_stanza = u.toStanza(`
|
|
<message to='${_converse.jid}' from='${muc_jid}/mallory' type='groupchat' id='${_converse.connection.getUniqueId()}'>
|
|
<body>Visit this site to get free Bitcoin!</body>
|
|
<stanza-id xmlns='urn:xmpp:sid:0' id='stanza-id-1' by='${muc_jid}'/>
|
|
</message>
|
|
`);
|
|
await view.model.handleMessageStanza(received_stanza);
|
|
await u.waitUntil(() => view.model.messages.length === 1);
|
|
expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
|
|
|
|
const reason = "This content is inappropriate for this forum!"
|
|
const retract_button = await u.waitUntil(() => view.el.querySelector('.chat-msg__content .chat-msg__action-retract'));
|
|
retract_button.click();
|
|
|
|
await u.waitUntil(() => u.isVisible(document.querySelector('#converse-modals .modal')));
|
|
|
|
const reason_input = document.querySelector('#converse-modals .modal input[name="reason"]');
|
|
reason_input.value = 'This content is inappropriate for this forum!';
|
|
const submit_button = document.querySelector('#converse-modals .modal button[type="submit"]');
|
|
submit_button.click();
|
|
|
|
const sent_IQs = _converse.connection.IQ_stanzas;
|
|
const stanza = await u.waitUntil(() => sent_IQs.filter(iq => iq.querySelector('iq apply-to[xmlns="urn:xmpp:fasten:0"]')).pop());
|
|
const message = view.model.messages.at(0);
|
|
const stanza_id = message.get(`stanza_id ${view.model.get('jid')}`);
|
|
|
|
expect(Strophe.serialize(stanza)).toBe(
|
|
`<iq id="${stanza.getAttribute('id')}" to="${muc_jid}" type="set" xmlns="jabber:client">`+
|
|
`<apply-to id="${stanza_id}" xmlns="urn:xmpp:fasten:0">`+
|
|
`<moderate xmlns="urn:xmpp:message-moderate:0">`+
|
|
`<retract xmlns="urn:xmpp:message-retract:0"/>`+
|
|
`<reason>This content is inappropriate for this forum!</reason>`+
|
|
`</moderate>`+
|
|
`</apply-to>`+
|
|
`</iq>`);
|
|
|
|
const result_iq = $iq({'from': muc_jid, 'id': stanza.getAttribute('id'), 'to': _converse.bare_jid, 'type': 'result'});
|
|
_converse.connection._dataRecv(mock.createRequest(result_iq));
|
|
|
|
// We opportunistically save the message as retracted, even before receiving the retraction message
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('moderated')).toBe('retracted');
|
|
expect(view.model.messages.at(0).get('moderation_reason')).toBe(reason);
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBe(false);
|
|
expect(view.model.messages.at(0).get('editable')).toBe(false);
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
|
|
const msg_el = view.el.querySelector('.chat-msg--retracted .chat-msg__message');
|
|
expect(msg_el.firstElementChild.textContent.trim()).toBe('romeo has removed this message');
|
|
|
|
const qel = msg_el.querySelector('q');
|
|
expect(qel.textContent.trim()).toBe('This content is inappropriate for this forum!');
|
|
|
|
// The server responds with a retraction message
|
|
const retraction = u.toStanza(`
|
|
<message type="groupchat" id='retraction-id-1' from="${muc_jid}" to="${muc_jid}/romeo">
|
|
<apply-to id="${stanza_id}" xmlns="urn:xmpp:fasten:0">
|
|
<moderated by='${_converse.bare_jid}' xmlns='urn:xmpp:message-moderate:0'>
|
|
<retract xmlns='urn:xmpp:message-retract:0' />
|
|
<reason>${reason}</reason>
|
|
</moderated>
|
|
</apply-to>
|
|
</message>`);
|
|
await view.model.handleMessageStanza(retraction);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('moderated')).toBe('retracted');
|
|
expect(view.model.messages.at(0).get('moderation_reason')).toBe(reason);
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBe(false);
|
|
expect(view.model.messages.at(0).get('editable')).toBe(false);
|
|
done();
|
|
}));
|
|
|
|
it("can not be retracted if the MUC doesn't support message moderation",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo');
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
const occupant = view.model.getOwnOccupant();
|
|
expect(occupant.get('role')).toBe('moderator');
|
|
|
|
const received_stanza = u.toStanza(`
|
|
<message to='${_converse.jid}' from='${muc_jid}/mallory' type='groupchat' id='${_converse.connection.getUniqueId()}'>
|
|
<body>Visit this site to get free Bitcoin!</body>
|
|
<stanza-id xmlns='urn:xmpp:sid:0' id='stanza-id-1' by='${muc_jid}'/>
|
|
</message>
|
|
`);
|
|
await view.model.handleMessageStanza(received_stanza);
|
|
await u.waitUntil(() => view.el.querySelector('.chat-msg__content'));
|
|
expect(view.el.querySelector('.chat-msg__content .chat-msg__action-retract')).toBe(null);
|
|
const result = await view.model.canModerateMessages();
|
|
expect(result).toBe(false);
|
|
done();
|
|
}));
|
|
|
|
|
|
it("can be retracted by a moderator, with the retraction message received before the IQ response",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
const occupant = view.model.getOwnOccupant();
|
|
expect(occupant.get('role')).toBe('moderator');
|
|
|
|
const received_stanza = u.toStanza(`
|
|
<message to='${_converse.jid}' from='${muc_jid}/mallory' type='groupchat' id='${_converse.connection.getUniqueId()}'>
|
|
<body>Visit this site to get free Bitcoin!</body>
|
|
<stanza-id xmlns='urn:xmpp:sid:0' id='stanza-id-1' by='${muc_jid}'/>
|
|
</message>
|
|
`);
|
|
await view.model.handleMessageStanza(received_stanza);
|
|
await u.waitUntil(() => view.model.messages.length === 1);
|
|
expect(view.model.messages.length).toBe(1);
|
|
|
|
const retract_button = await u.waitUntil(() => view.el.querySelector('.chat-msg__content .chat-msg__action-retract'));
|
|
retract_button.click();
|
|
await u.waitUntil(() => u.isVisible(document.querySelector('#converse-modals .modal')));
|
|
|
|
const reason_input = document.querySelector('#converse-modals .modal input[name="reason"]');
|
|
const reason = "This content is inappropriate for this forum!"
|
|
reason_input.value = reason;
|
|
const submit_button = document.querySelector('#converse-modals .modal button[type="submit"]');
|
|
submit_button.click();
|
|
|
|
const sent_IQs = _converse.connection.IQ_stanzas;
|
|
const stanza = await u.waitUntil(() => sent_IQs.filter(iq => iq.querySelector('iq apply-to[xmlns="urn:xmpp:fasten:0"]')).pop());
|
|
const message = view.model.messages.at(0);
|
|
const stanza_id = message.get(`stanza_id ${view.model.get('jid')}`);
|
|
// The server responds with a retraction message
|
|
const retraction = u.toStanza(`
|
|
<message type="groupchat" id='retraction-id-1' from="${muc_jid}" to="${muc_jid}/romeo">
|
|
<apply-to id="${stanza_id}" xmlns="urn:xmpp:fasten:0">
|
|
<moderated by='${_converse.bare_jid}' xmlns='urn:xmpp:message-moderate:0'>
|
|
<retract xmlns='urn:xmpp:message-retract:0' />
|
|
<reason>${reason}</reason>
|
|
</moderated>
|
|
</apply-to>
|
|
</message>`);
|
|
await view.model.handleMessageStanza(retraction);
|
|
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('moderated')).toBe('retracted');
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
const msg_el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
|
|
expect(msg_el.textContent).toBe('romeo has removed this message');
|
|
const qel = view.el.querySelector('.chat-msg--retracted .chat-msg__message q');
|
|
expect(qel.textContent).toBe('This content is inappropriate for this forum!');
|
|
|
|
const result_iq = $iq({'from': muc_jid, 'id': stanza.getAttribute('id'), 'to': _converse.bare_jid, 'type': 'result'});
|
|
_converse.connection._dataRecv(mock.createRequest(result_iq));
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('moderated')).toBe('retracted');
|
|
expect(view.model.messages.at(0).get('moderated_by')).toBe(_converse.bare_jid);
|
|
expect(view.model.messages.at(0).get('moderation_reason')).toBe(reason);
|
|
expect(view.model.messages.at(0).get('editable')).toBe(false);
|
|
done();
|
|
}));
|
|
});
|
|
|
|
|
|
describe("A Sent Groupchat Message", function () {
|
|
|
|
it("can be retracted by its author",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
const occupant = view.model.getOwnOccupant();
|
|
expect(occupant.get('role')).toBe('moderator');
|
|
occupant.save('role', 'member');
|
|
const retraction_stanza = await sendAndThenRetractMessage(_converse, view);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
|
|
const msg_obj = view.model.messages.last();
|
|
expect(Strophe.serialize(retraction_stanza)).toBe(
|
|
`<message id="${retraction_stanza.getAttribute('id')}" to="${muc_jid}" type="groupchat" xmlns="jabber:client">`+
|
|
`<store xmlns="urn:xmpp:hints"/>`+
|
|
`<apply-to id="${msg_obj.get('origin_id')}" xmlns="urn:xmpp:fasten:0">`+
|
|
`<retract xmlns="urn:xmpp:message-retract:0"/>`+
|
|
`</apply-to>`+
|
|
`</message>`);
|
|
|
|
const message = view.model.messages.last();
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('is_ephemeral')).toBe(false);
|
|
expect(message.get('editable')).toBeFalsy();
|
|
|
|
const stanza_id = message.get(`stanza_id ${muc_jid}`);
|
|
// The server responds with a retraction message
|
|
const reflection = u.toStanza(`
|
|
<message type="groupchat" id="${retraction_stanza.getAttribute('id')}" from="${muc_jid}" to="${muc_jid}/romeo">
|
|
<apply-to id="${stanza_id}" xmlns="urn:xmpp:fasten:0">
|
|
<moderated by='${_converse.bare_jid}' xmlns='urn:xmpp:message-moderate:0'>
|
|
<retract xmlns='urn:xmpp:message-retract:0' />
|
|
</moderated>
|
|
</apply-to>
|
|
</message>`);
|
|
|
|
spyOn(view.model, 'handleRetraction').and.callThrough();
|
|
_converse.connection._dataRecv(mock.createRequest(reflection));
|
|
await u.waitUntil(() => view.model.handleRetraction.calls.count() === 1);
|
|
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.last().get('retracted')).toBeTruthy();
|
|
expect(view.model.messages.last().get('is_ephemeral')).toBe(false);
|
|
expect(view.model.messages.last().get('editable')).toBe(false);
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
|
|
expect(el.textContent).toBe('romeo has removed this message');
|
|
done();
|
|
}));
|
|
|
|
it("can be retracted by its author, causing an error message in response",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
const occupant = view.model.getOwnOccupant();
|
|
expect(occupant.get('role')).toBe('moderator');
|
|
occupant.save('role', 'member');
|
|
await u.waitUntil(() => view.el.querySelector('.chat-content__notifications').textContent.includes("romeo is no longer a moderator"));
|
|
const retraction_stanza = await sendAndThenRetractMessage(_converse, view);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.last().get('retracted')).toBeTruthy();
|
|
const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
|
|
expect(el.textContent.trim()).toBe('romeo has removed this message');
|
|
|
|
const message = view.model.messages.last();
|
|
const stanza_id = message.get(`stanza_id ${view.model.get('jid')}`);
|
|
// The server responds with an error message
|
|
const error = u.toStanza(`
|
|
<message type="error" id="${retraction_stanza.getAttribute('id')}" from="${muc_jid}" to="${view.model.get('jid')}/romeo">
|
|
<error by='${muc_jid}' type='auth'>
|
|
<forbidden xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'/>
|
|
</error>
|
|
<apply-to id="${stanza_id}" xmlns="urn:xmpp:fasten:0">
|
|
<moderated by='${_converse.bare_jid}' xmlns='urn:xmpp:message-moderate:0'>
|
|
<retract xmlns='urn:xmpp:message-retract:0' />
|
|
</moderated>
|
|
</apply-to>
|
|
</message>`);
|
|
|
|
_converse.connection._dataRecv(mock.createRequest(error));
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-error').length === 1);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 0);
|
|
expect(view.model.messages.length).toBe(2);
|
|
expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBeFalsy();
|
|
expect(view.model.messages.at(0).get('editable')).toBeTruthy();
|
|
|
|
const err_msg = "Sorry, something went wrong while trying to retract your message."
|
|
expect(view.model.messages.at(1).get('message')).toBe(err_msg);
|
|
expect(view.model.messages.at(1).get('type')).toBe('error');
|
|
|
|
expect(view.el.querySelectorAll('.chat-error').length).toBe(1);
|
|
const errmsg = view.el.querySelector('.chat-error');
|
|
expect(errmsg.textContent.trim()).toBe("Sorry, something went wrong while trying to retract your message.");
|
|
done();
|
|
}));
|
|
|
|
it("can be retracted by its author, causing a timeout error in response",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
_converse.STANZA_TIMEOUT = 1;
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
const occupant = view.model.getOwnOccupant();
|
|
expect(occupant.get('role')).toBe('moderator');
|
|
occupant.save('role', 'member');
|
|
await u.waitUntil(() => view.el.querySelector('.chat-content__notifications').textContent.includes("romeo is no longer a moderator"))
|
|
await sendAndThenRetractMessage(_converse, view);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.last().get('retracted')).toBeTruthy();
|
|
const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
|
|
expect(el.textContent.trim()).toBe('romeo has removed this message');
|
|
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 1);
|
|
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 0);
|
|
expect(view.model.messages.length).toBe(3);
|
|
expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBeFalsy();
|
|
expect(view.model.messages.at(0).get('editable')).toBeTruthy();
|
|
|
|
const error_messages = view.el.querySelectorAll('.chat-error');
|
|
expect(error_messages.length).toBe(2);
|
|
expect(error_messages[0].textContent.trim()).toBe("Sorry, something went wrong while trying to retract your message.");
|
|
expect(error_messages[1].textContent.trim()).toBe("Timeout Error: No response from server");
|
|
done();
|
|
}));
|
|
|
|
|
|
it("can be retracted by a moderator",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
const occupant = view.model.getOwnOccupant();
|
|
expect(occupant.get('role')).toBe('moderator');
|
|
|
|
view.model.sendMessage('Visit this site to get free bitcoin');
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 1);
|
|
const stanza_id = 'retraction-id-1';
|
|
const msg_obj = view.model.messages.at(0);
|
|
const reflection_stanza = u.toStanza(`
|
|
<message xmlns="jabber:client"
|
|
from="${msg_obj.get('from')}"
|
|
to="${_converse.connection.jid}"
|
|
type="groupchat">
|
|
<msg_body>${msg_obj.get('message')}</msg_body>
|
|
<stanza-id xmlns="urn:xmpp:sid:0"
|
|
id="${stanza_id}"
|
|
by="lounge@montague.lit"/>
|
|
<origin-id xmlns="urn:xmpp:sid:0" id="${msg_obj.get('origin_id')}"/>
|
|
</message>`);
|
|
await view.model.handleMessageStanza(reflection_stanza);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg__body.chat-msg__body--received').length, 500);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('editable')).toBe(true);
|
|
|
|
// The server responds with a retraction message
|
|
const reason = "This content is inappropriate for this forum!"
|
|
const retraction = u.toStanza(`
|
|
<message type="groupchat" id='retraction-id-1' from="${muc_jid}" to="${muc_jid}/romeo">
|
|
<apply-to id="${stanza_id}" xmlns="urn:xmpp:fasten:0">
|
|
<moderated by='${_converse.bare_jid}' xmlns='urn:xmpp:message-moderate:0'>
|
|
<retract xmlns='urn:xmpp:message-retract:0' />
|
|
<reason>${reason}</reason>
|
|
</moderated>
|
|
</apply-to>
|
|
</message>`);
|
|
await view.model.handleMessageStanza(retraction);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('moderated')).toBe('retracted');
|
|
expect(view.model.messages.at(0).get('moderation_reason')).toBe(reason);
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBe(false);
|
|
expect(view.model.messages.at(0).get('editable')).toBe(false);
|
|
done();
|
|
}));
|
|
|
|
it("can be retracted by the sender if they're a moderator",
|
|
mock.initConverse(
|
|
['rosterGroupsFetched', 'chatBoxesFetched'], {'allow_message_retraction': 'moderator'},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const view = _converse.api.chatviews.get(muc_jid);
|
|
const occupant = view.model.getOwnOccupant();
|
|
expect(occupant.get('role')).toBe('moderator');
|
|
|
|
view.model.sendMessage('Visit this site to get free bitcoin');
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 1);
|
|
const stanza_id = 'retraction-id-1';
|
|
const msg_obj = view.model.messages.at(0);
|
|
const reflection_stanza = u.toStanza(`
|
|
<message xmlns="jabber:client"
|
|
from="${msg_obj.get('from')}"
|
|
to="${_converse.connection.jid}"
|
|
type="groupchat">
|
|
<msg_body>${msg_obj.get('message')}</msg_body>
|
|
<stanza-id xmlns="urn:xmpp:sid:0"
|
|
id="${stanza_id}"
|
|
by="lounge@montague.lit"/>
|
|
<origin-id xmlns="urn:xmpp:sid:0" id="${msg_obj.get('origin_id')}"/>
|
|
</message>`);
|
|
await view.model.handleMessageStanza(reflection_stanza);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg__body.chat-msg__body--received').length, 500);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('editable')).toBe(true);
|
|
|
|
const retract_button = await u.waitUntil(() => view.msgs_container.querySelector('.chat-msg__content .chat-msg__action-retract'));
|
|
retract_button.click();
|
|
await u.waitUntil(() => u.isVisible(document.querySelector('#converse-modals .modal')));
|
|
const submit_button = document.querySelector('#converse-modals .modal button[type="submit"]');
|
|
submit_button.click();
|
|
|
|
const sent_IQs = _converse.connection.IQ_stanzas;
|
|
const stanza = await u.waitUntil(() => sent_IQs.filter(iq => iq.querySelector('iq apply-to[xmlns="urn:xmpp:fasten:0"]')).pop());
|
|
|
|
expect(Strophe.serialize(stanza)).toBe(
|
|
`<iq id="${stanza.getAttribute('id')}" to="${muc_jid}" type="set" xmlns="jabber:client">`+
|
|
`<apply-to id="${stanza_id}" xmlns="urn:xmpp:fasten:0">`+
|
|
`<moderate xmlns="urn:xmpp:message-moderate:0">`+
|
|
`<retract xmlns="urn:xmpp:message-retract:0"/>`+
|
|
`<reason></reason>`+
|
|
`</moderate>`+
|
|
`</apply-to>`+
|
|
`</iq>`);
|
|
|
|
const result_iq = $iq({'from': muc_jid, 'id': stanza.getAttribute('id'), 'to': _converse.bare_jid, 'type': 'result'});
|
|
_converse.connection._dataRecv(mock.createRequest(result_iq));
|
|
|
|
// We opportunistically save the message as retracted, even before receiving the retraction message
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg--retracted').length === 1);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('moderated')).toBe('retracted');
|
|
expect(view.model.messages.at(0).get('moderation_reason')).toBe(undefined);
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBe(false);
|
|
expect(view.model.messages.at(0).get('editable')).toBe(false);
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
|
|
const msg_el = view.el.querySelector('.chat-msg--retracted .chat-msg__message');
|
|
expect(msg_el.firstElementChild.textContent.trim()).toBe('romeo has removed this message');
|
|
expect(msg_el.querySelector('q')).toBe(null);
|
|
|
|
// The server responds with a retraction message
|
|
const retraction = u.toStanza(`
|
|
<message type="groupchat" id='retraction-id-1' from="${muc_jid}" to="${muc_jid}/romeo">
|
|
<apply-to id="${stanza_id}" xmlns="urn:xmpp:fasten:0">
|
|
<moderated by='${_converse.bare_jid}' xmlns='urn:xmpp:message-moderate:0'>
|
|
<retract xmlns='urn:xmpp:message-retract:0' />
|
|
</moderated>
|
|
</apply-to>
|
|
</message>`);
|
|
await view.model.handleMessageStanza(retraction);
|
|
expect(view.model.messages.length).toBe(1);
|
|
expect(view.model.messages.at(0).get('moderated')).toBe('retracted');
|
|
expect(view.model.messages.at(0).get('moderation_reason')).toBe(undefined);
|
|
expect(view.model.messages.at(0).get('is_ephemeral')).toBe(false);
|
|
expect(view.model.messages.at(0).get('editable')).toBe(false);
|
|
done();
|
|
}));
|
|
});
|
|
|
|
|
|
describe("when archived", function () {
|
|
|
|
it("may be returned as a tombstone message",
|
|
mock.initConverse(
|
|
['discoInitialized'], {},
|
|
async function (done, _converse) {
|
|
|
|
await mock.waitForRoster(_converse, 'current', 1);
|
|
const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
|
|
await mock.openChatBoxFor(_converse, contact_jid);
|
|
await mock.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, null, [Strophe.NS.MAM]);
|
|
const sent_IQs = _converse.connection.IQ_stanzas;
|
|
const stanza = await u.waitUntil(() => sent_IQs.filter(iq => iq.querySelector(`iq[type="set"] query[xmlns="${Strophe.NS.MAM}"]`)).pop());
|
|
const queryid = stanza.querySelector('query').getAttribute('queryid');
|
|
const view = _converse.chatboxviews.get(contact_jid);
|
|
const first_id = u.getUniqueId();
|
|
|
|
spyOn(view.model, 'handleRetraction').and.callThrough();
|
|
const first_message = u.toStanza(`
|
|
<message id='${u.getUniqueId()}' to='${_converse.jid}'>
|
|
<result xmlns='urn:xmpp:mam:2' queryid='${queryid}' id="${first_id}">
|
|
<forwarded xmlns='urn:xmpp:forward:0'>
|
|
<delay xmlns='urn:xmpp:delay' stamp='2019-09-20T23:01:15Z'/>
|
|
<message type="chat" from="${contact_jid}" to="${_converse.bare_jid}" id="message-id-0">
|
|
<origin-id xmlns='urn:xmpp:sid:0' id="origin-id-0"/>
|
|
<body>😊</body>
|
|
</message>
|
|
</forwarded>
|
|
</result>
|
|
</message>
|
|
`);
|
|
_converse.connection._dataRecv(mock.createRequest(first_message));
|
|
|
|
const tombstone = u.toStanza(`
|
|
<message id='${u.getUniqueId()}' to='${_converse.jid}'>
|
|
<result xmlns='urn:xmpp:mam:2' queryid='${queryid}' id="${u.getUniqueId()}">
|
|
<forwarded xmlns='urn:xmpp:forward:0'>
|
|
<delay xmlns='urn:xmpp:delay' stamp='2019-09-20T23:08:25Z'/>
|
|
<message type="chat" from="${contact_jid}" to="${_converse.bare_jid}" id="message-id-1">
|
|
<origin-id xmlns='urn:xmpp:sid:0' id="origin-id-1"/>
|
|
<retracted stamp='2019-09-20T23:09:32Z' xmlns='urn:xmpp:message-retract:0'/>
|
|
</message>
|
|
</forwarded>
|
|
</result>
|
|
</message>
|
|
`);
|
|
_converse.connection._dataRecv(mock.createRequest(tombstone));
|
|
|
|
const last_id = u.getUniqueId();
|
|
const retraction = u.toStanza(`
|
|
<message id='${u.getUniqueId()}' to='${_converse.jid}'>
|
|
<result xmlns='urn:xmpp:mam:2' queryid='${queryid}' id="${last_id}">
|
|
<forwarded xmlns='urn:xmpp:forward:0'>
|
|
<delay xmlns='urn:xmpp:delay' stamp='2019-09-20T23:08:25Z'/>
|
|
<message from="${contact_jid}" to='${_converse.bare_jid}' id='retract-message-1'>
|
|
<apply-to id="origin-id-1" xmlns="urn:xmpp:fasten:0">
|
|
<retract xmlns='urn:xmpp:message-retract:0'/>
|
|
</apply-to>
|
|
</message>
|
|
</forwarded>
|
|
</result>
|
|
</message>
|
|
`);
|
|
_converse.connection._dataRecv(mock.createRequest(retraction));
|
|
|
|
const iq_result = $iq({'type': 'result', 'id': stanza.getAttribute('id')})
|
|
.c('fin', {'xmlns': 'urn:xmpp:mam:2'})
|
|
.c('set', {'xmlns': 'http://jabber.org/protocol/rsm'})
|
|
.c('first', {'index': '0'}).t(first_id).up()
|
|
.c('last').t(last_id).up()
|
|
.c('count').t('2');
|
|
_converse.connection._dataRecv(mock.createRequest(iq_result));
|
|
|
|
await u.waitUntil(() => view.model.handleRetraction.calls.count() === 3);
|
|
|
|
expect(view.model.messages.length).toBe(2);
|
|
const message = view.model.messages.at(1);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('is_tombstone')).toBe(true);
|
|
expect(await view.model.handleRetraction.calls.first().returnValue).toBe(false);
|
|
expect(await view.model.handleRetraction.calls.all()[1].returnValue).toBe(false);
|
|
expect(await view.model.handleRetraction.calls.all()[2].returnValue).toBe(true);
|
|
await u.waitUntil(() => view.el.querySelectorAll('.chat-msg').length === 2);
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
|
|
expect(el.textContent.trim()).toBe('Mercutio has removed this message');
|
|
expect(u.hasClass('chat-msg--followup', el.parentElement)).toBe(false);
|
|
done();
|
|
}));
|
|
|
|
it("may be returned as a tombstone groupchat message",
|
|
mock.initConverse(
|
|
['discoInitialized'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const view = _converse.chatboxviews.get(muc_jid);
|
|
|
|
const sent_IQs = _converse.connection.IQ_stanzas;
|
|
const stanza = await u.waitUntil(() => sent_IQs.filter(iq => iq.querySelector(`iq[type="set"] query[xmlns="${Strophe.NS.MAM}"]`)).pop());
|
|
const queryid = stanza.querySelector('query').getAttribute('queryid');
|
|
|
|
const first_id = u.getUniqueId();
|
|
const tombstone = u.toStanza(`
|
|
<message id="${u.getUniqueId()}" to="${_converse.jid}" from="${muc_jid}">
|
|
<result xmlns="urn:xmpp:mam:2" queryid="${queryid}" id="stanza-id">
|
|
<forwarded xmlns="urn:xmpp:forward:0">
|
|
<delay xmlns="urn:xmpp:delay" stamp="2019-09-20T23:08:25Z"/>
|
|
<message type="groupchat" from="${muc_jid}/eve" to="${_converse.bare_jid}" id="message-id-1">
|
|
<origin-id xmlns='urn:xmpp:sid:0' id="origin-id-1"/>
|
|
<retracted stamp="2019-09-20T23:09:32Z" xmlns="urn:xmpp:message-retract:0"/>
|
|
</message>
|
|
</forwarded>
|
|
</result>
|
|
</message>
|
|
`);
|
|
spyOn(view.model, 'handleRetraction').and.callThrough();
|
|
const promise = new Promise(resolve => _converse.api.listen.once('messageAdded', resolve));
|
|
_converse.connection._dataRecv(mock.createRequest(tombstone));
|
|
|
|
const last_id = u.getUniqueId();
|
|
const retraction = u.toStanza(`
|
|
<message id="${u.getUniqueId()}" to="${_converse.jid}" from="${muc_jid}">
|
|
<result xmlns="urn:xmpp:mam:2" queryid="${queryid}" id="${last_id}">
|
|
<forwarded xmlns="urn:xmpp:forward:0">
|
|
<delay xmlns="urn:xmpp:delay" stamp="2019-09-20T23:08:25Z"/>
|
|
<message type="groupchat" from="${muc_jid}/eve" to="${_converse.bare_jid}" id="retract-message-1">
|
|
<apply-to id="origin-id-1" xmlns="urn:xmpp:fasten:0">
|
|
<retract xmlns="urn:xmpp:message-retract:0"/>
|
|
</apply-to>
|
|
</message>
|
|
</forwarded>
|
|
</result>
|
|
</message>
|
|
`);
|
|
_converse.connection._dataRecv(mock.createRequest(retraction));
|
|
|
|
const iq_result = $iq({'type': 'result', 'id': stanza.getAttribute('id')})
|
|
.c('fin', {'xmlns': 'urn:xmpp:mam:2'})
|
|
.c('set', {'xmlns': 'http://jabber.org/protocol/rsm'})
|
|
.c('first', {'index': '0'}).t(first_id).up()
|
|
.c('last').t(last_id).up()
|
|
.c('count').t('2');
|
|
_converse.connection._dataRecv(mock.createRequest(iq_result));
|
|
|
|
await promise;
|
|
expect(view.model.messages.length).toBe(1);
|
|
let message = view.model.messages.at(0);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('is_tombstone')).toBe(true);
|
|
|
|
await u.waitUntil(() => view.model.handleRetraction.calls.count() === 2);
|
|
expect(await view.model.handleRetraction.calls.first().returnValue).toBe(false);
|
|
expect(await view.model.handleRetraction.calls.all()[1].returnValue).toBe(true);
|
|
expect(view.model.messages.length).toBe(1);
|
|
message = view.model.messages.at(0);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('is_tombstone')).toBe(true);
|
|
expect(view.el.querySelectorAll('.chat-msg').length).toBe(1);
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
|
|
expect(el.textContent.trim()).toBe('eve has removed this message');
|
|
done();
|
|
}));
|
|
|
|
it("may be returned as a tombstone moderated groupchat message",
|
|
mock.initConverse(
|
|
['discoInitialized', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
const muc_jid = 'lounge@montague.lit';
|
|
const features = [...mock.default_muc_features, Strophe.NS.MODERATE];
|
|
await mock.openAndEnterChatRoom(_converse, muc_jid, 'romeo', features);
|
|
const view = _converse.chatboxviews.get(muc_jid);
|
|
|
|
const sent_IQs = _converse.connection.IQ_stanzas;
|
|
const stanza = await u.waitUntil(() => sent_IQs.filter(iq => iq.querySelector(`iq[type="set"] query[xmlns="${Strophe.NS.MAM}"]`)).pop());
|
|
const queryid = stanza.querySelector('query').getAttribute('queryid');
|
|
|
|
const first_id = u.getUniqueId();
|
|
const tombstone = u.toStanza(`
|
|
<message id="${u.getUniqueId()}" to="${_converse.jid}" from="${muc_jid}">
|
|
<result xmlns="urn:xmpp:mam:2" queryid="${queryid}" id="stanza-id">
|
|
<forwarded xmlns="urn:xmpp:forward:0">
|
|
<delay xmlns="urn:xmpp:delay" stamp="2019-09-20T23:08:25Z"/>
|
|
<message type="groupchat" from="${muc_jid}/eve" to="${_converse.bare_jid}" id="message-id-1">
|
|
<moderated by="${muc_jid}/bob" stamp="2019-09-20T23:09:32Z" xmlns='urn:xmpp:message-moderate:0'>
|
|
<retracted xmlns="urn:xmpp:message-retract:0"/>
|
|
<reason>This message contains inappropriate content</reason>
|
|
</moderated>
|
|
</message>
|
|
</forwarded>
|
|
</result>
|
|
</message>
|
|
`);
|
|
spyOn(view.model, 'handleModeration').and.callThrough();
|
|
const promise = new Promise(resolve => _converse.api.listen.once('messageAdded', resolve));
|
|
_converse.connection._dataRecv(mock.createRequest(tombstone));
|
|
|
|
const last_id = u.getUniqueId();
|
|
const retraction = u.toStanza(`
|
|
<message id="${u.getUniqueId()}" to="${_converse.jid}" from="${muc_jid}">
|
|
<result xmlns="urn:xmpp:mam:2" queryid="${queryid}" id="${last_id}">
|
|
<forwarded xmlns="urn:xmpp:forward:0">
|
|
<delay xmlns="urn:xmpp:delay" stamp="2019-09-20T23:08:25Z"/>
|
|
<message type="groupchat" from="${muc_jid}" to="${_converse.bare_jid}" id="retract-message-1">
|
|
<apply-to id="stanza-id" xmlns="urn:xmpp:fasten:0">
|
|
<moderated by="${muc_jid}/bob" xmlns='urn:xmpp:message-moderate:0'>
|
|
<retract xmlns="urn:xmpp:message-retract:0"/>
|
|
<reason>This message contains inappropriate content</reason>
|
|
</moderated>
|
|
</apply-to>
|
|
</message>
|
|
</forwarded>
|
|
</result>
|
|
</message>
|
|
`);
|
|
_converse.connection._dataRecv(mock.createRequest(retraction));
|
|
|
|
const iq_result = $iq({'type': 'result', 'id': stanza.getAttribute('id')})
|
|
.c('fin', {'xmlns': 'urn:xmpp:mam:2'})
|
|
.c('set', {'xmlns': 'http://jabber.org/protocol/rsm'})
|
|
.c('first', {'index': '0'}).t(first_id).up()
|
|
.c('last').t(last_id).up()
|
|
.c('count').t('2');
|
|
_converse.connection._dataRecv(mock.createRequest(iq_result));
|
|
|
|
await promise;
|
|
expect(view.model.messages.length).toBe(1);
|
|
let message = view.model.messages.at(0);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('is_tombstone')).toBe(true);
|
|
|
|
await u.waitUntil(() => view.model.handleModeration.calls.count() === 2);
|
|
expect(await view.model.handleModeration.calls.first().returnValue).toBe(false);
|
|
expect(await view.model.handleModeration.calls.all()[1].returnValue).toBe(true);
|
|
|
|
expect(view.model.messages.length).toBe(1);
|
|
message = view.model.messages.at(0);
|
|
expect(message.get('retracted')).toBeTruthy();
|
|
expect(message.get('is_tombstone')).toBe(true);
|
|
expect(message.get('moderation_reason')).toBe("This message contains inappropriate content");
|
|
expect(view.el.querySelectorAll('.chat-msg').length).toBe(1);
|
|
|
|
expect(view.el.querySelectorAll('.chat-msg--retracted').length).toBe(1);
|
|
const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
|
|
expect(el.textContent.trim()).toBe('A moderator has removed this message');
|
|
const qel = view.el.querySelector('.chat-msg--retracted .chat-msg__message q');
|
|
expect(qel.textContent.trim()).toBe('This message contains inappropriate content');
|
|
done();
|
|
}));
|
|
});
|
|
})
|