modularized remote backends

1 files changed, 41 insertions, 0 deletions

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 <http://www.gnu.org/licenses/>.
+
+    @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()