import logging

from formencode import htmlfill

from pylons import request, response, session, tmpl_context as c, url

from pylons.controllers.util import abort, redirect

from pylons_app.lib.base import BaseController, render

import formencode

from pylons_app.model.forms import LoginForm

from pylons_app.lib.auth import AuthUser

log = logging.getLogger(__name__)

class LoginController(BaseController):

    def index(self):

            return redirect(url('hg_home'))

        if request.POST:

            #import Login Form validator class

            login_form = LoginForm()

            try:

                c.form_result = login_form.to_python(dict(request.POST))

                return redirect(url('hg_home'))

            except formencode.Invalid as errors:

                c.form_errors = errors.error_dict

                return htmlfill.render(

                    render('/login.html'),

                    defaults=errors.value,

                    encoding="UTF-8")

        return render('/login.html')

    def logout(self):

        session['hg_app_user'] = AuthUser()

        session.save()

        redirect(url('hg_home'))

        if value != authentication_token():

            raise formencode.Invalid(self.message('invalid_token', state,

                                            search_number=value), value, state)

class ValidAuth(formencode.validators.FancyValidator):

    messages = {

            'invalid_password':_('invalid password'),

            'invalid_login':_('invalid user name'),

            'disabled_account':_('Your acccount is disabled')

            }

    #error mapping

    e_dict = {'username':messages['invalid_login'],

              'password':messages['invalid_password']}

    def validate_python(self, value, state):

        sa = meta.Session

        crypted_passwd = get_crypt_password(value['password'])

        username = value['username']

        try:

            user = sa.query(Users).filter(Users.username == username).one()

        except (NoResultFound, MultipleResultsFound, OperationalError) as e:

            log.error(e)

            user = None

        if user:

            if user.active:

                if user.username == username and user.password == crypted_passwd:

                    log.info('user %s authenticated correctly', username)

                    from pylons_app.lib.auth import AuthUser

                    auth_user = AuthUser()

                    auth_user.username = username

                    auth_user.is_authenticated = True

                    auth_user.is_admin = user.admin

                    session['hg_app_user'] = auth_user

                    session.save()

                    return value

                else:

                    log.warning('user %s not authenticated', username)

                    raise formencode.Invalid(self.message('invalid_password',

                                             state=State_obj), value, state,

                                             error_dict=self.e_dict)

            else:

                log.warning('user %s is disabled', username)

                raise formencode.Invalid(self.message('disabled_account',

                                         state=State_obj),

                                         value, state, error_dict=self.e_dict)

#!/usr/bin/env python

# encoding: utf-8

#

# Copyright (c) 2010 marcink.  All rights reserved.

#

from vcs.exceptions import RepositoryError

'''

Created on Apr 9, 2010

@author: marcink

'''

import os

from pylons import tmpl_context as c, app_globals as g, session, request, config

from pylons.controllers.util import abort

try:

    from vcs.backends.hg import get_repositories, MercurialRepository

except ImportError:

    raise Exception('Unable to import vcs')

class HgModel(object):

    """

    Mercurial Model

    """

    def __init__(self):

        """

        Constructor

        """

        pass

    def get_repos(self):

        for mercurial_repo in get_repositories(g.paths[0][0], g.paths[0][1], g.baseui):

            if mercurial_repo._get_hidden():

                #skip hidden web repository

                continue

            last_change = mercurial_repo.last_change

            try:

                tip = mercurial_repo.get_changeset('tip')