Files
@ a8ea3ce3cdc4
Branch filter:
Location: kallithea/pylons_app/lib/middleware/simplehg.py
a8ea3ce3cdc4
5.1 KiB
text/x-python
Created middleware package. Crated special middleware to handle https requests redirections.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 | #!/usr/bin/env python
# encoding: utf-8
#
# Copyright (c) 2010 marcink. All rights reserved.
#
"""
Created on 2010-04-28
@author: marcink
SimpleHG middleware for handling mercurial protocol request (push/clone etc.)
It's implemented with basic auth function
"""
from datetime import datetime
from mercurial.hgweb import hgweb
from mercurial.hgweb.request import wsgiapplication
from paste.auth.basic import AuthBasicAuthenticator
from paste.httpheaders import REMOTE_USER, AUTH_TYPE
from pylons_app.lib.auth import authfunc
from pylons_app.lib.utils import is_mercurial, make_ui, invalidate_cache
from pylons_app.model import meta
from pylons_app.model.db import UserLogs, Users
from webob.exc import HTTPNotFound
import logging
import os
log = logging.getLogger(__name__)
class SimpleHg(object):
def __init__(self, application, config):
self.application = application
self.config = config
#authenticate this mercurial request using
realm = '%s %s' % (config['hg_app_name'], 'mercurial repository')
self.authenticate = AuthBasicAuthenticator(realm, authfunc)
def __call__(self, environ, start_response):
if not is_mercurial(environ):
return self.application(environ, start_response)
else:
#===================================================================
# AUTHENTICATE THIS MERCURIAL REQUEST
#===================================================================
username = REMOTE_USER(environ)
if not username:
result = self.authenticate(environ)
if isinstance(result, str):
AUTH_TYPE.update(environ, 'basic')
REMOTE_USER.update(environ, result)
else:
return result.wsgi_application(environ, start_response)
try:
repo_name = environ['PATH_INFO'].split('/')[1]
except:
return HTTPNotFound()(environ, start_response)
#since we wrap into hgweb, just reset the path
environ['PATH_INFO'] = '/'
self.baseui = make_ui()
self.basepath = self.baseui.configitems('paths')[0][1]\
.replace('*', '')
self.repo_path = os.path.join(self.basepath, repo_name)
try:
app = wsgiapplication(self.__make_app)
except Exception as e:
return HTTPNotFound()(environ, start_response)
action = self.__get_action(environ)
#invalidate cache on push
if action == 'push':
self.__invalidate_cache(repo_name)
if action:
username = self.__get_environ_user(environ)
self.__log_user_action(username, action, repo_name)
return app(environ, start_response)
def __make_app(self):
hgserve = hgweb(self.repo_path)
return self.load_web_settings(hgserve)
def __get_environ_user(self, environ):
return environ.get('REMOTE_USER')
def __get_action(self, environ):
"""
Maps mercurial request commands into a pull or push command.
@param environ:
"""
mapping = {
'changegroup': 'pull',
'changegroupsubset': 'pull',
'unbundle': 'push',
'stream_out': 'pull',
}
for qry in environ['QUERY_STRING'].split('&'):
if qry.startswith('cmd'):
cmd = qry.split('=')[-1]
if mapping.has_key(cmd):
return mapping[cmd]
def __log_user_action(self, username, action, repo):
sa = meta.Session
try:
user = sa.query(Users)\
.filter(Users.username == username).one()
user_log = UserLogs()
user_log.user_id = user.user_id
user_log.action = action
user_log.repository = repo.replace('/', '')
user_log.action_date = datetime.now()
sa.add(user_log)
sa.commit()
log.info('Adding user %s, action %s on %s',
username, action, repo)
except Exception as e:
sa.rollback()
log.error('could not log user action:%s', str(e))
def __invalidate_cache(self, repo_name):
"""we know that some change was made to repositories and we should
invalidate the cache to see the changes right away but only for
push requests"""
invalidate_cache('cached_repo_list')
invalidate_cache('full_changelog', repo_name)
def load_web_settings(self, hgserve):
repoui = make_ui(os.path.join(self.repo_path, '.hg', 'hgrc'), False)
#set the global ui for hgserve
hgserve.repo.ui = self.baseui
if repoui:
#set the repository based config
hgserve.repo.ui = repoui
return hgserve
|