import asyncio
import unittest.mock
from datetime import datetime, timezone
from typing import Optional

import pytest
from slixmpp.exceptions import XMPPError

from conftest import AvatarFixtureMixin
from slixmpp import JID, Iq
from slixmpp import __version__ as slix_version

from slidge import BaseGateway, BaseSession, MucType, GatewayUser
from slidge.contact import LegacyContact
from slidge.core.session import _sessions
from slidge.group import LegacyBookmarks, LegacyMUC
from slidge.util.test import SlidgeTest
from slidge.util.types import HoleBound


class Gateway(BaseGateway):
    COMPONENT_NAME = "A test"
    GROUPS = True


class Session(BaseSession):
    async def login(self):
        return "YUP"


class Contact(LegacyContact):
    async def update_info(self):
        if self.legacy_id.startswith("room"):
            raise XMPPError
        if self.legacy_id != "juliet":
            return
        self.is_friend = True
        self.added_to_roster = True
        self.name = "A name"
        self.online("status msg")
        await self.set_avatar("AVATAR_URL")


class MUC(LegacyMUC):
    async def update_info(self):
        if self.legacy_id in ("room-noinfo",
                              "room-duplicate-participant",
                              "room-avatar-slow",
                              "room-contact-conflict",
                              "room-reaction-fallback",
                              "room-mark-all-carbon"):
            return
        if self.legacy_id == "room-avatar-in-slow-task":
            self.session.create_task(self._slow_set_avatar(), "slow-avatar")
            return
        self.name = "Cool name"
        self.description = "Cool description"
        self.type = MucType.CHANNEL_NON_ANONYMOUS
        self.subject = "Cool subject"
        self.subject_setter = await self.get_participant_by_legacy_id("juliet")
        self.subject_date = datetime(2000, 1, 1, 0, 0, tzinfo=timezone.utc)
        self.n_participants = 666
        self.user_nick = "Cool nick"
        await self.set_avatar("AVATAR_URL")

    async def backfill(
        self,
        after: Optional[HoleBound] = None,
        before: Optional[HoleBound] = None,
    ):
        if self.legacy_id == "room-history":
            juliet = await self.get_participant_by_legacy_id("juliet")
            juliet.send_text("history")

    async def fill_participants(self):
        if "duplicate-participant" in self.legacy_id:
            yield await self.get_participant_by_legacy_id("duplicate")
            yield await self.get_participant_by_legacy_id("duplicate")
        if "contact-conflict" in self.legacy_id:
            yield await self.get_participant_by_legacy_id("contact-conflict")

    async def _slow_set_avatar(self):
        await asyncio.sleep(1)
        await self.set_avatar("AVATAR_URL")

class Bookmarks(LegacyBookmarks):
    async def fill(self):
        return


