Show More
repositories.py
184 lines
| 7.1 KiB
| text/x-python
|
PythonLexer
r2014 | # -*- coding: utf-8 -*- | |||
r2487 | # Copyright (C) 2016-2018 RhodeCode GmbH | |||
r2014 | # | |||
# 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 | ||||
import formencode | ||||
r2079 | import formencode.htmlfill | |||
r2014 | ||||
from pyramid.httpexceptions import HTTPFound, HTTPForbidden | ||||
from pyramid.view import view_config | ||||
from pyramid.renderers import render | ||||
from pyramid.response import Response | ||||
r2852 | from rhodecode import events | |||
r2014 | from rhodecode.apps._base import BaseAppView, DataGridAppView | |||
r2359 | from rhodecode.lib.celerylib.utils import get_task_id | |||
r2014 | ||||
from rhodecode.lib.ext_json import json | ||||
from rhodecode.lib.auth import ( | ||||
LoginRequired, CSRFRequired, NotAnonymous, | ||||
HasPermissionAny, HasRepoGroupPermissionAny) | ||||
from rhodecode.lib import helpers as h | ||||
from rhodecode.lib.utils import repo_name_slug | ||||
from rhodecode.lib.utils2 import safe_int, safe_unicode | ||||
from rhodecode.model.forms import RepoForm | ||||
from rhodecode.model.repo import RepoModel | ||||
from rhodecode.model.scm import RepoList, RepoGroupList, ScmModel | ||||
from rhodecode.model.settings import SettingsModel | ||||
from rhodecode.model.db import Repository, RepoGroup | ||||
log = logging.getLogger(__name__) | ||||
class AdminReposView(BaseAppView, DataGridAppView): | ||||
def load_default_context(self): | ||||
c = self._get_local_tmpl_context() | ||||
r2351 | ||||
r2014 | return c | |||
def _load_form_data(self, c): | ||||
acl_groups = RepoGroupList(RepoGroup.query().all(), | ||||
perm_set=['group.write', 'group.admin']) | ||||
c.repo_groups = RepoGroup.groups_choices(groups=acl_groups) | ||||
c.repo_groups_choices = map(lambda k: safe_unicode(k[0]), c.repo_groups) | ||||
c.landing_revs_choices, c.landing_revs = \ | ||||
r2358 | ScmModel().get_repo_landing_revs(self.request.translate) | |||
r2014 | c.personal_repo_group = self._rhodecode_user.personal_repo_group | |||
@LoginRequired() | ||||
@NotAnonymous() | ||||
r2172 | # perms check inside | |||
r2014 | @view_config( | |||
route_name='repos', request_method='GET', | ||||
renderer='rhodecode:templates/admin/repos/repos.mako') | ||||
def repository_list(self): | ||||
c = self.load_default_context() | ||||
repo_list = Repository.get_all_repos() | ||||
c.repo_list = RepoList(repo_list, perm_set=['repository.admin']) | ||||
repos_data = RepoModel().get_repos_as_dict( | ||||
repo_list=c.repo_list, admin=True, super_user_actions=True) | ||||
# json used to render the grid | ||||
c.data = json.dumps(repos_data) | ||||
return self._get_template_context(c) | ||||
@LoginRequired() | ||||
@NotAnonymous() | ||||
# perms check inside | ||||
@view_config( | ||||
route_name='repo_new', request_method='GET', | ||||
renderer='rhodecode:templates/admin/repos/repo_add.mako') | ||||
def repository_new(self): | ||||
c = self.load_default_context() | ||||
new_repo = self.request.GET.get('repo', '') | ||||
parent_group = safe_int(self.request.GET.get('parent_group')) | ||||
_gr = RepoGroup.get(parent_group) | ||||
if not HasPermissionAny('hg.admin', 'hg.create.repository')(): | ||||
# you're not super admin nor have global create permissions, | ||||
# but maybe you have at least write permission to a parent group ? | ||||
gr_name = _gr.group_name if _gr else None | ||||
# create repositories with write permission on group is set to true | ||||
create_on_write = HasPermissionAny('hg.create.write_on_repogroup.true')() | ||||
group_admin = HasRepoGroupPermissionAny('group.admin')(group_name=gr_name) | ||||
group_write = HasRepoGroupPermissionAny('group.write')(group_name=gr_name) | ||||
if not (group_admin or (group_write and create_on_write)): | ||||
raise HTTPForbidden() | ||||
self._load_form_data(c) | ||||
c.new_repo = repo_name_slug(new_repo) | ||||
# apply the defaults from defaults page | ||||
defaults = SettingsModel().get_default_repo_settings(strip_prefix=True) | ||||
# set checkbox to autochecked | ||||
defaults['repo_copy_permissions'] = True | ||||
parent_group_choice = '-1' | ||||
if not self._rhodecode_user.is_admin and self._rhodecode_user.personal_repo_group: | ||||
parent_group_choice = self._rhodecode_user.personal_repo_group | ||||
if parent_group and _gr: | ||||
if parent_group in [x[0] for x in c.repo_groups]: | ||||
parent_group_choice = safe_unicode(parent_group) | ||||
defaults.update({'repo_group': parent_group_choice}) | ||||
data = render('rhodecode:templates/admin/repos/repo_add.mako', | ||||
self._get_template_context(c), self.request) | ||||
html = formencode.htmlfill.render( | ||||
data, | ||||
defaults=defaults, | ||||
encoding="UTF-8", | ||||
force_defaults=False | ||||
) | ||||
return Response(html) | ||||
@LoginRequired() | ||||
@NotAnonymous() | ||||
@CSRFRequired() | ||||
# perms check inside | ||||
@view_config( | ||||
route_name='repo_create', request_method='POST', | ||||
renderer='rhodecode:templates/admin/repos/repos.mako') | ||||
def repository_create(self): | ||||
c = self.load_default_context() | ||||
form_result = {} | ||||
r2359 | self._load_form_data(c) | |||
r2014 | task_id = None | |||
try: | ||||
# CanWriteToGroup validators checks permissions of this POST | ||||
r2351 | form = RepoForm( | |||
self.request.translate, repo_groups=c.repo_groups_choices, | ||||
landing_revs=c.landing_revs_choices)() | ||||
r2359 | form_result = form.to_python(dict(self.request.POST)) | |||
r2014 | ||||
# create is done sometimes async on celery, db transaction | ||||
# management is handled there. | ||||
task = RepoModel().create(form_result, self._rhodecode_user.user_id) | ||||
r2359 | task_id = get_task_id(task) | |||
r2014 | except formencode.Invalid as errors: | |||
data = render('rhodecode:templates/admin/repos/repo_add.mako', | ||||
self._get_template_context(c), self.request) | ||||
html = formencode.htmlfill.render( | ||||
data, | ||||
defaults=errors.value, | ||||
errors=errors.error_dict or {}, | ||||
prefix_error=False, | ||||
encoding="UTF-8", | ||||
force_defaults=False | ||||
) | ||||
return Response(html) | ||||
except Exception as e: | ||||
msg = self._log_creation_exception(e, form_result.get('repo_name')) | ||||
h.flash(msg, category='error') | ||||
raise HTTPFound(h.route_path('home')) | ||||
r2852 | events.trigger(events.UserPermissionsChange([self._rhodecode_user.user_id])) | |||
r2014 | raise HTTPFound( | |||
h.route_path('repo_creating', | ||||
repo_name=form_result['repo_name_full'], | ||||
_query=dict(task_id=task_id))) | ||||