comparison mercurial/hgweb/hgweb_mod.py @ 35856:ef3a24a023ec

wireprotoserver: rename hgweb.protocol to wireprotoserver (API)

The HTTP wire protocol server / response handler is currently defined
in the hgweb sub-package. That only kind of makes sense. hgweb does
contain most of the HTTP server code. However, hgweb is more tailored
for providing HTTP server and WSGI scaffolding and serving hgweb
requests. The wire protocol is kind of its own beast.

In addition, the code for HTTP and SSH wire protocol handling is
actually pretty small and it needs to stay in sync to ensure parity
between the transport implementations.

We rename mercurial/hgweb/protocol.py to mercurial/wireprotoserver.py.
The new module will eventually become the home of the SSH handler
as well.

.. api::

   Content from mercurial.hgweb.protocol has been moved to
   mercurial.wireprotoserver.

Differential Revision: https://phab.mercurial-scm.org/D1965

35855:69d7fcd91696

    repoview,
    templatefilters,
    templater,
    ui as uimod,
    util,
)

from . import (
    protocol,
    webcommands,
    webutil,
    wsgicgi,
)

        # process this if it's a protocol request
        # protocol bits don't need to create any URLs
        # and the clients always use the old URL structure

        cmd = pycompat.sysbytes(req.form.get(r'cmd', [r''])[0])
        if protocol.iscmd(cmd):
            try:
                if query:
                    raise ErrorResponse(HTTP_NOT_FOUND)
                if cmd in perms:
                    self.check_perm(rctx, req, perms[cmd])
                return protocol.call(rctx.repo, req, cmd)
            except ErrorResponse as inst:
                # A client that sends unbundle without 100-continue will
                # break if we respond early.
                if (cmd == 'unbundle' and
                    (req.env.get('HTTP_EXPECT',
                                 '').lower() != '100-continue') or
                    req.env.get('X-HgHttp2', '')):
                    req.drain()
                else:
                    req.headers.append((r'Connection', r'Close'))
                req.respond(inst, protocol.HGTYPE,
                            body='0\n%s\n' % inst)
                return ''

        # translate user-visible url structure to internal structure

35856:ef3a24a023ec

    repoview,
    templatefilters,
    templater,
    ui as uimod,
    util,
    wireprotoserver,
)

from . import (
    webcommands,
    webutil,
    wsgicgi,
)

        # process this if it's a protocol request
        # protocol bits don't need to create any URLs
        # and the clients always use the old URL structure

        cmd = pycompat.sysbytes(req.form.get(r'cmd', [r''])[0])
        if wireprotoserver.iscmd(cmd):
            try:
                if query:
                    raise ErrorResponse(HTTP_NOT_FOUND)
                if cmd in perms:
                    self.check_perm(rctx, req, perms[cmd])
                return wireprotoserver.call(rctx.repo, req, cmd)
            except ErrorResponse as inst:
                # A client that sends unbundle without 100-continue will
                # break if we respond early.
                if (cmd == 'unbundle' and
                    (req.env.get('HTTP_EXPECT',
                                 '').lower() != '100-continue') or
                    req.env.get('X-HgHttp2', '')):
                    req.drain()
                else:
                    req.headers.append((r'Connection', r'Close'))
                req.respond(inst, wireprotoserver.HGTYPE,
                            body='0\n%s\n' % inst)
                return ''

        # translate user-visible url structure to internal structure