Show More
@@ -43,12 +43,15 b' from rhodecode.lib import helpers as h' | |||||
43 | from rhodecode.lib.auth import HasRepoPermissionAny |
|
43 | from rhodecode.lib.auth import HasRepoPermissionAny | |
44 | from rhodecode.lib.utils import get_repos, make_ui, action_logger |
|
44 | from rhodecode.lib.utils import get_repos, make_ui, action_logger | |
45 | from rhodecode.model import BaseModel |
|
45 | from rhodecode.model import BaseModel | |
46 | from rhodecode.model.db import Repository, User, RhodeCodeUi, CacheInvalidation, \ |
|
46 | from rhodecode.model.user import UserModel | |
|
47 | ||||
|
48 | from rhodecode.model.db import Repository, RhodeCodeUi, CacheInvalidation, \ | |||
47 | UserFollowing |
|
49 | UserFollowing | |
48 | from rhodecode.model.caching_query import FromCache |
|
50 | from rhodecode.model.caching_query import FromCache | |
49 |
|
51 | |||
50 | from sqlalchemy.orm import joinedload |
|
52 | from sqlalchemy.orm import joinedload | |
51 | from sqlalchemy.orm.session import make_transient |
|
53 | from sqlalchemy.orm.session import make_transient | |
|
54 | from sqlalchemy.exc import DatabaseError | |||
52 |
|
55 | |||
53 | log = logging.getLogger(__name__) |
|
56 | log = logging.getLogger(__name__) | |
54 |
|
57 | |||
@@ -176,7 +179,6 b' class ScmModel(BaseModel):' | |||||
176 | log.error(traceback.format_exc()) |
|
179 | log.error(traceback.format_exc()) | |
177 | return |
|
180 | return | |
178 |
|
181 | |||
179 | #TODO: get the baseui from somewhere for this |
|
|||
180 | if alias == 'hg': |
|
182 | if alias == 'hg': | |
181 | from pylons import app_globals as g |
|
183 | from pylons import app_globals as g | |
182 | repo = backend(repo_path, create=False, baseui=g.baseui) |
|
184 | repo = backend(repo_path, create=False, baseui=g.baseui) | |
@@ -238,7 +240,7 b' class ScmModel(BaseModel):' | |||||
238 | try: |
|
240 | try: | |
239 | self.sa.add(cache) |
|
241 | self.sa.add(cache) | |
240 | self.sa.commit() |
|
242 | self.sa.commit() | |
241 | except: |
|
243 | except (DatabaseError,): | |
242 | log.error(traceback.format_exc()) |
|
244 | log.error(traceback.format_exc()) | |
243 | self.sa.rollback() |
|
245 | self.sa.rollback() | |
244 |
|
246 | |||
@@ -315,8 +317,7 b' class ScmModel(BaseModel):' | |||||
315 | return f is not None |
|
317 | return f is not None | |
316 |
|
318 | |||
317 | def is_following_user(self, username, user_id): |
|
319 | def is_following_user(self, username, user_id): | |
318 | u = self.sa.query(User)\ |
|
320 | u = UserModel(self.sa).get_by_username(username) | |
319 | .filter(User.username == username).scalar() |
|
|||
320 |
|
321 | |||
321 | f = self.sa.query(UserFollowing)\ |
|
322 | f = self.sa.query(UserFollowing)\ | |
322 | .filter(UserFollowing.follows_user == u)\ |
|
323 | .filter(UserFollowing.follows_user == u)\ | |
@@ -350,7 +351,7 b' class ScmModel(BaseModel):' | |||||
350 | def _mark_invalidated(self, cache_key): |
|
351 | def _mark_invalidated(self, cache_key): | |
351 | """ |
|
352 | """ | |
352 | Marks all occurences of cache to invaldation as already invalidated |
|
353 | Marks all occurences of cache to invaldation as already invalidated | |
353 |
|
|
354 | :param repo_name: | |
354 | """ |
|
355 | """ | |
355 | if cache_key: |
|
356 | if cache_key: | |
356 | log.debug('marking %s as already invalidated', cache_key) |
|
357 | log.debug('marking %s as already invalidated', cache_key) | |
@@ -358,7 +359,7 b' class ScmModel(BaseModel):' | |||||
358 | cache_key.cache_active = True |
|
359 | cache_key.cache_active = True | |
359 | self.sa.add(cache_key) |
|
360 | self.sa.add(cache_key) | |
360 | self.sa.commit() |
|
361 | self.sa.commit() | |
361 | except: |
|
362 | except (DatabaseError,): | |
362 | log.error(traceback.format_exc()) |
|
363 | log.error(traceback.format_exc()) | |
363 | self.sa.rollback() |
|
364 | self.sa.rollback() | |
364 |
|
365 |
General Comments 0
You need to be logged in to leave comments.
Login now