From cccc1253aa12f62a6cf8403ee54facf656521504 Mon Sep 17 00:00:00 2001 From: mathieui Date: Sun, 10 Jan 2021 14:38:43 +0100 Subject: XEP-0045: add more elements () --- slixmpp/plugins/xep_0045/muc.py | 30 +++++++++--------- slixmpp/plugins/xep_0045/stanza.py | 64 +++++++++++++++++++++++++++----------- tests/test_stanza_xep_0045.py | 59 +++++++++++++++++++++++++++++++++++ 3 files changed, 120 insertions(+), 33 deletions(-) diff --git a/slixmpp/plugins/xep_0045/muc.py b/slixmpp/plugins/xep_0045/muc.py index 4220978d..03d01dba 100644 --- a/slixmpp/plugins/xep_0045/muc.py +++ b/slixmpp/plugins/xep_0045/muc.py @@ -42,6 +42,8 @@ from slixmpp.plugins.xep_0045.stanza import ( MUCOwnerQuery, MUCOwnerDestroy, MUCStatus, + MUCActor, + MUCUserItem, ) @@ -66,6 +68,9 @@ class XEP_0045(BasePlugin): self.rooms = {} self.our_nicks = {} # load MUC support in presence stanzas + register_stanza_plugin(MUCMessage, MUCUserItem) + register_stanza_plugin(MUCPresence, MUCUserItem) + register_stanza_plugin(MUCUserItem, MUCActor) register_stanza_plugin(MUCMessage, MUCInvite) register_stanza_plugin(MUCMessage, MUCDecline) register_stanza_plugin(MUCMessage, MUCStatus) @@ -248,24 +253,22 @@ class XEP_0045(BasePlugin): iq['mucowner_query']['destroy']['reason'] = reason await iq.send(**iqkwargs) - async def set_affiliation(self, room: JID, jid: Optional[JID] = None, nick: Optional[str] = None, *, affiliation: str, - reason: str = '', ifrom: Optional[JID] = None, **iqkwargs): + async def set_affiliation(self, room: JID, affiliation: str, *, jid: Optional[JID] = None, + nick: Optional[str] = None, reason: str = '', + ifrom: Optional[JID] = None, **iqkwargs): """ Change room affiliation.""" if affiliation not in AFFILIATIONS: raise ValueError('%s is not a valid affiliation' % affiliation) if not any((jid, nick)): raise ValueError('One of jid or nick must be set') iq = self.xmpp.make_iq_set(ito=room, ifrom=ifrom) - iq.enable('mucadmin_query') - item = MUCAdminItem() - item['affiliation'] = affiliation + iq['mucadmin_query']['item']['affiliation'] = affiliation if nick: - item['nick'] = nick + iq['mucadmin_query']['item']['nick'] = nick if jid: - item['jid'] = jid + iq['mucadmin_query']['item']['jid'] = jid if reason: - item['reason'] = reason - iq['mucadmin_query'].append(item) + iq['mucadmin_query']['item']['reason'] = reason await iq.send(**iqkwargs) async def set_role(self, room: JID, nick: str, role: str, *, @@ -278,13 +281,10 @@ class XEP_0045(BasePlugin): if role not in ROLES: raise ValueError("Role %s does not exist" % role) iq = self.xmpp.make_iq_set(ito=room, ifrom=ifrom) - iq.enable('mucadmin_query') - item = MUCAdminItem() - item['role'] = role - item['nick'] = nick + iq['mucadmin_query']['item']['role'] = role + iq['mucadmin_query']['item']['nick'] = nick if reason: - item['reason'] = reason - iq['mucadmin_query'].append(item) + iq['mucadmin_query']['item']['reason'] = reason await iq.send(**iqkwargs) def invite(self, room: JID, jid: JID, reason: str = '', *, diff --git a/slixmpp/plugins/xep_0045/stanza.py b/slixmpp/plugins/xep_0045/stanza.py index 8de938fb..65c7dafe 100644 --- a/slixmpp/plugins/xep_0045/stanza.py +++ b/slixmpp/plugins/xep_0045/stanza.py @@ -7,7 +7,12 @@ See the file LICENSE for copying permission. """ -from typing import Iterable, Set +from typing import ( + Iterable, + Set, + Optional, + Union, +) import logging from slixmpp.xmlstream import ElementBase, ET, JID @@ -45,24 +50,21 @@ class MUCBase(ElementBase): status['code'] = code self.append(status) - def get_item_attr(self, attr, default: str): + def get_item_attr(self, attr: str, default): item = self.xml.find(f'{{{NS_USER}}}item') if item is None: return default - return item.get(attr) + return self['item'][attr] - def set_item_attr(self, attr, value: str): - item = self.xml.find(f'{{{NS_USER}}}item') - if item is None: - item = ET.Element(f'{{{NS_USER}}}item') - self.xml.append(item) - item.attrib[attr] = value + def set_item_attr(self, attr: str, value: str): + item = self['item'] + item[attr] = value return item def del_item_attr(self, attr): item = self.xml.find(f'{{{NS_USER}}}item') - if item is not None and attr in item.attrib: - del item.attrib[attr] + if item is not None: + del self['item'][attr] def get_affiliation(self): return self.get_item_attr('affiliation', '') @@ -71,13 +73,12 @@ class MUCBase(ElementBase): self.set_item_attr('affiliation', value) def del_affiliation(self): - # TODO: set default affiliation self.del_item_attr('affiliation') - def get_jid(self): + def get_jid(self) -> JID: return JID(self.get_item_attr('jid', '')) - def set_jid(self, value): + def set_jid(self, value: Union[JID, str]): if not isinstance(value, str): value = str(value) self.set_item_attr('jid', value) @@ -85,10 +86,10 @@ class MUCBase(ElementBase): def del_jid(self): self.del_item_attr('jid') - def get_role(self): + def get_role(self) -> str: return self.get_item_attr('role', '') - def set_role(self, value): + def set_role(self, value: str): # TODO: check for valid role self.set_item_attr('role', value) @@ -96,10 +97,10 @@ class MUCBase(ElementBase): # TODO: set default role self.del_item_attr('role') - def get_nick(self): + def get_nick(self) -> str: return self.parent()['from'].resource - def get_room(self): + def get_room(self) -> str: return self.parent()['from'].bare def set_nick(self, value): @@ -232,3 +233,30 @@ class MUCStatus(ElementBase): def set_code(self, code: int): self.xml.attrib['code'] = str(code) + + +class MUCUserItem(ElementBase): + namespace = NS_USER + name = 'item' + plugin_attrib = 'item' + interfaces = {'role', 'affiliation', 'jid', 'reason', 'nick'} + sub_interfaces = {'reason'} + + def get_jid(self) -> Optional[JID]: + jid = self.xml.attrib.get('jid', None) + if jid: + return JID(jid) + return jid + + +class MUCActor(ElementBase): + namespace = NS_USER + name = 'actor' + plugin_attrib = 'actor' + interfaces = {'jid', 'nick'} + + def get_jid(self) -> Optional[JID]: + jid = self.xml.attrib.get('jid', None) + if jid: + return JID(jid) + return jid diff --git a/tests/test_stanza_xep_0045.py b/tests/test_stanza_xep_0045.py index 29dd75db..707d91cd 100644 --- a/tests/test_stanza_xep_0045.py +++ b/tests/test_stanza_xep_0045.py @@ -13,6 +13,8 @@ from slixmpp.plugins.xep_0045.stanza import ( MUCStatus, MUCInvite, MUCDecline, + MUCUserItem, + MUCActor, ) from slixmpp.xmlstream import register_stanza_plugin, ET @@ -20,6 +22,9 @@ from slixmpp.xmlstream import register_stanza_plugin, ET class TestMUC(SlixTest): def setUp(self): + register_stanza_plugin(MUCPresence, MUCUserItem) + register_stanza_plugin(MUCMessage, MUCUserItem) + register_stanza_plugin(MUCUserItem, MUCActor) register_stanza_plugin(MUCMessage, MUCInvite) register_stanza_plugin(MUCMessage, MUCDecline) register_stanza_plugin(MUCMessage, MUCStatus) @@ -33,7 +38,46 @@ class TestMUC(SlixTest): register_stanza_plugin(MUCOwnerQuery, MUCOwnerDestroy) register_stanza_plugin(MUCAdminQuery, MUCAdminItem, iterable=True) + def testPresence(self): + presence = Presence() + presence['from'] = JID('muc@service/nick') + presence['muc']['item']['affiliation'] = 'member' + presence['muc']['item']['role'] = 'participant' + presence['muc']['status_codes'] = (100, 110, 210) + + self.check(presence, """ + + + + + + + + + """, use_values=False) + + def testPresenceReason(self): + presence = Presence() + presence['from'] = JID('muc@service/nick') + presence['muc']['item']['affiliation'] = 'member' + presence['muc']['item']['role'] = 'participant' + presence['muc']['item']['reason'] = 'coucou' + presence['muc']['item']['actor']['nick'] = 'JPR' + + self.check(presence, """ + + + + + coucou + + + + """, use_values=False) + + + def testPresenceLegacy(self): presence = Presence() presence['from'] = JID('muc@service/nick') presence['muc']['affiliation'] = 'member' @@ -96,5 +140,20 @@ class TestMUC(SlixTest): """, use_values=False) + def testSetAffiliation(self): + iq = Iq() + iq['type'] = 'set' + iq['id'] = '1' + iq['mucadmin_query']['item']['jid'] = JID('test@example.com') + iq['mucadmin_query']['item']['affiliation'] = 'owner' + self.check(iq, """ + + + + + + """, use_values=False) + suite = unittest.TestLoader().loadTestsFromTestCase(TestMUC) -- cgit v1.2.3