"""Routes configuration

The more specific and detailed routes should be defined first so they

may take precedent over the more generic routes. For more information

refer to the routes manual at http://routes.groovie.org/docs/

"""

from routes import Mapper

def make_map(config):

    """Create, configure and return the routes Mapper"""

    map = Mapper(directory=config['pylons.paths']['controllers'],

                 always_scan=config['debug'])

    map.minimization = False

    map.explicit = False

    # The ErrorController route (handles 404/500 error pages); it should

    # likely stay at the top, ensuring it can always be resolved

    map.connect('/error/{action}', controller='error')

    map.connect('/error/{action}/{id}', controller='error')

    # CUSTOM ROUTES HERE

    with map.submapper(path_prefix='/_admin', controller='admin') as m:

        m.connect('admin_home', '/', action='index')#main page

        m.connect('admin_add_repo', '/add_repo/{new_repo:[a-z0-9\. _-]*}', action='add_repo')

    map.connect('hg', '/{path_info:.*}', controller='hg',

                action="view", path_info='/')

    return map

import logging

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

from pylons.controllers.util import abort, redirect

from pylons_app.lib.base import BaseController, render

import os

from mercurial import ui, hg

from mercurial.error import RepoError

from ConfigParser import ConfigParser

log = logging.getLogger(__name__)

class AdminController(BaseController):

    def __before__(self):

        c.staticurl = g.statics

    def index(self):

        # Return a rendered template

        return render('/admin.html')

    def manage_hgrc(self):

        pass

    def hgrc(self, dirname):

        filename = os.path.join(dirname, '.hg', 'hgrc')

        return filename

    def add_repo(self, new_repo):

        #extra check it can be add since it's the command

            c.new_repo = ''

            return render('add.html')

        new_repo = new_repo.replace(" ", "_")

        new_repo = new_repo.replace("-", "_")

        try:

            self._create_repo(new_repo)

            c.new_repo = new_repo

            c.msg = 'added repo'

        except Exception as e:

            c.new_repo = 'Exception when adding: %s' % new_repo

            c.msg = str(e)

        return render('add.html')

    def _check_repo(self, repo_name):

        p = os.path.dirname(os.path.dirname(os.path.dirname(__file__)))

        config_path = os.path.join(p, 'hgwebdir.config')

        cp = ConfigParser()

        cp.read(config_path)

        repos_path = cp.get('paths', '/').replace("**", '')

import sqlite3

import os

import logging

from os.path import dirname as dn

from datetime import datetime

import crypt

log = logging.getLogger(__name__)

ROOT = dn(dn(dn(os.path.realpath(__file__))))

    conn = sqlite3.connect(os.path.join(ROOT, 'auth.sqlite'))

    cur = conn.cursor()

    return conn, cur

def authfunc(environ, username, password):

    password_crypt = crypt.crypt(password, '6a')

    try:

        cur.execute("SELECT * FROM users WHERE username=?", (username,))

        data = cur.fetchone()

    except sqlite3.OperationalError as e:

        data = None

        log.error(e)

    if data:

        if data[3]:

            if data[1] == username and data[2] == password_crypt:

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

                http_accept = environ.get('HTTP_ACCEPT')

                if http_accept.startswith('application/mercurial') or \

                    environ['PATH_INFO'].find('raw-file') != -1:

                    cmd = environ['PATH_INFO']

                    for qry in environ['QUERY_STRING'].split('&'):

                        if qry.startswith('cmd'):

                            cmd += "|" + qry

                            try:

                                cur.execute('''INSERT INTO 

                                                    user_logs 

                                               VALUES(?,?,?,?)''',

                                                (None, data[0], cmd, datetime.now()))

                                conn.commit()

                            except Exception as e:

                                conn.rollback()

                                log.error(e)

                return True

        else:

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

    return False

def create_user_table():

    '''

    Create a auth database

    '''

    try:

        log.info('creating table %s', 'users')

        cur.execute('''DROP TABLE IF EXISTS users ''')

        cur.execute('''CREATE TABLE users

                        (id INTEGER PRIMARY KEY AUTOINCREMENT, 

                         username TEXT, 

                         password TEXT,

                         active INTEGER)''')

        log.info('creating table %s', 'user_logs')

        cur.execute('''DROP TABLE IF EXISTS user_logs ''')

        cur.execute('''CREATE TABLE user_logs

                        (id INTEGER PRIMARY KEY AUTOINCREMENT,

                            user_id INTEGER,

                            last_action TEXT, 

                            last_action_date DATETIME)''')

        conn.commit()

    except:

        conn.rollback()

        raise

    cur.close()

def create_user(username, password):

    password_crypt = crypt.crypt(password, '6a')

    cur_date = datetime.now()

    log.info('creating user %s', username)

    try:

        cur.execute('''INSERT INTO users values (?,?,?,?) ''',

                    (None, username, password_crypt, 1,))     

        conn.commit()

    except:

        conn.rollback()

        raise

if __name__ == "__main__":

    create_user_table()

    create_user('marcink', 'qweqwe')

    create_user('lukaszd', 'qweqwe')

    create_user('adriand', 'qweqwe')

    create_user('radek', 'qweqwe')

    create_user('skrzeka', 'qweqwe')

    create_user('bart', 'qweqwe')

    create_user('maho', 'qweqwe')

    create_user('michalg', 'qweqwe')

    #authfunc('', 'marcink', 'qweqwe')

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

    </div>

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

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">

<html xmlns="http://www.w3.org/1999/xhtml">

<head>

</head>

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

{header}

    <title>{repo|escape}: Mercurial repositories index</title>

</head>

<body>

<div id="container">

    <div class="page-header">

        <h1>${c.repos_prefix} Mercurial Repositories</h1>

        <ul class="page-nav">

        </ul>

    </div>

    <table cellspacing="0">

        <tr>

            <td><a href="?sort={sort_name}">Name</a></td>

            <td><a href="?sort={sort_description}">Description</a></td>

            <td><a href="?sort={sort_contact}">Contact</a></td>

            <td><a href="?sort={sort_lastchange}">Last change</a></td>

            <td>&nbsp;</td>

            <td>&nbsp;</td>

        </tr>

        {entries%indexentry}

    </table>

    <div class="page-footer">

        {motd}

    </div>

    <div id="powered-by">

        <p><a href="http://mercurial.selenic.com/" title="Mercurial"><img src="{staticurl}hglogo.png" width="75" height="90" alt="mercurial"/></a></p>

    </div>

    <div id="corner-top-left"></div>

    <div id="corner-top-right"></div>