mirror of
https://github.com/facebook/sapling.git
synced 2024-10-16 11:52:02 +03:00
9e0a7c41a4
Summary: Subrepo is another unloved features that we don't want to support. Aggressively remove it everywhere, instead of just turning off configs. I didn't spend much time to split this commit so it's smaller and more friendly to review. But it seems tests are passing. Reviewed By: sfilipco Differential Revision: D14220099 fbshipit-source-id: adc512a047d99cd4bafd0362e3e9b24e71defe13
449 lines
14 KiB
Python
449 lines
14 KiB
Python
# no-check-code -- see T24862348
|
|
|
|
"""integration with Subversion repositories
|
|
|
|
hgsubversion is an extension for Mercurial that allows it to act as a Subversion
|
|
client, offering fast, incremental and bidirectional synchronisation.
|
|
|
|
At this point, hgsubversion is usable by users reasonably familiar with
|
|
Mercurial as a VCS. It's not recommended to dive into hgsubversion as an
|
|
introduction to Mercurial, since hgsubversion "bends the rules" a little
|
|
and violates some of the typical assumptions of early Mercurial users.
|
|
|
|
Before using hgsubversion, we *strongly* encourage running the
|
|
automated tests. See 'README' in the hgsubversion directory for
|
|
details.
|
|
|
|
For more information and instructions, see :hg:`help subversion`.
|
|
"""
|
|
|
|
testedwith = "3.7 3.8 3.9 4.0 4.1 4.2 4.3 4.4"
|
|
|
|
import os
|
|
import zlib
|
|
|
|
import compathacks
|
|
import svncommands
|
|
import svnexternals
|
|
import svnrepo
|
|
import util
|
|
import wrappers
|
|
from edenscm.mercurial import (
|
|
commands,
|
|
demandimport,
|
|
extensions,
|
|
help,
|
|
hg,
|
|
localrepo,
|
|
namespaces,
|
|
policy,
|
|
registrar,
|
|
revset,
|
|
util as hgutil,
|
|
)
|
|
|
|
|
|
try:
|
|
from edenscm.mercurial import exchange
|
|
|
|
exchange.push # existed in first iteration of this file
|
|
except ImportError:
|
|
# We only *use* the exchange module in hg 3.2+, so this is safe
|
|
pass
|
|
|
|
|
|
base85 = policy.importmod(r"base85")
|
|
|
|
demandimport.ignore.extend(["svn", "svn.client", "svn.core", "svn.delta", "svn.ra"])
|
|
|
|
namespacepredicate = registrar.namespacepredicate()
|
|
|
|
svnopts = [
|
|
(
|
|
"",
|
|
"stupid",
|
|
None,
|
|
"use slower, but more compatible, protocol for Subversion (ADVANCED)",
|
|
)
|
|
]
|
|
|
|
# generic means it picks up all options from svnopts
|
|
# fixdoc means update the docstring
|
|
# TODO: fixdoc hoses l18n
|
|
wrapcmds = { # cmd: generic, target, fixdoc, ppopts, opts
|
|
"parents": (
|
|
False,
|
|
None,
|
|
False,
|
|
False,
|
|
[("", "svn", None, "show parent svn revision instead")],
|
|
),
|
|
"diff": (
|
|
False,
|
|
None,
|
|
False,
|
|
False,
|
|
[("", "svn", None, "show svn diffs against svn parent")],
|
|
),
|
|
"pull": (True, "sources", True, True, []),
|
|
"push": (True, "destinations", True, True, []),
|
|
"incoming": (False, "sources", True, True, []),
|
|
"version": (
|
|
False,
|
|
None,
|
|
False,
|
|
False,
|
|
[("", "svn", None, "print hgsubversion information as well")],
|
|
),
|
|
"clone": (
|
|
False,
|
|
"sources",
|
|
True,
|
|
True,
|
|
[
|
|
(
|
|
"T",
|
|
"tagpaths",
|
|
"",
|
|
"list of paths to search for tags in Subversion repositories",
|
|
),
|
|
(
|
|
"",
|
|
"branchdir",
|
|
"",
|
|
"path to search for branches in subversion repositories",
|
|
),
|
|
("", "trunkdir", "", "path to trunk in subversion repositories"),
|
|
("", "infix", "", "path relative to trunk, branch an tag dirs to import"),
|
|
(
|
|
"A",
|
|
"authors",
|
|
"",
|
|
"file mapping Subversion usernames to Mercurial authors",
|
|
),
|
|
(
|
|
"",
|
|
"filemap",
|
|
"",
|
|
"file containing rules for remapping Subversion repository paths",
|
|
),
|
|
(
|
|
"",
|
|
"layout",
|
|
"auto",
|
|
(
|
|
"import standard layout or single "
|
|
"directory? Can be standard, single, or auto."
|
|
),
|
|
),
|
|
("", "branchmap", "", "file containing rules for branch conversion"),
|
|
("", "tagmap", "", "file containing rules for renaming tags"),
|
|
(
|
|
"",
|
|
"startrev",
|
|
"",
|
|
(
|
|
"convert Subversion revisions starting at the one "
|
|
"specified, either an integer revision or HEAD; "
|
|
"HEAD causes only the latest revision to be "
|
|
"pulled"
|
|
),
|
|
),
|
|
],
|
|
),
|
|
}
|
|
|
|
try:
|
|
from edenscm.mercurial import discovery
|
|
|
|
def findcommonoutgoing(orig, *args, **opts):
|
|
capable = getattr(args[1], "capable", lambda x: False)
|
|
if capable("subversion"):
|
|
return wrappers.findcommonoutgoing(*args, **opts)
|
|
else:
|
|
return orig(*args, **opts)
|
|
|
|
extensions.wrapfunction(discovery, "findcommonoutgoing", findcommonoutgoing)
|
|
except AttributeError:
|
|
# only need the discovery variant of this code when we drop hg < 1.6
|
|
def findoutgoing(orig, *args, **opts):
|
|
capable = getattr(args[1], "capable", lambda x: False)
|
|
if capable("subversion"):
|
|
return wrappers.findoutgoing(*args, **opts)
|
|
else:
|
|
return orig(*args, **opts)
|
|
|
|
extensions.wrapfunction(discovery, "findoutgoing", findoutgoing)
|
|
except ImportError:
|
|
pass
|
|
|
|
|
|
def extsetup(ui):
|
|
"""insert command wrappers for a bunch of commands"""
|
|
|
|
docvals = {"extension": "hgsubversion"}
|
|
for cmd, (generic, target, fixdoc, ppopts, opts) in wrapcmds.iteritems():
|
|
|
|
if fixdoc and wrappers.generic.__doc__:
|
|
docvals["command"] = cmd
|
|
docvals["Command"] = cmd.capitalize()
|
|
docvals["target"] = target
|
|
doc = wrappers.generic.__doc__.strip() % docvals
|
|
fn = getattr(commands, cmd)
|
|
fn.__doc__ = fn.__doc__.rstrip() + "\n\n " + doc
|
|
|
|
wrapped = generic and wrappers.generic or getattr(wrappers, cmd)
|
|
entry = extensions.wrapcommand(commands.table, cmd, wrapped)
|
|
if ppopts:
|
|
entry[1].extend(svnopts)
|
|
if opts:
|
|
entry[1].extend(opts)
|
|
|
|
try:
|
|
rebase = extensions.find("rebase")
|
|
if not rebase:
|
|
return
|
|
entry = extensions.wrapcommand(rebase.cmdtable, "rebase", wrappers.rebase)
|
|
entry[1].append(("", "svn", None, "automatic svn rebase"))
|
|
except:
|
|
pass
|
|
|
|
if not hgutil.safehasattr(localrepo.localrepository, "push"):
|
|
# Mercurial >= 3.2
|
|
extensions.wrapfunction(exchange, "push", wrappers.exchangepush)
|
|
if not hgutil.safehasattr(localrepo.localrepository, "pull"):
|
|
# Mercurial >= 3.2
|
|
extensions.wrapfunction(exchange, "pull", wrappers.exchangepull)
|
|
|
|
helpdir = os.path.join(hgutil.datapath, "help", "subversion")
|
|
|
|
entries = (
|
|
(
|
|
["subversion"],
|
|
"Working with Subversion Repositories",
|
|
# Mercurial >= 3.6: doc(ui)
|
|
lambda *args: open(os.path.join(helpdir, "subversion.rst")).read(),
|
|
),
|
|
)
|
|
|
|
help.helptable.extend(entries)
|
|
|
|
revset.symbols.update(util.revsets)
|
|
|
|
|
|
def reposetup(ui, repo):
|
|
if repo.local():
|
|
svnrepo.generate_repo_class(ui, repo)
|
|
for tunnel in ui.configlist("hgsubversion", "tunnels"):
|
|
hg.schemes["svn+" + tunnel] = svnrepo
|
|
|
|
|
|
@namespacepredicate("hgsubversion", priority=80)
|
|
def _getnamespace(repo):
|
|
if repo.ui.configbool("hgsubversion", "nativerevs"):
|
|
return namespaces.namespace(
|
|
listnames=lambda repo: [],
|
|
namemap=util.lookupname,
|
|
nodemap=lambda repo, node: [],
|
|
)
|
|
|
|
|
|
_old_local = hg.schemes["file"]
|
|
|
|
|
|
def _lookup(url):
|
|
if util.islocalrepo(url):
|
|
return svnrepo
|
|
else:
|
|
return _old_local(url)
|
|
|
|
|
|
# install scheme handlers
|
|
hg.schemes.update(
|
|
{
|
|
"file": _lookup,
|
|
"http": svnrepo,
|
|
"https": svnrepo,
|
|
"svn": svnrepo,
|
|
"svn+ssh": svnrepo,
|
|
"svn+http": svnrepo,
|
|
"svn+https": svnrepo,
|
|
}
|
|
)
|
|
|
|
if hgutil.safehasattr(commands, "optionalrepo"):
|
|
commands.optionalrepo += " svn"
|
|
|
|
svncommandopts = [
|
|
("u", "svn-url", "", "path to the Subversion server."),
|
|
("", "stupid", False, "be stupid and use diffy replay."),
|
|
("A", "authors", "", "username mapping filename"),
|
|
("", "filemap", "", "remap file to exclude paths or include only certain paths"),
|
|
("", "force", False, "force an operation to happen"),
|
|
("", "username", "", "username for authentication"),
|
|
("", "password", "", "password for authentication"),
|
|
("r", "rev", "", "Mercurial revision"),
|
|
("", "unsafe-skip-uuid-check", False, "skip repository uuid check in rebuildmeta"),
|
|
]
|
|
svnusage = "hg svn <subcommand> ..."
|
|
|
|
# only these methods are public
|
|
__all__ = ("cmdtable", "reposetup", "uisetup")
|
|
|
|
# set up commands and templatekeywords (written this way to maintain backwards
|
|
# compatibility until we drop support for 3.7 for templatekeywords and 4.3 for
|
|
# commands)
|
|
cmdtable = {"svn": (svncommands.svn, svncommandopts, svnusage)}
|
|
configtable = {}
|
|
try:
|
|
from edenscm.mercurial import registrar
|
|
|
|
templatekeyword = registrar.templatekeyword()
|
|
loadkeyword = lambda registrarobj: None # no-op
|
|
|
|
if hgutil.safehasattr(registrar, "command"):
|
|
cmdtable = {}
|
|
command = registrar.command(cmdtable)
|
|
|
|
@command("svn", svncommandopts, svnusage)
|
|
def svncommand(*args, **kwargs):
|
|
return svncommands.svn(*args, **kwargs)
|
|
|
|
if hgutil.safehasattr(registrar, "configitem"):
|
|
configitem = registrar.configitem(configtable)
|
|
else:
|
|
|
|
def configitem(*args, **kwargs):
|
|
pass
|
|
|
|
|
|
except (ImportError, AttributeError):
|
|
# registrar.templatekeyword isn't available = loading by old hg
|
|
|
|
templatekeyword = compathacks._funcregistrarbase()
|
|
templatekeyword._docformat = ":%s: %s"
|
|
|
|
# minimum copy from templatekw.loadkeyword
|
|
def loadkeyword(registrarobj):
|
|
from edenscm.mercurial import templatekw
|
|
|
|
for name, func in registrarobj._table.iteritems():
|
|
templatekw.keywords[name] = func
|
|
|
|
def configitem(*args, **kwargs):
|
|
# no-op so we can put config items at the top level instead of
|
|
# deeply nested
|
|
pass
|
|
|
|
|
|
if not hgutil.safehasattr(configitem, "dynamicdefault"):
|
|
# hg 4.3 lacks support for dynamicdefault in a way that means we
|
|
# have to not use the config registrar at all.
|
|
def configitem(*args, **kwargs):
|
|
pass
|
|
|
|
configitem.dynamicdefault = None
|
|
|
|
# real default is 'svnexternals'. Can also be 'subrepos' or
|
|
# 'ignore'. Defines how to handle svn:externals.
|
|
configitem("hgsubversion", "externals", default=configitem.dynamicdefault)
|
|
|
|
# If true, use diff+patch instead of svn native replay RPC.
|
|
configitem("hgsubversion", "stupid", default=False)
|
|
|
|
# Allows configuring extra of svn+$SCHEME tunnel protocols
|
|
configitem("hgsubversion", "tunnels", default=list)
|
|
# If true, monkeypatch revset parser to allow r123 to map to
|
|
# Subversion revision 123.
|
|
configitem("hgsubversion", "nativerevs", default=False)
|
|
|
|
# Auth config for the Subversion backend
|
|
configitem("hgsubversion", "username", default="")
|
|
configitem("hgsubversion", "password", default="")
|
|
# The default value of the empty list means to use a default set of
|
|
# password stores. The specific ones that will be consulted depend on
|
|
# the compile-time options of your Subversion libraries.
|
|
configitem("hgsubversion", "password_stores", default=list)
|
|
|
|
# real default is None
|
|
configitem("hgsubversion", "revmapimpl", default=configitem.dynamicdefault)
|
|
# real default is 'auto'
|
|
configitem("hgsubversion", "layout", default=configitem.dynamicdefault)
|
|
|
|
# real default is True
|
|
configitem("hgsubversion", "defaultauthors", default=configitem.dynamicdefault)
|
|
# real default is False
|
|
configitem("hgsubversion", "caseignoreauthors", default=configitem.dynamicdefault)
|
|
# real default is None
|
|
configitem("hgsubversion", "mapauthorscmd", default=configitem.dynamicdefault)
|
|
# Defaults to the UUID identifying the source svn repo.
|
|
configitem("hgsubversion", "defaulthost", default=configitem.dynamicdefault)
|
|
# real default is True
|
|
configitem("hgsubversion", "usebranchnames", default=configitem.dynamicdefault)
|
|
# real default is ''
|
|
configitem("hgsubversion", "defaultmessage", default=configitem.dynamicdefault)
|
|
# real default is ''
|
|
configitem("hgsubversion", "branch", default=configitem.dynamicdefault)
|
|
# real default is ['tags']
|
|
configitem("hgsubversion", "taglocations", default=configitem.dynamicdefault)
|
|
# real default is 'trunk'
|
|
configitem("hgsubversion", "trunkdir", default=configitem.dynamicdefault)
|
|
# real default is ''
|
|
configitem("hgsubversion", "infix", default=configitem.dynamicdefault)
|
|
# real default is ''
|
|
configitem("hgsubversion", "unsafeskip", default=configitem.dynamicdefault)
|
|
# real default is ['tags']
|
|
configitem("hgsubversion", "tagpaths", default=configitem.dynamicdefault)
|
|
# real default is 'branches'
|
|
configitem("hgsubversion", "branchdir", default=configitem.dynamicdefault)
|
|
# real default is 200
|
|
configitem("hgsubversion", "filestoresize", default=configitem.dynamicdefault)
|
|
# Typically unset, custom location of map files typically stored inside .hg
|
|
configitem("hgsubversion", "filemap", default=None)
|
|
configitem("hgsubversion", "branchmap", default=None)
|
|
configitem("hgsubversion", "authormap", default=None)
|
|
configitem("hgsubversion", "tagmap", default=None)
|
|
# real default is False
|
|
configitem("hgsubversion", "failoninvalidreplayfile", default=configitem.dynamicdefault)
|
|
# real default is 0
|
|
configitem("hgsubversion", "startrev", default=configitem.dynamicdefault)
|
|
# extra pragmas to feed to sqlite revmap implementation
|
|
configitem("hgsubversion", "sqlitepragmas", default=list)
|
|
# real default is False
|
|
configitem("hgsubversion", "failonmissing", default=configitem.dynamicdefault)
|
|
|
|
|
|
@templatekeyword("svnrev")
|
|
def svnrevkw(**args):
|
|
""":svnrev: String. Converted subversion revision number."""
|
|
convertinfo = util.getsvnrev(args["ctx"], "")
|
|
|
|
if not convertinfo or not convertinfo.startswith("svn:"):
|
|
return ""
|
|
|
|
return convertinfo[40:].rsplit("@", 1)[-1]
|
|
|
|
|
|
loadkeyword(templatekeyword)
|
|
|
|
|
|
def listsvnkeys(repo):
|
|
keys = {}
|
|
repo = repo.local()
|
|
metadir = os.path.join(repo.path, "svn")
|
|
|
|
if util.subversionmetaexists(repo.path):
|
|
w = repo.wlock()
|
|
try:
|
|
for key in util.pushkeyfiles:
|
|
fullpath = os.path.join(metadir, key)
|
|
if os.path.isfile(fullpath):
|
|
data = open(fullpath).read()
|
|
|
|
# Some of the files could be large, but also quite compressible
|
|
keys[key] = base85.b85encode(zlib.compress(data))
|
|
finally:
|
|
w.release()
|
|
|
|
return keys
|