1 #----------------------------------------------------------
2 # ir_http modular http routing
3 #----------------------------------------------------------
8 import werkzeug.exceptions
9 import werkzeug.routing
12 from openerp import http
13 from openerp.http import request
14 from openerp.osv import osv, orm
16 _logger = logging.getLogger(__name__)
19 # FIXME: replace by proxy on request.uid?
22 class ModelConverter(werkzeug.routing.BaseConverter):
24 def __init__(self, url_map, model=False):
25 super(ModelConverter, self).__init__(url_map)
27 self.regex = '([0-9]+)'
29 def to_python(self, value):
30 m = re.match(self.regex, value)
31 return request.registry[self.model].browse(
32 request.cr, _uid, int(m.group(1)), context=request.context)
34 def to_url(self, value):
37 class ModelsConverter(werkzeug.routing.BaseConverter):
39 def __init__(self, url_map, model=False):
40 super(ModelsConverter, self).__init__(url_map)
42 # TODO add support for slug in the form [A-Za-z0-9-] bla-bla-89 -> id 89
43 self.regex = '([0-9,]+)'
45 def to_python(self, value):
47 # - raise routing.ValidationError() if no browse record can be createdm
49 return request.registry[self.model].browse(request.cr, _uid, [int(i) for i in value.split(',')], context=request.context)
51 def to_url(self, value):
52 return ",".join(i.id for i in value)
54 class ir_http(osv.AbstractModel):
56 _description = "HTTP routing"
58 def _get_converters(self):
59 return {'model': ModelConverter, 'models': ModelsConverter}
61 def _find_handler(self):
62 return self.routing_map().bind_to_environ(request.httprequest.environ).match()
64 def _auth_method_user(self):
65 request.uid = request.session.uid
67 raise http.SessionExpiredException("Session expired")
69 def _auth_method_admin(self):
71 raise http.SessionExpiredException("No valid database for request %s" % request.httprequest)
72 request.uid = openerp.SUPERUSER_ID
74 def _auth_method_none(self):
75 request.disable_db = True
78 def _authenticate(self, auth_method='user'):
79 if request.session.uid:
81 request.session.check_security()
82 # what if error in security.check()
83 # -> res_users.check()
84 # -> res_users.check_credentials()
85 except http.SessionExpiredException:
86 request.session.logout()
87 raise http.SessionExpiredException("Session expired for request %s" % request.httprequest)
88 getattr(self, "_auth_method_%s" % auth_method)()
91 def _handle_exception(self, exception):
92 if isinstance(exception, openerp.exceptions.AccessError):
95 code = getattr(exception, 'code', 500)
97 fn = getattr(self, '_handle_%d' % code, self._handle_unknown_exception)
100 def _handle_unknown_exception(self, exception):
104 # locate the controller method
106 func, arguments = self._find_handler()
107 except werkzeug.exceptions.NotFound, e:
108 return self._handle_exception(e)
110 # check authentication level
112 auth_method = self._authenticate(getattr(func, "auth", None))
114 # force a Forbidden exception with the original traceback
115 return self._handle_exception(
116 convert_exception_to(
117 werkzeug.exceptions.Forbidden))
119 # post process arg to set uid on browse records
120 for arg in arguments.itervalues():
121 if isinstance(arg, orm.browse_record) and arg._uid is _uid:
122 arg._uid = request.uid
124 # set and execute handler
126 request.set_handler(func, arguments, auth_method)
127 result = request.dispatch()
128 if isinstance(result, Exception):
131 return self._handle_exception(e)
135 def routing_map(self):
136 if not hasattr(self, '_routing_map'):
137 _logger.info("Generating routing map")
139 m = request.registry.get('ir.module.module')
140 ids = m.search(cr, openerp.SUPERUSER_ID, [('state', '=', 'installed'), ('name', '!=', 'web')], context=request.context)
141 installed = set(x['name'] for x in m.read(cr, 1, ids, ['name'], context=request.context))
142 mods = ['', "web"] + sorted(installed)
143 self._routing_map = http.routing_map(mods, False, converters=self._get_converters())
145 return self._routing_map
147 def convert_exception_to(to_type, with_message=False):
148 """ Should only be called from an exception handler. Fetches the current
149 exception data from sys.exc_info() and creates a new exception of type
150 ``to_type`` with the original traceback.
152 If ``with_message`` is ``True``, sets the new exception's message to be
153 the stringification of the original exception. If ``False``, does not
154 set the new exception's message. Otherwise, uses ``with_message`` as the
155 new exception's message.
157 :type with_message: str|bool
159 etype, original, tb = sys.exc_info()
161 if with_message is False:
163 elif with_message is True:
164 message = str(original)
166 message = str(with_message)
168 raise to_type, message, tb