"""

dirstate.py - working directory tracking for mercurial

Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>

This software may be used and distributed according to the terms

of the GNU General Public License, incorporated herein by reference.

"""

from node import *

from i18n import _

import struct, os, time, bisect, stat, strutil, util, re, errno, ignore

import cStringIO

_unknown = ('?', 0, 0, 0)

_format = ">cllll"

class dirstate(object):

    def __init__(self, opener, ui, root):

        self._opener = opener

        self._root = root

        self._dirty = 0

        self._ui = ui

    def __getattr__(self, name):

        if name == '_map':

            self._read()

            return self._map

        elif name == '_copymap':

            self._read()

            return self._copymap

        elif name == '_branch':

            try:

                self._branch = self._opener("branch").read().strip()\

                               or "default"

            except IOError:

                self._branch = "default"

            return self._branch

        elif name == '_pl':

            self._pl = [nullid, nullid]

            try:

                st = self._opener("dirstate").read(40)

                if len(st) == 40:

                    self._pl = st[:20], st[20:40]

            except IOError, err:

                if err.errno != errno.ENOENT: raise

            return self._pl

        elif name == '_dirs':

            self._dirs = {}

            for f in self._map:

                self._incpath(f)

            return self._dirs

        elif name == '_ignore':

            self._ignore = ignore.ignore(self._root, files, self._ui.warn)

            return self._ignore

        elif name == '_slash':

            self._slash = self._ui.configbool('ui', 'slash') and os.sep != '/'

            return self._slash

        else:

            raise AttributeError, name

    def wjoin(self, f):

        return os.path.join(self._root, f)

    def getcwd(self):

        cwd = os.getcwd()

        if cwd == self._root: return ''

        # self._root ends with a path separator if self._root is '/' or 'C:\'

        rootsep = self._root

        if not rootsep.endswith(os.sep):

            rootsep += os.sep

        if cwd.startswith(rootsep):

            return cwd[len(rootsep):]

        else:

            # we're outside the repo. return an absolute path.

            return cwd

    def pathto(self, f, cwd=None):

        if cwd is None:

            cwd = self.getcwd()

        path = util.pathto(self._root, cwd, f)

        if self._slash:

            return path.replace(os.sep, '/')

        return path

    def __del__(self):

        self.write()

    def __getitem__(self, key):

        return self._map[key]

    def __contains__(self, key):

        return key in self._map

    def __iter__(self):

        a = self._map.keys()

        a.sort()

        for x in a:

            yield x

    def parents(self):

        return self._pl

    def branch(self):

        return self._branch

    def markdirty(self):

        self._dirty = 1

    def setparents(self, p1, p2=nullid):

        self.markdirty()

        self._pl = p1, p2

    def setbranch(self, branch):

        self._branch = branch

        self._opener("branch", "w").write(branch + '\n')

    def state(self, key):

        return self._map.get(key, ("?",))[0]

    def _read(self):

        self._map = {}

        self._copymap = {}

        self._pl = [nullid, nullid]

        try:

            st = self._opener("dirstate").read()

        except IOError, err:

            if err.errno != errno.ENOENT: raise

            return

        if not st:

            return

        self._pl = [st[:20], st[20: 40]]

        # deref fields so they will be local in loop

        dmap = self._map

        copymap = self._copymap

        unpack = struct.unpack

        pos = 40

        e_size = struct.calcsize(_format)

        while pos < len(st):

            newpos = pos + e_size

            e = unpack(_format, st[pos:newpos])

            l = e[4]

            pos = newpos

            newpos = pos + l

            f = st[pos:newpos]

            if '\0' in f:

                f, c = f.split('\0')

                copymap[f] = c

            dmap[f] = e[:4]

            pos = newpos

    def invalidate(self):

        for a in "_map _copymap _branch pl _dirs _ignore".split():

            if hasattr(self, a):

                self.__delattr__(a)

    def copy(self, source, dest):

        self.markdirty()

        self._copymap[dest] = source

    def copied(self, file):

        return self._copymap.get(file, None)

    def copies(self):

        return self._copymap

    def _incpath(self, path):

        for c in strutil.findall(path, '/'):

            pc = path[:c]

            self._dirs.setdefault(pc, 0)

            self._dirs[pc] += 1

    def _decpath(self, path):

        for c in strutil.findall(path, '/'):

            pc = path[:c]

            self._dirs.setdefault(pc, 0)

            self._dirs[pc] -= 1

    def _incpathcheck(self, f):

        if '\r' in f or '\n' in f:

            raise util.Abort(_("'\\n' and '\\r' disallowed in filenames"))

        # shadows

        if f in self._dirs:

            raise util.Abort(_('directory named %r already in dirstate') % f)

        for c in strutil.rfindall(f, '/'):

            d = f[:c]

            if d in self._dirs:

                break

            if d in self._map:

                raise util.Abort(_('file named %r already in dirstate') % d)

        self._incpath(f)

    def update(self, files, state, **kw):

        ''' current states:

        n  normal

        m  needs merging

        r  marked for removal

        a  marked for addition'''

        if not files: return

        self.markdirty()

        for f in files:

            if self._copymap.has_key(f):

                del self._copymap[f]

            if state == "r":

                self._map[f] = ('r', 0, 0, 0)

                self._decpath(f)

                continue

            else:

                if state == "a":

                    self._incpathcheck(f)

                s = os.lstat(self.wjoin(f))

                st_size = kw.get('st_size', s.st_size)

                st_mtime = kw.get('st_mtime', s.st_mtime)

                self._map[f] = (state, s.st_mode, st_size, st_mtime)

    def forget(self, files):

        if not files: return

        self.markdirty()

        for f in files:

            try:

                del self._map[f]

                self._decpath(f)

            except KeyError:

                self._ui.warn(_("not in dirstate: %s!\n") % f)

                pass

    def rebuild(self, parent, files):

        self.invalidate()

        for f in files:

            if files.execf(f):

                self._map[f] = ('n', 0777, -1, 0)

            else:

                self._map[f] = ('n', 0666, -1, 0)

        self._pl = (parent, nullid)

        self.markdirty()

    def write(self):

        if not self._dirty:

            return

        cs = cStringIO.StringIO()

        cs.write("".join(self._pl))

        for f, e in self._map.iteritems():

            c = self.copied(f)

            if c:

                f = f + "\0" + c

            e = struct.pack(_format, e[0], e[1], e[2], e[3], len(f))

            cs.write(e)

            cs.write(f)

        st = self._opener("dirstate", "w", atomictemp=True)

        st.write(cs.getvalue())

        st.rename()

        self._dirty = 0

    def filterfiles(self, files):

        ret = {}

        unknown = []

        for x in files:

            if x == '.':

                return self._map.copy()

            if x not in self._map:

                unknown.append(x)

            else:

                ret[x] = self._map[x]

        if not unknown:

            return ret

        b = self._map.keys()

        b.sort()

        blen = len(b)

        for x in unknown:

            bs = bisect.bisect(b, "%s%s" % (x, '/'))

            while bs < blen:

                s = b[bs]

                if len(s) > len(x) and s.startswith(x):

                    ret[s] = self._map[s]

                else:

                    break

                bs += 1

        return ret

    def _supported(self, f, st, verbose=False):

        if stat.S_ISREG(st.st_mode) or stat.S_ISLNK(st.st_mode):

            return True

        if verbose:

            kind = 'unknown'

            if stat.S_ISCHR(st.st_mode): kind = _('character device')

            elif stat.S_ISBLK(st.st_mode): kind = _('block device')

            elif stat.S_ISFIFO(st.st_mode): kind = _('fifo')

            elif stat.S_ISSOCK(st.st_mode): kind = _('socket')

            elif stat.S_ISDIR(st.st_mode): kind = _('directory')

            self._ui.warn(_('%s: unsupported file type (type is %s)\n')

                         % (self.pathto(f), kind))

        return False

    def walk(self, files=None, match=util.always, badmatch=None):

        # filter out the stat

        for src, f, st in self.statwalk(files, match, badmatch=badmatch):

            yield src, f

    def statwalk(self, files=None, match=util.always, ignored=False,

                 badmatch=None, directories=False):

        '''

        walk recursively through the directory tree, finding all files

        matched by the match function

        results are yielded in a tuple (src, filename, st), where src

        is one of:

        'f' the file was found in the directory tree

        'd' the file is a directory of the tree

        'm' the file was only in the dirstate and not in the tree

        'b' file was not found and matched badmatch

        and st is the stat result if the file was found in the directory.

        '''

        # walk all files by default

        if not files:

            files = ['.']

            dc = self._map.copy()

        else:

            files = util.unique(files)

            dc = self.filterfiles(files)

        def imatch(file_):

            if file_ not in dc and self._ignore(file_):

                return False

            return match(file_)

        ignore = self._ignore

        if ignored:

            imatch = match

            ignore = util.never

        # self._root may end with a path separator when self._root == '/'

        common_prefix_len = len(self._root)

        if not self._root.endswith(os.sep):

            common_prefix_len += 1

        # recursion free walker, faster than os.walk.

        def findfiles(s):

            work = [s]

            if directories:

                yield 'd', util.normpath(s[common_prefix_len:]), os.lstat(s)

            while work: