im-changing.ru
/
converse.js
Mirror von https://github.com/conversejs/converse.js.git


			
							12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148
							(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.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.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);
                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(1);
                expect(view.model.messages.at(0).get('retracted')).toBeTruthy();
                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 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');
                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 removed 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.model.messages.at(0).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 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 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(1);
                expect(view.model.messages.at(0).get('retracted')).toBeFalsy();
                expect(view.model.messages.at(0).get('is_ephemeral')).toBeFalsy();
                expect(view.model.messages.at(0).get('editable')).toBeTruthy();

                const error_messages = view.el.querySelectorAll('.chat-error');
                expect(error_messages.length).toBe(2);
                expect(error_messages[0].textContent).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();
            }));
        });
    })
}));