new repo2db mapper, now uses repoModel to make scanns

pylons_app/lib/utils.py

@@ -1,181 +0,0 b''
-#!/usr/bin/env python
-# encoding: utf-8
-# Utilities for hg app
-# Copyright (C) 2009-2010 Marcin Kuzminski <[e-mail]>
- 
-# 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; version 2
-# of the License or (at your opinion) any later version of the license.
-# 
-# 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, write to the Free Software
-# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
-# MA  02110-1301, USA.
-
-"""
-Created on April 18, 2010
-Utilities for hg app
-@author: marcink
-"""
-
-import os
-import logging
-from mercurial import ui, config, hg
-from mercurial.error import RepoError
-from pylons_app.model.db import Repository, User
-log = logging.getLogger(__name__)
-
-
-def get_repo_slug(request):
-    return request.environ['pylons.routes_dict'].get('repo_name')
-
-def is_mercurial(environ):
-    """
-    Returns True if request's target is mercurial server - header
-    ``HTTP_ACCEPT`` of such request would start with ``application/mercurial``.
-    """
-    http_accept = environ.get('HTTP_ACCEPT')
-    if http_accept and http_accept.startswith('application/mercurial'):
-        return True
-    return False
-
-def check_repo_dir(paths):
-    repos_path = paths[0][1].split('/')
-    if repos_path[-1] in ['*', '**']:
-        repos_path = repos_path[:-1]
-    if repos_path[0] != '/':
-        repos_path[0] = '/'
-    if not os.path.isdir(os.path.join(*repos_path)):
-        raise Exception('Not a valid repository in %s' % paths[0][1])
-
-def check_repo(repo_name, base_path):
-
-    repo_path = os.path.join(base_path, repo_name)
-
-    try:
-        r = hg.repository(ui.ui(), repo_path)
-        hg.verify(r)
-        #here we hnow that repo exists it was verified
-        log.info('%s repo is already created', repo_name)
-        return False
-        #raise Exception('Repo exists')
-    except RepoError:
-        log.info('%s repo is free for creation', repo_name)
-        #it means that there is no valid repo there...
-        return True
-                
-def make_ui(path=None, checkpaths=True):        
-    """
-    A funcion that will read python rc files and make an ui from read options
-    
-    @param path: path to mercurial config file
-    """
-    if not path:
-        log.error('repos config path is empty !')
-    
-    if not os.path.isfile(path):
-        log.warning('Unable to read config file %s' % path)
-        return False
-    #propagated from mercurial documentation
-    sections = [
-                'alias',
-                'auth',
-                'decode/encode',
-                'defaults',
-                'diff',
-                'email',
-                'extensions',
-                'format',
-                'merge-patterns',
-                'merge-tools',
-                'hooks',
-                'http_proxy',
-                'smtp',
-                'patch',
-                'paths',
-                'profiling',
-                'server',
-                'trusted',
-                'ui',
-                'web',
-                ]
-
-    baseui = ui.ui()
-    cfg = config.config()
-    cfg.read(path)
-    if checkpaths:check_repo_dir(cfg.items('paths'))
-
-    for section in sections:
-        for k, v in cfg.items(section):
-            baseui.setconfig(section, k, v)
-    
-    return baseui
-
-def invalidate_cache(name, *args):
-    """Invalidates given name cache"""
-    
-    from beaker.cache import region_invalidate
-    log.info('INVALIDATING CACHE FOR %s', name)
-    
-    """propagate our arguments to make sure invalidation works. First
-    argument has to be the name of cached func name give to cache decorator
-    without that the invalidation would not work"""
-    tmp = [name]
-    tmp.extend(args)
-    args = tuple(tmp)
-    
-    if name == 'cached_repo_list':
-        from pylons_app.model.hg_model import _get_repos_cached
-        region_invalidate(_get_repos_cached, None, *args)
-        
-    if name == 'full_changelog':
-        from pylons_app.model.hg_model import _full_changelog_cached
-        region_invalidate(_full_changelog_cached, None, *args)
-        
-from vcs.backends.base import BaseChangeset
-from vcs.utils.lazy import LazyProperty
-class EmptyChangeset(BaseChangeset):
-    
-    revision = -1
-    message = ''
-    
-    @LazyProperty
-    def raw_id(self):
-        """
-        Returns raw string identifing this changeset, useful for web
-        representation.
-        """
-        return '0' * 12
-
-
-def repo2db_mapper(initial_repo_list):
-    """
-    maps all found repositories into db
-    """
-    from pylons_app.model.meta import Session
-    sa = Session()
-    user = sa.query(User).filter(User.admin == True).first()
-    for name, repo in initial_repo_list.items():
-        if not sa.query(Repository).get(name):
-            log.info('%s not found creating default', name)
-            try:
-                
-                new_repo = Repository()
-                new_repo.repo_name = name
-                desc = repo.description if repo.description != 'unknown' else \
-                                            'auto description for %s' % name
-                new_repo.description = desc
-                new_repo.user_id = user.user_id
-                new_repo.private = False
-                sa.add(new_repo)
-                sa.commit()
-            except:
-                sa.rollback()
-                raise
-