( )⚙ D1949 streamclone: extract requirements formatting

This is an archive of the discontinued Mercurial Phabricator instance.

Differential D1949

streamclone: extract requirements formatting
ClosedPublic

Authored by lothiraldan on Jan 31 2018, 11:24 AM.

Details

Reviewers
None
Group Reviewers
hg-reviewers
Commits
rHG84965e5f3241: streamclone: extract requirements formatting
Summary

It will be reused for the formatting of the requirements of the stream v2 part
requirement and later for the stream v2 requirements.

Diff Detail

Repository
rHG Mercurial
Lint
Automatic diff as part of commit; lint not applicable.
Unit
Automatic diff as part of commit; unit tests not applicable.

Revision Contents
Changeset List

PathPackages
Mmercurial/exchange.py (11 lines)

Diff 5030

mercurial/exchange.py

return changegroup.cg1unpacker(fh, alg) return changegroup.cg1unpacker(fh, alg)
elif version.startswith('2'): elif version.startswith('2'):
return bundle2.getunbundler(ui, fh, magicstring=magic + version) return bundle2.getunbundler(ui, fh, magicstring=magic + version)
elif version == 'S1': elif version == 'S1':
return streamclone.streamcloneapplier(fh) return streamclone.streamcloneapplier(fh)
else: else:
raise error.Abort(_('%s: unknown bundle version %s') % (fname, version)) raise error.Abort(_('%s: unknown bundle version %s') % (fname, version))
def _formatrequirementsspec(requirements):
return urlreq.quote(','.join(sorted(requirements)))
def _formatrequirementsparams(requirements):
requirements = _formatrequirementsspec(requirements)
params = "%s%s" % (urlreq.quote("requirements="), requirements)
return params
def getbundlespec(ui, fh): def getbundlespec(ui, fh):
"""Infer the bundlespec from a bundle file handle. """Infer the bundlespec from a bundle file handle.
The input file handle is seeked and the original seek position is not The input file handle is seeked and the original seek position is not
restored. restored.
""" """
def speccompression(alg): def speccompression(alg):
try: try:
if not version: if not version:
raise error.Abort(_('could not identify changegroup version in ' raise error.Abort(_('could not identify changegroup version in '
'bundle')) 'bundle'))
return '%s-%s' % (comp, version) return '%s-%s' % (comp, version)
elif isinstance(b, streamclone.streamcloneapplier): elif isinstance(b, streamclone.streamcloneapplier):
requirements = streamclone.readbundle1header(fh)[2] requirements = streamclone.readbundle1header(fh)[2]
params = 'requirements=%s' % ','.join(sorted(requirements)) return 'none-packed1;%s' % _formatrequirementsparams(requirements)
return 'none-packed1;%s' % urlreq.quote(params)
else: else:
raise error.Abort(_('unknown bundle type: %s') % b) raise error.Abort(_('unknown bundle type: %s') % b)
def _computeoutgoing(repo, heads, common): def _computeoutgoing(repo, heads, common):
"""Computes which revs are outgoing given a set of common """Computes which revs are outgoing given a set of common
and a set of heads. and a set of heads.
This is a separate function so extensions can have access to This is a separate function so extensions can have access to