source: ralphm-patches/component_server.patch @ 34:e46c5701df9e

new file twisted/plugins/server.py

@@ +1 @@
+# Copyright (c) 2003-2009 Ralph Meijer
+# See LICENSE for details.
+
+from twisted.application.service import ServiceMaker
+
+WokkelXMPPComponentServer = ServiceMaker(
+    "XMPP Component Server",
+    "wokkel.componentservertap",
+    "An XMPP Router server",
+    "wokkel-component-server")

new file wokkel/componentservertap.py

@@ +1 @@
+from twisted.application import service, strports
+from twisted.python import usage
+from twisted.words.protocols.jabber import component
+from wokkel import server
+
+class Options(usage.Options):
+
+    optParameters = [
+            ('component-port', None, 'tcp:5347:interface=127.0.0.1',
+                'Port components connect to'),
+            ('component-secret', None, 'secret',
+                'Secret components use to connect'),
+            ('server-port', None, '5269',
+                'Port other servers connect to'),
+            ('server-secret', None, 'secret',
+                'Shared secret for dialback verification'),
+    ]
+
+    optFlags = [
+            ('verbose', 'v', 'Log traffic'),
+    ]
+
+    def __init__(self):
+        usage.Options.__init__(self)
+        self['domains'] = []
+
+    def opt_domain(self, domain):
+        self['domains'].append(domain)
+
+    def postOptions(self):
+        if not self['domains']:
+            raise usage.UsageError('Need at least one domain')
+
+
+
+def makeService(config):
+    s = service.MultiService()
+
+    router = component.Router()
+
+    # Set up the XMPP server service
+
+    serverService = server.ServerService(router, secret=config['server-secret'])
+    serverService.domains = config['domains']
+    serverService.logTraffic = config['verbose']
+
+    # Hook up XMPP server-to-server service
+    s2sFactory = server.XMPPS2SServerFactory(serverService)
+    s2sFactory.logTraffic = config['verbose']
+    s2sService = strports.service(config['server-port'], s2sFactory)
+    s2sService.setServiceParent(s)
+
+    # Hook up XMPP external server-side component service
+    cFactory = component.XMPPComponentServerFactory(router,
+                                                    config['component-secret'])
+
+    cFactory.logTraffic = config['verbose']
+    cServer = strports.service(config['component-port'], cFactory)
+    cServer.setServiceParent(s)
+
+    return s