comparison mercurial/wireproto.py @ 11592:26e0782b8380

protocol: unify client unbundle support

- introduce _callpush helper
- factor out differences in result handling into helpers
- unify

11591:0d9cb3f3b0a1

        bases = " ".join(map(hex, bases))
        heads = " ".join(map(hex, heads))
        return self._decompress(self._callstream("changegroupsubset",
                                                 bases=bases, heads=heads))

# server side

def dispatch(repo, proto, command):
    if command not in commands:
        return False

11592:26e0782b8380

        bases = " ".join(map(hex, bases))
        heads = " ".join(map(hex, heads))
        return self._decompress(self._callstream("changegroupsubset",
                                                 bases=bases, heads=heads))

    def unbundle(self, cg, heads, source):
        '''Send cg (a readable file-like object representing the
        changegroup to push, typically a chunkbuffer object) to the
        remote server as a bundle. Return an integer indicating the
        result of the push (see localrepository.addchangegroup()).'''

        ret, output = self._callpush("unbundle", cg, heads=' '.join(map(hex, heads)))
        if ret == "":
            raise error.ResponseError(
                _('push failed:'), output)
        try:
            ret = int(ret)
        except ValueError, err:
            raise error.ResponseError(
                _('push failed (unexpected response):'), ret)

        for l in output.splitlines(True):
            self.ui.status(_('remote: '), l)
        return ret

# server side

def dispatch(repo, proto, command):
    if command not in commands:
        return False