repos_group.py
157 lines
| 4.7 KiB
| text/x-python
|
PythonLexer
r1345 | # -*- coding: utf-8 -*- | |||
""" | ||||
rhodecode.model.user_group | ||||
~~~~~~~~~~~~~~~~~~~~~~~~~~ | ||||
users groups model for RhodeCode | ||||
:created_on: Jan 25, 2011 | ||||
:author: marcink | ||||
:copyright: (C) 2009-2011 Marcin Kuzminski <marcin@python-works.com> | ||||
:license: GPLv3, see COPYING for more details. | ||||
""" | ||||
# This program is free software: you can redistribute it and/or modify | ||||
# it under the terms of the GNU General Public License as published by | ||||
# the Free Software Foundation, either version 3 of the License, or | ||||
# (at your option) any later version. | ||||
# | ||||
# 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 General Public License | ||||
# along with this program. If not, see <http://www.gnu.org/licenses/>. | ||||
import os | ||||
import logging | ||||
import traceback | ||||
r1347 | import shutil | |||
r1345 | ||||
from pylons.i18n.translation import _ | ||||
from vcs.utils.lazy import LazyProperty | ||||
from rhodecode.model import BaseModel | ||||
r1633 | from rhodecode.model.db import RepoGroup, RhodeCodeUi | |||
r1345 | ||||
Nicolas VINOT
|
r1593 | log = logging.getLogger(__name__) | ||
r1345 | ||||
Nicolas VINOT
|
r1593 | class ReposGroupModel(BaseModel): | ||
r1345 | ||||
@LazyProperty | ||||
Nicolas VINOT
|
r1593 | def repos_path(self): | ||
r1345 | """ | |||
Get's the repositories root path from database | ||||
""" | ||||
Nicolas VINOT
|
r1593 | q = RhodeCodeUi.get_by_key('/').one() | ||
r1345 | return q.ui_value | |||
r1594 | def __create_group(self, group_name): | |||
r1345 | """ | |||
makes repositories group on filesystem | ||||
:param repo_name: | ||||
:param parent_id: | ||||
""" | ||||
r1594 | create_path = os.path.join(self.repos_path, group_name) | |||
Nicolas VINOT
|
r1593 | log.debug('creating new group in %s', create_path) | ||
r1345 | ||||
Nicolas VINOT
|
r1593 | if os.path.isdir(create_path): | ||
raise Exception('That directory already exists !') | ||||
r1345 | ||||
Nicolas VINOT
|
r1593 | os.makedirs(create_path) | ||
r1345 | ||||
r1594 | def __rename_group(self, old, new): | |||
r1345 | """ | |||
Renames a group on filesystem | ||||
r1818 | ||||
r1345 | :param group_name: | |||
""" | ||||
r1594 | ||||
if old == new: | ||||
log.debug('skipping group rename') | ||||
return | ||||
Nicolas VINOT
|
r1593 | log.debug('renaming repos group from %s to %s', old, new) | ||
r1349 | ||||
r1347 | ||||
r1594 | old_path = os.path.join(self.repos_path, old) | |||
new_path = os.path.join(self.repos_path, new) | ||||
r1349 | ||||
Nicolas VINOT
|
r1593 | log.debug('renaming repos paths from %s to %s', old_path, new_path) | ||
r1349 | ||||
Nicolas VINOT
|
r1593 | if os.path.isdir(new_path): | ||
raise Exception('Was trying to rename to already ' | ||||
'existing dir %s' % new_path) | ||||
shutil.move(old_path, new_path) | ||||
r1345 | ||||
Nicolas VINOT
|
r1593 | def __delete_group(self, group): | ||
r1345 | """ | |||
Deletes a group from a filesystem | ||||
r1818 | ||||
r1346 | :param group: instance of group from database | |||
r1345 | """ | |||
r1633 | paths = group.full_path.split(RepoGroup.url_sep()) | |||
Nicolas VINOT
|
r1593 | paths = os.sep.join(paths) | ||
r1346 | ||||
Nicolas VINOT
|
r1593 | rm_path = os.path.join(self.repos_path, paths) | ||
r1594 | if os.path.isdir(rm_path): | |||
# delete only if that path really exists | ||||
os.rmdir(rm_path) | ||||
r1345 | ||||
Nicolas VINOT
|
r1593 | def create(self, form_data): | ||
r1345 | try: | |||
r1633 | new_repos_group = RepoGroup() | |||
r1594 | new_repos_group.group_description = form_data['group_description'] | |||
r1633 | new_repos_group.parent_group = RepoGroup.get(form_data['group_parent_id']) | |||
r1594 | new_repos_group.group_name = new_repos_group.get_new_name(form_data['group_name']) | |||
r1345 | ||||
Nicolas VINOT
|
r1593 | self.sa.add(new_repos_group) | ||
r1734 | self.sa.flush() | |||
r1594 | self.__create_group(new_repos_group.group_name) | |||
r1345 | ||||
Nicolas VINOT
|
r1589 | return new_repos_group | ||
r1345 | except: | |||
Nicolas VINOT
|
r1593 | log.error(traceback.format_exc()) | ||
r1345 | raise | |||
Nicolas VINOT
|
r1593 | def update(self, repos_group_id, form_data): | ||
r1345 | ||||
try: | ||||
r1633 | repos_group = RepoGroup.get(repos_group_id) | |||
r1594 | old_path = repos_group.full_path | |||
r1734 | ||||
r1594 | # change properties | |||
repos_group.group_description = form_data['group_description'] | ||||
r1633 | repos_group.parent_group = RepoGroup.get(form_data['group_parent_id']) | |||
r1594 | repos_group.group_name = repos_group.get_new_name(form_data['group_name']) | |||
r1345 | ||||
r1594 | new_path = repos_group.full_path | |||
r1345 | ||||
Nicolas VINOT
|
r1593 | self.sa.add(repos_group) | ||
r1347 | ||||
r1594 | self.__rename_group(old_path, new_path) | |||
r1818 | # we need to get all repositories from this new group and | |||
r1594 | # rename them accordingly to new group path | |||
for r in repos_group.repositories: | ||||
r.repo_name = r.get_new_name(r.just_name) | ||||
self.sa.add(r) | ||||
r1347 | ||||
r1594 | return repos_group | |||
r1345 | except: | |||
Nicolas VINOT
|
r1593 | log.error(traceback.format_exc()) | ||
r1345 | raise | |||
Nicolas VINOT
|
r1593 | def delete(self, users_group_id): | ||
r1345 | try: | |||
r1633 | users_group = RepoGroup.get(users_group_id) | |||
Nicolas VINOT
|
r1593 | self.sa.delete(users_group) | ||
self.__delete_group(users_group) | ||||
r1345 | except: | |||
Nicolas VINOT
|
r1593 | log.error(traceback.format_exc()) | ||
r1345 | raise | |||