Mercurial > kallithea

comparison rhodecode/model/repo_model.py @ 547:1e757ac98988

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
renamed project to rhodecode
author Marcin Kuzminski <marcin@python-works.com>
date Wed, 06 Oct 2010 03:18:16 +0200
parents pylons_app/model/repo_model.py@a08f610e545e
children
comparison
equal deleted inserted replaced
546:7c2f5e4d7bbf 547:1e757ac98988
1 #!/usr/bin/env python
2 # encoding: utf-8
3 # model for handling repositories actions
4 # Copyright (C) 2009-2010 Marcin Kuzminski <marcin@python-works.com>
5 # This program is free software; you can redistribute it and/or
6 # modify it under the terms of the GNU General Public License
7 # as published by the Free Software Foundation; version 2
8 # of the License or (at your opinion) any later version of the license.
9 #
10 # This program is distributed in the hope that it will be useful,
11 # but WITHOUT ANY WARRANTY; without even the implied warranty of
12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 # GNU General Public License for more details.
14 #
15 # You should have received a copy of the GNU General Public License
16 # along with this program; if not, write to the Free Software
17 # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
18 # MA 02110-1301, USA.
19 """
20 Created on Jun 5, 2010
21 model for handling repositories actions
22 @author: marcink
23 """
24 from datetime import datetime
25 from pylons import app_globals as g
26 from rhodecode.lib.utils import check_repo
27 from rhodecode.model.db import Repository, RepoToPerm, User, Permission
28 from rhodecode.model.meta import Session
29 from rhodecode.model.user_model import UserModel
30 from rhodecode.lib.celerylib.tasks import create_repo_fork, run_task
31 import logging
32 import os
33 import shutil
34 import traceback
35 log = logging.getLogger(__name__)
36
37 class RepoModel(object):
38
39 def __init__(self, sa=None):
40 if not sa:
41 self.sa = Session()
42 else:
43 self.sa = sa
44
45 def get(self, id):
46 return self.sa.query(Repository)\
47 .filter(Repository.repo_name == id).scalar()
48
49 def get_users_js(self):
50
51 users = self.sa.query(User).filter(User.active == True).all()
52 u_tmpl = '''{id:%s, fname:"%s", lname:"%s", nname:"%s"},'''
53 users_array = '[%s];' % '\n'.join([u_tmpl % (u.user_id, u.name,
54 u.lastname, u.username)
55 for u in users])
56 return users_array
57
58
59 def update(self, repo_name, form_data):
60 try:
61
62 #update permissions
63 for username, perm in form_data['perms_updates']:
64 r2p = self.sa.query(RepoToPerm)\
65 .filter(RepoToPerm.user == self.sa.query(User)\
66 .filter(User.username == username).one())\
67 .filter(RepoToPerm.repository == self.get(repo_name))\
68 .one()
69
70 r2p.permission_id = self.sa.query(Permission).filter(
71 Permission.permission_name ==
72 perm).one().permission_id
73 self.sa.add(r2p)
74
75 #set new permissions
76 for username, perm in form_data['perms_new']:
77 r2p = RepoToPerm()
78 r2p.repository = self.get(repo_name)
79 r2p.user = self.sa.query(User)\
80 .filter(User.username == username).one()
81
82 r2p.permission_id = self.sa.query(Permission).filter(
83 Permission.permission_name == perm)\
84 .one().permission_id
85 self.sa.add(r2p)
86
87 #update current repo
88 cur_repo = self.get(repo_name)
89
90 for k, v in form_data.items():
91 if k == 'user':
92 cur_repo.user_id = v
93 else:
94 setattr(cur_repo, k, v)
95
96 self.sa.add(cur_repo)
97
98 if repo_name != form_data['repo_name']:
99 #rename our data
100 self.__rename_repo(repo_name, form_data['repo_name'])
101
102 self.sa.commit()
103 except:
104 log.error(traceback.format_exc())
105 self.sa.rollback()
106 raise
107
108 def create(self, form_data, cur_user, just_db=False, fork=False):
109 try:
110 if fork:
111 repo_name = str(form_data['fork_name'])
112 org_name = str(form_data['repo_name'])
113
114 else:
115 org_name = repo_name = str(form_data['repo_name'])
116 new_repo = Repository()
117 for k, v in form_data.items():
118 if k == 'repo_name':
119 v = repo_name
120 setattr(new_repo, k, v)
121
122 if fork:
123 parent_repo = self.sa.query(Repository)\
124 .filter(Repository.repo_name == org_name).scalar()
125 new_repo.fork = parent_repo
126
127 new_repo.user_id = cur_user.user_id
128 self.sa.add(new_repo)
129
130 #create default permission
131 repo_to_perm = RepoToPerm()
132 default = 'repository.read'
133 for p in UserModel(self.sa).get_default().user_perms:
134 if p.permission.permission_name.startswith('repository.'):
135 default = p.permission.permission_name
136 break
137
138 default_perm = 'repository.none' if form_data['private'] else default
139
140 repo_to_perm.permission_id = self.sa.query(Permission)\
141 .filter(Permission.permission_name == default_perm)\
142 .one().permission_id
143
144 repo_to_perm.repository_id = new_repo.repo_id
145 repo_to_perm.user_id = self.sa.query(User)\
146 .filter(User.username == 'default').one().user_id
147
148 self.sa.add(repo_to_perm)
149 self.sa.commit()
150 if not just_db:
151 self.__create_repo(repo_name)
152 except:
153 log.error(traceback.format_exc())
154 self.sa.rollback()
155 raise
156
157 def create_fork(self, form_data, cur_user):
158 run_task(create_repo_fork, form_data, cur_user)
159
160 def delete(self, repo):
161 try:
162 self.sa.delete(repo)
163 self.sa.commit()
164 self.__delete_repo(repo.repo_name)
165 except:
166 log.error(traceback.format_exc())
167 self.sa.rollback()
168 raise
169
170 def delete_perm_user(self, form_data, repo_name):
171 try:
172 self.sa.query(RepoToPerm)\
173 .filter(RepoToPerm.repository == self.get(repo_name))\
174 .filter(RepoToPerm.user_id == form_data['user_id']).delete()
175 self.sa.commit()
176 except:
177 log.error(traceback.format_exc())
178 self.sa.rollback()
179 raise
180
181 def __create_repo(self, repo_name):
182 repo_path = os.path.join(g.base_path, repo_name)
183 if check_repo(repo_name, g.base_path):
184 log.info('creating repo %s in %s', repo_name, repo_path)
185 from vcs.backends.hg import MercurialRepository
186 MercurialRepository(repo_path, create=True)
187
188 def __rename_repo(self, old, new):
189 log.info('renaming repo from %s to %s', old, new)
190
191 old_path = os.path.join(g.base_path, old)
192 new_path = os.path.join(g.base_path, new)
193 if os.path.isdir(new_path):
194 raise Exception('Was trying to rename to already existing dir %s',
195 new_path)
196 shutil.move(old_path, new_path)
197
198 def __delete_repo(self, name):
199 rm_path = os.path.join(g.base_path, name)
200 log.info("Removing %s", rm_path)
201 #disable hg
202 shutil.move(os.path.join(rm_path, '.hg'), os.path.join(rm_path, 'rm__.hg'))
203 #disable repo
204 shutil.move(rm_path, os.path.join(g.base_path, 'rm__%s__%s' \
205 % (datetime.today(), name)))