##// END OF EJS Templates
code cleanups
marcink -
r758:6a31e64a beta
parent child Browse files
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 @param repo_name:
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