From f3296c034427447b72c3d842bb2ff4b3f716200a Mon Sep 17 00:00:00 2001 From: mkaay Date: Wed, 26 Jan 2011 15:02:14 +0100 Subject: modularized remote backends --- module/remote/XMLRPCBackend.py | 41 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100644 module/remote/XMLRPCBackend.py (limited to 'module/remote/XMLRPCBackend.py') diff --git a/module/remote/XMLRPCBackend.py b/module/remote/XMLRPCBackend.py new file mode 100644 index 000000000..6a7f9f96e --- /dev/null +++ b/module/remote/XMLRPCBackend.py @@ -0,0 +1,41 @@ +# -*- coding: utf-8 -*- +""" + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 3 of the License, + or (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. + See the GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, see . + + @author: mkaay, RaNaN +""" + +import module.lib.SecureXMLRPCServer as Server +from module.remote.RemoteManager import BackendBase + +from traceback import print_exc + +class XMLRPCBackend(BackendBase): + def setup(self): + server_addr = (self.core.config['remote']['listenaddr'], int(self.core.config['remote']['port'])) + usermap = {self.core.config.username: self.core.config.password} + if self.core.config['ssl']['activated']: + if exists(self.core.config['ssl']['cert']) and exists(self.core.config['ssl']['key']): + self.server = Server.SecureXMLRPCServer(server_addr, self.core.config['ssl']['cert'], + self.core.config['ssl']['key'], usermap) + else: + self.core.log.warning(_("SSL Certificates not found, fallback to auth XMLRPC server")) + self.server = Server.AuthXMLRPCServer(server_addr, usermap) + else: + self.server = Server.AuthXMLRPCServer(server_addr, usermap) + + self.server.register_instance(self.core.server_methods) + + def serve(self): + self.server.serve_forever() -- cgit v1.2.3