1157 lines
67 KiB
JavaScript
1157 lines
67 KiB
JavaScript
(function (root, factory) {
|
|
define([
|
|
"jasmine",
|
|
"mock",
|
|
"test-utils"
|
|
], factory);
|
|
} (this, function (jasmine, mock, test_utils) {
|
|
"use strict";
|
|
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.queueMessage(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 test_utils.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.queueMessage(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(test_utils.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 test_utils.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(test_utils.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(test_utils.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 test_utils.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(test_utils.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(test_utils.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 test_utils.waitForRoster(_converse, 'current', 1);
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, [], [Strophe.NS.SID]);
|
|
const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
|
|
const view = await test_utils.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(test_utils.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(test_utils.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 test_utils.waitForRoster(_converse, 'current', 1);
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, [], [Strophe.NS.SID]);
|
|
const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
|
|
const view = await test_utils.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(test_utils.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(test_utils.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(test_utils.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 test_utils.waitForRoster(_converse, 'current', 1);
|
|
const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
|
|
const view = await test_utils.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 test_utils.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.queueMessage(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(test_utils.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 test_utils.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.queueMessage(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(test_utils.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.queueMessage(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 test_utils.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.queueMessage(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 test_utils.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.queueMessage(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.queueMessage(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(test_utils.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 test_utils.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(test_utils.createRequest(reflection));
|
|
await u.waitUntil(() => view.model.handleRetraction.calls.count() === 1);
|
|
|
|
expect(view.model.messages.length).toBe(2);
|
|
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 test_utils.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(() =>
|
|
Array.from(view.el.querySelectorAll('.chat-info__message')).pop()?.textContent.trim() ===
|
|
"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(2);
|
|
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(test_utils.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.last().get('retracted')).toBeFalsy();
|
|
expect(view.model.messages.last().get('is_ephemeral')).toBeFalsy();
|
|
expect(view.model.messages.last().get('editable')).toBeTruthy();
|
|
|
|
expect(view.el.querySelectorAll('.chat-error').length).toBe(1);
|
|
const errmsg = view.el.querySelector('.chat-error');
|
|
expect(errmsg.textContent).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 test_utils.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(() =>
|
|
Array.from(view.el.querySelectorAll('.chat-info__message')).pop()?.textContent.trim() ===
|
|
"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(2);
|
|
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(2);
|
|
expect(view.model.messages.last().get('retracted')).toBeFalsy();
|
|
expect(view.model.messages.last().get('is_ephemeral')).toBeFalsy();
|
|
expect(view.model.messages.last().get('editable')).toBeTruthy();
|
|
|
|
const error_messages = view.el.querySelectorAll('.chat-error');
|
|
expect(error_messages.length).toBe(2);
|
|
expect(error_messages[0].textContent).toBe("Sorry, something went wrong while trying to retract your message.");
|
|
expect(error_messages[1].textContent).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 test_utils.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.queueMessage(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.queueMessage(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 test_utils.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.queueMessage(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(test_utils.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.queueMessage(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 test_utils.waitForRoster(_converse, 'current', 1);
|
|
const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
|
|
await test_utils.openChatBoxFor(_converse, contact_jid);
|
|
await test_utils.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(test_utils.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(test_utils.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(test_utils.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(test_utils.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 test_utils.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(test_utils.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(test_utils.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(test_utils.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 test_utils.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(test_utils.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(test_utils.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(test_utils.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();
|
|
}));
|
|
});
|
|
})
|
|
}));
|