61 lines
1.6 KiB
Python
61 lines
1.6 KiB
Python
|
"""
|
||
|
|
Slixmpp: The Slick XMPP Library
|
||
|
|
Copyright (C) 2018 Maxime “pep” Buquet <pep@bouah.net>
|
||
|
|
This file is part of Slixmpp.
|
||
|
|
|
||
|
|
See the file LICENSE for copying permission.
|
||
|
|
"""
|
||
|
|
|
||
|
|
import logging
|
||
|
|
|
||
|
|
from slixmpp.jid import JID
|
||
|
|
from slixmpp.plugins.xep_0384.stanza import OMEMO_BASE_NS
|
||
|
|
from slixmpp.plugins.xep_0384.stanza import OMEMO_DEVICES_NS, OMEMO_BUNDLE_NS
|
||
|
|
from slixmpp.plugins.base import BasePlugin, register_plugin
|
||
|
|
|
||
|
|
log = logging.getLogger(__name__)
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
class XEP_0384(BasePlugin):
|
||
|
|
|
||
|
|
"""
|
||
|
|
XEP-0384: OMEMO
|
||
|
|
"""
|
||
|
|
|
||
|
|
name = 'xep_0384'
|
||
|
|
description = 'XEP-0384 OMEMO'
|
||
|
|
dependencies = {'xep_0163'}
|
||
|
|
|
||
|
|
device_ids = {}
|
||
|
|
|
||
|
|
def plugin_init(self):
|
||
|
|
self.xmpp.add_event_handler('pubsub_publish', self.device_list)
|
||
|
|
|
||
|
|
def plugin_end(self):
|
||
|
|
self.xmpp.del_event_handler('pubsub_publish', self.device_list)
|
||
|
|
self.xmpp['xep_0163'].remove_interest(OMEMO_DEVICES_NS)
|
||
|
|
|
||
|
|
def session_bind(self, _jid):
|
||
|
|
self.xmpp['xep_0163'].add_interest(OMEMO_DEVICES_NS)
|
||
|
|
|
||
|
|
def device_list(self, msg):
|
||
|
|
if msg['pubsub_event']['items']['node'] != OMEMO_DEVICES_NS:
|
||
|
|
return
|
||
|
|
|
||
|
|
jid = JID(msg['from']).bare
|
||
|
|
items = msg['pubsub_event']['items']
|
||
|
|
for item in items:
|
||
|
|
device_ids = [d['id'] for d in item['list']]
|
||
|
|
if jid not in self.device_ids:
|
||
|
|
self.device_ids[jid] = device_ids
|
||
|
|
self.xmpp.event('omemo_device_ids', (jid, device_ids))
|
||
|
|
|
||
|
|
# XXX: There should only be one item so this is fine, but slixmpp
|
||
|
|
# loops forever otherwise. ???
|
||
|
|
return
|
||
|
|
|
||
|
|
|
||
|
|
register_plugin(XEP_0384)
|