dumbhttp.py
113 lines
| 2.7 KiB
| text/x-python
|
PythonLexer
/ tests / dumbhttp.py
Gregory Szorc
|
r46434 | #!/usr/bin/env python3 | ||
Mike Hommey
|
r22959 | |||
Gregory Szorc
|
r27282 | from __future__ import absolute_import | ||
Mike Hommey
|
r22959 | """ | ||
Small and dumb HTTP server for use in tests. | ||||
""" | ||||
Gregory Szorc
|
r27282 | import optparse | ||
Jun Wu
|
r31004 | import os | ||
Gregory Szorc
|
r27282 | import signal | ||
Jun Wu
|
r31004 | import socket | ||
Gregory Szorc
|
r27282 | import sys | ||
Mike Hommey
|
r22959 | |||
Gregory Szorc
|
r27282 | from mercurial import ( | ||
Yuya Nishihara
|
r38612 | encoding, | ||
Pulkit Goyal
|
r37690 | pycompat, | ||
Yuya Nishihara
|
r30506 | server, | ||
Pulkit Goyal
|
r29566 | util, | ||
Gregory Szorc
|
r27282 | ) | ||
Pulkit Goyal
|
r29566 | httpserver = util.httpserver | ||
Gregory Szorc
|
r27282 | OptionParser = optparse.OptionParser | ||
Mike Hommey
|
r22959 | |||
Jun Wu
|
r31004 | if os.environ.get('HGIPV6', '0') == '1': | ||
Augie Fackler
|
r43346 | |||
Jun Wu
|
r31004 | class simplehttpserver(httpserver.httpserver): | ||
address_family = socket.AF_INET6 | ||||
Augie Fackler
|
r43346 | |||
Jun Wu
|
r31004 | else: | ||
simplehttpserver = httpserver.httpserver | ||||
Augie Fackler
|
r43346 | |||
Yuya Nishihara
|
r34945 | class _httprequesthandler(httpserver.simplehttprequesthandler): | ||
def log_message(self, format, *args): | ||||
httpserver.simplehttprequesthandler.log_message(self, format, *args) | ||||
sys.stderr.flush() | ||||
Augie Fackler
|
r43346 | |||
Yuya Nishihara
|
r23136 | class simplehttpservice(object): | ||
def __init__(self, host, port): | ||||
self.address = (host, port) | ||||
Augie Fackler
|
r43346 | |||
Yuya Nishihara
|
r23136 | def init(self): | ||
Yuya Nishihara
|
r34945 | self.httpd = simplehttpserver(self.address, _httprequesthandler) | ||
Augie Fackler
|
r43346 | |||
Yuya Nishihara
|
r23136 | def run(self): | ||
self.httpd.serve_forever() | ||||
Mike Hommey
|
r22959 | |||
Augie Fackler
|
r43346 | |||
Mike Hommey
|
r22959 | if __name__ == '__main__': | ||
parser = OptionParser() | ||||
Augie Fackler
|
r43346 | parser.add_option( | ||
'-p', | ||||
'--port', | ||||
dest='port', | ||||
type='int', | ||||
default=8000, | ||||
help='TCP port to listen on', | ||||
metavar='PORT', | ||||
) | ||||
parser.add_option( | ||||
'-H', | ||||
'--host', | ||||
dest='host', | ||||
default='localhost', | ||||
help='hostname or IP to listen on', | ||||
metavar='HOST', | ||||
) | ||||
Yuya Nishihara
|
r34926 | parser.add_option('--logfile', help='file name of access/error log') | ||
Augie Fackler
|
r43346 | parser.add_option( | ||
'--pid', | ||||
dest='pid', | ||||
help='file name where the PID of the server is stored', | ||||
) | ||||
parser.add_option( | ||||
'-f', | ||||
'--foreground', | ||||
dest='foreground', | ||||
Mike Hommey
|
r22959 | action='store_true', | ||
Augie Fackler
|
r43346 | help='do not start the HTTP server in the background', | ||
) | ||||
Jun Wu
|
r28451 | parser.add_option('--daemon-postexec', action='append') | ||
Mike Hommey
|
r22959 | |||
(options, args) = parser.parse_args() | ||||
signal.signal(signal.SIGTERM, lambda x, y: sys.exit(0)) | ||||
Yuya Nishihara
|
r34926 | if options.foreground and options.logfile: | ||
Augie Fackler
|
r43346 | parser.error( | ||
"options --logfile and --foreground are mutually " "exclusive" | ||||
) | ||||
Mike Hommey
|
r22959 | if options.foreground and options.pid: | ||
parser.error("options --pid and --foreground are mutually exclusive") | ||||
Augie Fackler
|
r43346 | opts = { | ||
b'pid_file': options.pid, | ||||
b'daemon': not options.foreground, | ||||
b'daemon_postexec': pycompat.rapply( | ||||
encoding.strtolocal, options.daemon_postexec | ||||
), | ||||
} | ||||
Yuya Nishihara
|
r23136 | service = simplehttpservice(options.host, options.port) | ||
Pulkit Goyal
|
r37690 | runargs = [sys.executable, __file__] + sys.argv[1:] | ||
runargs = [pycompat.fsencode(a) for a in runargs] | ||||
Augie Fackler
|
r43346 | server.runservice( | ||
opts, | ||||
initfn=service.init, | ||||
runfn=service.run, | ||||
logfile=options.logfile, | ||||
runargs=runargs, | ||||
) | ||||