Gecko [ goons4good.org ]

Name	Size	Permission	Date
__init__.py	1.05 KB	-rw-r--r--	2013-06-01 18:10
__init__.pyc	1.1 KB	-rw-r--r--	2020-03-31 23:33
__init__.pyo	1.1 KB	-rw-r--r--	2020-03-31 23:33
common.py	6.45 KB	-rw-r--r--	2013-06-01 18:10
common.pyc	7.58 KB	-rw-r--r--	2020-03-31 23:33
common.pyo	7.58 KB	-rw-r--r--	2020-03-31 23:33
hgweb_mod.py	15.06 KB	-rw-r--r--	2020-03-31 23:33
hgweb_mod.pyc	12.77 KB	-rw-r--r--	2020-03-31 23:33
hgweb_mod.pyo	12.77 KB	-rw-r--r--	2020-03-31 23:33
hgwebdir_mod.py	17.73 KB	-rw-r--r--	2013-06-01 18:10
hgwebdir_mod.pyc	15.34 KB	-rw-r--r--	2020-03-31 23:33
hgwebdir_mod.pyo	15.34 KB	-rw-r--r--	2020-03-31 23:33
protocol.py	3.13 KB	-rw-r--r--	2020-03-31 23:33
protocol.pyc	4.36 KB	-rw-r--r--	2020-03-31 23:33
protocol.pyo	4.36 KB	-rw-r--r--	2020-03-31 23:33
request.py	4.97 KB	-rw-r--r--	2013-06-01 18:10
request.pyc	5.78 KB	-rw-r--r--	2020-03-31 23:33
request.pyo	5.78 KB	-rw-r--r--	2020-03-31 23:33
server.py	11.49 KB	-rw-r--r--	2013-06-01 18:10
server.pyc	14.71 KB	-rw-r--r--	2020-03-31 23:33
server.pyo	14.71 KB	-rw-r--r--	2020-03-31 23:33
webcommands.py	34.62 KB	-rw-r--r--	2013-06-01 18:10
webcommands.pyc	34.66 KB	-rw-r--r--	2020-03-31 23:33
webcommands.pyo	34.66 KB	-rw-r--r--	2020-03-31 23:33
webutil.py	12.86 KB	-rw-r--r--	2013-06-01 18:10
webutil.pyc	17.75 KB	-rw-r--r--	2020-03-31 23:33
webutil.pyo	17.68 KB	-rw-r--r--	2020-03-31 23:33
wsgicgi.py	2.73 KB	-rw-r--r--	2013-06-01 18:10
wsgicgi.pyc	2.59 KB	-rw-r--r--	2020-03-31 23:33
wsgicgi.pyo	2.59 KB	-rw-r--r--	2020-03-31 23:33

Rename

#
# Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>
# Copyright 2005-2007 Matt Mackall <mpm@selenic.com>
#
# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

import cgi, cStringIO, zlib, urllib
from mercurial import util, wireproto
from common import HTTP_OK

HGTYPE = 'application/mercurial-0.1'
HGERRTYPE = 'application/hg-error'

class webproto(object):
    def __init__(self, req, ui):
        self.req = req
        self.response = ''
        self.ui = ui
        self.checkperm = req.checkperm
    def getargs(self, args):
        knownargs = self._args()
        data = {}
        keys = args.split()
        for k in keys:
            if k == '*':
                star = {}
                for key in knownargs.keys():
                    if key != 'cmd' and key not in keys:
                        star[key] = knownargs[key][0]
                data['*'] = star
            else:
                data[k] = knownargs[k][0]
        return [data[k] for k in keys]
    def _args(self):
        args = self.req.form.copy()
        chunks = []
        i = 1
        while True:
            h = self.req.env.get('HTTP_X_HGARG_' + str(i))
            if h is None:
                break
            chunks += [h]
            i += 1
        args.update(cgi.parse_qs(''.join(chunks), keep_blank_values=True))
        return args
    def getfile(self, fp):
        length = int(self.req.env['CONTENT_LENGTH'])
        for s in util.filechunkiter(self.req, limit=length):
            fp.write(s)
    def redirect(self):
        self.oldio = self.ui.fout, self.ui.ferr
        self.ui.ferr = self.ui.fout = cStringIO.StringIO()
    def restore(self):
        val = self.ui.fout.getvalue()
        self.ui.ferr, self.ui.fout = self.oldio
        return val
    def groupchunks(self, cg):
        z = zlib.compressobj()
        while True:
            chunk = cg.read(4096)
            if not chunk:
                break
            yield z.compress(chunk)
        yield z.flush()
    def _client(self):
        return 'remote:%s:%s:%s' % (
            self.req.env.get('wsgi.url_scheme') or 'http',
            urllib.quote(self.req.env.get('REMOTE_HOST', '')),
            urllib.quote(self.req.env.get('REMOTE_USER', '')))

def iscmd(cmd):
    return cmd in wireproto.commands

def call(repo, req, cmd):
    p = webproto(req, repo.ui)
    rsp = wireproto.dispatch(repo, p, cmd)
    if isinstance(rsp, str):
        req.respond(HTTP_OK, HGTYPE, body=rsp)
        return []
    elif isinstance(rsp, wireproto.streamres):
        req.respond(HTTP_OK, HGTYPE)
        return rsp.gen
    elif isinstance(rsp, wireproto.pushres):
        val = p.restore()
        rsp = '%d\n%s' % (rsp.res, val)
        req.respond(HTTP_OK, HGTYPE, body=rsp)
        return []
    elif isinstance(rsp, wireproto.pusherr):
        # drain the incoming bundle
        req.drain()
        p.restore()
        rsp = '0\n%s\n' % rsp.res
        req.respond(HTTP_OK, HGTYPE, body=rsp)
        return []
    elif isinstance(rsp, wireproto.ooberror):
        rsp = rsp.message
        req.respond(HTTP_OK, HGERRTYPE, body=rsp)
        return []