from kallithea.lib.vcs.exceptions import (

    BranchDoesNotExistError, ChangesetDoesNotExistError, EmptyRepositoryError,

    RepositoryError, VCSError, TagAlreadyExistError, TagDoesNotExistError

)

from kallithea.lib.vcs.utils import (

    author_email, author_name, date_fromtimestamp, makedate, safe_unicode, safe_str,

)

from kallithea.lib.vcs.utils.lazy import LazyProperty

from kallithea.lib.vcs.utils.ordered_dict import OrderedDict

from kallithea.lib.vcs.utils.paths import abspath

from kallithea.lib.vcs.utils.hgcompat import (

    ui, nullid, match, patch, diffopts, clone, get_contact,

    httpbasicauthhandler, httpdigestauthhandler, peer, httppeer, sshpeer, tag

)

from .changeset import MercurialChangeset

from .inmemory import MercurialInMemoryChangeset

from .workdir import MercurialWorkdir

log = logging.getLogger(__name__)

class MercurialRepository(BaseRepository):

    """

        try:

            if src_url:

                url = safe_str(self._get_url(src_url))

                opts = {}

                if not update_after_clone:

                    opts.update({'noupdate': True})

                MercurialRepository._check_url(url, self.baseui)

                clone(self.baseui, url, self.path, **opts)

                # Don't try to create if we've already cloned repo

                create = False

        except (Abort, RepoError) as err:

            if create:

                msg = "Cannot create repository at %s. Original error was %s" \

                    % (self.path, err)

            else:

                msg = "Not valid repository at %s. Original error was %s" \

                    % (self.path, err)

            raise RepositoryError(msg)

    @LazyProperty

    def in_memory_changeset(self):

        return MercurialInMemoryChangeset(self)

from mercurial import archival, merge as hg_merge, patch, ui

from mercurial import discovery

from mercurial import localrepo

from mercurial import unionrepo

from mercurial import scmutil

from mercurial import config

from mercurial import tags as tagsmod

from mercurial.commands import clone, nullid, pull

from mercurial.context import memctx, memfilectx

from mercurial.error import RepoError, RepoLookupError, Abort

from mercurial.hgweb import hgweb_mod

from mercurial.hgweb.common import get_contact

from mercurial.match import match

from mercurial.mdiff import diffopts

from mercurial.node import hex

from mercurial.encoding import tolocal

from mercurial.discovery import findcommonoutgoing

from mercurial.hg import peer

from mercurial.httppeer import httppeer

try: # sshpeer was renamed in Mercurial 4.6 (625038cb4b1d), but v1 is still good enough

    from mercurial.sshpeer import sshv1peer as sshpeer

except ImportError:

    from mercurial.sshpeer import sshpeer

from mercurial.util import url as hg_url

from mercurial.url import httpbasicauthhandler, httpdigestauthhandler

# Mercurial 4.5 8a0cac20a1ad introduced an extra memctx changectx argument

# - introduce an optional wrapper factory that doesn't pass it on

import inspect

if inspect.getargspec(memfilectx.__init__).args[2] != 'changectx':

    __org_memfilectx = memfilectx

    memfilectx = lambda repo, changectx, *args, **kwargs: __org_memfilectx(repo, *args, **kwargs)

# workaround for 3.3 94ac64bcf6fe and not calling largefiles reposetup correctly

# 3.5 7699d3212994 added the invariant that repo.lfstatus must exist before hitting overridearchive

# Mercurial 4.2 moved tag from localrepo to the tags module

def tag(repo, *args):

    try:

        tag_f  = tagsmod.tag

    except AttributeError:

        return repo.tag(*args)

    tag_f(repo, *args)