context.py
799 lines
| 27.4 KiB
| text/x-python
|
PythonLexer
/ mercurial / context.py
|
r2563 | # context.py - changeset and file context objects for mercurial | ||
# | ||||
|
r4635 | # Copyright 2006, 2007 Matt Mackall <mpm@selenic.com> | ||
|
r2563 | # | ||
# This software may be used and distributed according to the terms | ||||
# of the GNU General Public License, incorporated herein by reference. | ||||
|
r6763 | from node import nullid, nullrev, short, hex | ||
|
r3891 | from i18n import _ | ||
|
r6212 | import ancestor, bdiff, revlog, util, os, errno | ||
|
r3122 | |||
|
r2563 | class changectx(object): | ||
"""A changecontext object makes access to data related to a particular | ||||
changeset convenient.""" | ||||
|
r6741 | def __init__(self, repo, changeid=''): | ||
|
r2563 | """changeid is a revision number, node, or tag""" | ||
|
r6741 | if changeid == '': | ||
changeid = '.' | ||||
|
r2563 | self._repo = repo | ||
|
r7367 | if isinstance(changeid, (long, int)): | ||
self._rev = changeid | ||||
self._node = self._repo.changelog.node(changeid) | ||||
else: | ||||
self._node = self._repo.lookup(changeid) | ||||
self._rev = self._repo.changelog.rev(self._node) | ||||
|
r2563 | |||
|
r3166 | def __str__(self): | ||
return short(self.node()) | ||||
|
r6763 | def __int__(self): | ||
return self.rev() | ||||
|
r3151 | def __repr__(self): | ||
|
r3216 | return "<changectx %s>" % str(self) | ||
|
r3151 | |||
|
r6469 | def __hash__(self): | ||
try: | ||||
return hash(self._rev) | ||||
except AttributeError: | ||||
return id(self) | ||||
|
r3165 | def __eq__(self, other): | ||
|
r3715 | try: | ||
return self._rev == other._rev | ||||
except AttributeError: | ||||
return False | ||||
|
r3165 | |||
|
r4748 | def __ne__(self, other): | ||
return not (self == other) | ||||
|
r3168 | def __nonzero__(self): | ||
|
r3578 | return self._rev != nullrev | ||
|
r3168 | |||
|
r3215 | def __getattr__(self, name): | ||
if name == '_changeset': | ||||
|
r2563 | self._changeset = self._repo.changelog.read(self.node()) | ||
return self._changeset | ||||
|
r3215 | elif name == '_manifest': | ||
self._manifest = self._repo.manifest.read(self._changeset[0]) | ||||
|
r2563 | return self._manifest | ||
|
r3337 | elif name == '_manifestdelta': | ||
md = self._repo.manifest.readdelta(self._changeset[0]) | ||||
self._manifestdelta = md | ||||
return self._manifestdelta | ||||
|
r6742 | elif name == '_parents': | ||
|
r7367 | p = self._repo.changelog.parentrevs(self._rev) | ||
if p[1] == nullrev: | ||||
|
r6742 | p = p[:-1] | ||
self._parents = [changectx(self._repo, x) for x in p] | ||||
return self._parents | ||||
|
r3215 | else: | ||
|
r7008 | raise AttributeError(name) | ||
|
r3215 | |||
|
r4909 | def __contains__(self, key): | ||
return key in self._manifest | ||||
def __getitem__(self, key): | ||||
return self.filectx(key) | ||||
def __iter__(self): | ||||
|
r6762 | for f in util.sort(self._manifest): | ||
|
r5485 | yield f | ||
|
r4909 | |||
|
r3215 | def changeset(self): return self._changeset | ||
def manifest(self): return self._manifest | ||||
|
r2563 | |||
def rev(self): return self._rev | ||||
def node(self): return self._node | ||||
|
r6763 | def hex(self): return hex(self._node) | ||
|
r3215 | def user(self): return self._changeset[1] | ||
def date(self): return self._changeset[2] | ||||
def files(self): return self._changeset[3] | ||||
def description(self): return self._changeset[4] | ||||
|
r4178 | def branch(self): return self._changeset[5].get("branch") | ||
|
r5439 | def extra(self): return self._changeset[5] | ||
|
r4663 | def tags(self): return self._repo.nodetags(self._node) | ||
|
r2563 | |||
def parents(self): | ||||
"""return contexts for each parent changeset""" | ||||
|
r6742 | return self._parents | ||
|
r2563 | |||
def children(self): | ||||
"""return contexts for each child changeset""" | ||||
|
r2627 | c = self._repo.changelog.children(self._node) | ||
|
r3673 | return [changectx(self._repo, x) for x in c] | ||
|
r2563 | |||
|
r6876 | def ancestors(self): | ||
for a in self._repo.changelog.ancestors(self._rev): | ||||
yield changectx(self._repo, a) | ||||
def descendants(self): | ||||
for d in self._repo.changelog.descendants(self._rev): | ||||
yield changectx(self._repo, d) | ||||
|
r5389 | def _fileinfo(self, path): | ||
|
r3336 | if '_manifest' in self.__dict__: | ||
|
r3242 | try: | ||
|
r5389 | return self._manifest[path], self._manifest.flags(path) | ||
|
r3242 | except KeyError: | ||
|
r6228 | raise revlog.LookupError(self._node, path, | ||
_('not found in manifest')) | ||||
|
r3337 | if '_manifestdelta' in self.__dict__ or path in self.files(): | ||
if path in self._manifestdelta: | ||||
|
r5389 | return self._manifestdelta[path], self._manifestdelta.flags(path) | ||
|
r3215 | node, flag = self._repo.manifest.find(self._changeset[0], path) | ||
|
r3242 | if not node: | ||
|
r6228 | raise revlog.LookupError(self._node, path, | ||
_('not found in manifest')) | ||||
|
r3242 | |||
|
r5389 | return node, flag | ||
def filenode(self, path): | ||||
return self._fileinfo(path)[0] | ||||
|
r6743 | def flags(self, path): | ||
|
r5389 | try: | ||
return self._fileinfo(path)[1] | ||||
except revlog.LookupError: | ||||
return '' | ||||
|
r2563 | |||
|
r3966 | def filectx(self, path, fileid=None, filelog=None): | ||
|
r2563 | """get a file context from this changeset""" | ||
|
r2628 | if fileid is None: | ||
fileid = self.filenode(path) | ||||
|
r3966 | return filectx(self._repo, path, fileid=fileid, | ||
changectx=self, filelog=filelog) | ||||
|
r2563 | |||
|
r3125 | def ancestor(self, c2): | ||
""" | ||||
return the ancestor context of self and c2 | ||||
""" | ||||
n = self._repo.changelog.ancestor(self._node, c2._node) | ||||
return changectx(self._repo, n) | ||||
|
r6764 | def walk(self, match): | ||
fdict = dict.fromkeys(match.files()) | ||||
# for dirstate.walk, files=['.'] means "walk the whole tree". | ||||
# follow that here, too | ||||
fdict.pop('.', None) | ||||
for fn in self: | ||||
for ffn in fdict: | ||||
# match if the file is the exact name or a directory | ||||
if ffn == fn or fn.startswith("%s/" % ffn): | ||||
del fdict[ffn] | ||||
break | ||||
if match(fn): | ||||
yield fn | ||||
for fn in util.sort(fdict): | ||||
if match.bad(fn, 'No such file in rev ' + str(self)) and match(fn): | ||||
yield fn | ||||
|
r2563 | class filectx(object): | ||
"""A filecontext object makes access to data related to a particular | ||||
filerevision convenient.""" | ||||
|
r3214 | def __init__(self, repo, path, changeid=None, fileid=None, | ||
filelog=None, changectx=None): | ||||
|
r2563 | """changeid can be a changeset revision, node, or tag. | ||
fileid can be a file revision or node.""" | ||||
self._repo = repo | ||||
self._path = path | ||||
|
r3964 | assert (changeid is not None | ||
or fileid is not None | ||||
or changectx is not None) | ||||
|
r2643 | |||
|
r3124 | if filelog: | ||
self._filelog = filelog | ||||
|
r5810 | if changeid is not None: | ||
self._changeid = changeid | ||||
if changectx is not None: | ||||
self._changectx = changectx | ||||
if fileid is not None: | ||||
|
r3213 | self._fileid = fileid | ||
|
r2563 | |||
|
r3144 | def __getattr__(self, name): | ||
if name == '_changectx': | ||||
|
r2643 | self._changectx = changectx(self._repo, self._changeid) | ||
return self._changectx | ||||
|
r3213 | elif name == '_filelog': | ||
self._filelog = self._repo.file(self._path) | ||||
return self._filelog | ||||
elif name == '_changeid': | ||||
|
r5810 | if '_changectx' in self.__dict__: | ||
self._changeid = self._changectx.rev() | ||||
else: | ||||
|
r7361 | self._changeid = self._filelog.linkrev(self._filerev) | ||
|
r3213 | return self._changeid | ||
|
r3144 | elif name == '_filenode': | ||
|
r3961 | if '_fileid' in self.__dict__: | ||
self._filenode = self._filelog.lookup(self._fileid) | ||||
else: | ||||
self._filenode = self._changectx.filenode(self._path) | ||||
|
r3144 | return self._filenode | ||
elif name == '_filerev': | ||||
self._filerev = self._filelog.rev(self._filenode) | ||||
return self._filerev | ||||
|
r6286 | elif name == '_repopath': | ||
self._repopath = self._path | ||||
return self._repopath | ||||
|
r3144 | else: | ||
|
r7008 | raise AttributeError(name) | ||
|
r2563 | |||
|
r3168 | def __nonzero__(self): | ||
|
r3712 | try: | ||
n = self._filenode | ||||
return True | ||||
|
r3930 | except revlog.LookupError: | ||
|
r3712 | # file is missing | ||
return False | ||||
|
r3168 | |||
|
r3166 | def __str__(self): | ||
return "%s@%s" % (self.path(), short(self.node())) | ||||
|
r3151 | def __repr__(self): | ||
|
r3216 | return "<filectx %s>" % str(self) | ||
|
r3151 | |||
|
r6469 | def __hash__(self): | ||
try: | ||||
return hash((self._path, self._fileid)) | ||||
except AttributeError: | ||||
return id(self) | ||||
|
r3165 | def __eq__(self, other): | ||
|
r3715 | try: | ||
return (self._path == other._path | ||||
|
r4889 | and self._fileid == other._fileid) | ||
|
r3715 | except AttributeError: | ||
return False | ||||
|
r3165 | |||
|
r4748 | def __ne__(self, other): | ||
return not (self == other) | ||||
|
r3207 | def filectx(self, fileid): | ||
'''opens an arbitrary revision of the file without | ||||
opening a new filelog''' | ||||
return filectx(self._repo, self._path, fileid=fileid, | ||||
filelog=self._filelog) | ||||
|
r2563 | def filerev(self): return self._filerev | ||
def filenode(self): return self._filenode | ||||
|
r6743 | def flags(self): return self._changectx.flags(self._path) | ||
|
r2563 | def filelog(self): return self._filelog | ||
|
r3150 | def rev(self): | ||
|
r3336 | if '_changectx' in self.__dict__: | ||
|
r3150 | return self._changectx.rev() | ||
|
r5810 | if '_changeid' in self.__dict__: | ||
|
r6210 | return self._changectx.rev() | ||
|
r7361 | return self._filelog.linkrev(self._filerev) | ||
|
r3150 | |||
|
r7361 | def linkrev(self): return self._filelog.linkrev(self._filerev) | ||
|
r3144 | def node(self): return self._changectx.node() | ||
def user(self): return self._changectx.user() | ||||
def date(self): return self._changectx.date() | ||||
def files(self): return self._changectx.files() | ||||
def description(self): return self._changectx.description() | ||||
|
r3413 | def branch(self): return self._changectx.branch() | ||
|
r3144 | def manifest(self): return self._changectx.manifest() | ||
|
r3149 | def changectx(self): return self._changectx | ||
|
r2563 | |||
def data(self): return self._filelog.read(self._filenode) | ||||
|
r3122 | def path(self): return self._path | ||
|
r3302 | def size(self): return self._filelog.size(self._filerev) | ||
|
r2563 | |||
|
r3310 | def cmp(self, text): return self._filelog.cmp(self._filenode, text) | ||
|
r5811 | def renamed(self): | ||
"""check if file was actually renamed in this changeset revision | ||||
If rename logged in file revision, we report copy for changeset only | ||||
if file revisions linkrev points back to the changeset in question | ||||
or both changeset parents contain different file revisions. | ||||
""" | ||||
renamed = self._filelog.renamed(self._filenode) | ||||
if not renamed: | ||||
return renamed | ||||
if self.rev() == self.linkrev(): | ||||
return renamed | ||||
name = self.path() | ||||
fnode = self._filenode | ||||
for p in self._changectx.parents(): | ||||
try: | ||||
if fnode == p.filenode(name): | ||||
return None | ||||
except revlog.LookupError: | ||||
pass | ||||
return renamed | ||||
|
r2563 | def parents(self): | ||
|
r3124 | p = self._path | ||
fl = self._filelog | ||||
|
r3673 | pl = [(p, n, fl) for n in self._filelog.parents(self._filenode)] | ||
|
r3123 | |||
|
r5813 | r = self._filelog.renamed(self._filenode) | ||
|
r3122 | if r: | ||
|
r3124 | pl[0] = (r[0], r[1], None) | ||
|
r3673 | return [filectx(self._repo, p, fileid=n, filelog=l) | ||
for p,n,l in pl if n != nullid] | ||||
|
r2563 | |||
def children(self): | ||||
# hard for renames | ||||
c = self._filelog.children(self._filenode) | ||||
|
r3673 | return [filectx(self._repo, self._path, fileid=x, | ||
filelog=self._filelog) for x in c] | ||||
|
r2566 | |||
|
r4856 | def annotate(self, follow=False, linenumber=None): | ||
|
r3172 | '''returns a list of tuples of (ctx, line) for each line | ||
in the file, where ctx is the filectx of the node where | ||||
|
r4856 | that line was last changed. | ||
This returns tuples of ((ctx, linenumber), line) for each line, | ||||
if "linenumber" parameter is NOT "None". | ||||
In such tuples, linenumber means one at the first appearance | ||||
in the managed file. | ||||
To reduce annotation cost, | ||||
this returns fixed value(False is used) as linenumber, | ||||
if "linenumber" parameter is "False".''' | ||||
|
r3172 | |||
|
r4856 | def decorate_compat(text, rev): | ||
|
r3172 | return ([rev] * len(text.splitlines()), text) | ||
|
r4856 | def without_linenumber(text, rev): | ||
return ([(rev, False)] * len(text.splitlines()), text) | ||||
def with_linenumber(text, rev): | ||||
size = len(text.splitlines()) | ||||
return ([(rev, i) for i in xrange(1, size + 1)], text) | ||||
decorate = (((linenumber is None) and decorate_compat) or | ||||
(linenumber and with_linenumber) or | ||||
without_linenumber) | ||||
|
r3172 | def pair(parent, child): | ||
for a1, a2, b1, b2 in bdiff.blocks(parent[1], child[1]): | ||||
child[0][b1:b2] = parent[0][a1:a2] | ||||
return child | ||||
getlog = util.cachefunc(lambda x: self._repo.file(x)) | ||||
def getctx(path, fileid): | ||||
log = path == self._path and self._filelog or getlog(path) | ||||
return filectx(self._repo, path, fileid=fileid, filelog=log) | ||||
getctx = util.cachefunc(getctx) | ||||
def parents(f): | ||||
# we want to reuse filectx objects as much as possible | ||||
p = f._path | ||||
|
r3217 | if f._filerev is None: # working dir | ||
|
r3673 | pl = [(n.path(), n.filerev()) for n in f.parents()] | ||
|
r3217 | else: | ||
|
r3673 | pl = [(p, n) for n in f._filelog.parentrevs(f._filerev)] | ||
|
r3172 | |||
if follow: | ||||
r = f.renamed() | ||||
if r: | ||||
pl[0] = (r[0], getlog(r[0]).rev(r[1])) | ||||
|
r3146 | |||
|
r3578 | return [getctx(p, n) for p, n in pl if n != nullrev] | ||
|
r3217 | |||
|
r3404 | # use linkrev to find the first changeset where self appeared | ||
|
r5811 | if self.rev() != self.linkrev(): | ||
|
r3404 | base = self.filectx(self.filerev()) | ||
else: | ||||
base = self | ||||
|
r3172 | # find all ancestors | ||
|
r3404 | needed = {base: 1} | ||
visit = [base] | ||||
files = [base._path] | ||||
|
r3172 | while visit: | ||
f = visit.pop(0) | ||||
for p in parents(f): | ||||
if p not in needed: | ||||
needed[p] = 1 | ||||
visit.append(p) | ||||
if p._path not in files: | ||||
files.append(p._path) | ||||
else: | ||||
# count how many times we'll use this | ||||
needed[p] += 1 | ||||
# sort by revision (per file) which is a topological order | ||||
visit = [] | ||||
for f in files: | ||||
|
r6762 | fn = [(n.rev(), n) for n in needed if n._path == f] | ||
|
r3172 | visit.extend(fn) | ||
|
r6762 | |||
|
r3172 | hist = {} | ||
|
r6762 | for r, f in util.sort(visit): | ||
|
r3172 | curr = decorate(f.data(), f) | ||
for p in parents(f): | ||||
if p != nullid: | ||||
curr = pair(hist[p], curr) | ||||
# trim the history of unneeded revs | ||||
needed[p] -= 1 | ||||
if not needed[p]: | ||||
del hist[p] | ||||
hist[f] = curr | ||||
return zip(hist[f][0], hist[f][1].splitlines(1)) | ||||
|
r3124 | |||
|
r3126 | def ancestor(self, fc2): | ||
""" | ||||
find the common ancestor file context, if any, of self, and fc2 | ||||
""" | ||||
|
r3135 | acache = {} | ||
|
r3217 | |||
# prime the ancestor cache for the working directory | ||||
for c in (self, fc2): | ||||
if c._filerev == None: | ||||
|
r3673 | pl = [(n.path(), n.filenode()) for n in c.parents()] | ||
|
r3217 | acache[(c._path, None)] = pl | ||
|
r6286 | flcache = {self._repopath:self._filelog, fc2._repopath:fc2._filelog} | ||
|
r3135 | def parents(vertex): | ||
if vertex in acache: | ||||
return acache[vertex] | ||||
f, n = vertex | ||||
if f not in flcache: | ||||
|
r3126 | flcache[f] = self._repo.file(f) | ||
|
r3135 | fl = flcache[f] | ||
|
r3673 | pl = [(f, p) for p in fl.parents(n) if p != nullid] | ||
|
r3135 | re = fl.renamed(n) | ||
if re: | ||||
pl.append(re) | ||||
|
r3673 | acache[vertex] = pl | ||
|
r3135 | return pl | ||
|
r3126 | |||
|
r3135 | a, b = (self._path, self._filenode), (fc2._path, fc2._filenode) | ||
v = ancestor.ancestor(a, b, parents) | ||||
if v: | ||||
|
r3673 | f, n = v | ||
|
r3135 | return filectx(self._repo, f, fileid=n, filelog=flcache[f]) | ||
|
r3126 | |||
|
r3135 | return None | ||
|
r3217 | |||
class workingctx(changectx): | ||||
"""A workingctx object makes access to data related to | ||||
|
r6705 | the current working directory convenient. | ||
parents - a pair of parent nodeids, or None to use the dirstate. | ||||
|
r6709 | date - any valid date string or (unixtime, offset), or None. | ||
user - username string, or None. | ||||
|
r6708 | extra - a dictionary of extra values, or None. | ||
|
r6707 | changes - a list of file lists as returned by localrepo.status() | ||
or None to use the repository status. | ||||
|
r6705 | """ | ||
|
r6721 | def __init__(self, repo, parents=None, text="", user=None, date=None, | ||
|
r6709 | extra=None, changes=None): | ||
|
r3217 | self._repo = repo | ||
self._rev = None | ||||
self._node = None | ||||
|
r6709 | self._text = text | ||
|
r6718 | if date: | ||
|
r6709 | self._date = util.parsedate(date) | ||
|
r6817 | if user: | ||
self._user = user | ||||
|
r6705 | if parents: | ||
|
r6772 | self._parents = [changectx(self._repo, p) for p in parents] | ||
|
r6707 | if changes: | ||
self._status = list(changes) | ||||
|
r3217 | |||
|
r6708 | self._extra = {} | ||
if extra: | ||||
self._extra = extra.copy() | ||||
if 'branch' not in self._extra: | ||||
branch = self._repo.dirstate.branch() | ||||
try: | ||||
branch = branch.decode('UTF-8').encode('UTF-8') | ||||
except UnicodeDecodeError: | ||||
raise util.Abort(_('branch name not in UTF-8!')) | ||||
self._extra['branch'] = branch | ||||
if self._extra['branch'] == '': | ||||
self._extra['branch'] = 'default' | ||||
|
r3217 | def __str__(self): | ||
|
r3313 | return str(self._parents[0]) + "+" | ||
|
r3217 | |||
def __nonzero__(self): | ||||
return True | ||||
|
r6771 | def __contains__(self, key): | ||
|
r6845 | return self._dirstate[key] not in "?r" | ||
|
r6771 | |||
|
r3217 | def __getattr__(self, name): | ||
if name == '_status': | ||||
|
r6760 | self._status = self._repo.status(unknown=True) | ||
|
r3217 | return self._status | ||
|
r6817 | elif name == '_user': | ||
self._user = self._repo.ui.username() | ||||
return self._user | ||||
elif name == '_date': | ||||
self._date = util.makedate() | ||||
return self._date | ||||
|
r3217 | if name == '_manifest': | ||
self._buildmanifest() | ||||
return self._manifest | ||||
|
r6742 | elif name == '_parents': | ||
p = self._repo.dirstate.parents() | ||||
if p[1] == nullid: | ||||
p = p[:-1] | ||||
self._parents = [changectx(self._repo, x) for x in p] | ||||
return self._parents | ||||
|
r3217 | else: | ||
|
r7008 | raise AttributeError(name) | ||
|
r3217 | |||
def _buildmanifest(self): | ||||
"""generate a manifest corresponding to the working directory""" | ||||
|
r3218 | man = self._parents[0].manifest().copy() | ||
|
r3217 | copied = self._repo.dirstate.copies() | ||
|
r6743 | cf = lambda x: man.flags(copied.get(x, x)) | ||
ff = self._repo.dirstate.flagfunc(cf) | ||||
|
r3217 | modified, added, removed, deleted, unknown = self._status[:5] | ||
|
r3673 | for i, l in (("a", added), ("m", modified), ("u", unknown)): | ||
|
r3217 | for f in l: | ||
man[f] = man.get(copied.get(f, f), nullid) + i | ||||
|
r3823 | try: | ||
|
r6743 | man.set(f, ff(f)) | ||
|
r3823 | except OSError: | ||
pass | ||||
|
r3217 | |||
for f in deleted + removed: | ||||
|
r3325 | if f in man: | ||
del man[f] | ||||
|
r3217 | |||
self._manifest = man | ||||
def manifest(self): return self._manifest | ||||
|
r6809 | def user(self): return self._user or self._repo.ui.username() | ||
|
r6709 | def date(self): return self._date | ||
def description(self): return self._text | ||||
|
r3217 | def files(self): | ||
|
r6762 | return util.sort(self._status[0] + self._status[1] + self._status[2]) | ||
|
r3217 | |||
def modified(self): return self._status[0] | ||||
def added(self): return self._status[1] | ||||
def removed(self): return self._status[2] | ||||
def deleted(self): return self._status[3] | ||||
def unknown(self): return self._status[4] | ||||
def clean(self): return self._status[5] | ||||
|
r6708 | def branch(self): return self._extra['branch'] | ||
def extra(self): return self._extra | ||||
|
r3217 | |||
|
r4663 | def tags(self): | ||
t = [] | ||||
[t.extend(p.tags()) for p in self.parents()] | ||||
return t | ||||
|
r3217 | def children(self): | ||
return [] | ||||
|
r6743 | def flags(self, path): | ||
|
r5389 | if '_manifest' in self.__dict__: | ||
try: | ||||
return self._manifest.flags(path) | ||||
except KeyError: | ||||
return '' | ||||
|
r5760 | |||
|
r5389 | pnode = self._parents[0].changeset()[0] | ||
|
r5407 | orig = self._repo.dirstate.copies().get(path, path) | ||
node, flag = self._repo.manifest.find(pnode, orig) | ||||
|
r5389 | try: | ||
|
r6743 | ff = self._repo.dirstate.flagfunc(lambda x: flag or '') | ||
return ff(path) | ||||
|
r5389 | except OSError: | ||
pass | ||||
if not node or path in self.deleted() or path in self.removed(): | ||||
return '' | ||||
return flag | ||||
|
r3966 | def filectx(self, path, filelog=None): | ||
|
r3217 | """get a file context from the working directory""" | ||
|
r3966 | return workingfilectx(self._repo, path, workingctx=self, | ||
filelog=filelog) | ||||
|
r3217 | |||
def ancestor(self, c2): | ||||
"""return the ancestor context of self and c2""" | ||||
return self._parents[0].ancestor(c2) # punt on two parents for now | ||||
|
r6764 | def walk(self, match): | ||
|
r6829 | return util.sort(self._repo.dirstate.walk(match, True, False).keys()) | ||
|
r6764 | |||
|
r3217 | class workingfilectx(filectx): | ||
"""A workingfilectx object makes access to data related to a particular | ||||
file in the working directory convenient.""" | ||||
def __init__(self, repo, path, filelog=None, workingctx=None): | ||||
"""changeid can be a changeset revision, node, or tag. | ||||
fileid can be a file revision or node.""" | ||||
self._repo = repo | ||||
self._path = path | ||||
self._changeid = None | ||||
self._filerev = self._filenode = None | ||||
if filelog: | ||||
self._filelog = filelog | ||||
if workingctx: | ||||
self._changectx = workingctx | ||||
def __getattr__(self, name): | ||||
if name == '_changectx': | ||||
|
r4414 | self._changectx = workingctx(self._repo) | ||
|
r3217 | return self._changectx | ||
elif name == '_repopath': | ||||
|
r3298 | self._repopath = (self._repo.dirstate.copied(self._path) | ||
or self._path) | ||||
return self._repopath | ||||
|
r3217 | elif name == '_filelog': | ||
self._filelog = self._repo.file(self._repopath) | ||||
return self._filelog | ||||
else: | ||||
|
r7008 | raise AttributeError(name) | ||
|
r3217 | |||
def __nonzero__(self): | ||||
return True | ||||
def __str__(self): | ||||
|
r3313 | return "%s@%s" % (self.path(), self._changectx) | ||
|
r3217 | |||
def filectx(self, fileid): | ||||
'''opens an arbitrary revision of the file without | ||||
opening a new filelog''' | ||||
return filectx(self._repo, self._repopath, fileid=fileid, | ||||
filelog=self._filelog) | ||||
def rev(self): | ||||
|
r3336 | if '_changectx' in self.__dict__: | ||
|
r3217 | return self._changectx.rev() | ||
|
r7361 | return self._filelog.linkrev(self._filerev) | ||
|
r3217 | |||
def data(self): return self._repo.wread(self._path) | ||||
def renamed(self): | ||||
rp = self._repopath | ||||
if rp == self._path: | ||||
return None | ||||
|
r3965 | return rp, self._changectx._parents[0]._manifest.get(rp, nullid) | ||
|
r3217 | |||
def parents(self): | ||||
'''return parent filectxs, following copies if necessary''' | ||||
p = self._path | ||||
rp = self._repopath | ||||
|
r3298 | pcl = self._changectx._parents | ||
|
r3217 | fl = self._filelog | ||
|
r3673 | pl = [(rp, pcl[0]._manifest.get(rp, nullid), fl)] | ||
|
r3217 | if len(pcl) > 1: | ||
if rp != p: | ||||
fl = None | ||||
pl.append((p, pcl[1]._manifest.get(p, nullid), fl)) | ||||
|
r3673 | return [filectx(self._repo, p, fileid=n, filelog=l) | ||
for p,n,l in pl if n != nullid] | ||||
|
r3217 | |||
def children(self): | ||||
return [] | ||||
|
r3302 | def size(self): return os.stat(self._repo.wjoin(self._path)).st_size | ||
|
r3962 | def date(self): | ||
t, tz = self._changectx.date() | ||||
try: | ||||
|
r4117 | return (int(os.lstat(self._repo.wjoin(self._path)).st_mtime), tz) | ||
|
r3962 | except OSError, err: | ||
if err.errno != errno.ENOENT: raise | ||||
return (t, tz) | ||||
|
r3310 | |||
def cmp(self, text): return self._repo.wread(self._path) == text | ||||
|
r6715 | |||
class memctx(object): | ||||
|
r7077 | """Use memctx to perform in-memory commits via localrepo.commitctx(). | ||
|
r6715 | |||
|
r7077 | Revision information is supplied at initialization time while | ||
related files data and is made available through a callback | ||||
mechanism. 'repo' is the current localrepo, 'parents' is a | ||||
sequence of two parent revisions identifiers (pass None for every | ||||
missing parent), 'text' is the commit message and 'files' lists | ||||
names of files touched by the revision (normalized and relative to | ||||
repository root). | ||||
|
r6715 | |||
|
r7077 | filectxfn(repo, memctx, path) is a callable receiving the | ||
repository, the current memctx object and the normalized path of | ||||
requested file, relative to repository root. It is fired by the | ||||
commit function for every file in 'files', but calls order is | ||||
undefined. If the file is available in the revision being | ||||
committed (updated or added), filectxfn returns a memfilectx | ||||
object. If the file was removed, filectxfn raises an | ||||
IOError. Moved files are represented by marking the source file | ||||
removed and the new file added with copy information (see | ||||
memfilectx). | ||||
user receives the committer name and defaults to current | ||||
repository username, date is the commit date in any format | ||||
supported by util.parsedate() and defaults to current date, extra | ||||
is a dictionary of metadata or is left empty. | ||||
|
r6715 | """ | ||
|
r6721 | def __init__(self, repo, parents, text, files, filectxfn, user=None, | ||
|
r6715 | date=None, extra=None): | ||
self._repo = repo | ||||
self._rev = None | ||||
self._node = None | ||||
self._text = text | ||||
self._date = date and util.parsedate(date) or util.makedate() | ||||
|
r6809 | self._user = user | ||
|
r6715 | parents = [(p or nullid) for p in parents] | ||
p1, p2 = parents | ||||
|
r6747 | self._parents = [changectx(self._repo, p) for p in (p1, p2)] | ||
|
r6762 | files = util.sort(list(files)) | ||
|
r6715 | self._status = [files, [], [], [], []] | ||
self._filectxfn = filectxfn | ||||
self._extra = extra and extra.copy() or {} | ||||
if 'branch' not in self._extra: | ||||
self._extra['branch'] = 'default' | ||||
elif self._extra.get('branch') == '': | ||||
self._extra['branch'] = 'default' | ||||
def __str__(self): | ||||
return str(self._parents[0]) + "+" | ||||
|
r6763 | def __int__(self): | ||
return self._rev | ||||
|
r6715 | def __nonzero__(self): | ||
return True | ||||
|
r6809 | def user(self): return self._user or self._repo.ui.username() | ||
|
r6715 | def date(self): return self._date | ||
def description(self): return self._text | ||||
def files(self): return self.modified() | ||||
def modified(self): return self._status[0] | ||||
def added(self): return self._status[1] | ||||
def removed(self): return self._status[2] | ||||
def deleted(self): return self._status[3] | ||||
def unknown(self): return self._status[4] | ||||
def clean(self): return self._status[5] | ||||
def branch(self): return self._extra['branch'] | ||||
def extra(self): return self._extra | ||||
|
r6743 | def flags(self, f): return self[f].flags() | ||
|
r6715 | |||
def parents(self): | ||||
"""return contexts for each parent changeset""" | ||||
return self._parents | ||||
def filectx(self, path, filelog=None): | ||||
"""get a file context from the working directory""" | ||||
return self._filectxfn(self._repo, self, path) | ||||
class memfilectx(object): | ||||
|
r7077 | """memfilectx represents an in-memory file to commit. | ||
See memctx for more details. | ||||
|
r6715 | """ | ||
def __init__(self, path, data, islink, isexec, copied): | ||||
|
r7077 | """ | ||
path is the normalized file path relative to repository root. | ||||
data is the file content as a string. | ||||
islink is True if the file is a symbolic link. | ||||
isexec is True if the file is executable. | ||||
copied is the source file path if current file was copied in the | ||||
revision being committed, or None.""" | ||||
|
r6715 | self._path = path | ||
self._data = data | ||||
self._flags = (islink and 'l' or '') + (isexec and 'x' or '') | ||||
self._copied = None | ||||
if copied: | ||||
self._copied = (copied, nullid) | ||||
def __nonzero__(self): return True | ||||
def __str__(self): return "%s@%s" % (self.path(), self._changectx) | ||||
def path(self): return self._path | ||||
def data(self): return self._data | ||||
|
r6743 | def flags(self): return self._flags | ||
|
r6715 | def isexec(self): return 'x' in self._flags | ||
def islink(self): return 'l' in self._flags | ||||
def renamed(self): return self._copied | ||||