| hg-reviewers |
We will need to access these logic form the copies module. So we move them from
their higher level module to the lower level copies module. We cannot use them
from their top level module as it would create cycles.
| Lint Skipped |
| Unit Tests Skipped |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/changelog.py (72 lines) | |||
| M | mercurial/context.py (8 lines) | |||
| M | mercurial/copies.py (76 lines) | |||
| M | mercurial/scmutil.py (20 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| c07badb1d42b | a0c4e732da8b | Pierre-Yves David | Oct 6 2019, 11:36 PM |
| from .node import ( | from .node import ( | ||||
| bin, | bin, | ||||
| hex, | hex, | ||||
| nullid, | nullid, | ||||
| ) | ) | ||||
| from .thirdparty import attr | from .thirdparty import attr | ||||
| from . import ( | from . import ( | ||||
| copies, | |||||
| encoding, | encoding, | ||||
| error, | error, | ||||
| pycompat, | pycompat, | ||||
| revlog, | revlog, | ||||
| util, | util, | ||||
| ) | ) | ||||
| from .utils import ( | from .utils import ( | ||||
| dateutil, | dateutil, | ||||
| # keys must be sorted to produce a deterministic changelog entry | # keys must be sorted to produce a deterministic changelog entry | ||||
| items = [ | items = [ | ||||
| _string_escape(b'%s:%s' % (k, pycompat.bytestr(d[k]))) | _string_escape(b'%s:%s' % (k, pycompat.bytestr(d[k]))) | ||||
| for k in sorted(d) | for k in sorted(d) | ||||
| ] | ] | ||||
| return b"\0".join(items) | return b"\0".join(items) | ||||
| def encodecopies(files, copies): | |||||
| items = [] | |||||
| for i, dst in enumerate(files): | |||||
| if dst in copies: | |||||
| items.append(b'%d\0%s' % (i, copies[dst])) | |||||
| if len(items) != len(copies): | |||||
| raise error.ProgrammingError( | |||||
| b'some copy targets missing from file list' | |||||
| ) | |||||
| return b"\n".join(items) | |||||
| def decodecopies(files, data): | |||||
| try: | |||||
| copies = {} | |||||
| if not data: | |||||
| return copies | |||||
| for l in data.split(b'\n'): | |||||
| strindex, src = l.split(b'\0') | |||||
| i = int(strindex) | |||||
| dst = files[i] | |||||
| copies[dst] = src | |||||
| return copies | |||||
| except (ValueError, IndexError): | |||||
| # Perhaps someone had chosen the same key name (e.g. "p1copies") and | |||||
| # used different syntax for the value. | |||||
| return None | |||||
| def encodefileindices(files, subset): | |||||
| subset = set(subset) | |||||
| indices = [] | |||||
| for i, f in enumerate(files): | |||||
| if f in subset: | |||||
| indices.append(b'%d' % i) | |||||
| return b'\n'.join(indices) | |||||
| def decodefileindices(files, data): | |||||
| try: | |||||
| subset = [] | |||||
| if not data: | |||||
| return subset | |||||
| for strindex in data.split(b'\n'): | |||||
| i = int(strindex) | |||||
| if i < 0 or i >= len(files): | |||||
| return None | |||||
| subset.append(files[i]) | |||||
| return subset | |||||
| except (ValueError, IndexError): | |||||
| # Perhaps someone had chosen the same key name (e.g. "added") and | |||||
| # used different syntax for the value. | |||||
| return None | |||||
| def stripdesc(desc): | def stripdesc(desc): | ||||
| """strip trailing whitespace and leading and trailing empty lines""" | """strip trailing whitespace and leading and trailing empty lines""" | ||||
| return b'\n'.join([l.rstrip() for l in desc.splitlines()]).strip(b'\n') | return b'\n'.join([l.rstrip() for l in desc.splitlines()]).strip(b'\n') | ||||
| class appender(object): | class appender(object): | ||||
| '''the changelog index must be updated last on disk, so we use this class | '''the changelog index must be updated last on disk, so we use this class | ||||
| to delay writes to it''' | to delay writes to it''' | ||||
| @property | @property | ||||
| def filesadded(self): | def filesadded(self): | ||||
| if sidedatamod.SD_FILESADDED in self._sidedata: | if sidedatamod.SD_FILESADDED in self._sidedata: | ||||
| rawindices = self._sidedata.get(sidedatamod.SD_FILESADDED) | rawindices = self._sidedata.get(sidedatamod.SD_FILESADDED) | ||||
| else: | else: | ||||
| rawindices = self.extra.get(b'filesadded') | rawindices = self.extra.get(b'filesadded') | ||||
| if rawindices is not None: | if rawindices is not None: | ||||
| rawindices = decodefileindices(self.files, rawindices) | rawindices = copies.decodefileindices(self.files, rawindices) | ||||
| return rawindices | return rawindices | ||||
| @property | @property | ||||
| def filesremoved(self): | def filesremoved(self): | ||||
| if sidedatamod.SD_FILESREMOVED in self._sidedata: | if sidedatamod.SD_FILESREMOVED in self._sidedata: | ||||
| rawindices = self._sidedata.get(sidedatamod.SD_FILESREMOVED) | rawindices = self._sidedata.get(sidedatamod.SD_FILESREMOVED) | ||||
| else: | else: | ||||
| rawindices = self.extra.get(b'filesremoved') | rawindices = self.extra.get(b'filesremoved') | ||||
| if rawindices is not None: | if rawindices is not None: | ||||
| rawindices = decodefileindices(self.files, rawindices) | rawindices = copies.decodefileindices(self.files, rawindices) | ||||
| return rawindices | return rawindices | ||||
| @property | @property | ||||
| def p1copies(self): | def p1copies(self): | ||||
| if sidedatamod.SD_P1COPIES in self._sidedata: | if sidedatamod.SD_P1COPIES in self._sidedata: | ||||
| rawcopies = self._sidedata.get(sidedatamod.SD_P1COPIES) | rawcopies = self._sidedata.get(sidedatamod.SD_P1COPIES) | ||||
| else: | else: | ||||
| rawcopies = self.extra.get(b'p1copies') | rawcopies = self.extra.get(b'p1copies') | ||||
| if rawcopies is not None: | if rawcopies is not None: | ||||
| rawcopies = decodecopies(self.files, rawcopies) | rawcopies = copies.decodecopies(self.files, rawcopies) | ||||
| return rawcopies | return rawcopies | ||||
| @property | @property | ||||
| def p2copies(self): | def p2copies(self): | ||||
| if sidedatamod.SD_P2COPIES in self._sidedata: | if sidedatamod.SD_P2COPIES in self._sidedata: | ||||
| rawcopies = self._sidedata.get(sidedatamod.SD_P2COPIES) | rawcopies = self._sidedata.get(sidedatamod.SD_P2COPIES) | ||||
| else: | else: | ||||
| rawcopies = self.extra.get(b'p2copies') | rawcopies = self.extra.get(b'p2copies') | ||||
| if rawcopies is not None: | if rawcopies is not None: | ||||
| rawcopies = decodecopies(self.files, rawcopies) | rawcopies = copies.decodecopies(self.files, rawcopies) | ||||
| return rawcopies | return rawcopies | ||||
| @property | @property | ||||
| def description(self): | def description(self): | ||||
| return encoding.tolocal(self._text[self._offsets[3] + 2 :]) | return encoding.tolocal(self._text[self._offsets[3] + 2 :]) | ||||
| class changelog(revlog.revlog): | class changelog(revlog.revlog): | ||||
| for name in ( | for name in ( | ||||
| b'p1copies', | b'p1copies', | ||||
| b'p2copies', | b'p2copies', | ||||
| b'filesadded', | b'filesadded', | ||||
| b'filesremoved', | b'filesremoved', | ||||
| ): | ): | ||||
| extra.pop(name, None) | extra.pop(name, None) | ||||
| if p1copies is not None: | if p1copies is not None: | ||||
| p1copies = encodecopies(sortedfiles, p1copies) | p1copies = copies.encodecopies(sortedfiles, p1copies) | ||||
| if p2copies is not None: | if p2copies is not None: | ||||
| p2copies = encodecopies(sortedfiles, p2copies) | p2copies = copies.encodecopies(sortedfiles, p2copies) | ||||
| if filesadded is not None: | if filesadded is not None: | ||||
| filesadded = encodefileindices(sortedfiles, filesadded) | filesadded = copies.encodefileindices(sortedfiles, filesadded) | ||||
| if filesremoved is not None: | if filesremoved is not None: | ||||
| filesremoved = encodefileindices(sortedfiles, filesremoved) | filesremoved = copies.encodefileindices(sortedfiles, filesremoved) | ||||
| if self._copiesstorage == b'extra': | if self._copiesstorage == b'extra': | ||||
| extrasentries = p1copies, p2copies, filesadded, filesremoved | extrasentries = p1copies, p2copies, filesadded, filesremoved | ||||
| if extra is None and any(x is not None for x in extrasentries): | if extra is None and any(x is not None for x in extrasentries): | ||||
| extra = {} | extra = {} | ||||
| if p1copies is not None: | if p1copies is not None: | ||||
| extra[b'p1copies'] = p1copies | extra[b'p1copies'] = p1copies | ||||
| if p2copies is not None: | if p2copies is not None: | ||||
| extra[b'p2copies'] = p2copies | extra[b'p2copies'] = p2copies | ||||
| filesadded = [] | filesadded = [] | ||||
| else: | else: | ||||
| source = self._repo.ui.config(b'experimental', b'copies.read-from') | source = self._repo.ui.config(b'experimental', b'copies.read-from') | ||||
| if source == b'changeset-only': | if source == b'changeset-only': | ||||
| if filesadded is None: | if filesadded is None: | ||||
| filesadded = [] | filesadded = [] | ||||
| elif source == b'compatibility': | elif source == b'compatibility': | ||||
| if filesadded is None: | if filesadded is None: | ||||
| filesadded = scmutil.computechangesetfilesadded(self) | filesadded = copies.computechangesetfilesadded(self) | ||||
| else: | else: | ||||
| filesadded = scmutil.computechangesetfilesadded(self) | filesadded = copies.computechangesetfilesadded(self) | ||||
| return filesadded | return filesadded | ||||
| def filesremoved(self): | def filesremoved(self): | ||||
| filesremoved = self._changeset.filesremoved | filesremoved = self._changeset.filesremoved | ||||
| if self._repo.filecopiesmode == b'changeset-sidedata': | if self._repo.filecopiesmode == b'changeset-sidedata': | ||||
| if filesremoved is None: | if filesremoved is None: | ||||
| filesremoved = [] | filesremoved = [] | ||||
| else: | else: | ||||
| source = self._repo.ui.config(b'experimental', b'copies.read-from') | source = self._repo.ui.config(b'experimental', b'copies.read-from') | ||||
| if source == b'changeset-only': | if source == b'changeset-only': | ||||
| if filesremoved is None: | if filesremoved is None: | ||||
| filesremoved = [] | filesremoved = [] | ||||
| elif source == b'compatibility': | elif source == b'compatibility': | ||||
| if filesremoved is None: | if filesremoved is None: | ||||
| filesremoved = scmutil.computechangesetfilesremoved(self) | filesremoved = copies.computechangesetfilesremoved(self) | ||||
| else: | else: | ||||
| filesremoved = scmutil.computechangesetfilesremoved(self) | filesremoved = copies.computechangesetfilesremoved(self) | ||||
| return filesremoved | return filesremoved | ||||
| @propertycache | @propertycache | ||||
| def _copies(self): | def _copies(self): | ||||
| p1copies = self._changeset.p1copies | p1copies = self._changeset.p1copies | ||||
| p2copies = self._changeset.p2copies | p2copies = self._changeset.p2copies | ||||
| if self._repo.filecopiesmode == b'changeset-sidedata': | if self._repo.filecopiesmode == b'changeset-sidedata': | ||||
| if p1copies is None: | if p1copies is None: | ||||
| # copies.py - copy detection for Mercurial | # copies.py - copy detection for Mercurial | ||||
| # | # | ||||
| # Copyright 2008 Matt Mackall <mpm@selenic.com> | # Copyright 2008 Matt Mackall <mpm@selenic.com> | ||||
| # | # | ||||
| # This software may be used and distributed according to the terms of the | # This software may be used and distributed according to the terms of the | ||||
| # GNU General Public License version 2 or any later version. | # GNU General Public License version 2 or any later version. | ||||
| from __future__ import absolute_import | from __future__ import absolute_import | ||||
| import collections | import collections | ||||
| import heapq | import heapq | ||||
| import os | import os | ||||
| from .i18n import _ | from .i18n import _ | ||||
| from . import ( | from . import ( | ||||
| error, | |||||
| match as matchmod, | match as matchmod, | ||||
| node, | node, | ||||
| pathutil, | pathutil, | ||||
| util, | util, | ||||
| ) | ) | ||||
| from .utils import stringutil | from .utils import stringutil | ||||
| exclude = pathcopies(repo[fromrev], repo[skiprev]) | exclude = pathcopies(repo[fromrev], repo[skiprev]) | ||||
| for dst, src in pathcopies(repo[fromrev], repo[rev]).iteritems(): | for dst, src in pathcopies(repo[fromrev], repo[rev]).iteritems(): | ||||
| if dst in exclude: | if dst in exclude: | ||||
| continue | continue | ||||
| if dst in wctx: | if dst in wctx: | ||||
| wctx[dst].markcopied(src) | wctx[dst].markcopied(src) | ||||
| def computechangesetfilesadded(ctx): | |||||
| """return the list of files added in a changeset | |||||
| """ | |||||
| added = [] | |||||
| for f in ctx.files(): | |||||
| if not any(f in p for p in ctx.parents()): | |||||
| added.append(f) | |||||
| return added | |||||
| def computechangesetfilesremoved(ctx): | |||||
| """return the list of files removed in a changeset | |||||
| """ | |||||
| removed = [] | |||||
| for f in ctx.files(): | |||||
| if f not in ctx: | |||||
| removed.append(f) | |||||
| return removed | |||||
| def computechangesetcopies(ctx): | def computechangesetcopies(ctx): | ||||
| """return the copies data for a changeset | """return the copies data for a changeset | ||||
| The copies data are returned as a pair of dictionnary (p1copies, p2copies). | The copies data are returned as a pair of dictionnary (p1copies, p2copies). | ||||
| Each dictionnary are in the form: `{newname: oldname}` | Each dictionnary are in the form: `{newname: oldname}` | ||||
| """ | """ | ||||
| p1copies = {} | p1copies = {} | ||||
| p2copies = {} | p2copies = {} | ||||
| p1 = ctx.p1() | p1 = ctx.p1() | ||||
| p2 = ctx.p2() | p2 = ctx.p2() | ||||
| narrowmatch = ctx._repo.narrowmatch() | narrowmatch = ctx._repo.narrowmatch() | ||||
| for dst in ctx.files(): | for dst in ctx.files(): | ||||
| if not narrowmatch(dst) or dst not in ctx: | if not narrowmatch(dst) or dst not in ctx: | ||||
| continue | continue | ||||
| copied = ctx[dst].renamed() | copied = ctx[dst].renamed() | ||||
| if not copied: | if not copied: | ||||
| continue | continue | ||||
| src, srcnode = copied | src, srcnode = copied | ||||
| if src in p1 and p1[src].filenode() == srcnode: | if src in p1 and p1[src].filenode() == srcnode: | ||||
| p1copies[dst] = src | p1copies[dst] = src | ||||
| elif src in p2 and p2[src].filenode() == srcnode: | elif src in p2 and p2[src].filenode() == srcnode: | ||||
| p2copies[dst] = src | p2copies[dst] = src | ||||
| return p1copies, p2copies | return p1copies, p2copies | ||||
| def encodecopies(files, copies): | |||||
| items = [] | |||||
| for i, dst in enumerate(files): | |||||
| if dst in copies: | |||||
| items.append(b'%d\0%s' % (i, copies[dst])) | |||||
| if len(items) != len(copies): | |||||
| raise error.ProgrammingError( | |||||
| b'some copy targets missing from file list' | |||||
| ) | |||||
| return b"\n".join(items) | |||||
| def decodecopies(files, data): | |||||
| try: | |||||
| copies = {} | |||||
| if not data: | |||||
| return copies | |||||
| for l in data.split(b'\n'): | |||||
| strindex, src = l.split(b'\0') | |||||
| i = int(strindex) | |||||
| dst = files[i] | |||||
| copies[dst] = src | |||||
| return copies | |||||
| except (ValueError, IndexError): | |||||
| # Perhaps someone had chosen the same key name (e.g. "p1copies") and | |||||
| # used different syntax for the value. | |||||
| return None | |||||
| def encodefileindices(files, subset): | |||||
| subset = set(subset) | |||||
| indices = [] | |||||
| for i, f in enumerate(files): | |||||
| if f in subset: | |||||
| indices.append(b'%d' % i) | |||||
| return b'\n'.join(indices) | |||||
| def decodefileindices(files, data): | |||||
| try: | |||||
| subset = [] | |||||
| if not data: | |||||
| return subset | |||||
| for strindex in data.split(b'\n'): | |||||
| i = int(strindex) | |||||
| if i < 0 or i >= len(files): | |||||
| return None | |||||
| subset.append(files[i]) | |||||
| return subset | |||||
| except (ValueError, IndexError): | |||||
| # Perhaps someone had chosen the same key name (e.g. "added") and | |||||
| # used different syntax for the value. | |||||
| return None | |||||
| return repo.revs( | return repo.revs( | ||||
| b"ancestors(bookmark(%s)) - " | b"ancestors(bookmark(%s)) - " | ||||
| b"ancestors(head() and not bookmark(%s)) - " | b"ancestors(head() and not bookmark(%s)) - " | ||||
| b"ancestors(bookmark() and not bookmark(%s))", | b"ancestors(bookmark() and not bookmark(%s))", | ||||
| mark, | mark, | ||||
| mark, | mark, | ||||
| mark, | mark, | ||||
| ) | ) | ||||
| def computechangesetfilesadded(ctx): | |||||
| """return the list of files added in a changeset | |||||
| """ | |||||
| added = [] | |||||
| for f in ctx.files(): | |||||
| if not any(f in p for p in ctx.parents()): | |||||
| added.append(f) | |||||
| return added | |||||
| def computechangesetfilesremoved(ctx): | |||||
| """return the list of files removed in a changeset | |||||
| """ | |||||
| removed = [] | |||||
| for f in ctx.files(): | |||||
| if f not in ctx: | |||||
| removed.append(f) | |||||
| return removed | |||||