comparison mercurial/wireprotoserver.py @ 37296:78103e4138b1

wireproto: port protocol handler to zope.interface

zope.interface is superior to the abc module. Let's port to it.

As part of this, we add tests for interface conformance for
classes implementing the interface.

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

37295:45b39c69fae0

import struct
import sys
import threading

from .i18n import _
from . import (
    encoding,
    error,
    hook,
    pycompat,

        chunks.append(pycompat.bytesurl(v))
        i += 1

    return ''.join(chunks)

class httpv1protocolhandler(wireprototypes.baseprotocolhandler):
    def __init__(self, req, ui, checkperm):
        self._req = req
        self._ui = ui
        self._checkperm = checkperm

        'config': ('experimental', 'web.api.http-v2'),
        'handler': _handlehttpv2request,
    },
}

class httpv2protocolhandler(wireprototypes.baseprotocolhandler):
    def __init__(self, req, ui, args=None):
        self._req = req
        self._ui = ui
        self._args = args

    ferr.write(b'%s\n-\n' % rsp)
    ferr.flush()
    fout.write(b'\n')
    fout.flush()

class sshv1protocolhandler(wireprototypes.baseprotocolhandler):
    """Handler for requests services via version 1 of SSH protocol."""
    def __init__(self, ui, fin, fout):
        self._ui = ui
        self._fin = fin
        self._fout = fout

37296:78103e4138b1

import struct
import sys
import threading

from .i18n import _
from .thirdparty.zope import (
    interface as zi,
)
from . import (
    encoding,
    error,
    hook,
    pycompat,

        chunks.append(pycompat.bytesurl(v))
        i += 1

    return ''.join(chunks)

@zi.implementer(wireprototypes.baseprotocolhandler)
class httpv1protocolhandler(object):
    def __init__(self, req, ui, checkperm):
        self._req = req
        self._ui = ui
        self._checkperm = checkperm

        'config': ('experimental', 'web.api.http-v2'),
        'handler': _handlehttpv2request,
    },
}

@zi.implementer(wireprototypes.baseprotocolhandler)
class httpv2protocolhandler(object):
    def __init__(self, req, ui, args=None):
        self._req = req
        self._ui = ui
        self._args = args

    ferr.write(b'%s\n-\n' % rsp)
    ferr.flush()
    fout.write(b'\n')
    fout.flush()

@zi.implementer(wireprototypes.baseprotocolhandler)
class sshv1protocolhandler(object):
    """Handler for requests services via version 1 of SSH protocol."""
    def __init__(self, ui, fin, fout):
        self._ui = ui
        self._fin = fin
        self._fout = fout