| Index: third_party/logilab/common/hg.py
|
| diff --git a/third_party/logilab/common/hg.py b/third_party/logilab/common/hg.py
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..edf2d3be0b4a5acdae69cd86a2059f5509fc6fff
|
| --- /dev/null
|
| +++ b/third_party/logilab/common/hg.py
|
| @@ -0,0 +1,130 @@
|
| +# copyright 2003-2011 LOGILAB S.A. (Paris, FRANCE), all rights reserved.
|
| +# contact http://www.logilab.fr/ -- mailto:contact@logilab.fr
|
| +#
|
| +# This file is part of logilab-common.
|
| +#
|
| +# logilab-common is free software: you can redistribute it and/or modify it under
|
| +# the terms of the GNU Lesser General Public License as published by the Free
|
| +# Software Foundation, either version 2.1 of the License, or (at your option) any
|
| +# later version.
|
| +#
|
| +# logilab-common is distributed in the hope that it will be useful, but WITHOUT
|
| +# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
| +# FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
|
| +# details.
|
| +#
|
| +# You should have received a copy of the GNU Lesser General Public License along
|
| +# with logilab-common. If not, see <http://www.gnu.org/licenses/>.
|
| +"""mercurial utilities (mercurial should be installed)"""
|
| +
|
| +__docformat__ = "restructuredtext en"
|
| +
|
| +import os
|
| +import sys
|
| +import os.path as osp
|
| +
|
| +try:
|
| + from mercurial.error import RepoError
|
| + from mercurial.__version__ import version as hg_version
|
| +except ImportError:
|
| + from mercurial.repo import RepoError
|
| + from mercurial.version import get_version
|
| + hg_version = get_version()
|
| +
|
| +from mercurial.hg import repository as Repository
|
| +from mercurial.ui import ui as Ui
|
| +from mercurial.node import short
|
| +try:
|
| + # mercurial >= 1.2 (?)
|
| + from mercurial.cmdutil import walkchangerevs
|
| +except ImportError, ex:
|
| + from mercurial.commands import walkchangerevs
|
| +try:
|
| + # mercurial >= 1.1 (.1?)
|
| + from mercurial.util import cachefunc
|
| +except ImportError, ex:
|
| + def cachefunc(func):
|
| + return func
|
| +try:
|
| + # mercurial >= 1.3.1
|
| + from mercurial import encoding
|
| + _encoding = encoding.encoding
|
| +except ImportError:
|
| + try:
|
| + from mercurial.util import _encoding
|
| + except ImportError:
|
| + import locale
|
| + # stay compatible with mercurial 0.9.1 (etch debian release)
|
| + # (borrowed from mercurial.util 1.1.2)
|
| + try:
|
| + _encoding = os.environ.get("HGENCODING")
|
| + if sys.platform == 'darwin' and not _encoding:
|
| + # On darwin, getpreferredencoding ignores the locale environment and
|
| + # always returns mac-roman. We override this if the environment is
|
| + # not C (has been customized by the user).
|
| + locale.setlocale(locale.LC_CTYPE, '')
|
| + _encoding = locale.getlocale()[1]
|
| + if not _encoding:
|
| + _encoding = locale.getpreferredencoding() or 'ascii'
|
| + except locale.Error:
|
| + _encoding = 'ascii'
|
| +try:
|
| + # demandimport causes problems when activated, ensure it isn't
|
| + # XXX put this in apycot where the pb has been noticed?
|
| + from mercurial import demandimport
|
| + demandimport.disable()
|
| +except:
|
| + pass
|
| +
|
| +Ui.warn = lambda *args, **kwargs: 0 # make it quiet
|
| +
|
| +def find_repository(path):
|
| + """returns <path>'s mercurial repository
|
| +
|
| + None if <path> is not under hg control
|
| + """
|
| + path = osp.realpath(osp.abspath(path))
|
| + while not osp.isdir(osp.join(path, ".hg")):
|
| + oldpath = path
|
| + path = osp.dirname(path)
|
| + if path == oldpath:
|
| + return None
|
| + return path
|
| +
|
| +
|
| +def get_repository(path):
|
| + """Simple function that open a hg repository"""
|
| + repopath = find_repository(path)
|
| + if repopath is None:
|
| + raise RuntimeError('no repository found in %s' % osp.abspath(path))
|
| + return Repository(Ui(), path=repopath)
|
| +
|
| +def incoming(wdrepo, masterrepo):
|
| + try:
|
| + return wdrepo.findincoming(masterrepo)
|
| + except AttributeError:
|
| + from mercurial import hg, discovery
|
| + revs, checkout = hg.addbranchrevs(wdrepo, masterrepo, ('', []), None)
|
| + common, incoming, rheads = discovery.findcommonincoming(
|
| + wdrepo, masterrepo, heads=revs)
|
| + if not masterrepo.local():
|
| + from mercurial import bundlerepo, changegroup
|
| + if revs is None and masterrepo.capable('changegroupsubset'):
|
| + revs = rheads
|
| + if revs is None:
|
| + cg = masterrepo.changegroup(incoming, "incoming")
|
| + else:
|
| + cg = masterrepo.changegroupsubset(incoming, revs, 'incoming')
|
| + fname = changegroup.writebundle(cg, None, "HG10UN")
|
| + # use the created uncompressed bundlerepo
|
| + masterrepo = bundlerepo.bundlerepository(wdrepo.ui, wdrepo.root, fname)
|
| + return masterrepo.changelog.nodesbetween(incoming, revs)[0]
|
| +
|
| +def outgoing(wdrepo, masterrepo):
|
| + try:
|
| + return wdrepo.findoutgoing(masterrepo)
|
| + except AttributeError:
|
| + from mercurial import hg, discovery
|
| + revs, checkout = hg.addbranchrevs(wdrepo, wdrepo, ('', []), None)
|
| + o = discovery.findoutgoing(wdrepo, masterrepo)
|
| + return wdrepo.changelog.nodesbetween(o, revs)[0]
|
|
|