Mercurial > hg > gitweb
changeset 1159:b6f5a947e62e
Change use of global sys.stdout, sys.stdin os.environ to a hgrequest object.
Note: also change hgrequest.write(str(thing)) to hgrequest.write(thing),
people should make sure they write strings.
| author | Vincent Wagelaar <vincent@ricardis.tudelft.nl> |
|---|---|
| date | Tue, 30 Aug 2005 10:57:52 +0200 |
| parents | c3cb9f39a91f |
| children | 0da98529a476 |
| files | mercurial/hgweb.py |
| diffstat | 1 files changed, 96 insertions(+), 83 deletions(-) [+] |
line wrap: on
line diff
--- a/mercurial/hgweb.py Mon Aug 29 12:15:37 2005 -0700 +++ b/mercurial/hgweb.py Tue Aug 30 10:57:52 2005 +0200 @@ -60,26 +60,38 @@ return "/" return up + "/" -def httphdr(type, file="", size=0): - sys.stdout.write('Content-type: %s\n' % type) - if file: - sys.stdout.write('Content-disposition: attachment; filename=%s\n' - % file) - if size > 0: - sys.stdout.write('Content-length: %d\n' % size) - sys.stdout.write('\n') +class hgrequest: + def __init__(self, inp=None, out=None, env=None): + self.inp = inp or sys.stdin + self.out = out or sys.stdout + self.env = env or os.environ + self.form = cgi.parse(self.inp, self.env) -def write(*things): - for thing in things: - if hasattr(thing, "__iter__"): - for part in thing: - write(part) - else: - try: - sys.stdout.write(str(thing)) - except socket.error, x: - if x[0] != errno.ECONNRESET: - raise + def write(self, *things): + for thing in things: + if hasattr(thing, "__iter__"): + for part in thing: + self.write(part) + else: + try: + self.out.write(thing) + except socket.error, x: + if x[0] != errno.ECONNRESET: + raise + + def header(self, headers=[('Content-type','text/html')]): + for header in headers: + self.out.write("%s: %s\r\n" % header) + self.out.write("\r\n") + + def httphdr(self, type, file="", size=0): + + headers = [('Content-type', type)] + if file: + headers.append(('Content-disposition', 'attachment; filename=%s' % file)) + if size > 0: + headers.append(('Content-length', str(size))) + self.header(headers) class templater: def __init__(self, mapfile, filters={}, defaults={}): @@ -154,6 +166,8 @@ "rfc822date": rfc822date, } + + class hgweb: def __init__(self, repo, name=None): if type(repo) == type(""): @@ -635,7 +649,7 @@ cl.parents(n), cl.rev), diff=diff) - def archive(self, cnode, type): + def archive(self, req, cnode, type): cs = self.repo.changelog.read(cnode) mnode = cs[0] mf = self.repo.manifest.read(mnode) @@ -658,9 +672,9 @@ zf.close() f = open(tmp, 'r') - httphdr('application/zip', name[:-1] + '.zip', + req.httphdr('application/zip', name[:-1] + '.zip', os.path.getsize(tmp)) - sys.stdout.write(f.read()) + req.write(f.read()) f.close() finally: os.unlink(tmp) @@ -670,11 +684,11 @@ import time import tarfile - tf = tarfile.TarFile.open(mode='w|' + type, fileobj=sys.stdout) + tf = tarfile.TarFile.open(mode='w|' + type, fileobj=req.out) mff = self.repo.manifest.readflags(mnode) mtime = int(time.time()) - httphdr('application/octet-stream', name[:-1] + '.tar.' + type) + req.httphdr('application/octet-stream', name[:-1] + '.tar.' + type) for fname in files: rcont = self.repo.file(fname).read(mf[fname]) finfo = tarfile.TarInfo(name + fname) @@ -688,7 +702,7 @@ # tags -> list of changesets corresponding to tags # find tag, changeset, file - def run(self): + def run(self, req=hgrequest()): def header(**map): yield self.t("header", **map) @@ -696,25 +710,24 @@ yield self.t("footer", **map) self.refresh() - args = cgi.parse() t = self.repo.ui.config("web", "templates", templatepath()) m = os.path.join(t, "map") style = self.repo.ui.config("web", "style", "") - if args.has_key('style'): - style = args['style'][0] + if req.form.has_key('style'): + style = req.form['style'][0] if style: b = os.path.basename("map-" + style) p = os.path.join(t, b) if os.path.isfile(p): m = p - port = os.environ["SERVER_PORT"] + port = req.env["SERVER_PORT"] port = port != "80" and (":" + port) or "" - uri = os.environ["REQUEST_URI"] + uri = req.env["REQUEST_URI"] if "?" in uri: uri = uri.split("?")[0] - url = "http://%s%s%s" % (os.environ["SERVER_NAME"], port, uri) + url = "http://%s%s%s" % (req.env["SERVER_NAME"], port, uri) self.t = templater(m, common_filters, {"url": url, @@ -723,73 +736,73 @@ "footer": footer, }) - if not args.has_key('cmd'): - args['cmd'] = [self.t.cache['default'],] + if not req.form.has_key('cmd'): + req.form['cmd'] = [self.t.cache['default'],] - if args['cmd'][0] == 'changelog': + if req.form['cmd'][0] == 'changelog': c = self.repo.changelog.count() - 1 hi = c - if args.has_key('rev'): - hi = args['rev'][0] + if req.form.has_key('rev'): + hi = req.form['rev'][0] try: hi = self.repo.changelog.rev(self.repo.lookup(hi)) except RepoError: - write(self.search(hi)) + req.write(self.search(hi)) return - write(self.changelog(hi)) + req.write(self.changelog(hi)) - elif args['cmd'][0] == 'changeset': - write(self.changeset(args['node'][0])) + elif req.form['cmd'][0] == 'changeset': + req.write(self.changeset(req.form['node'][0])) - elif args['cmd'][0] == 'manifest': - write(self.manifest(args['manifest'][0], args['path'][0])) + elif req.form['cmd'][0] == 'manifest': + req.write(self.manifest(req.form['manifest'][0], req.form['path'][0])) - elif args['cmd'][0] == 'tags': - write(self.tags()) + elif req.form['cmd'][0] == 'tags': + req.write(self.tags()) - elif args['cmd'][0] == 'filediff': - write(self.filediff(args['file'][0], args['node'][0])) + elif req.form['cmd'][0] == 'filediff': + req.write(self.filediff(req.form['file'][0], req.form['node'][0])) - elif args['cmd'][0] == 'file': - write(self.filerevision(args['file'][0], args['filenode'][0])) + elif req.form['cmd'][0] == 'file': + req.write(self.filerevision(req.form['file'][0], req.form['filenode'][0])) - elif args['cmd'][0] == 'annotate': - write(self.fileannotate(args['file'][0], args['filenode'][0])) + elif req.form['cmd'][0] == 'annotate': + req.write(self.fileannotate(req.form['file'][0], req.form['filenode'][0])) - elif args['cmd'][0] == 'filelog': - write(self.filelog(args['file'][0], args['filenode'][0])) + elif req.form['cmd'][0] == 'filelog': + req.write(self.filelog(req.form['file'][0], req.form['filenode'][0])) - elif args['cmd'][0] == 'heads': - httphdr("application/mercurial-0.1") + elif req.form['cmd'][0] == 'heads': + req.httphdr("application/mercurial-0.1") h = self.repo.heads() - sys.stdout.write(" ".join(map(hex, h)) + "\n") + req.write(" ".join(map(hex, h)) + "\n") - elif args['cmd'][0] == 'branches': - httphdr("application/mercurial-0.1") + elif req.form['cmd'][0] == 'branches': + req.httphdr("application/mercurial-0.1") nodes = [] - if args.has_key('nodes'): - nodes = map(bin, args['nodes'][0].split(" ")) + if req.form.has_key('nodes'): + nodes = map(bin, req.form['nodes'][0].split(" ")) for b in self.repo.branches(nodes): - sys.stdout.write(" ".join(map(hex, b)) + "\n") + req.write(" ".join(map(hex, b)) + "\n") - elif args['cmd'][0] == 'between': - httphdr("application/mercurial-0.1") + elif req.form['cmd'][0] == 'between': + req.httphdr("application/mercurial-0.1") nodes = [] - if args.has_key('pairs'): + if req.form.has_key('pairs'): pairs = [map(bin, p.split("-")) - for p in args['pairs'][0].split(" ")] + for p in req.form['pairs'][0].split(" ")] for b in self.repo.between(pairs): - sys.stdout.write(" ".join(map(hex, b)) + "\n") + req.write(" ".join(map(hex, b)) + "\n") - elif args['cmd'][0] == 'changegroup': - httphdr("application/mercurial-0.1") + elif req.form['cmd'][0] == 'changegroup': + req.httphdr("application/mercurial-0.1") nodes = [] if not self.allowpull: return - if args.has_key('roots'): - nodes = map(bin, args['roots'][0].split(" ")) + if req.form.has_key('roots'): + nodes = map(bin, req.form['roots'][0].split(" ")) z = zlib.compressobj() f = self.repo.changegroup(nodes) @@ -797,22 +810,22 @@ chunk = f.read(4096) if not chunk: break - sys.stdout.write(z.compress(chunk)) + req.write(z.compress(chunk)) - sys.stdout.write(z.flush()) + req.write(z.flush()) - elif args['cmd'][0] == 'archive': - changeset = bin(args['node'][0]) - type = args['type'][0] + elif req.form['cmd'][0] == 'archive': + changeset = bin(req.form['node'][0]) + type = req.form['type'][0] if (type in self.archives and self.repo.ui.configbool("web", "allow" + type, False)): - self.archive(changeset, type) + self.archive(req, changeset, type) return - write(self.t("error")) + req.write(self.t("error")) else: - write(self.t("error")) + req.write(self.t("error")) def create_server(repo): @@ -933,7 +946,7 @@ self.repos = cp.items("paths") self.repos.sort() - def run(self): + def run(self, req=hgrequest()): def header(**map): yield tmpl("header", **map) @@ -951,7 +964,7 @@ u.readconfig(file(os.path.join(path, '.hg', 'hgrc'))) get = u.config - url = ('/'.join([os.environ["REQUEST_URI"], name]) + url = ('/'.join([req.env["REQUEST_URI"], name]) .replace("//", "/")) yield dict(contact=get("web", "contact") or @@ -965,12 +978,12 @@ parity = 1 - parity - virtual = os.environ.get("PATH_INFO", "").strip('/') + virtual = req.env.get("PATH_INFO", "").strip('/') if virtual: real = dict(self.repos).get(virtual) if real: - hgweb(real).run() + hgweb(real).run(req) else: - write(tmpl("notfound", repo=virtual)) + req.write(tmpl("notfound", repo=virtual)) else: - write(tmpl("index", entries=entries)) + req.write(tmpl("index", entries=entries))