~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/workingtree.py

  • Committer: Robert Collins
  • Date: 2005-10-30 00:00:09 UTC
  • mfrom: (1185.16.134)
  • Revision ID: robertc@robertcollins.net-20051030000009-9db99a338a0dfdac
MergeĀ fromĀ Martin.

Show diffs side-by-side

added added

removed removed

Lines of Context:
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
 
17
"""WorkingTree object and friends.
 
18
 
 
19
A WorkingTree represents the editable working copy of a branch.
 
20
Operations which represent the WorkingTree are also done here, 
 
21
such as renaming or adding files.  The WorkingTree has an inventory 
 
22
which is updated by these operations.  A commit produces a 
 
23
new revision based on the workingtree and its inventory.
 
24
 
 
25
At the moment every WorkingTree has its own branch.  Remote
 
26
WorkingTrees aren't supported.
 
27
 
 
28
To get a WorkingTree, call Branch.working_tree():
 
29
"""
 
30
 
 
31
 
 
32
# TODO: Don't allow WorkingTrees to be constructed for remote branches if 
 
33
# they don't work.
 
34
 
 
35
# FIXME: I don't know if writing out the cache from the destructor is really a
 
36
# good idea, because destructors are considered poor taste in Python, and it's
 
37
# not predictable when it will be written out.
 
38
 
 
39
# TODO: Give the workingtree sole responsibility for the working inventory;
 
40
# remove the variable and references to it from the branch.  This may require
 
41
# updating the commit code so as to update the inventory within the working
 
42
# copy, and making sure there's only one WorkingTree for any directory on disk.
 
43
# At the momenthey may alias the inventory and have old copies of it in memory.
17
44
 
18
45
import os
19
 
    
 
46
import stat
 
47
import fnmatch
 
48
 
 
49
from bzrlib.branch import Branch, needs_read_lock, needs_write_lock, quotefn
20
50
import bzrlib.tree
21
 
from errors import BzrCheckError
22
 
from trace import mutter
23
 
import statcache
 
51
from bzrlib.osutils import appendpath, file_kind, isdir, splitpath, relpath
 
52
from bzrlib.errors import BzrCheckError, DivergedBranches, NotVersionedError
 
53
from bzrlib.trace import mutter
 
54
 
 
55
 
 
56
class TreeEntry(object):
 
57
    """An entry that implements the minium interface used by commands.
 
58
 
 
59
    This needs further inspection, it may be better to have 
 
60
    InventoryEntries without ids - though that seems wrong. For now,
 
61
    this is a parallel hierarchy to InventoryEntry, and needs to become
 
62
    one of several things: decorates to that hierarchy, children of, or
 
63
    parents of it.
 
64
    Another note is that these objects are currently only used when there is
 
65
    no InventoryEntry available - i.e. for unversioned objects.
 
66
    Perhaps they should be UnversionedEntry et al. ? - RBC 20051003
 
67
    """
 
68
 
 
69
    def __eq__(self, other):
 
70
        # yes, this us ugly, TODO: best practice __eq__ style.
 
71
        return (isinstance(other, TreeEntry)
 
72
                and other.__class__ == self.__class__)
 
73
 
 
74
    def kind_character(self):
 
75
        return "???"
 
76
 
 
77
 
 
78
class TreeDirectory(TreeEntry):
 
79
    """See TreeEntry. This is a directory in a working tree."""
 
80
 
 
81
    def __eq__(self, other):
 
82
        return (isinstance(other, TreeDirectory)
 
83
                and other.__class__ == self.__class__)
 
84
 
 
85
    def kind_character(self):
 
86
        return "/"
 
87
 
 
88
 
 
89
class TreeFile(TreeEntry):
 
90
    """See TreeEntry. This is a regular file in a working tree."""
 
91
 
 
92
    def __eq__(self, other):
 
93
        return (isinstance(other, TreeFile)
 
94
                and other.__class__ == self.__class__)
 
95
 
 
96
    def kind_character(self):
 
97
        return ''
 
98
 
 
99
 
 
100
class TreeLink(TreeEntry):
 
101
    """See TreeEntry. This is a symlink in a working tree."""
 
102
 
 
103
    def __eq__(self, other):
 
