# monotone support for the convert extension

from mercurial import util

    def __init__(self, ui, path=None, rev=None):

        converter_source.__init__(self, ui, path, rev)

        self.ui = ui

        self.path = path

        # regular expressions for parsing monotone output

        space    = r'\s*'

        name     = r'\s+"((?:[^"]|\\")*)"\s*'

        value    = name

        revision = r'\s+\[(\w+)\]\s*'

        lines    = r'(?:.|\n)+'

        self.add_file_re = re.compile(space + "add_file" + name + "content" + revision)

        self.cert_re     = re.compile(lines + space + "name" + name + "value" + value)

        attr = space + "file" + lines + space + "attr" + space

        self.attr_execute_re = re.compile(attr  + '"mtn:execute"' + space + '"true"')

        # cached data

        self.manifest_rev = None

        self.manifest = None

        if not os.path.exists(path):

            raise norepo

        checktool('mtn')

        self.rev = None

            self.getheads()

        self.rev = rev

    def mtnloadmanifest(self, rev):

        if self.manifest_rev == rev:

            return

        self.manifest_rev = rev

            m = self.file_re.match(e)

                attr = ""

                name = m.group(1)

                node = m.group(2)

                if self.attr_execute_re.match(e):

                    attr += "x"

            m = self.dir_re.match(e)

            if m:

    def mtnisfile(self, name, rev):

        # a non-file could be a directory or a deleted or renamed file

        self.mtnloadmanifest(rev)

            self.files[name]

            return True

        except KeyError:

            return False

    def mtnisdir(self, name, rev):

        self.mtnloadmanifest(rev)

            self.dirs[name]

            return True

        except KeyError:

            return False

    def mtngetcerts(self, rev):

        certs = {"author":"<missing>", "date":"<missing>",

            "changelog":"<missing>", "branch":"<missing>"}

        for e in cert_list:

            m = self.cert_re.match(e)

            if m:

                certs[m.group(1)] = m.group(2)

        return certs

    def mtnrenamefiles(self, files, fromdir, todir):

        renamed = {}

        for tofile in files:

            suffix = tofile.lstrip(todir)

            if todir + suffix == tofile:

                renamed[tofile] = (fromdir + suffix).lstrip("/")

        return renamed

    # implement the converter_source interface:

    def getheads(self):

        else:

            return [self.rev]

    def getchanges(self, rev):

        files = {}

        copies = {}

        for e in revision:

            m = self.add_file_re.match(e)

            if m:

                files[m.group(1)] = rev

            m = self.patch_re.match(e)

            if m:

                files[m.group(1)] = rev

            # Delete/rename is handled later when the convert engine

            # discovers an IOError exception from getfile,

            # but only if we add the "from" file to the list of changes.

            m = self.rename_re.match(e)

            if m:

                toname = m.group(2)

                fromname = m.group(1)

                if self.mtnisfile(toname, rev):

                    copies[toname] = fromname

                    files[toname] = rev

                    files[fromname] = rev

                if self.mtnisdir(toname, rev):

                    renamed = self.mtnrenamefiles(self.files, fromname, toname)

                    for tofile, fromfile in renamed.items():

                        files[tofile] = rev

                    for fromfile in renamed.values():

                        files[fromfile] = rev

    def getmode(self, name, rev):

        self.mtnloadmanifest(rev)

            node, attr = self.files[name]

            return attr

        except KeyError:

            return ""

    def getfile(self, name, rev):

        if not self.mtnisfile(name, rev):

            raise IOError() # file was deleted or renamed

        certs   = self.mtngetcerts(rev)

        return commit(

            author=certs["author"],

            date=util.datestr(util.strdate(certs["date"], "%Y-%m-%dT%H:%M:%S")),

            desc=certs["changelog"],

            rev=rev,

            branch=certs["branch"])

    def gettags(self):

        tags = {}

            m = self.tag_re.match(e)

            if m:

                tags[m.group(1)] = m.group(2)

        return tags

    def getchangedfiles(self, rev, i):

        # This function is only needed to support --filemap

        # ... and we don't support that

        raise NotImplementedError()