comparison mercurial/exchange.py @ 37168:a2b350d9f6ae

bundlespec: add support for some variants

This way the stream v2 bundle spec can disable the changegroup part while
enabling the stream v2 part.

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

37167:6f467adf9f05

        'cg.version': 's1'
    }
}
_bundlespeccontentopts['bundle2'] = _bundlespeccontentopts['v2']

# Compression engines allowed in version 1. THIS SHOULD NEVER CHANGE.
_bundlespecv1compengines = {'gzip', 'bzip2', 'none'}

@attr.s
class bundlespec(object):

                      ', '.join(sorted(missingreqs)))

    # Compute contentopts based on the version
    contentopts = _bundlespeccontentopts.get(version, {}).copy()

    if not externalnames:
        engine = util.compengines.forbundlename(compression)
        compression = engine.bundletype()[1]
        version = _bundlespeccgversions[version]

                else:
                    raise error.Abort(_('changegroup version %s does not have '
                                        'a known bundlespec') % version,
                                      hint=_('try upgrading your Mercurial '
                                              'client'))

        if not version:
            raise error.Abort(_('could not identify changegroup version in '
                                'bundle'))

37168:a2b350d9f6ae

        'cg.version': 's1'
    }
}
_bundlespeccontentopts['bundle2'] = _bundlespeccontentopts['v2']

_bundlespecvariants = {"streamv2": {"changegroup": False, "streamv2": True,
                                    "tagsfnodescache": False,
                                    "revbranchcache": False}}

# Compression engines allowed in version 1. THIS SHOULD NEVER CHANGE.
_bundlespecv1compengines = {'gzip', 'bzip2', 'none'}

@attr.s
class bundlespec(object):

                      ', '.join(sorted(missingreqs)))

    # Compute contentopts based on the version
    contentopts = _bundlespeccontentopts.get(version, {}).copy()

    # Process the variants
    if "stream" in params and params["stream"] == "v2":
        variant = _bundlespecvariants["streamv2"]
        contentopts.update(variant)

    if not externalnames:
        engine = util.compengines.forbundlename(compression)
        compression = engine.bundletype()[1]
        version = _bundlespeccgversions[version]

                else:
                    raise error.Abort(_('changegroup version %s does not have '
                                        'a known bundlespec') % version,
                                      hint=_('try upgrading your Mercurial '
                                              'client'))
            elif part.type == 'stream2' and version is None:
                # A stream2 part requires to be part of a v2 bundle
                version = "v2"
                requirements = urlreq.unquote(part.params['requirements'])
                splitted = requirements.split()
                params = bundle2._formatrequirementsparams(splitted)
                return 'none-v2;stream=v2;%s' % params

        if not version:
            raise error.Abort(_('could not identify changegroup version in '
                                'bundle'))