104
        return (isinstance(other, TreeLink)
 
105
                and other.__class__ == self.__class__)
 
106
 
 
107
    def kind_character(self):
 
108
        return ''
 
109
 
24
110
 
25
111
class WorkingTree(bzrlib.tree.Tree):
26
112
    """Working copy tree.
31
117
    It is possible for a `WorkingTree` to have a filename which is
32
118
    not listed in the Inventory and vice versa.
33
119
    """
34
 
    _statcache = None
35
 
    
36
 
    def __init__(self, basedir, inv):
37
 
        self._inventory = inv
 
120
 
 
121
    def __init__(self, basedir, branch=None):
 
122
        """Construct a WorkingTree for basedir.
 
123
 
 
124
        If the branch is not supplied, it is opened automatically.
 
125
        If the branch is supplied, it must be the branch for this basedir.
 
126
        (branch.base is not cross checked, because for remote branches that
 
127
        would be meaningless).
 
128
        """
 
129
        from bzrlib.hashcache import HashCache
 
130
        from bzrlib.trace import note, mutter
 
131
        assert isinstance(basedir, basestring), \
 
132
            "base directory %r is not a string" % basedir
 
133
        if branch is None:
 
134
            branch = Branch.open(basedir)
 
135
        assert isinstance(branch, Branch), \
 
136
            "branch %r is not a Branch" % branch
 
137
        self._inventory = branch.inventory
 
138
        self.path2id = self._inventory.path2id
 
139
        self.branch = branch
38
140
        self.basedir = basedir
39
 
        self.path2id = inv.path2id
40
 
        self._update_statcache()
 
141
 
 
142
        # update the whole cache up front and write to disk if anything changed;
 
143
        # in the future we might want to do this more selectively
 
144
        # two possible ways offer themselves : in self._unlock, write the cache
 
145
        # if needed, or, when the cache sees a change, append it to the hash
 
146
        # cache file, and have the parser take the most recent entry for a
 
147
        # given path only.
 
148
        hc = self._hashcache = HashCache(basedir)
 
149
        hc.read()
 
150
        hc.scan()
 
151
 
 
152
        if hc.needs_write:
 
153
            mutter("write hc")
 
154
            hc.write()
41
155
 
42
156
    def __iter__(self):
43
157
        """Iterate through file_ids for this tree.
46
160
        and the working file exists.
47
161
        """
48
162
        inv = self._inventory
49
 
        for file_id in self._inventory:
50
 
            # TODO: This is slightly redundant; we should be able to just
51
 
            # check the statcache but it only includes regular files.
52
 
            # only include files which still exist on disk
53
 
            ie = inv[file_id]
54
 
            if ie.kind == 'file':
55
 
                if ((file_id in self._statcache)
56
 
                    or (os.path.exists(self.abspath(inv.id2path(file_id))))):
57
 
                    yield file_id
58
 
 
 
163
        for path, ie in inv.iter_entries():
 
164
            if bzrlib.osutils.lexists(self.abspath(path)):
 
165
                yield ie.file_id
59
166
 
60
167
 
61
168
    def __repr__(self):
62
169
        return "<%s of %s>" % (self.__class__.__name__,
63
 
                               self.basedir)
 
170
                               getattr(self, 'basedir', None))
 
171
 
 
172
 
64
173
 
65
174
    def abspath(self, filename):
66
175
        return os.path.join(self.basedir, filename)
67
176
 
 
177
    def relpath(self, abspath):
 
178
        """Return the local path portion from a given absolute path."""
 
179
        return relpath(self.basedir, abspath)
 
180
 
68
181
    def has_filename(self, filename):
69
 
        return os.path.exists(self.abspath(filename))
 
182
        return bzrlib.osutils.lexists(self.abspath(filename))
70
183
 
71
184
    def get_file(self, file_id):
72
185
        return self.get_file_byname(self.id2path(file_id))
78
191
        ## XXX: badly named; this isn't in the store at all
79
192
        return self.abspath(self.id2path(file_id))
80
193
 
 
194
 
 
195
    def id2abspath(self, file_id):
 
196
        return self.abspath(self.id2path(file_id))
 
197
 
81
198
                
