| hg-reviewers |
| Lint Skipped |
| Unit Tests Skipped |
| ] | ] | ||||
| }, | }, | ||||
| "repositoryPHID": "PHID-REPO-hub2hx62ieuqeheznasv", | "repositoryPHID": "PHID-REPO-hub2hx62ieuqeheznasv", | ||||
| "sourcePath": null | "sourcePath": null | ||||
| } | } | ||||
| """ | """ | ||||
| def fetch(params): | def fetch(params): | ||||
| """params -> single drev or None""" | """params -> single drev or None""" | ||||
| key = (params.get(r'ids') or params.get(r'phids') or [None])[0] | key = (params.get(b'ids') or params.get(b'phids') or [None])[0] | ||||
| if key in prefetched: | if key in prefetched: | ||||
| return prefetched[key] | return prefetched[key] | ||||
| drevs = callconduit(repo, b'differential.query', params) | drevs = callconduit(repo, b'differential.query', params) | ||||
| # Fill prefetched with the result | # Fill prefetched with the result | ||||
| for drev in drevs: | for drev in drevs: | ||||
| prefetched[drev[b'phid']] = drev | prefetched[drev[b'phid']] = drev | ||||
| prefetched[int(drev[b'id'])] = drev | prefetched[int(drev[b'id'])] = drev | ||||
| if key not in prefetched: | if key not in prefetched: | ||||
| raise error.Abort(_(b'cannot get Differential Revision %r') | raise error.Abort(_(b'cannot get Differential Revision %r') | ||||
| % params) | % params) | ||||
| return prefetched[key] | return prefetched[key] | ||||
| def getstack(topdrevids): | def getstack(topdrevids): | ||||
| """given a top, get a stack from the bottom, [id] -> [id]""" | """given a top, get a stack from the bottom, [id] -> [id]""" | ||||
| visited = set() | visited = set() | ||||
| result = [] | result = [] | ||||
| queue = [{r'ids': [i]} for i in topdrevids] | queue = [{b'ids': [i]} for i in topdrevids] | ||||
| while queue: | while queue: | ||||
| params = queue.pop() | params = queue.pop() | ||||
| drev = fetch(params) | drev = fetch(params) | ||||
| if drev[b'id'] in visited: | if drev[b'id'] in visited: | ||||
| continue | continue | ||||
| visited.add(drev[b'id']) | visited.add(drev[b'id']) | ||||
| result.append(int(drev[b'id'])) | result.append(int(drev[b'id'])) | ||||
| auxiliary = drev.get(b'auxiliary', {}) | auxiliary = drev.get(b'auxiliary', {}) | ||||
| body = callconduit(repo, b'differential.getrawdiff', | body = callconduit(repo, b'differential.getrawdiff', | ||||
| {b'diffID': diffid}) | {b'diffID': diffid}) | ||||
| desc = getdescfromdrev(drev) | desc = getdescfromdrev(drev) | ||||
| header = b'# HG changeset patch\n' | header = b'# HG changeset patch\n' | ||||
| # Try to preserve metadata from hg:meta property. Write hg patch | # Try to preserve metadata from hg:meta property. Write hg patch | ||||
| # headers that can be read by the "import" command. See patchheadermap | # headers that can be read by the "import" command. See patchheadermap | ||||
| # and extract in mercurial/patch.py for supported headers. | # and extract in mercurial/patch.py for supported headers. | ||||
| meta = getdiffmeta(diffs[str(diffid)]) | meta = getdiffmeta(diffs[b'%d' % diffid]) | ||||
| for k in _metanamemap.keys(): | for k in _metanamemap.keys(): | ||||
| if k in meta: | if k in meta: | ||||
| header += b'# %s %s\n' % (_metanamemap[k], meta[k]) | header += b'# %s %s\n' % (_metanamemap[k], meta[k]) | ||||
| content = b'%s%s\n%s' % (header, desc, body) | content = b'%s%s\n%s' % (header, desc, body) | ||||
| write(content) | write(content) | ||||
| @vcrcommand(b'phabread', | @vcrcommand(b'phabread', | ||||