Dateien nach „slixmpp/plugins/xep_0339“ hochladen

slixmpp/plugins/xep_0339/__init__.py

@@ -0,0 +1,9 @@
+# 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_0339.source import XEP_0339
+
+register_plugin(XEP_0339)

slixmpp/plugins/xep_0339/source.py

@@ -0,0 +1,72 @@
+# Copyright (C) 2020 Emmanuel Gil Peyrot
+# This file is part of slixmpp.
+# See the file LICENSE for copying permission.
+
+import logging
+
+
+from slixmpp import Iq
+from slixmpp.plugins import BasePlugin
+from slixmpp.xmlstream import register_stanza_plugin
+from slixmpp.plugins.xep_0166 import Jingle, Content
+from slixmpp.plugins.xep_0167 import Description
+from slixmpp.plugins.xep_0339.stanza import SourceGroup, Source, Parameter
+
+import re
+
+log = logging.getLogger(__name__)
+
+
+class XEP_0339(BasePlugin):
+
+    name = 'xep_0339'
+    description = 'XEP-0339: Jingle'
+    dependencies = set(['xep_0166','xep_0167'])
+#    stanza = stanza
+
+    def plugin_init(self):
+        register_stanza_plugin(Iq,Jingle)
+        register_stanza_plugin(Jingle,Content,True)
+        register_stanza_plugin(Content,Description)
+        register_stanza_plugin(Description,SourceGroup)
+        register_stanza_plugin(Description,Source,True)
+        register_stanza_plugin(SourceGroup,Source,True)
+        register_stanza_plugin(Source,Parameter,True)
+
+    def make_ssrcgroup(self, sdp):
+        m = re.search(r'^a=ssrc-group:FID ([^\r]+)\r$',sdp,re.M)
+        if m:
+            ssrcgroup = SourceGroup()
+            ssrcgroup['semantics'] = 'FID'
+            ssrcs =m.group(1).split(' ')
+            sources = []
+            for ssrc_id in ssrcs:
+                source = Source()
+                source['ssrc'] = ssrc_id
+                ssrcgroup.append(source)
+                sources.append(self.make_source(sdp, ssrc_id))
+#                ssrcgroup.append(self.make_source(sdp, ssrc_id))
+            return (ssrcgroup, sources)
+        return None
+
+    def make_source(self, sdp, id = None):
+        if id is None:
+            m = re.search(r'^a=ssrc:(\S+)',sdp,re.M)
+            if m is None:
+               return None 
+            id = m.group(1)
+        iter = re.finditer(r'^a=ssrc:'+id+' ([^\r]+)\r$',sdp,re.M)
+        if iter:
+            source = Source()
+            source['ssrc'] = id
+            for p in iter:
+                parameter = Parameter()
+                s = p.group(1).split(':')
+                if len(s)>1:
+                    parameter['name'] = s[0]
+                    parameter['value'] = s[1]
+                else:
+                    parameter['name'] = s[0]
+                source.append(parameter)
+            return source
+        return None

slixmpp/plugins/xep_0339/stanza.py

@@ -0,0 +1,47 @@
+# 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.xmlstream import ElementBase
+
+class SourceGroup(ElementBase):
+    name = 'ssrc-group'
+    namespace = 'urn:xmpp:jingle:apps:rtp:ssma:0'
+    plugin_attrib = 'ssrc-group'
+    interfaces = {'semantics'}
+
+    def getSDP(self):
+        ret = ''
+        for source in self['sources']:
+            ret += ' '+source['ssrc']
+        if ret!='':
+            ret = "\r\na=ssrc-group:FID" + ret
+        return ret
+
+class Source(ElementBase):
+    name = 'source'
+    namespace = 'urn:xmpp:jingle:apps:rtp:ssma:0'
+    plugin_attrib = 'source'
+    interfaces = {'ssrc'}
+    plugin_multi_attrib = 'sources'
+
+    def getSDP(self):
+        ret = ''
+        for parameter in self['parameters']:
+            ret += "\r\na=ssrc:%s %s" % (self['ssrc'],parameter.getSDP())
+        return ret
+
+class Parameter(ElementBase):
+    name = 'parameter'
+    namespace = 'urn:xmpp:jingle:apps:rtp:ssma:0'
+    plugin_attrib = 'parameter'
+    plugin_multi_attrib = 'parameters'
+    interfaces = {'name','value'}
+    plugin_multi_attrib = 'parameters'
+
+    def getSDP(self):
+        parameter = self['name']
+        if self['value']:
+            parameter += ":"+self['value']
+        return parameter