82
199
    def has_id(self, file_id):
83
200
        # files that have been deleted are excluded
84
 
        if not self.inventory.has_id(file_id):
 
201
        inv = self._inventory
 
202
        if not inv.has_id(file_id):
85
203
            return False
86
 
        if file_id in self._statcache:
 
204
        path = inv.id2path(file_id)
 
205
        return bzrlib.osutils.lexists(self.abspath(path))
 
206
 
 
207
    def has_or_had_id(self, file_id):
 
208
        if file_id == self.inventory.root.file_id:
87
209
            return True
88
 
        return os.path.exists(self.abspath(self.id2path(file_id)))
89
 
 
 
210
        return self.inventory.has_id(file_id)
90
211
 
91
212
    __contains__ = has_id
92
213
    
93
214
 
94
 
    def _update_statcache(self):
95
 
        import statcache
96
 
        if not self._statcache:
97
 
            self._statcache = statcache.update_cache(self.basedir, self.inventory)
98
 
 
99
215
    def get_file_size(self, file_id):
100
 
        import os, stat
101
 
        return os.stat(self._get_store_filename(file_id))[stat.ST_SIZE]
102
 
 
 
216
        return os.path.getsize(self.id2abspath(file_id))
103
217
 
104
218
    def get_file_sha1(self, file_id):
105
 
        return self._statcache[file_id][statcache.SC_SHA1]
106
 
 
 
219
        path = self._inventory.id2path(file_id)
 
220
        return self._hashcache.get_sha1(path)
 
221
 
 
222
 
 
223
    def is_executable(self, file_id):
 
224
        if os.name == "nt":
 
225
            return self._inventory[file_id].executable
 
226
        else:
 
227
            path = self._inventory.id2path(file_id)
 
228
            mode = os.lstat(self.abspath(path)).st_mode
 
229
            return bool(stat.S_ISREG(mode) and stat.S_IEXEC&mode)
 
230
 
 
231
    def get_symlink_target(self, file_id):
 
232
        return os.readlink(self.id2abspath(file_id))
107
233
 
108
234
    def file_class(self, filename):
109
235
        if self.path2id(filename):
124
250
 
125
251
        Skips the control directory.
126
252
        """
127
 
        from osutils import appendpath, file_kind
128
 
        import os
129
 
 
130
 
        inv = self.inventory
 
253
        inv = self._inventory
131
254
 
132
255
        def descend(from_dir_relpath, from_dir_id, dp):
133
256
            ls = os.listdir(dp)
161
284
                                            "now of kind %r"
162
285
                                            % (fap, f_ie.kind, f_ie.file_id, fk))
163
286
 
164
 
                yield fp, c, fk, (f_ie and f_ie.file_id)
 
287
                # make a last minute entry
 
288
                if f_ie:
 
289
                    entry = f_ie
 
290
                else:
 
291
                    if fk == 'directory':
 
292
                        entry = TreeDirectory()
 
293
                    elif fk == 'file':
 
294
                        entry = TreeFile()
 
295
                    elif fk == 'symlink':
 
296
                        entry = TreeLink()
 
297
                    else:
 
298
                        entry = TreeEntry()
 
299
                
 
300
                yield fp, c, fk, (f_ie and f_ie.file_id), entry
165
301
 
166
302
                if fk != 'directory':
167
303
                    continue
183
319
            if not self.is_ignored(subp):
184
320
                yield subp
185
321
 
 
322
    def iter_conflicts(self):
 
323
        conflicted = set()
 
324
        for path in (s[0] for s in self.list_files()):
 
325
            stem = get_conflicted_stem(path)
 
326
            if stem is None:
 
327
                continue
 
328
            if stem not in conflicted:
 
329
                conflicted.add(stem)
 
330
                yield stem
 
331
 
 
332
    @needs_write_lock
 
333
    def pull(self, source, overwrite=False):
 
334
        from bzrlib.merge import merge_inner
 
335
        source.lock_read()
 
336
        try:
 
337
            old_revision_history = self.branch.revision_history()
 
338
            self.branch.pull(source, overwrite)
 
339
            new_revision_history = self.branch.revision_history()
 
340
            if new_revision_history != old_revision_history:
 
341
                if len(old_revision_history):
 
342
                    other_revision = old_revision_history[-1]
 
343
                else:
 
344
                    other_revision = None
 
345
                merge_inner(self.branch,
 
346
                            self.branch.basis_tree(), 
 
347
                            self.branch.revision_tree(other_revision))
 
348
        finally:
 
349
            source.unlock()
186
350
 
187
351
    def extras(self):
188
352
        """Yield all unknown files in this WorkingTree.
