Show More
repo_caches.py
87 lines
| 3.2 KiB
| text/x-python
|
PythonLexer
r1722 | # -*- coding: utf-8 -*- | ||
r2487 | # Copyright (C) 2011-2018 RhodeCode GmbH | ||
r1722 | # | ||
# 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/ | |||
r2687 | import os | ||
r1722 | import logging | ||
from pyramid.httpexceptions import HTTPFound | |||
from pyramid.view import view_config | |||
from rhodecode.apps._base import RepoAppView | |||
r2080 | from rhodecode.lib.auth import ( | ||
LoginRequired, HasRepoPermissionAnyDecorator, CSRFRequired) | |||
r2846 | from rhodecode.lib import helpers as h, rc_cache | ||
r2687 | from rhodecode.lib import system_info | ||
r1722 | from rhodecode.model.meta import Session | ||
from rhodecode.model.scm import ScmModel | |||
log = logging.getLogger(__name__) | |||
class RepoCachesView(RepoAppView): | |||
def load_default_context(self): | |||
c = self._get_local_tmpl_context() | |||
return c | |||
@LoginRequired() | |||
@HasRepoPermissionAnyDecorator('repository.admin') | |||
@view_config( | |||
route_name='edit_repo_caches', request_method='GET', | |||
renderer='rhodecode:templates/admin/repos/repo_edit.mako') | |||
def repo_caches(self): | |||
c = self.load_default_context() | |||
c.active = 'caches' | |||
r2687 | cached_diffs_dir = c.rhodecode_db_repo.cached_diffs_dir | ||
c.cached_diff_count = len(c.rhodecode_db_repo.cached_diffs()) | |||
c.cached_diff_size = 0 | |||
if os.path.isdir(cached_diffs_dir): | |||
c.cached_diff_size = system_info.get_storage_size(cached_diffs_dir) | |||
r2811 | c.shadow_repos = c.rhodecode_db_repo.shadow_repos() | ||
r2846 | |||
cache_namespace_uid = 'cache_repo.{}'.format(self.db_repo.repo_id) | |||
c.region = rc_cache.get_or_create_region('cache_repo', cache_namespace_uid) | |||
c.backend = c.region.backend | |||
c.repo_keys = sorted(c.region.backend.list_keys(prefix=cache_namespace_uid)) | |||
r1722 | return self._get_template_context(c) | ||
@LoginRequired() | |||
@HasRepoPermissionAnyDecorator('repository.admin') | |||
r1811 | @CSRFRequired() | ||
r1722 | @view_config( | ||
route_name='edit_repo_caches', request_method='POST') | |||
def repo_caches_purge(self): | |||
_ = self.request.translate | |||
c = self.load_default_context() | |||
c.active = 'caches' | |||
try: | |||
ScmModel().mark_for_invalidation(self.db_repo_name, delete=True) | |||
r2846 | |||
r1722 | Session().commit() | ||
r2846 | |||
r1722 | h.flash(_('Cache invalidation successful'), | ||
category='success') | |||
except Exception: | |||
log.exception("Exception during cache invalidation") | |||
h.flash(_('An error occurred during cache invalidation'), | |||
category='error') | |||
raise HTTPFound(h.route_path( | |||
'edit_repo_caches', repo_name=self.db_repo_name)) |