bookmarks.py
242 lines
| 7.1 KiB
| text/x-python
|
PythonLexer
/ mercurial / bookmarks.py
|
r13350 | # Mercurial bookmark support code | ||
# | ||||
# Copyright 2008 David Soria Parra <dsp@php.net> | ||||
# | ||||
# This software may be used and distributed according to the terms of the | ||||
# GNU General Public License version 2 or any later version. | ||||
from mercurial.i18n import _ | ||||
|
r14064 | from mercurial.node import hex | ||
|
r14027 | from mercurial import encoding, error, util | ||
import errno, os | ||||
|
r13350 | |||
|
r13425 | def valid(mark): | ||
for c in (':', '\0', '\n', '\r'): | ||||
if c in mark: | ||||
return False | ||||
return True | ||||
|
r13351 | def read(repo): | ||
'''Parse .hg/bookmarks file and return a dictionary | ||||
Bookmarks are stored as {HASH}\\s{NAME}\\n (localtags format) values | ||||
in the .hg/bookmarks file. | ||||
Read the file and return a (name=>nodeid) dictionary | ||||
''' | ||||
|
r14027 | bookmarks = {} | ||
|
r13351 | try: | ||
for line in repo.opener('bookmarks'): | ||||
|
r14845 | line = line.strip() | ||
|
r14848 | if not line: | ||
continue | ||||
|
r14845 | if ' ' not in line: | ||
|
r14848 | repo.ui.warn(_('malformed line in .hg/bookmarks: %r\n') % line) | ||
|
r14845 | continue | ||
|
r14847 | sha, refspec = line.split(' ', 1) | ||
|
r13351 | refspec = encoding.tolocal(refspec) | ||
|
r14027 | try: | ||
bookmarks[refspec] = repo.changelog.lookup(sha) | ||||
except error.RepoLookupError: | ||||
pass | ||||
except IOError, inst: | ||||
if inst.errno != errno.ENOENT: | ||||
raise | ||||
|
r13351 | return bookmarks | ||
def readcurrent(repo): | ||||
'''Get the current bookmark | ||||
If we use gittishsh branches we have a current bookmark that | ||||
we are on. This function returns the name of the bookmark. It | ||||
is stored in .hg/bookmarks.current | ||||
''' | ||||
mark = None | ||||
|
r14027 | try: | ||
|
r13351 | file = repo.opener('bookmarks.current') | ||
|
r14027 | except IOError, inst: | ||
if inst.errno != errno.ENOENT: | ||||
raise | ||||
return None | ||||
try: | ||||
|
r13351 | # No readline() in posixfile_nt, reading everything is cheap | ||
|
r13381 | mark = encoding.tolocal((file.readlines() or [''])[0]) | ||
|
r13627 | if mark == '' or mark not in repo._bookmarks: | ||
|
r13351 | mark = None | ||
|
r14027 | finally: | ||
|
r13351 | file.close() | ||
return mark | ||||
|
r13350 | def write(repo): | ||
'''Write bookmarks | ||||
Write the given bookmark => hash dictionary to the .hg/bookmarks file | ||||
in a format equal to those of localtags. | ||||
We also store a backup of the previous state in undo.bookmarks that | ||||
can be copied back on rollback. | ||||
''' | ||||
refs = repo._bookmarks | ||||
if repo._bookmarkcurrent not in refs: | ||||
setcurrent(repo, None) | ||||
|
r13425 | for mark in refs.keys(): | ||
if not valid(mark): | ||||
raise util.Abort(_("bookmark '%s' contains illegal " | ||||
"character" % mark)) | ||||
|
r15908 | wlock = repo.wlock() | ||
|
r13350 | try: | ||
|
r13425 | |||
|
r13350 | file = repo.opener('bookmarks', 'w', atomictemp=True) | ||
for refspec, node in refs.iteritems(): | ||||
file.write("%s %s\n" % (hex(node), encoding.fromlocal(refspec))) | ||||
|
r15057 | file.close() | ||
|
r13350 | |||
# touch 00changelog.i so hgweb reloads bookmarks (no lock needed) | ||||
try: | ||||
os.utime(repo.sjoin('00changelog.i'), None) | ||||
except OSError: | ||||
pass | ||||
finally: | ||||
|
r15908 | wlock.release() | ||
|
r13350 | |||
def setcurrent(repo, mark): | ||||
'''Set the name of the bookmark that we are currently on | ||||
Set the name of the bookmark that we are on (hg update <bookmark>). | ||||
The name is recorded in .hg/bookmarks.current | ||||
''' | ||||
current = repo._bookmarkcurrent | ||||
if current == mark: | ||||
return | ||||
|
r13647 | if mark not in repo._bookmarks: | ||
|
r13350 | mark = '' | ||
|
r13425 | if not valid(mark): | ||
raise util.Abort(_("bookmark '%s' contains illegal " | ||||
"character" % mark)) | ||||
|
r15908 | wlock = repo.wlock() | ||
|
r13350 | try: | ||
file = repo.opener('bookmarks.current', 'w', atomictemp=True) | ||||
|
r14559 | file.write(encoding.fromlocal(mark)) | ||
|
r15057 | file.close() | ||
|
r13350 | finally: | ||
|
r15908 | wlock.release() | ||
|
r13350 | repo._bookmarkcurrent = mark | ||
|
r13352 | |||
|
r16191 | def unsetcurrent(repo): | ||
wlock = repo.wlock() | ||||
try: | ||||
|
r16194 | try: | ||
util.unlink(repo.join('bookmarks.current')) | ||||
repo._bookmarkcurrent = None | ||||
except OSError, inst: | ||||
if inst.errno != errno.ENOENT: | ||||
raise | ||||
|
r16191 | finally: | ||
wlock.release() | ||||
|
r13663 | def updatecurrentbookmark(repo, oldnode, curbranch): | ||
try: | ||||
|
r15621 | return update(repo, oldnode, repo.branchtags()[curbranch]) | ||
|
r13663 | except KeyError: | ||
if curbranch == "default": # no default branch! | ||||
|
r15621 | return update(repo, oldnode, repo.lookup("tip")) | ||
|
r13663 | else: | ||
raise util.Abort(_("branch %s not found") % curbranch) | ||||
|
r13352 | def update(repo, parents, node): | ||
marks = repo._bookmarks | ||||
update = False | ||||
|
r13416 | mark = repo._bookmarkcurrent | ||
if mark and marks[mark] in parents: | ||||
|
r13478 | old = repo[marks[mark]] | ||
new = repo[node] | ||||
if new in old.descendants(): | ||||
marks[mark] = new.node() | ||||
update = True | ||||
|
r13352 | if update: | ||
|
r15237 | repo._writebookmarks(marks) | ||
|
r15621 | return update | ||
|
r13353 | |||
def listbookmarks(repo): | ||||
# We may try to list bookmarks on a repo type that does not | ||||
# support it (e.g., statichttprepository). | ||||
|
r14946 | marks = getattr(repo, '_bookmarks', {}) | ||
|
r13353 | |||
d = {} | ||||
|
r14946 | for k, v in marks.iteritems(): | ||
|
r15613 | # don't expose local divergent bookmarks | ||
|
r16276 | if '@' not in k or k.endswith('@'): | ||
|
r15613 | d[k] = hex(v) | ||
|
r13353 | return d | ||
def pushbookmark(repo, key, old, new): | ||||
|
r15908 | w = repo.wlock() | ||
|
r13353 | try: | ||
marks = repo._bookmarks | ||||
if hex(marks.get(key, '')) != old: | ||||
return False | ||||
if new == '': | ||||
del marks[key] | ||||
else: | ||||
if new not in repo: | ||||
return False | ||||
marks[key] = repo[new].node() | ||||
write(repo) | ||||
return True | ||||
finally: | ||||
|
r15908 | w.release() | ||
|
r13354 | |||
|
r15614 | def updatefromremote(ui, repo, remote, path): | ||
|
r13646 | ui.debug("checking for updated bookmarks\n") | ||
rb = remote.listkeys('bookmarks') | ||||
changed = False | ||||
for k in rb.keys(): | ||||
if k in repo._bookmarks: | ||||
nr, nl = rb[k], repo._bookmarks[k] | ||||
if nr in repo: | ||||
cr = repo[nr] | ||||
cl = repo[nl] | ||||
if cl.rev() >= cr.rev(): | ||||
continue | ||||
if cr in cl.descendants(): | ||||
repo._bookmarks[k] = cr.node() | ||||
changed = True | ||||
ui.status(_("updating bookmark %s\n") % k) | ||||
else: | ||||
|
r15614 | # find a unique @ suffix | ||
|
r15613 | for x in range(1, 100): | ||
n = '%s@%d' % (k, x) | ||||
if n not in repo._bookmarks: | ||||
break | ||||
|
r15614 | # try to use an @pathalias suffix | ||
# if an @pathalias already exists, we overwrite (update) it | ||||
for p, u in ui.configitems("paths"): | ||||
if path == u: | ||||
n = '%s@%s' % (k, p) | ||||
|
r15613 | repo._bookmarks[n] = cr.node() | ||
changed = True | ||||
ui.warn(_("divergent bookmark %s stored as %s\n") % (k, n)) | ||||
|
r13646 | if changed: | ||
write(repo) | ||||
|
r13354 | def diff(ui, repo, remote): | ||
ui.status(_("searching for changed bookmarks\n")) | ||||
lmarks = repo.listkeys('bookmarks') | ||||
rmarks = remote.listkeys('bookmarks') | ||||
diff = sorted(set(rmarks) - set(lmarks)) | ||||
for k in diff: | ||||
|
r15984 | mark = ui.debugflag and rmarks[k] or rmarks[k][:12] | ||
ui.write(" %-25s %s\n" % (k, mark)) | ||||
|
r13354 | |||
if len(diff) <= 0: | ||||
ui.status(_("no changed bookmarks found\n")) | ||||
return 1 | ||||
return 0 | ||||