123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936 |
- (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').length === 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="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.onMessage(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.onMessage(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(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(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(view.model.handleRetraction.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 retracted 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 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>`);
- const message = view.model.messages.at(0);
- expect(view.model.messages.length).toBe(1);
- expect(message.get('retracted')).toBeTruthy();
- 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 retracted 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.onMessage(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.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 retracted 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.onMessage(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.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 retracted this message from mallory');
- 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.onMessage(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);
- 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.onMessage(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.canRetractMessages();
- 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.onMessage(received_stanza);
- await u.waitUntil(() => view.model.messages.length === 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.onMessage(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 retracted this message from mallory');
- 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);
- 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.at(0);
- 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.at(0);
- expect(message.get('retracted')).toBeTruthy();
- expect(message.get('is_ephemeral')).toBe(false);
- 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(1);
- expect(view.model.messages.at(0).get('retracted')).toBeTruthy();
- expect(view.model.messages.at(0).get('is_ephemeral')).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 retracted 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');
- 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.at(0).get('retracted')).toBeTruthy();
- const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
- expect(el.textContent.trim()).toBe('romeo has retracted this message');
- const message = view.model.messages.at(0);
- 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(1);
- expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
- expect(view.model.messages.at(0).get('is_ephemeral')).toBeFalsy();
- 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 an 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 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.at(0).get('retracted')).toBeTruthy();
- const el = view.el.querySelector('.chat-msg--retracted .chat-msg__message div');
- expect(el.textContent.trim()).toBe('romeo has retracted 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(1);
- expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
- expect(view.model.messages.at(0).get('is_ephemeral')).toBeFalsy();
- 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();
- }));
- });
- 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(view.model.handleRetraction.calls.first().returnValue).toBe(false);
- expect(view.model.handleRetraction.calls.all()[1].returnValue).toBe(false);
- expect(view.model.handleRetraction.calls.all()[2].returnValue).toBe(true);
- expect(view.el.querySelectorAll('.chat-msg').length).toBe(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 retracted 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(view.model.handleRetraction.calls.first().returnValue).toBe(false);
- expect(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 retracted 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(view.model.handleModeration.calls.first().returnValue).toBe(false);
- expect(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 retracted this message from eve');
- const qel = view.el.querySelector('.chat-msg--retracted .chat-msg__message q');
- expect(qel.textContent.trim()).toBe('This message contains inappropriate content');
- done();
- }));
- });
- })
- }));
|