#
##############################################################################
-#
-# OSV: Objects Services
-#
+#.apidoc title: Objects Services (OSV)
+
+from functools import wraps
+import logging
+from psycopg2 import IntegrityError, errorcodes
import orm
+import openerp
import openerp.netsvc as netsvc
import openerp.pooler as pooler
import openerp.sql_db as sql_db
-import logging
-from psycopg2 import IntegrityError, errorcodes
-from openerp.tools.func import wraps
from openerp.tools.translate import translate
+from openerp.osv.orm import MetaModel, Model, TransientModel, AbstractModel
+import openerp.exceptions
+_logger = logging.getLogger(__name__)
+# Deprecated.
class except_osv(Exception):
- def __init__(self, name, value, exc_type='warning'):
+ def __init__(self, name, value):
self.name = name
- self.exc_type = exc_type
self.value = value
- self.args = (exc_type, name)
+ self.args = (name, value)
+service = None
-class object_proxy(netsvc.Service):
+class object_proxy(object):
def __init__(self):
- self.logger = logging.getLogger('web-services')
- netsvc.Service.__init__(self, 'object_proxy', audience='')
- self.exportMethod(self.exec_workflow)
- self.exportMethod(self.execute)
+ global service
+ service = self
def check(f):
@wraps(f)
# We open a *new* cursor here, one reason is that failed SQL
# queries (as in IntegrityError) will invalidate the current one.
cr = False
-
+
if hasattr(src, '__call__'):
# callable. We need to find the right parameters to call
# the orm._sql_message(self, cr, uid, ids, context) function,
pass
finally:
if cr: cr.close()
-
+
return False # so that the original SQL error will
# be returned, it is the best we have.
raise except_osv('Database not ready', 'Currently, this database is not fully loaded and can not be used.')
return f(self, dbname, *args, **kwargs)
except orm.except_orm, inst:
- if inst.name == 'AccessError':
- self.logger.debug("AccessError", exc_info=True)
- self.abortResponse(1, inst.name, 'warning', inst.value)
- except except_osv, inst:
- self.abortResponse(1, inst.name, inst.exc_type, inst.value)
+ raise except_osv(inst.name, inst.value)
+ except except_osv:
+ raise
except IntegrityError, inst:
osv_pool = pooler.get_pool(dbname)
for key in osv_pool._sql_error.keys():
if key in inst[0]:
- self.abortResponse(1, _('Constraint Error'), 'warning',
+ netsvc.abort_response(1, _('Constraint Error'), 'warning',
tr(osv_pool._sql_error[key], 'sql_constraint') or inst[0])
if inst.pgcode in (errorcodes.NOT_NULL_VIOLATION, errorcodes.FOREIGN_KEY_VIOLATION, errorcodes.RESTRICT_VIOLATION):
msg = _('The operation cannot be completed, probably due to the following:\n- deletion: you may be trying to delete a record while other records still reference it\n- creation/update: a mandatory field is not correctly set')
- self.logger.debug("IntegrityError", exc_info=True)
+ _logger.debug("IntegrityError", exc_info=True)
try:
errortxt = inst.pgerror.replace('«','"').replace('»','"')
if '"public".' in errortxt:
msg += _('\n\n[object with reference: %s - %s]') % (model_name, model)
except Exception:
pass
- self.abortResponse(1, _('Integrity Error'), 'warning', msg)
+ netsvc.abort_response(1, _('Integrity Error'), 'warning', msg)
else:
- self.abortResponse(1, _('Integrity Error'), 'warning', inst[0])
+ netsvc.abort_response(1, _('Integrity Error'), 'warning', inst[0])
except Exception:
- self.logger.exception("Uncaught exception")
+ _logger.exception("Uncaught exception")
raise
return wrapper
raise except_osv('Object Error', 'Object %s doesn\'t exist' % str(obj))
return getattr(object, method)(cr, uid, *args, **kw)
+ def execute_kw(self, db, uid, obj, method, args, kw=None):
+ return self.execute(db, uid, obj, method, *args, **kw or {})
+
@check
def execute(self, db, uid, obj, method, *args, **kw):
cr = pooler.get_db(db).cursor()
raise except_osv('Access Denied', 'Private methods (such as %s) cannot be called remotely.' % (method,))
res = self.execute_cr(cr, uid, obj, method, *args, **kw)
if res is None:
- self.logger.warning('The method %s of the object %s can not return `None` !', method, obj)
+ _logger.warning('The method %s of the object %s can not return `None` !', method, obj)
cr.commit()
except Exception:
cr.rollback()
cr.close()
return res
-
-class osv_memory(orm.orm_memory):
- """ Deprecated class. """
- pass
-
-
-class osv(orm.orm):
- """ Deprecated class. """
- pass
+# deprecated - for backward compatibility.
+osv = Model
+osv_memory = TransientModel
+osv_abstract = AbstractModel # ;-)
def start_object_proxy():