[rset] Use RQL cache in syntax_tree method
This avoid several unnecessary parsings per HTTP request, since in most case
rset's rql is in the rql cache (since it has just been executed), while yapps
based parsing is known to be slow.
# copyright 2003-2016 LOGILAB S.A. (Paris, FRANCE), all rights reserved.
# contact http://www.logilab.fr/ -- mailto:contact@logilab.fr
#
# This file is part of CubicWeb.
#
# CubicWeb is free software: you can redistribute it and/or modify it under the
# terms of the GNU Lesser General Public License as published by the Free
# Software Foundation, either version 2.1 of the License, or (at your option)
# any later version.
#
# CubicWeb 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 Lesser General Public License for more
# details.
#
# You should have received a copy of the GNU Lesser General Public License along
# with CubicWeb. If not, see <http://www.gnu.org/licenses/>.
"""Core hooks: set generic metadata"""
from datetime import datetime
from pytz import utc
from cubicweb.predicates import is_instance
from cubicweb.server import hook
class MetaDataHook(hook.Hook):
__abstract__ = True
category = 'metadata'
class InitMetaAttrsHook(MetaDataHook):
"""before create a new entity -> set creation and modification date
this is a conveniency hook, you shouldn't have to disable it
"""
__regid__ = 'metaattrsinit'
events = ('before_add_entity',)
def __call__(self):
timestamp = datetime.now(utc)
edited = self.entity.cw_edited
if not edited.get('creation_date'):
edited['creation_date'] = timestamp
if not edited.get('modification_date'):
edited['modification_date'] = timestamp
if not self._cw.transaction_data.get('do-not-insert-cwuri'):
cwuri = u'%s%s' % (self._cw.base_url(), self.entity.eid)
edited.setdefault('cwuri', cwuri)
class UpdateMetaAttrsHook(MetaDataHook):
"""update an entity -> set modification date"""
__regid__ = 'metaattrsupdate'
events = ('before_update_entity',)
def __call__(self):
# repairing is true during c-c upgrade/shell and similar commands. We
# usually don't want to update modification date in such cases.
#
# XXX to be really clean, we should turn off modification_date update
# explicitly on each command where we do not want that behaviour.
if not self._cw.vreg.config.repairing:
self.entity.cw_edited.setdefault('modification_date', datetime.now(utc))
class SetCreatorOp(hook.DataOperationMixIn, hook.Operation):
def precommit_event(self):
cnx = self.cnx
relations = [(eid, cnx.user.eid) for eid in self.get_data()
# don't consider entities that have been created and deleted in
# the same transaction, nor ones where created_by has been
# explicitly set
if not cnx.deleted_in_transaction(eid) and \
not cnx.entity_from_eid(eid).created_by]
cnx.add_relations([('created_by', relations)])
class SetOwnershipHook(MetaDataHook):
"""create a new entity -> set owner and creator metadata"""
__regid__ = 'setowner'
events = ('after_add_entity',)
def __call__(self):
if not self._cw.is_internal_session:
self._cw.add_relation(self.entity.eid, 'owned_by', self._cw.user.eid)
SetCreatorOp.get_instance(self._cw).add_data(self.entity.eid)
class SyncOwnersOp(hook.DataOperationMixIn, hook.Operation):
def precommit_event(self):
for compositeeid, composedeid in self.get_data():
if self.cnx.deleted_in_transaction(compositeeid):
continue
if self.cnx.deleted_in_transaction(composedeid):
continue
self.cnx.execute('SET X owned_by U WHERE C owned_by U, C eid %(c)s,'
'NOT EXISTS(X owned_by U, X eid %(x)s)',
{'c': compositeeid, 'x': composedeid})
class SyncCompositeOwner(MetaDataHook):
"""when adding composite relation, the composed should have the same owners
has the composite
"""
__regid__ = 'synccompositeowner'
events = ('after_add_relation',)
def __call__(self):
if self.rtype == 'wf_info_for':
# skip this special composite relation # XXX (syt) why?
return
eidfrom, eidto = self.eidfrom, self.eidto
composite = self._cw.rtype_eids_rdef(self.rtype, eidfrom, eidto).composite
if composite == 'subject':
SyncOwnersOp.get_instance(self._cw).add_data( (eidfrom, eidto) )
elif composite == 'object':
SyncOwnersOp.get_instance(self._cw).add_data( (eidto, eidfrom) )
class FixUserOwnershipHook(MetaDataHook):
"""when a user has been created, add owned_by relation on itself"""
__regid__ = 'fixuserowner'
__select__ = MetaDataHook.__select__ & is_instance('CWUser')
events = ('after_add_entity',)
def __call__(self):
self._cw.add_relation(self.entity.eid, 'owned_by', self.entity.eid)
class UpdateFTIHook(MetaDataHook):
"""sync fulltext index text index container when a relation with
fulltext_container set is added / removed
"""
__regid__ = 'updateftirel'
events = ('after_add_relation', 'after_delete_relation')
def __call__(self):
rtype = self.rtype
cnx = self._cw
ftcontainer = cnx.vreg.schema.rschema(rtype).fulltext_container
if ftcontainer == 'subject':
cnx.repo.system_source.index_entity(
cnx, cnx.entity_from_eid(self.eidfrom))
elif ftcontainer == 'object':
cnx.repo.system_source.index_entity(
cnx, cnx.entity_from_eid(self.eidto))