from pylons_app.lib.filters import clean_repo

from pylons_app.lib.utils import check_repo, invalidate_cache

from pylons_app.model.hg_model import HgModel

import logging

import os

import shutil

from operator import itemgetter

log = logging.getLogger(__name__)

class ReposController(BaseController):

    """REST Controller styled on the Atom Publishing Protocol"""

    # To properly map this controller, ensure your config/routing.py

    # file has a resource setup:

    #     map.resource('repo', 'repos')

    @LoginRequired()

    def __before__(self):

        c.admin_user = session.get('admin_user')

        c.admin_username = session.get('admin_username')

        super(ReposController, self).__before__()

    def index(self, format='html'):

        """GET /repos: All items in the collection"""

        # url('repos')

        cached_repo_list = HgModel().get_repos()

        return render('admin/repos/repos.html')

    def create(self):

        """POST /repos: Create a new item"""

        # url('repos')

        name = request.POST.get('name')

        try:

            self._create_repo(name)

            #clear our cached list for refresh with new repo

            invalidate_cache('cached_repo_list')

        except Exception as e:

            log.error(e)

        return redirect('repos')

    def _create_repo(self, repo_name):        

        repo_path = os.path.join(g.base_path, repo_name)

        if check_repo(repo_name, g.base_path):

            log.info('creating repo %s in %s', repo_name, repo_path)

            from vcs.backends.hg import MercurialRepository

            MercurialRepository(repo_path, create=True)