Dateien nach „slixmpp/plugins/xep_0177“ hochladen

slixmpp/plugins/xep_0177/__init__.py

@@ -0,0 +1,11 @@
+# slixmpp: The Slick XMPP Library
+# Copyright (C) 2020 Emmanuel Gil Peyrot
+# This file is part of slixmpp.
+# See the file LICENSE for copying permission.
+
+from slixmpp.plugins.base import register_plugin
+
+from slixmpp.plugins.xep_0177.stanza import Transport, Candidate
+from slixmpp.plugins.xep_0177.transport import XEP_0177
+
+register_plugin(XEP_0177)

slixmpp/plugins/xep_0177/stanza.py

@@ -0,0 +1,28 @@
+# slixmpp: The Slick XMPP Library
+# Copyright (C) 2020 Emmanuel Gil Peyrot
+# This file is part of slixmpp.
+# See the file LICENSE for copying permission.
+
+from typing import Iterable, List, Tuple, Optional
+from slixmpp.xmlstream import ElementBase, ET
+
+import re
+
+class Transport(ElementBase):
+    name = 'transport'
+    namespace = 'urn:xmpp:jingle:transports:raw-udp:1'
+    plugin_attrib = 'raw-transport'
+    interfaces = {}
+
+    def getSDP(self):
+        return self['candidate'].getSDP()
+
+class Candidate(ElementBase):
+    name = 'candidate'
+    namespace = 'urn:xmpp:jingle:transports:raw-udp:1'
+    plugin_attrib = 'candidate'
+    interfaces = {'component','generation','id','ip','port','type'}
+    plugin_multi_attrib = 'candidates'
+
+    def getSDP(self):
+        return '\r\nc=IN IP4 '+self['ip']

slixmpp/plugins/xep_0177/transport.py

@@ -0,0 +1,84 @@
+# slixmpp: The Slick XMPP Library
+# Copyright (C) 2020 Emmanuel Gil Peyrot
+# This file is part of slixmpp.
+# See the file LICENSE for copying permission.
+
+import logging
+
+from typing import Iterable, Tuple, Optional
+
+from slixmpp import JID, Iq
+from slixmpp.plugins import BasePlugin
+from slixmpp.xmlstream import register_stanza_plugin
+from slixmpp.xmlstream.handler import Callback
+from slixmpp.xmlstream.matcher import StanzaPath
+from slixmpp.plugins.xep_0166 import Jingle, Content
+from slixmpp.plugins.xep_0177 import stanza, Transport, Candidate
+
+import re
+
+log = logging.getLogger(__name__)
+
+class XEP_0177(BasePlugin):
+
+    name = 'xep_0177'
+    description = 'XEP-0177: Raw-Udp Transport'
+    dependencies = set(['xep_0166'])
+    stanza = stanza
+
+    def plugin_init(self):
+        register_stanza_plugin(Iq,Jingle)
+        register_stanza_plugin(Jingle,Content,True)
+        register_stanza_plugin(Content,Transport)
+        register_stanza_plugin(Transport,Candidate,True)
+
+        self.xmpp.register_handler(
+            Callback('Rtp Jingle Raw-Udp Transport',
+                StanzaPath('iq/jingle/content/transport'),
+                self._handle_content_transport))
+
+#    def session_bind(self, jid):
+#        pass
+
+#    def plugin_end(self):
+#        pass
+
+
+#######################################################################
+
+    def _handle_content_transport(self, message):
+        self.xmpp.event('jingle_content_transport', message['jingle']['content']['transport'])
+
+    def make_transport(self,sdp):
+        m = re.search(r'^m=\S+ +(\S+)',sdp,re.M)
+        if m is None or m.group(1)=='0':
+            return None
+        transport = Transport()
+        port = m.group(1)
+        m = re.search(r'^c=IN +IP4 +(\S+)',sdp,re.M)
+        if m:
+            candidate = Candidate()
+            candidate['generation'] = '0'
+            candidate['id'] = 'a9j3mnbtu1' # just an identifier without use
+            candidate['ip'] = m.group(1)
+            candidate['port'] = port
+            transport.append(candidate)
+        else:
+# das ist noch syntatisch falsch
+            iter= re.finditer(r'^a=candidate:(\S+) +(\d+) +(\S+) +(\d+) +(\S+) +(\d+) +typ +(\S+)(?: +(raddr) +(\S+) +(rport)+(\d+))?(?: +(tcptype) +(\S+))?(?: +(generation) +(\d+))?(?: +(network-id) +(\d+))?(?: +(network-cost) +(\d+))?\r$',sdp,re.M)
+            if iter:
+                for m in iter:
+                    # required 'foundation', 'component', 'transport', 'priority', 'ip', 'port', 'type'
+                    # optional 'raddr', 'rport', 'tcptype', 'generation', 'network-id', 'network-cost'
+                    candidate = Candidate()
+                    candidate['foundation'] = m.group(1)
+                    candidate['id'] = m.group(2)
+                    candidate['protocol'] = m.group(3)
+                    candidate['priority'] = m.group(4)
+                    candidate['ip'] = m.group(5)
+                    candidate['port'] = m.group(6)
+                    candidate['type'] = m.group(7)
+                    for n,v in zip(*[m.groups()[7:][i::2] for i in range(2)]):
+                        candidate[n] = v
+                    transport.append(candidate)
+        return transport