| author | Sandro Knauß <knauss@netzguerilla.net> |
| Fri, 10 Aug 2012 14:42:26 +0200 | |
| branch | devel |
| changeset 291 | 84eb5a7a715a |
| parent 265 | f6c906b40cce |
| child 294 | 0e75bd39767d |
| permissions | -rw-r--r-- |
| 92 | 1 |
# -*- coding: utf-8 -*- |
|
112
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
2 |
from twisted.web import soap, xmlrpc |
| 92 | 3 |
|
|
93
ee10253258ad
now right relative imports
Sandro Knauß <knauss@netzguerilla.net>
parents:
92
diff
changeset
|
4 |
from ..controller.viewinterface import Interface |
| 92 | 5 |
|
|
110
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
6 |
from ..error import InterfaceException, ValidateException |
| 92 | 7 |
|
8 |
class TwistedInterface(Interface): |
|
|
265
f6c906b40cce
iro.view: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
200
diff
changeset
|
9 |
"""Class that addes needed function for XML-RPC/SOAP""" |
| 92 | 10 |
def __init__(self): |
11 |
Interface.__init__(self) |
|
12 |
||
13 |
def listMethods(self): |
|
14 |
"""Since we override lookupProcedure, its suggested to override |
|
15 |
listProcedures too. |
|
16 |
""" |
|
17 |
return self.listProcedures() |
|
18 |
||
19 |
||
20 |
def listProcedures(self): |
|
|
265
f6c906b40cce
iro.view: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
200
diff
changeset
|
21 |
"""returns a list of all functions that are allowed to call via XML-RPC.""" |
|
200
01c34f22be42
deleting stop function from iro.controller.viewinterface
Sandro Knauß <knauss@netzguerilla.net>
parents:
127
diff
changeset
|
22 |
return ['listMethods','status','sms','fax','mail','routes','defaultRoute','bill','telnumber','email'] |
| 92 | 23 |
|
24 |
||
25 |
class XMLRPCInterface(TwistedInterface,xmlrpc.XMLRPC): |
|
|
265
f6c906b40cce
iro.view: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
200
diff
changeset
|
26 |
"""XML-RPC interface""" |
| 92 | 27 |
def __init__(self): |
28 |
xmlrpc.XMLRPC.__init__(self) |
|
29 |
TwistedInterface.__init__(self) |
|
30 |
||
31 |
def lookupProcedure(self, procedurePath): |
|
32 |
if procedurePath not in self.listProcedures(): |
|
33 |
raise xmlrpc.NoSuchFunction(self.NOT_FOUND, |
|
34 |
"procedure %s not found" % procedurePath) |
|
35 |
try: |
|
36 |
return getattr(self,procedurePath) |
|
37 |
except KeyError: |
|
38 |
raise xmlrpc.NoSuchFunction(self.NOT_FOUND, |
|
39 |
"procedure %s not found" % procedurePath) |
|
40 |
||
|
110
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
41 |
def _ebRender(self, failure): |
|
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
42 |
if isinstance(failure.value, InterfaceException): |
|
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
43 |
return xmlrpc.Fault(failure.value.code, failure.value.msg) |
|
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
44 |
if isinstance(failure.value, ValidateException): |
|
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
45 |
return xmlrpc.Fault(failure.value.code, failure.value.msg) |
|
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
46 |
return xmlrpc.XMLRPC._ebRender(self, failure) |
|
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
47 |
|
|
601fc908d9f1
exception handling for xmprpc
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
48 |
|
| 92 | 49 |
class SOAPInterface(TwistedInterface,soap.SOAPPublisher): |
|
265
f6c906b40cce
iro.view: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
200
diff
changeset
|
50 |
"""SOAP interface""" |
| 92 | 51 |
def __init__(self): |
52 |
soap.SOAPPublisher.__init__(self) |
|
53 |
TwistedInterface.__init__(self) |
|
54 |
||
55 |
def lookupFunction(self, functionName): |
|
56 |
if functionName in self.listProcedures(): |
|
57 |
function = getattr(self, functionName, None) |
|
58 |
if function: |
|
59 |
return function, getattr(function, "useKeywords", False) |
|
60 |
return None |
|
61 |
else: |
|
62 |
return None |
|
63 |
||
|
112
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
64 |
def appendResource(root): |
|
265
f6c906b40cce
iro.view: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
200
diff
changeset
|
65 |
"""adding XML-RPC and SOAP to root.""" |
| 92 | 66 |
root.putChild('RPC2', XMLRPCInterface()) |
67 |
root.putChild('SOAP', SOAPInterface()) |
|
68 |
return root |
|
69 |
||
|
112
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
70 |
if __name__ == '__main__': |
|
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
71 |
from twisted.web import resource, server |
|
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
72 |
from twisted.internet import reactor |
|
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
73 |
|
|
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
74 |
root = resource.Resource() |
|
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
75 |
root = appendResource(root) |
|
ea437d1e7b65
reactor is now started my iro.main
Sandro Knauß <knauss@netzguerilla.net>
parents:
110
diff
changeset
|
76 |
reactor.listenTCP(7080, server.Site(root)) |
| 92 | 77 |
reactor.run() |