##// END OF EJS Templates
dependencies: bumped some not pinned libraries...
dependencies: bumped some not pinned libraries - beautifulsoup4 to 4.6.1 - more-itertools to 4.3.0

File last commit:

r2875:dd2ef754 default
r2919:342e4af9 default
Show More
subscribers.py
43 lines | 1.6 KiB | text/x-python | PythonLexer
events: add event to catch permission changed so we can flush affected users permission caches
r2849 # -*- coding: utf-8 -*-
# Copyright (C) 2016-2018 RhodeCode GmbH
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License, version 3
# (only), as published by the Free Software Foundation.
#
# 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 Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#
# This program is dual-licensed. If you wish to learn more about the
# RhodeCode Enterprise Edition, including its added features, Support services,
# and proprietary license terms, please see https://rhodecode.com/licenses/
import logging
from rhodecode import events
caches: flush the caches on permission changes for affected users.
r2850 from rhodecode.lib import rc_cache
events: add event to catch permission changed so we can flush affected users permission caches
r2849
log = logging.getLogger(__name__)
def trigger_user_permission_flush(event):
"""
permissions: flush cache when creating a new fork.
r2874 Subscriber to the `UserPermissionsChange`. This triggers the
events: add event to catch permission changed so we can flush affected users permission caches
r2849 automatic flush of permission caches, so the users affected receive new permissions
Right Away
"""
events: UserPermissionsChanged should not flush duplicates
r2875 affected_user_ids = set(event.user_ids)
caches: flush the caches on permission changes for affected users.
r2850 for user_id in affected_user_ids:
cache_namespace_uid = 'cache_user_auth.{}'.format(user_id)
del_keys = rc_cache.clear_cache_namespace('cache_perms', cache_namespace_uid)
log.debug('Deleted %s cache keys for user_id: %s', del_keys, user_id)
events: add event to catch permission changed so we can flush affected users permission caches
r2849
def includeme(config):
config.add_subscriber(trigger_user_permission_flush, events.UserPermissionsChange)