@pytest.mark.usefixtures("avatar")
class TestSession2(AvatarFixtureMixin, SlidgeTest):
    plugin = globals()
    xmpp: Gateway

    def setUp(self):
        super().setUp()
        with self.xmpp.store.session() as orm:
            user = GatewayUser(
                jid=JID("romeo@montague.lit/gajim").bare,
                legacy_module_data={"username": "romeo", "city": ""},
                preferences={"sync_avatar": True, "sync_presence": True},
            )
            orm.add(user)
            orm.commit()
        self.run_coro(
            self.xmpp._BaseGateway__dispatcher._on_user_register(
                Iq(sfrom="romeo@montague.lit/gajim")
            )
        )
        welcome = self.next_sent()
        assert welcome["body"]
        stanza = self.next_sent()
        assert "logging in" in stanza["status"].lower(), stanza
        stanza = self.next_sent()
        assert "syncing contacts" in stanza["status"].lower(), stanza
        stanza = self.next_sent()
        assert "syncing groups" in stanza["status"].lower(), stanza
        probe = self.next_sent()
        assert probe.get_type() == "probe"
        stanza = self.next_sent()
        assert "yup" in stanza["status"].lower(), stanza

        self.send(  # language=XML
            """
            <iq type="get"
                to="romeo@montague.lit"
                id="1"
                from="aim.shakespeare.lit">
              <pubsub xmlns="http://jabber.org/protocol/pubsub">
                <items node="urn:xmpp:avatar:metadata" />
              </pubsub>
            </iq>
            """
        )

    @property
    def romeo_session(self) -> Session:
        return BaseSession.get_self_or_unique_subclass().from_jid(
            JID("romeo@montague.lit")
        )

    def test_contact_init(self):
        self.run_coro(self.romeo_session.contacts.by_legacy_id("juliet"))
        self.send(  # language=XML
            f"""
            <presence from="juliet@aim.shakespeare.lit/slidge"
                      to="romeo@montague.lit">
              <c xmlns="http://jabber.org/protocol/caps"
                 node="http://slixmpp.com/ver/{slix_version}"
                 hash="sha-1"
                 ver="OErK4nBtx6JV2uK05xyCf47ioT0=" />
              <status>status msg</status>
            </presence>
            """
        )
        self.send(  # language=XML
            """
            <message type="headline"
                     from="juliet@aim.shakespeare.lit"
                     to="romeo@montague.lit">
              <event xmlns="http://jabber.org/protocol/pubsub#event">
                <items node="http://jabber.org/protocol/nick">
                  <item>
                    <nick xmlns="http://jabber.org/protocol/nick">A name</nick>
                  </item>
                </items>
              </event>
            </message>
            """,
            use_values=False,
        )
        self.send(  # language=XML
            f"""
            <message type="headline"
                     from="juliet@aim.shakespeare.lit"
                     to="romeo@montague.lit">
              <event xmlns="http://jabber.org/protocol/pubsub#event">
                <items node="urn:xmpp:avatar:metadata">
                  <item id="{self.avatar_sha1}">
                    <metadata xmlns="urn:xmpp:avatar:metadata">
                      <info id="{self.avatar_sha1}"
                            type="image/png"
                            bytes="{len(self.avatar_bytes)}"
                            height="5"
                            width="5" />
                    </metadata>
                  </item>
                </items>
              </event>
            </message>
            """,
            use_values=False,  # I do not understand why this is necessary, related on test run order?!?
        )
        assert self.next_sent() is None
        juliet: Contact = self.run_coro(
            self.romeo_session.contacts.by_legacy_id("juliet")
        )
        assert juliet.name == "A name"
        assert juliet.is_friend
        cached_presence = juliet._get_last_presence()
        assert cached_presence is not None
        assert cached_presence.pstatus == "status msg"
        assert juliet.avatar is not None

    def test_group_init(self):
        self.run_coro(self.romeo_session.bookmarks.by_legacy_id("room"))
        self.next_sent()  # juliet presence
        self.next_sent()  # juliet nick
        self.next_sent()  # juliet avatar
        muc = self.run_coro(self.romeo_session.bookmarks.by_legacy_id("room"))
        assert self.next_sent() is None
        # self.run_coro(muc._set)
        assert muc.name == "Cool name"
        assert muc.description == "Cool description"
        assert muc.type == MucType.CHANNEL_NON_ANONYMOUS
        assert muc.n_participants == 666
        assert muc.user_nick == "Cool nick"
        assert muc.avatar is not None
        assert muc.subject == "Cool subject"
        assert muc.subject_date == datetime(2000, 1, 1, 0, 0, tzinfo=timezone.utc)
        assert (
            muc.subject_setter
            == self.run_coro(self.romeo_session.contacts.by_legacy_id("juliet")).name
        )

    def test_set_user_nick_outside_update_info(self):
        muc = self.run_coro(self.romeo_session.bookmarks.by_legacy_id("room"))
        assert muc.user_nick == "Cool nick"
        muc.user_nick = "Cooler nick"
        muc = self.run_coro(self.romeo_session.bookmarks.by_legacy_id("room"))
        assert muc.user_nick == "Cooler nick"

    def test_user_available(self):
        self.run_coro(self.romeo_session.contacts.by_legacy_id("juliet"))
        for _ in range(3):
            assert self.next_sent() is not None
        self.recv(  # language=XML
            f"""
            <presence from="romeo@montague.lit/movim"
                      to="juliet@{self.xmpp.boundjid.bare}" />
            """
        )
        assert self.next_sent() is not None
        assert self.next_sent() is None

    def test_leave_group(self):
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room")
        )
        self.next_sent()  # juliet presence
        self.next_sent()  # juliet nick
        self.next_sent()  # juliet avatar
        assert self.next_sent() is None
        assert muc.jid in list([m.jid for m in self.romeo_session.bookmarks])

        muc.add_user_resource("gajim")
        self.run_coro(self.romeo_session.bookmarks.remove(muc))
        self.send(  # language=XML
            """
            <presence xmlns="jabber:component:accept"
                      type="unavailable"
                      from="room@aim.shakespeare.lit/Cool nick"
                      to="romeo@montague.lit/gajim">
              <x xmlns="http://jabber.org/protocol/muc#user">
                <item affiliation="member"
                      role="participant"
                      jid="romeo@montague.lit">
                  <reason>You left this group from the official client.</reason>
                </item>
                <status code="307" />
                <status code="100" />
                <status code="110" />
              </x>
              <occupant-id xmlns="urn:xmpp:occupant-id:0"
                           id="slidge-user" />
              <priority>0</priority>
            </presence>
            """
        )
        assert muc.jid not in list([m.jid for m in self.romeo_session.bookmarks])

    def test_correction(self):
        with unittest.mock.patch("slidge.BaseSession.on_text", return_value="legacy-msg-id") as on_text:
            self.recv(  # language=XML
                """
            <message from='romeo@montague.lit/gajim'
                     type='chat'
                     to='juliet@aim.shakespeare.lit'
                     id="msg-id">
              <body>body</body>
            </message>
            """
            )
            on_text.assert_awaited_once()
        with unittest.mock.patch("slidge.BaseSession.on_correct") as on_correct:
            self.recv(  # language=XML
                """
            <message from='romeo@montague.lit/gajim'
                     type='chat'
                     to='juliet@aim.shakespeare.lit'
                     id="msg-id">
              <body>new body</body>
              <replace id='msg-id'
                       xmlns='urn:xmpp:message-correct:0' />
            </message>
            """
            )
            on_correct.assert_awaited_once()
            contact, body, msg_id, *_ = on_correct.call_args[0]
            assert contact.name == "A name"
            assert body == "new body"
            assert msg_id == "legacy-msg-id"

    def test_participant_avatar_race_condition(self):
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room")
        )
        self.next_sent()  # juliet presence
        self.next_sent()  # juliet nick
        self.next_sent()  # juliet avatar
        contact1: Contact = self.run_coro(self.romeo_session.contacts.by_legacy_id("slow"))
        contact1.online()
        _participant1 = self.run_coro(muc.get_participant_by_contact(contact1))
        contact1.avatar = "SLOW"
        self.run_coro(asyncio.wait_for(contact1._set_avatar_task, 2))

        contact2: Contact = self.run_coro(self.romeo_session.contacts.by_legacy_id("slow"))
        assert contact2.avatar.url == "AVATAR_URL"

    def test_conflict_on_join(self):
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-noinfo")
        )
        assert self.next_sent() is None
        self.recv(  # language=XML
            f"""
            <presence from="romeo@montague.lit/movim"
                      to="{muc.jid}/nick">
              <x xmlns='http://jabber.org/protocol/muc' />
            </presence>
            """
        )
        self.send(  # language=XML
            """
            <presence from="room-noinfo@aim.shakespeare.lit/romeo"
                      to="romeo@montague.lit/movim">
              <x xmlns="http://jabber.org/protocol/muc#user">
                <item affiliation="member"
                      role="participant" />
                <status code="210" />
                <status code="110" />
              </x>
              <occupant-id xmlns="urn:xmpp:occupant-id:0"
                           id="slidge-user" />
            </presence>
            """
        )
        _subject = self.next_sent()
        self.send(  # language=XML
            """
            <presence to="romeo@montague.lit/movim"
                      from="room-noinfo@aim.shakespeare.lit">
              <x xmlns="vcard-temp:x:update">
                <photo />
              </x>
            </presence>
            """,
            use_values=False
        )
        assert self.next_sent() is None

    def test_fill_participant_duplicate(self):
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-duplicate-participant")
        )
        assert self.next_sent() is None
        self.recv(  # language=XML
            f"""
            <presence from="romeo@montague.lit/movim"
                      to="{muc.jid}/nick">
              <x xmlns='http://jabber.org/protocol/muc' />
            </presence>
            """
        )
        assert self.next_sent().get_from().resource == "duplicate"
        assert self.next_sent().get_from().resource == muc.user_nick

    def test_presence_to_user_account(self):
        self.romeo_session.contacts.user_legacy_id = "user-id"
        self.recv(  # language=XML
            """
            <presence from="romeo@montague.lit/movim"
                      to="user-id@aim.shakespeare.lit" />
            """
        )
        self.send(  # language=XML
            """
            <presence from="user-id@aim.shakespeare.lit"
                      to="romeo@montague.lit/movim"
                      type="error">
              <error type="modify">
                <bad-request xmlns="urn:ietf:params:xml:ns:xmpp-stanzas" />
                <text xmlns="urn:ietf:params:xml:ns:xmpp-stanzas">Actions with yourself are not supported.</text>
              </error>
            </presence>
            """
        )

    def test_slow_avatar_in_task(self):
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-avatar-in-slow-task")
        )
        assert not muc.participants_filled
        assert self.next_sent() is None
        assert not muc.participants_filled
        assert self.next_sent() is None
        self.recv(  # language=XML
            f"""
            <presence from="romeo@montague.lit/movim"
                      to="{muc.jid}/nick">
              <x xmlns='http://jabber.org/protocol/muc' />
            </presence>
            """
        )
        self.next_sent()
        muc = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-avatar-in-slow-task")
        )
        assert muc.participants_filled
        for task in self.romeo_session._BaseSession__tasks:
            task: asyncio.Task
            if task.get_name() == "slow-avatar":
                self.run_coro(asyncio.wait_for(task, 2))
                break
        else:
            assert False
        muc = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-avatar-in-slow-task")
        )
        assert muc.participants_filled

    def test_slow_avatar(self):
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-avatar-slow")
        )
        assert not muc.participants_filled
        assert self.next_sent() is None
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-avatar-slow")
        )
        muc.avatar = "SLOW"
        assert not muc.participants_filled
        assert self.next_sent() is None
        self.recv(  # language=XML
            f"""
            <presence from="romeo@montague.lit/movim"
                      to="{muc.jid}/nick">
              <x xmlns='http://jabber.org/protocol/muc' />
            </presence>
            """
        )
        self.next_sent()
        muc2 = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-avatar-slow")
        )
        assert muc2.participants_filled

        self.run_coro(asyncio.wait_for(muc._set_avatar_task, 2))
        muc = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-avatar-slow")
        )
        assert muc.participants_filled

    def test_live_message_then_fill_participants(self):
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-contact-conflict")
        )
        part = self.run_coro(muc.get_participant_by_legacy_id("contact-conflict"))
        part.send_text("some text")
        self.recv(  # language=XML
            f"""
            <presence from="romeo@montague.lit/movim"
                      to="{muc.jid}/nick">
              <x xmlns='http://jabber.org/protocol/muc' />
            </presence>
            """
        )
        self.send(  # language=XML
            """
            <presence from="room-contact-conflict@aim.shakespeare.lit/contact-conflict"
                      to="romeo@montague.lit/movim">
              <x xmlns="http://jabber.org/protocol/muc#user">
                <item affiliation="member"
                      role="participant" />
              </x>
              <occupant-id xmlns="urn:xmpp:occupant-id:0"
                           id="contact-conflict@aim.shakespeare.lit/slidge" />
            </presence>
            """
        )

    def test_disco_unnamed_room(self):
        self.recv(  # language=XML
            f"""
            <iq type="get"
                from="romeo@montague.lit/gajim"
                to="room-noinfo@{self.xmpp.boundjid.bare}"
                id="123">
              <query xmlns='http://jabber.org/protocol/disco#info' />
            </iq>
            """
        )
        self.send(  # language=XML
            f"""
            <iq xmlns="jabber:component:accept"
                type="result"
                from="room-noinfo@aim.shakespeare.lit"
                to="romeo@montague.lit/gajim"
                id="123">
              <query xmlns="http://jabber.org/protocol/disco#info">
                <identity category="conference"
                          type="text" />
                <feature var="http://jabber.org/protocol/muc" />
                <feature var="http://jabber.org/protocol/muc#stable_id" />
                <feature var="http://jabber.org/protocol/muc#self-ping-optimization" />
                <feature var="urn:xmpp:mam:2" />
                <feature var="urn:xmpp:mam:2#extended" />
                <feature var="urn:xmpp:sid:0" />
                <feature var="muc_persistent" />
                <feature var="vcard-temp" />
                <feature var="urn:xmpp:ping" />
                <feature var="urn:xmpp:occupant-id:0" />
                <feature var="jabber:iq:register" />
                <feature var="urn:xmpp:message-moderate:1" />
                <feature var="muc_open" />
                <feature var="muc_semianonymous" />
                <feature var="muc_public" />
                <x xmlns="jabber:x:data"
                   type="result">
                  <field var="FORM_TYPE"
                         type="hidden">
                    <value>http://jabber.org/protocol/muc#roominfo</value>
                  </field>
                  <field var="muc#roomconfig_persistentroom"
                         type="boolean">
                    <value>1</value>
                  </field>
                  <field var="muc#roomconfig_changesubject"
                         type="boolean">
                    <value>0</value>
                  </field>
                  <field var="muc#maxhistoryfetch">
                    <value>100</value>
                  </field>
                  <field var="muc#roominfo_subjectmod"
                         type="boolean">
                    <value>0</value>
                  </field>
                  <field var="muc#roomconfig_membersonly"
                         type="boolean">
                    <value>0</value>
                  </field>
                  <field var="muc#roomconfig_whois"
                         type="list-single">
                    <value>moderators</value>
                  </field>
                  <field var="muc#roomconfig_publicroom"
                         type="boolean">
                    <value>1</value>
                  </field>
                  <field var="muc#roomconfig_allowpm"
                         type="boolean">
                    <value>0</value>
                  </field>
                </x>
              </query>
            </iq>
            """,
        )

    def test_reaction_fallback(self):
        self.romeo_session.user.preferences["reaction_fallback"] = True
        contact = self.run_coro(self.romeo_session.contacts.by_legacy_id("reacter"))
        contact.react("msg-id", "♥")
        self.send(  # language=XML
            """
            <message xmlns="jabber:component:accept"
                     type="chat"
                     from="reacter@aim.shakespeare.lit/slidge"
                     to="romeo@montague.lit">
              <store xmlns="urn:xmpp:hints" />
              <reactions xmlns="urn:xmpp:reactions:0"
                         id="msg-id">
                <reaction>♥</reaction>
              </reactions>
              <fallback xmlns="urn:xmpp:fallback:0"
                        for="urn:xmpp:reactions:0">
                <body />
              </fallback>
              <body>♥</body>
            </message>
            """,
            use_values=False
        )

    def test_reaction_fallback_muc(self):
        self.romeo_session.user.preferences["reaction_fallback"] = True
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-reaction-fallback")
        )
        part = self.run_coro(muc.get_participant_by_legacy_id("participant-x"))
        muc.add_user_resource("gajim")
        part.send_text("some text\non lines", legacy_msg_id="msg-id")
        presence = self.next_sent()
        assert presence["from"] == "room-reaction-fallback@aim.shakespeare.lit/participant-x"
        self.send(  # language=XML
            """
            <message xmlns="jabber:component:accept"
                     type="groupchat"
                     id="msg-id"
                     from="room-reaction-fallback@aim.shakespeare.lit/participant-x"
                     to="romeo@montague.lit/gajim">
              <body>some text\non lines</body>
              <active xmlns="http://jabber.org/protocol/chatstates" />
              <markable xmlns="urn:xmpp:chat-markers:0" />
              <stanza-id xmlns="urn:xmpp:sid:0"
                         id="msg-id"
                         by="room-reaction-fallback@aim.shakespeare.lit" />
              <occupant-id xmlns="urn:xmpp:occupant-id:0"
                           id="participant-x@aim.shakespeare.lit/slidge" />
            </message>
            """,
            use_values=False,
        )
        with unittest.mock.patch("uuid.uuid4", return_value="uuid"):
            part.react("msg-id", "♥")
            self.send(  # language=XML
                """
            <message xmlns="jabber:component:accept"
                     type="groupchat"
                     from="room-reaction-fallback@aim.shakespeare.lit/participant-x"
                     to="romeo@montague.lit/gajim">
              <store xmlns="urn:xmpp:hints" />
              <stanza-id xmlns="urn:xmpp:sid:0"
                         id="uuid"
                         by="room-reaction-fallback@aim.shakespeare.lit" />
              <reactions xmlns="urn:xmpp:reactions:0"
                         id="msg-id">
                <reaction>♥</reaction>
              </reactions>
              <fallback xmlns="urn:xmpp:fallback:0"
                        for="urn:xmpp:reactions:0">
                <body />
              </fallback>
              <body>&gt; some text\n&gt; on lines\n♥</body>
              <occupant-id xmlns="urn:xmpp:occupant-id:0"
                           id="participant-x@aim.shakespeare.lit/slidge" />
            </message>
            """,
                use_values=False,
            )

    def test_muc_user_retract(self):
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-retract")
        )
        muc.add_user_resource("gajim")
        with unittest.mock.patch("slidge.core.session.BaseSession.on_text") as on_text:
            on_text.return_value = "legacy-id"
            self.recv(  # language=XML
                """
            <message type="groupchat"
                     to="room-retract@aim.shakespeare.lit"
                     from="romeo@montague.lit/gajim"
                     id="origin-id">
              <body>hoy</body>
            </message>
            """
            )
            on_text.assert_awaited_once()
            muc = on_text.call_args[0][0]
            text = on_text.call_args[0][1]
            assert muc.jid.node == "room-retract"
            assert text == "hoy"
        self.next_sent()
        with unittest.mock.patch("slidge.core.session.BaseSession.on_retract") as on_retract:
            self.recv(  # language=XML
                """
            <message type="groupchat"
                     to="room-retract@aim.shakespeare.lit"
                     from="romeo@montague.lit/gajim"
                     id="origin-id">
              <retract id="origin-id"
                       xmlns='urn:xmpp:message-retract:1' />
            </message>
            """
            )
            on_text.assert_awaited_once()
            muc = on_retract.call_args[0][0]
            legacy_msg_id = on_retract.call_args[0][1]
            assert muc.jid.node == "room-retract"
            assert legacy_msg_id == "legacy-id"

    def test_mark_all_messages_muc(self):
        self.xmpp.MARK_ALL_MESSAGES = True
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-mark-all")
        )
        muc.add_user_resource("gajim")
        part = self.run_coro(muc.get_participant_by_legacy_id("participant-x"))
        part.send_text("whatever", "msg_00")
        part.send_text("whatever", "msg_01")
        part.send_text("whatever", "msg_02")
        with unittest.mock.patch(
            "slidge.core.session.BaseSession.on_displayed"
        ) as on_displayed:
            self.recv(  # language=XML
                f"""
            <message from="{self.romeo_session.user_jid.bare}/gajim"
                     to="{muc.jid.bare}"
                     type="groupchat">
              <displayed xmlns='urn:xmpp:chat-markers:0'
                         id='msg_02' />
            </message>
            """
            )
        assert on_displayed.await_count == 3
        for i in range(3):
            assert on_displayed.call_args_list[i][0][0].jid.username == "room-mark-all"
            assert on_displayed.call_args_list[i][0][1] == f"msg_0{i}"

        with unittest.mock.patch(
            "slidge.core.session.BaseSession.on_displayed"
        ) as on_displayed:
            self.recv(  # language=XML
                f"""
            <message from="{self.romeo_session.user_jid.bare}/gajim"
                     to="{muc.jid.bare}"
                     type="groupchat">
              <displayed xmlns='urn:xmpp:chat-markers:0'
                         id='msg_02' />
            </message>
            """
            )
        on_displayed.assert_not_awaited()

    def test_mark_all_messages_muc_not_found(self):
        self.xmpp.MARK_ALL_MESSAGES = True
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-mark-all")
        )
        muc.add_user_resource("gajim")
        part = self.run_coro(muc.get_participant_by_legacy_id("participant-x"))
        part.send_text("whatever", "msg_00")
        part.send_text("whatever", "msg_01")
        part.send_text("whatever", "msg_02")
        with unittest.mock.patch(
            "slidge.core.session.BaseSession.on_displayed"
        ) as on_displayed:
            self.recv(  # language=XML
                f"""
            <message from="{self.romeo_session.user_jid.bare}/gajim"
                     to="{muc.jid.bare}"
                     type="groupchat">
              <displayed xmlns='urn:xmpp:chat-markers:0'
                         id='msg_03' />
            </message>
            """
            )
        assert on_displayed.await_count == 3, on_displayed.call_args_list
        for i in range(3):
            assert on_displayed.call_args_list[i][0][0].jid.username == "room-mark-all"
            assert on_displayed.call_args_list[i][0][1] == f"msg_0{i}"

        with unittest.mock.patch(
            "slidge.core.session.BaseSession.on_displayed"
        ) as on_displayed:
            self.recv(  # language=XML
                f"""
            <message from="{self.romeo_session.user_jid.bare}/gajim"
                     to="{muc.jid.bare}"
                     type="groupchat">
              <displayed xmlns='urn:xmpp:chat-markers:0'
                         id='msg_03' />
            </message>
            """
            )
        on_displayed.assert_not_awaited()
        # assert on_displayed.call_args_list[0][0][0].jid.username == "room-mark-all"
        # assert on_displayed.call_args_list[0][0][1] == f"msg_03"

    def test_mark_all_messages_muc_carbon(self):
        # Privileges are set as side effect of another test, when running the full test
        # suite. I have not found where unfortunately :(
        self.xmpp.plugin["xep_0356"].granted_privileges.clear()

        self.xmpp.MARK_ALL_MESSAGES = True
        muc: LegacyMUC = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-mark-all-carbon")
        )
        muc.add_user_resource("gajim")

        part = self.run_coro(muc.get_participant_by_legacy_id("participant-x"))
        part.send_text("whatever", f"msg_00")
        _pres=self.next_sent()
        _msg=self.next_sent()
        for i in range(1,3):
            part.send_text("whatever", f"msg_0{i}")
            _msg=self.next_sent()


        part = self.run_coro(muc.get_user_participant())

        with unittest.mock.patch("uuid.uuid4", return_value="some-uuid"):
            part.displayed("msg_01")
            self.send(  # language=XML
                f"""
            <message from="{muc.jid.bare}/romeo"
                     to="{self.romeo_session.user_jid.bare}/gajim"
                     type="groupchat">
              <displayed xmlns='urn:xmpp:chat-markers:0'
                         id='msg_01' />
              <occupant-id xmlns="urn:xmpp:occupant-id:0"
                           id="slidge-user" />
              <stanza-id xmlns="urn:xmpp:sid:0"
                         id="some-uuid"
                         by="room-mark-all-carbon@aim.shakespeare.lit" />
            </message>
            """
            )
            assert self.next_sent() is None
        part.displayed("msg_01")
        assert self.next_sent() is None
        self.xmpp.MARK_ALL_MESSAGES = False

    def test_mark_all_messages_muc_carbon_not_found(self):
        self.xmpp.MARK_ALL_MESSAGES = True
        muc = self.run_coro(
            self.romeo_session.bookmarks.by_legacy_id("room-mark-all-carbon")
        )
        muc.add_user_resource("gajim")
        part = self.run_coro(muc.get_user_participant())

        with unittest.mock.patch("uuid.uuid4", return_value="some-uuid"):
            part.displayed("msg_xx")
            self.send(  # language=XML
                f"""
            <message from="{muc.jid.bare}/romeo"
                     to="{self.romeo_session.user_jid.bare}/gajim"
                     type="groupchat">
              <displayed xmlns='urn:xmpp:chat-markers:0'
                         id='msg_xx' />
              <occupant-id xmlns="urn:xmpp:occupant-id:0"
                           id="slidge-user" />
              <stanza-id xmlns="urn:xmpp:sid:0"
                         id="some-uuid"
                         by="room-mark-all-carbon@aim.shakespeare.lit" />
            </message>
            """
            )
        self.xmpp.MARK_ALL_MESSAGES = False