#!/usr/bin/env python

# encoding: utf-8

# Model for hg app

# Copyright (C) 2009-2010 Marcin Kuzminski <marcin@python-works.com>

# 

# 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 9, 2010

Model for hg app

@author: marcink

"""

from beaker.cache import cache_region

from mercurial import ui

from mercurial.hgweb.hgwebdir_mod import findrepos

from pylons.i18n.translation import _

from pylons_app.lib.auth import HasRepoPermissionAny

from pylons_app.model import meta

from pylons_app.model.db import Repository, User

from pylons_app.lib import helpers as h

from vcs.exceptions import RepositoryError, VCSError

import logging

import os

import sys

log = logging.getLogger(__name__)

try:

    from vcs.backends.hg import MercurialRepository

except ImportError:

    sys.stderr.write('You have to import vcs module')

    raise Exception('Unable to import vcs')

def _get_repos_cached_initial(app_globals, initial):

    """return cached dict with repos

    """

    g = app_globals

    return HgModel.repo_scan(g.paths[0][0], g.paths[0][1], g.baseui, initial)

@cache_region('long_term', 'cached_repo_list')

def _get_repos_cached():

    """return cached dict with repos

    """

    log.info('getting all repositories list')

    from pylons import app_globals as g

    return HgModel.repo_scan(g.paths[0][0], g.paths[0][1], g.baseui)

@cache_region('super_short_term', 'cached_repos_switcher_list')

def _get_repos_switcher_cached(cached_repo_list):

    repos_lst = []

    for repo in [x for x in cached_repo_list.values()]:

        if HasRepoPermissionAny('repository.write', 'repository.read',

                    'repository.admin')(repo.name, 'main page check'):

            repos_lst.append((repo.name, repo.dbrepo.private,))

    return sorted(repos_lst, key=lambda k:k[0].lower())

@cache_region('long_term', 'full_changelog')

def _full_changelog_cached(repo_name):

    log.info('getting full changelog for %s', repo_name)

    return list(reversed(list(HgModel().get_repo(repo_name))))

class HgModel(object):

    """Mercurial Model

    """

    def __init__(self):

        pass

    @staticmethod

    def repo_scan(repos_prefix, repos_path, baseui, initial=False):

        """

        Listing of repositories in given path. This path should not be a 

        repository itself. Return a dictionary of repository objects

        :param repos_path: path to directory it could take syntax with 

        * or ** for deep recursive displaying repositories

        """

        sa = meta.Session()

        def check_repo_dir(path):

            """Checks the repository

            :param path:

            """

            repos_path = path.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 RepositoryError('Not a valid repository in %s' % path)        

        if not repos_path.endswith('*'):

            raise VCSError('You need to specify * or ** at the end of path '

                            'for recursive scanning')

        check_repo_dir(repos_path)

        log.info('scanning for repositories in %s', repos_path)

        repos = findrepos([(repos_prefix, repos_path)])

        if not isinstance(baseui, ui.ui):

            baseui = ui.ui()

        repos_list = {}

        for name, path in repos:

            try:

                #name = name.split('/')[-1]

                if repos_list.has_key(name):

                    raise RepositoryError('Duplicate repository name %s found in'

                                    ' %s' % (name, path))

                else:

                    repos_list[name] = MercurialRepository(path, baseui=baseui)

                    repos_list[name].name = name

                    dbrepo = None

                    if not initial:

                        dbrepo = sa.query(Repository)\

                    if dbrepo:

                        log.info('Adding db instance to cached list')

                        repos_list[name].dbrepo = dbrepo

                        repos_list[name].description = dbrepo.description

                        if dbrepo.user:

                            repos_list[name].contact = dbrepo.user.full_contact

                        else:

                            repos_list[name].contact = sa.query(User)\

                            .filter(User.admin == True).first().full_contact

            except OSError:

                continue

        meta.Session.remove()

        return repos_list

    def get_repos(self):

        for name, repo in _get_repos_cached().items():

            if repo._get_hidden():

                #skip hidden web repository

                continue

            last_change = repo.last_change

            tip = h.get_changeset_safe(repo, 'tip')

            tmp_d = {}

            tmp_d['name'] = repo.name

            tmp_d['name_sort'] = tmp_d['name'].lower()

            tmp_d['description'] = repo.description

            tmp_d['description_sort'] = tmp_d['description']

            tmp_d['last_change'] = last_change

            tmp_d['last_change_sort'] = last_change[1] - last_change[0]

            tmp_d['tip'] = tip.short_id

            tmp_d['tip_sort'] = tip.revision 

            tmp_d['rev'] = tip.revision

            tmp_d['contact'] = repo.contact

            tmp_d['contact_sort'] = tmp_d['contact']

            tmp_d['repo_archives'] = list(repo._get_archives())

            tmp_d['last_msg'] = tip.message

            tmp_d['repo'] = repo

            yield tmp_d

    def get_repo(self, repo_name):

        return _get_repos_cached()[repo_name]

## -*- coding: utf-8 -*-

<%inherit file="/base/base.html"/>

<%def name="title()">

    ${_('Repositories administration')}

</%def>

<%def name="breadcrumbs_links()">

    ${h.link_to(_('Admin'),h.url('admin_home'))} » ${_('Repositories')}

</%def>

<%def name="page_nav()">

	${self.menu('admin')}

</%def>

<%def name="main()">

<div class="box">

    <!-- box / title -->

    <div class="title">

        ${self.breadcrumbs()}

        <ul class="links">

          <li>

            <span>${h.link_to(u'ADD NEW REPOSITORY',h.url('new_repo'),class_="add_icon")}</span>

          </li>          

        </ul>        

    </div>

    <!-- end box / title -->

    <div class="table">

        <table class="table_disp">

        <tr class="header">

            <th class="left">${_('action')}</th>

        </tr>

            %for cnt,repo in enumerate(c.repos_list):

            <tr class="parity${cnt%2}">

                 <td>

                 %if repo['repo'].dbrepo.private:

                    <img alt="${_('private')}" src="/images/icons/lock.png"/>

                 %else:

                    <img alt="${_('public')}" src="/images/icons/lock_open.png"/>

                 %endif         

                <td>

                  ${h.form(url('repo', repo_name=repo['name']),method='delete')}

                    ${h.submit('remove_%s' % repo['name'],'delete',class_="delete_icon action_button",onclick="return confirm('Confirm to delete this repository');")}

                  ${h.end_form()}

                </td>

            </tr>

            %endfor

        </table>

    </div>

</div> 

</%def>    

	             </div>

	             <div class="field">

	                <div class="label">

	                    <label for="lastname">${_('Lastname')}:</label>

	                </div>

	                <div class="input">

	                    ${h.text('lastname')}

	                </div>

	             </div>

	             <div class="field">

	                <div class="label">

	                    <label for="email">${_('Email')}:</label>

	                </div>

	                <div class="input">

	                    ${h.text('email')}

	                </div>

	             </div>

	            <div class="buttons">

	              ${h.submit('save','save',class_="ui-button ui-widget ui-state-default ui-corner-all")}

	            </div>             

	    	</div>

	    </div>    	

    ${h.end_form()}

    </div>

</div>    

<div class="box box-right">

    <!-- box / title -->

    <div class="title">

        <h5>${_('My repositories')}</h5>   

    </div>

    <!-- end box / title -->

    <div class="table">

	    <table>

	     <tbody>

	     %if c.user_repos:

		     %for repo in c.user_repos:

		        <tr>

		            <td>

		             %if repo.dbrepo.private:

		                <img class="icon" alt="${_('private')}" src="/images/icons/lock.png"/>

		             %else:

		                <img class="icon" alt="${_('public')}" src="/images/icons/lock_open.png"/>

		             %endif

		            <td>${_('revision')}: ${h.get_changeset_safe(repo,'tip').revision}</td>

		            <td>${_('last changed')}: ${h.age(repo.last_change)}</td>

		            <td><img class="icon" alt="${_('private')}" src="/images/icons/application_form_edit.png"/> ${h.link_to(_('edit'),h.url('repo_settings_home',repo_name=repo.name))}</td>

		            <td>

	                  ${h.form(url('repo_settings_delete', repo_name=repo.name),method='delete')}

	                    ${h.submit('remove_%s' % repo.name,'delete',class_="delete_icon action_button",onclick="return confirm('Confirm to delete this repository');")}

	                  ${h.end_form()}	            

		            </td>

		        </tr>

		     %endfor

	     %else:

	     	${_('No repositories yet')} 

	     	%if h.HasPermissionAny('hg.admin','hg.create.repository')():

	     		${h.link_to(_('create one now'),h.url('admin_settings_create_repository'))}

	     	%endif

	     %endif

	     </tbody>

	     </table>

    </div>

</div>

</%def>  

		%if name_slug == c.sort_slug:

		  %if c.sort_by.startswith('-'):

		    <a href="?sort=${name_slug}">${name}&uarr;</a>

		  %else:

		    <a href="?sort=-${name_slug}">${name}&darr;</a>

		  %endif:

		%else:

		    <a href="?sort=${name_slug}">${name}</a>

		%endif

	</%def>

    <div class="box">

	    <!-- box / title -->

	    <div class="title">

	        <h5>${_('Dashboard')}</h5>

	        %if h.HasPermissionAny('hg.admin','hg.create.repository')():

	        <ul class="links">

	          <li>

	            <span>${h.link_to(_('ADD NEW REPOSITORY'),h.url('admin_settings_create_repository'),class_="add_icon")}</span>

	          </li>          

	        </ul>  	        

	        %endif

	    </div>

	    <!-- end box / title -->

        <div class="table">

                    <table>

            <thead>

	            <tr>

			        <th class="left">${get_sort(_('Name'))}</th>

			        <th class="left">${get_sort(_('Description'))}</th>

			        <th class="left">${get_sort(_('Last change'))}</th>

			        <th class="left">${get_sort(_('Tip'))}</th>

			        <th class="left">${get_sort(_('Contact'))}</th>

			        <th class="left">${_('RSS')}</th>

			        <th class="left">${_('Atom')}</th>

	            </tr>

            </thead>

                        <tbody>

					    %for cnt,repo in enumerate(c.repos_list):

					        %if h.HasRepoPermissionAny('repository.write','repository.read','repository.admin')(repo['name'],'main page check'):

					        <tr class="parity${cnt%2}">

					            <td>

					             %if repo['repo'].dbrepo.private:

					                <img class="icon" alt="${_('private')}" src="/images/icons/lock.png"/>

					             %else:

					                <img class="icon" alt="${_('public')}" src="/images/icons/lock_open.png"/>

					             %endif  

					            ${h.link_to(repo['name'],

					            <td title="${repo['description']}">${h.truncate(repo['description'],60)}</td>

					            <td>${h.age(repo['last_change'])}</td>

					            <td>

					            	%if repo['rev']>=0:

					            	${h.link_to('r%s:%s' % (repo['rev'],repo['tip']),

					                h.url('changeset_home',repo_name=repo['name'],revision=repo['tip']),

					                class_="tooltip",

					                tooltip_title=h.tooltip(repo['last_msg']))}

					            	%else:

					            		${_('No changesets yet')}

					            	%endif    

					            </td>

					            <td title="${repo['contact']}">${h.person(repo['contact'])}</td>

					            <td>

					                <a title="${_('Subscribe to %s rss feed')%repo['name']}" class="rss_icon"  href="${h.url('rss_feed_home',repo_name=repo['name'])}"></a>

					            </td>        

					            <td>

					                <a title="${_('Subscribe to %s atom feed')%repo['name']}"  class="atom_icon" href="${h.url('atom_feed_home',repo_name=repo['name'])}"></a>

					            </td>

					        </tr>

					        %endif

					    %endfor

                        </tbody>

                    </table>

            </div>

    </div>	

</%def>    

<%inherit file="/base/base.html"/>

<%def name="title()">

    ${_('Mercurial Repository Overview')}

</%def>

<%def name="breadcrumbs_links()">

    ${h.link_to(u'Home',h.url('/'))}

    » 

    ${h.link_to(c.repo_name,h.url('summary_home',repo_name=c.repo_name))}

    »

    ${_('summary')}

</%def>

<%def name="page_nav()">

	${self.menu('summary')}    

</%def>

<%def name="main()">

<script type="text/javascript">

var E = YAHOO.util.Event;

var D = YAHOO.util.Dom;

E.onDOMReady(function(e){

    id = 'clone_url';

    E.addListener(id,'click',function(e){

        D.get('clone_url').select();

    })

})

</script>

<div class="box box-left">

    <!-- box / title -->

    <div class="title">

        ${self.breadcrumbs()}

    </div>

    <!-- end box / title -->

	<div class="form">

	  <div class="fields">

			 <div class="field">

			  <div class="label">

			      <label>${_('Name')}:</label>

			  </div>

			  <div class="input-short">

			  </div>

			 </div>

			 <div class="field">

			  <div class="label">

			      <label>${_('Description')}:</label>

			  </div>

			  <div class="input-short">

			      ${c.repo_info.description}

			  </div>

			 </div>

			 <div class="field">

			  <div class="label">

			      <label>${_('Contact')}:</label>

			  </div>

			  <div class="input-short">

			  	<div class="gravatar">

			  		<img alt="gravatar" src="${h.gravatar_url(c.repo_info.dbrepo.user.email)}"/>

			  	</div>

			  		${_('Username')}: ${c.repo_info.dbrepo.user.username}<br/>

			  		${_('Name')}: ${c.repo_info.dbrepo.user.name} ${c.repo_info.dbrepo.user.lastname}<br/>

			  		${_('Email')}: <a href="mailto:${c.repo_info.dbrepo.user.email}">${c.repo_info.dbrepo.user.email}</a>

			  </div>

			 </div>

			 <div class="field">

			  <div class="label">

			      <label>${_('Last change')}:</label>

			  </div>

			  <div class="input-short">

			      ${h.age(c.repo_info.last_change)} - ${h.rfc822date_notz(c.repo_info.last_change)} 

			      ${_('by')} ${h.get_changeset_safe(c.repo_info,'tip').author} 

			  </div>

			 </div>

			 <div class="field">

			  <div class="label">

			      <label>${_('Clone url')}:</label>

			  </div>

			  <div class="input-short">

			      <input type="text" id="clone_url" readonly="readonly" value="hg clone ${c.clone_repo_url}" size="70"/>

			  </div>

			 </div>