194
358
        Currently returned depth-first, sorted by name within directories.
195
359
        """
196
360
        ## TODO: Work from given directory downwards
197
 
        from osutils import isdir, appendpath
198
 
        
199
361
        for path, dir_entry in self.inventory.directories():
200
362
            mutter("search for unknowns in %r" % path)
201
363
            dirabs = self.abspath(path)
258
420
        # Eventually it should be replaced with something more
259
421
        # accurate.
260
422
        
261
 
        import fnmatch
262
 
        from osutils import splitpath
263
 
        
264
423
        for pat in self.get_ignore_list():
265
424
            if '/' in pat or '\\' in pat:
266
425
                
279
438
                    return pat
280
439
        else:
281
440
            return None
282
 
        
283
 
 
284
 
        
285
 
        
286
 
 
 
441
 
 
442
    def kind(self, file_id):
 
443
        return file_kind(self.id2abspath(file_id))
 
444
 
 
445
    def lock_read(self):
 
446
        """See Branch.lock_read, and WorkingTree.unlock."""
 
447
        return self.branch.lock_read()
 
448
 
 
449
    def lock_write(self):
 
450
        """See Branch.lock_write, and WorkingTree.unlock."""
 
451
        return self.branch.lock_write()
 
452
 
 
453
    @needs_write_lock
 
454
    def remove(self, files, verbose=False):
 
455
        """Remove nominated files from the working inventory..
 
456
 
 
457
        This does not remove their text.  This does not run on XXX on what? RBC
 
458
 
 
459
        TODO: Refuse to remove modified files unless --force is given?
 
460
 
 
461
        TODO: Do something useful with directories.
 
462
 
 
463
        TODO: Should this remove the text or not?  Tough call; not
 
464
        removing may be useful and the user can just use use rm, and
 
465
        is the opposite of add.  Removing it is consistent with most
 
466
        other tools.  Maybe an option.
 
467
        """
 
468
        ## TODO: Normalize names
 
469
        ## TODO: Remove nested loops; better scalability
 
470
        if isinstance(files, basestring):
 
471
            files = [files]
 
472
 
 
473
        inv = self.inventory
 
474
 
 
475
        # do this before any modifications
 
476
        for f in files:
 
477
            fid = inv.path2id(f)
 
478
            if not fid:
 
479
                # TODO: Perhaps make this just a warning, and continue?
 
480
                # This tends to happen when 
 
481
                raise NotVersionedError(path=f)
 
482
            mutter("remove inventory entry %s {%s}" % (quotefn(f), fid))
 
483
            if verbose:
 
484
                # having remove it, it must be either ignored or unknown
 
485
                if self.is_ignored(f):
 
486
                    new_status = 'I'
 
487
                else:
 
488
                    new_status = '?'
 
489
                show_status(new_status, inv[fid].kind, quotefn(f))
 
490
            del inv[fid]
 
491
 
 
492
        self.branch._write_inventory(inv)
 
493
 
 
494
    def unlock(self):
 
495
        """See Branch.unlock.
 
496
        
 
497
        WorkingTree locking just uses the Branch locking facilities.
 
498
        This is current because all working trees have an embedded branch
 
499
        within them. IF in the future, we were to make branch data shareable
 
500
        between multiple working trees, i.e. via shared storage, then we 
 
501
        would probably want to lock both the local tree, and the branch.
 
502
        """
 
503
        return self.branch.unlock()
 
504
 
 
505
 
 
506
CONFLICT_SUFFIXES = ('.THIS', '.BASE', '.OTHER')
 
507
def get_conflicted_stem(path):
 
508
    for suffix in CONFLICT_SUFFIXES:
 
509
        if path.endswith(suffix):
 
510
            return path[:-len(suffix)]