comparison mercurial/localrepo.py @ 37615:f3dc8239e3a9

peer: scatter module to the wind (API)

peer.py hardly contained any code. The code it did contain was
generic to the version 1 peer interface or specific to the
local repository peer.

So code has been moved to wireprotov1peer and localrepo, as
appropriate.

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

37614:a81d02ea65db

    mergeutil,
    namespaces,
    narrowspec,
    obsolete,
    pathutil,
    peer,
    phases,
    pushkey,
    pycompat,
    repository,
    repoview,

    tags as tagsmod,
    transaction,
    txnutil,
    util,
    vfs as vfsmod,
)
from .utils import (
    procutil,
    stringutil,
)

    return wrapper

moderncaps = {'lookup', 'branchmap', 'pushkey', 'known', 'getbundle',
              'unbundle'}
legacycaps = moderncaps.union({'changegroupsubset'})

class localpeer(repository.peer):
    '''peer for a local repo; reflects only the most recent API'''

    def __init__(self, repo, caps=None):

    # End of _basewirecommands interface.

    # Begin of peer interface.

    def iterbatch(self):
        return peer.localiterbatcher(self)

    # End of peer interface.

class locallegacypeer(repository.legacypeer, localpeer):
    '''peer extension which implements legacy methods too; used for tests with

37615:f3dc8239e3a9

    mergeutil,
    namespaces,
    narrowspec,
    obsolete,
    pathutil,
    phases,
    pushkey,
    pycompat,
    repository,
    repoview,

    tags as tagsmod,
    transaction,
    txnutil,
    util,
    vfs as vfsmod,
    wireprotov1peer,
)
from .utils import (
    procutil,
    stringutil,
)

    return wrapper

moderncaps = {'lookup', 'branchmap', 'pushkey', 'known', 'getbundle',
              'unbundle'}
legacycaps = moderncaps.union({'changegroupsubset'})

class localiterbatcher(wireprotov1peer.iterbatcher):
    def __init__(self, local):
        super(localiterbatcher, self).__init__()
        self.local = local

    def submit(self):
        # submit for a local iter batcher is a noop
        pass

    def results(self):
        for name, args, opts, resref in self.calls:
            resref.set(getattr(self.local, name)(*args, **opts))
            yield resref.value

class localpeer(repository.peer):
    '''peer for a local repo; reflects only the most recent API'''

    def __init__(self, repo, caps=None):

    # End of _basewirecommands interface.

    # Begin of peer interface.

    def iterbatch(self):
        return localiterbatcher(self)

    # End of peer interface.

class locallegacypeer(repository.legacypeer, localpeer):
    '''peer extension which implements legacy methods too; used for tests with