comparison mercurial/hgweb/server.py @ 10640:90a095c24bc4

server: handle server-internal config setup inside server class

10639:a6808629f450

        myui = ui
    else:
        myui = repo.ui
    address = myui.config("web", "address", "")
    port = int(myui.config("web", "port", 8000))
    prefix = myui.config("web", "prefix", "")
    if prefix:
        prefix = "/" + prefix.strip("/")
    use_ipv6 = myui.configbool("web", "ipv6")
    webdir_conf = myui.config("web", "webdir_conf")
    ssl_cert = myui.config("web", "certificate")
    accesslog = openlog(myui.config("web", "accesslog", "-"), sys.stdout)
    errorlog = openlog(myui.config("web", "errorlog", "-"), sys.stderr)

    if webdir_conf:
        hgwebobj = hgwebdir(webdir_conf, ui)
    elif repo is not None:
        hgwebobj = hgweb(hg.repository(repo.ui, repo.root))

        # SO_REUSEADDR has broken semantics on windows
        if os.name == 'nt':
            allow_reuse_address = 0

        def __init__(self, *args, **kargs):
            BaseHTTPServer.HTTPServer.__init__(self, *args, **kargs)
            self.accesslog = accesslog
            self.errorlog = errorlog
            self.daemon_threads = True
            self.application = hgwebobj

            if ssl_cert:
                try:
                    from OpenSSL import SSL
                    ctx = SSL.Context(SSL.SSLv23_METHOD)
                except ImportError:

                sock = socket.socket(self.address_family, self.socket_type)
                self.socket = SSL.Connection(ctx, sock)
                self.server_bind()
                self.server_activate()

            self.addr, self.port = self.socket.getsockname()[0:2]
            self.prefix = prefix
            self.fqaddr = socket.getfqdn(address)

    class IPv6HTTPServer(MercurialHTTPServer):
        address_family = getattr(socket, 'AF_INET6', None)

        def __init__(self, *args, **kwargs):
            if self.address_family is None:
                raise error.RepoError(_('IPv6 is not available on this system'))
            super(IPv6HTTPServer, self).__init__(*args, **kwargs)

    if ssl_cert:
        handler = _shgwebhandler
    else:
        handler = _hgwebhandler

    # ugly hack due to python issue5853 (for threaded use)
    import mimetypes; mimetypes.init()

    try:
        if use_ipv6:
            return IPv6HTTPServer((address, port), handler)
        else:
            return MercurialHTTPServer((address, port), handler)
    except socket.error, inst:
        raise util.Abort(_("cannot start server at '%s:%d': %s")
                         % (address, port, inst.args[1]))

10640:90a095c24bc4

        myui = ui
    else:
        myui = repo.ui
    address = myui.config("web", "address", "")
    port = int(myui.config("web", "port", 8000))
    use_ipv6 = myui.configbool("web", "ipv6")
    webdir_conf = myui.config("web", "webdir_conf")

    if webdir_conf:
        hgwebobj = hgwebdir(webdir_conf, ui)
    elif repo is not None:
        hgwebobj = hgweb(hg.repository(repo.ui, repo.root))

        # SO_REUSEADDR has broken semantics on windows
        if os.name == 'nt':
            allow_reuse_address = 0

        def __init__(self, ui, *args, **kargs):
            BaseHTTPServer.HTTPServer.__init__(self, *args, **kargs)
            self.daemon_threads = True
            self.application = hgwebobj

            ssl_cert = ui.config('web', 'certificate')
            if ssl_cert:
                try:
                    from OpenSSL import SSL
                    ctx = SSL.Context(SSL.SSLv23_METHOD)
                except ImportError:

                sock = socket.socket(self.address_family, self.socket_type)
                self.socket = SSL.Connection(ctx, sock)
                self.server_bind()
                self.server_activate()

            prefix = ui.config('web', 'prefix', '')
            if prefix:
                prefix = '/' + prefix.strip('/')
            self.prefix = prefix

            alog = openlog(ui.config('web', 'accesslog', '-'), sys.stdout)
            elog = openlog(ui.config('web', 'errorlog', '-'), sys.stderr)
            self.accesslog = alog
            self.errorlog = elog

            self.addr, self.port = self.socket.getsockname()[0:2]
            self.fqaddr = socket.getfqdn(address)

    class IPv6HTTPServer(MercurialHTTPServer):
        address_family = getattr(socket, 'AF_INET6', None)

        def __init__(self, *args, **kwargs):
            if self.address_family is None:
                raise error.RepoError(_('IPv6 is not available on this system'))
            super(IPv6HTTPServer, self).__init__(*args, **kwargs)

    if myui.config('web', 'certificate'):
        handler = _shgwebhandler
    else:
        handler = _hgwebhandler

    # ugly hack due to python issue5853 (for threaded use)
    import mimetypes; mimetypes.init()

    try:
        if use_ipv6:
            return IPv6HTTPServer(myui, (address, port), handler)
        else:
            return MercurialHTTPServer(myui, (address, port), handler)
    except socket.error, inst:
        raise util.Abort(_("cannot start server at '%s:%d': %s")
                         % (address, port, inst.args[1]))