( )⚙ D2194 narrowwirepeer: add TODO about how we add wireproto args to unbundle :(

This is an archive of the discontinued Mercurial Phabricator instance.

Differential D2194

narrowwirepeer: add TODO about how we add wireproto args to unbundle :(
ClosedPublic

Authored by durin42 on Feb 12 2018, 3:03 PM.

Details

Reviewers
indygreg
Group Reviewers
hg-reviewers
Commits
rHGb60c577b6e03: narrowwirepeer: add TODO about how we add wireproto args to unbundle :(
Summary

Diff Detail

Repository
rHG Mercurial
Lint
Lint Skipped
Unit
Unit Tests Skipped

Event Timeline

durin42 created this revision.Feb 12 2018, 3:03 PM
indygreg accepted this revision.Feb 12 2018, 5:56 PM
This revision is now accepted and ready to land.Feb 12 2018, 5:56 PM
Closed by commit rHGb60c577b6e03: narrowwirepeer: add TODO about how we add wireproto args to unbundle :( (authored by durin42). · Explain WhyFeb 12 2018, 6:18 PM
This revision was automatically updated to reflect the committed changes.

Revision Contents
Changeset List

PathPackages
Mhgext/narrow/narrowwirepeer.py (2 lines)

Diff 5510

hgext/narrow/narrowwirepeer.py

return narrowspec.parseserverpatterns(new_narrowspec) return narrowspec.parseserverpatterns(new_narrowspec)
peer.__class__ = expandingpeer peer.__class__ = expandingpeer
hg.wirepeersetupfuncs.append(peersetup) hg.wirepeersetupfuncs.append(peersetup)
def reposetup(repo): def reposetup(repo):
def wirereposetup(ui, peer): def wirereposetup(ui, peer):
def wrapped(orig, cmd, *args, **kwargs): def wrapped(orig, cmd, *args, **kwargs):
if cmd == 'unbundle': if cmd == 'unbundle':
# TODO: don't blindly add include/exclude wireproto
# arguments to unbundle.
include, exclude = repo.narrowpats include, exclude = repo.narrowpats
kwargs["includepats"] = ','.join(include) kwargs["includepats"] = ','.join(include)
kwargs["excludepats"] = ','.join(exclude) kwargs["excludepats"] = ','.join(exclude)
return orig(cmd, *args, **kwargs) return orig(cmd, *args, **kwargs)
extensions.wrapfunction(peer, '_calltwowaystream', wrapped) extensions.wrapfunction(peer, '_calltwowaystream', wrapped)
hg.wirepeersetupfuncs.append(wirereposetup) hg.wirepeersetupfuncs.append(wirereposetup)