~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/workingtree.py

Exclude more files from dumb-rsync upload

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
 
# TODO: Don't allow WorkingTrees to be constructed for remote branches.
 
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.
18
34
 
19
35
# FIXME: I don't know if writing out the cache from the destructor is really a
20
 
# good idea, because destructors are considered poor taste in Python, and
21
 
# it's not predictable when it will be written out.
 
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.
22
44
 
23
45
import os
24
46
import stat
25
47
import fnmatch
26
 
        
 
48
 
 
49
from bzrlib.branch import Branch, needs_read_lock, needs_write_lock, quotefn
27
50
import bzrlib.tree
28
 
from bzrlib.osutils import appendpath, file_kind, isdir, splitpath
29
 
from bzrlib.errors import BzrCheckError
 
51
from bzrlib.osutils import (appendpath,
 
52
                            file_kind,
 
53
                            isdir,
 
54
                            pumpfile,
 
55
                            splitpath,
 
56
                            relpath)
 
57
from bzrlib.errors import BzrCheckError, DivergedBranches, NotVersionedError
30
58
from bzrlib.trace import mutter
 
59
import bzrlib.xml5
 
60
 
31
61
 
32
62
class TreeEntry(object):
33
63
    """An entry that implements the minium interface used by commands.
93
123
    It is possible for a `WorkingTree` to have a filename which is
94
124
    not listed in the Inventory and vice versa.
95
125
    """
96
 
    def __init__(self, basedir, inv):
 
126
 
 
127
    def __init__(self, basedir, branch=None):
 
128
        """Construct a WorkingTree for basedir.
 
129
 
 
130
        If the branch is not supplied, it is opened automatically.
 
131
        If the branch is supplied, it must be the branch for this basedir.
 
132
        (branch.base is not cross checked, because for remote branches that
 
133
        would be meaningless).
 
134
        """
97
135
        from bzrlib.hashcache import HashCache
98
136
        from bzrlib.trace import note, mutter
99
 
 
100
 
        self._inventory = inv
 
137
        assert isinstance(basedir, basestring), \
 
138
            "base directory %r is not a string" % basedir
 
139
        if branch is None:
 
140
            branch = Branch.open(basedir)
 
141
        assert isinstance(branch, Branch), \
 
142
            "branch %r is not a Branch" % branch
 
143
        self.branch = branch
101
144
        self.basedir = basedir
102
 
        self.path2id = inv.path2id
 
145
        self._inventory = self.read_working_inventory()
 
146
        self.path2id = self._inventory.path2id
103
147
 
104
148
        # update the whole cache up front and write to disk if anything changed;
105
149
        # in the future we might want to do this more selectively
 
150
        # two possible ways offer themselves : in self._unlock, write the cache
 
151
        # if needed, or, when the cache sees a change, append it to the hash
 
152
        # cache file, and have the parser take the most recent entry for a
 
153
        # given path only.
106
154
        hc = self._hashcache = HashCache(basedir)
107
155
        hc.read()
108
156
        hc.scan()
110
158
        if hc.needs_write:
111
159
            mutter("write hc")
112
160
            hc.write()
113
 
            
114
 
            
115
 
    def __del__(self):
116
 
        if self._hashcache.needs_write:
117
 
            self._hashcache.write()
118
 
 
119
161
 
120
162
    def __iter__(self):
121
163
        """Iterate through file_ids for this tree.
138
180
    def abspath(self, filename):
139
181
        return os.path.join(self.basedir, filename)
140
182
 
 
183
    def relpath(self, abspath):
 
184
        """Return the local path portion from a given absolute path."""
 
185
        return relpath(self.basedir, abspath)
 
186
 
141
187
    def has_filename(self, filename):
142
188
        return bzrlib.osutils.lexists(self.abspath(filename))
143
189
 
147
193
    def get_file_byname(self, filename):
148
194
        return file(self.abspath(filename), 'rb')
149
195
 
 
196
    def get_root_id(self):
 
197
        """Return the id of this trees root"""
 
198
        inv = self.read_working_inventory()
 
199
        return inv.root.file_id
 
200
        
150
201
    def _get_store_filename(self, file_id):
151
202
        ## XXX: badly named; this isn't in the store at all
152
203
        return self.abspath(self.id2path(file_id))
153
204
 
 
205
    @needs_write_lock
 
206
    def commit(self, *args, **kw):
 
207
        from bzrlib.commit import Commit
 
208
        Commit().commit(self.branch, *args, **kw)
 
209
        self._inventory = self.read_working_inventory()
154
210
 
155
211
    def id2abspath(self, file_id):
156
212
        return self.abspath(self.id2path(file_id))
164
220
        path = inv.id2path(file_id)
165
221
        return bzrlib.osutils.lexists(self.abspath(path))
166
222
 
 
223
    def has_or_had_id(self, file_id):
 
224
        if file_id == self.inventory.root.file_id:
 
225
            return True
 
226
        return self.inventory.has_id(file_id)
167
227
 
168
228
    __contains__ = has_id
169
229
    
184
244
            mode = os.lstat(self.abspath(path)).st_mode
185
245
            return bool(stat.S_ISREG(mode) and stat.S_IEXEC&mode)
186
246
 
 
247
    @needs_write_lock
 
248
    def add_pending_merge(self, *revision_ids):
 
249
        # TODO: Perhaps should check at this point that the
 
250
        # history of the revision is actually present?
 
251
        p = self.pending_merges()
 
252
        updated = False
 
253
        for rev_id in revision_ids:
 
254
            if rev_id in p:
 
255
                continue
 
256
            p.append(rev_id)
 
257
            updated = True
 
258
        if updated:
 
259
            self.set_pending_merges(p)
 
260
 
 
261
    def pending_merges(self):
 
262
        """Return a list of pending merges.
 
263
 
 
264
        These are revisions that have been merged into the working
 
265
        directory but not yet committed.
 
266
        """
 
267
        cfn = self.branch._rel_controlfilename('pending-merges')
 
268
        if not self.branch._transport.has(cfn):
 
269
            return []
 
270
        p = []
 
271
        for l in self.branch.controlfile('pending-merges', 'r').readlines():
 
272
            p.append(l.rstrip('\n'))
 
273
        return p
 
274
 
 
275
    @needs_write_lock
 
276
    def set_pending_merges(self, rev_list):
 
277
        self.branch.put_controlfile('pending-merges', '\n'.join(rev_list))
 
278
 
187
279
    def get_symlink_target(self, file_id):
188
 
        return os.readlink(self.id2path(file_id))
 
280
        return os.readlink(self.id2abspath(file_id))
189
281
 
190
282
    def file_class(self, filename):
191
283
        if self.path2id(filename):
275
367
            if not self.is_ignored(subp):
276
368
                yield subp
277
369
 
 
370
    def iter_conflicts(self):
 
371
        conflicted = set()
 
372
        for path in (s[0] for s in self.list_files()):
 
373
            stem = get_conflicted_stem(path)
 
374
            if stem is None:
 
375
                continue
 
376
            if stem not in conflicted:
 
377
                conflicted.add(stem)
 
378
                yield stem
 
379
 
 
380
    @needs_write_lock
 
381
    def pull(self, source, overwrite=False):
 
382
        from bzrlib.merge import merge_inner
 
383
        source.lock_read()
 
384
        try:
 
385
            old_revision_history = self.branch.revision_history()
 
386
            self.branch.pull(source, overwrite)
 
387
            new_revision_history = self.branch.revision_history()
 
388
            if new_revision_history != old_revision_history:
 
389
                if len(old_revision_history):
 
390
                    other_revision = old_revision_history[-1]
 
391
                else:
 
392
                    other_revision = None
 
393
                merge_inner(self.branch,
 
394
                            self.branch.basis_tree(), 
 
395
                            self.branch.revision_tree(other_revision))
 
396
        finally:
 
397
            source.unlock()
278
398
 
279
399
    def extras(self):
280
400
        """Yield all unknown files in this WorkingTree.
287
407
        """
288
408
        ## TODO: Work from given directory downwards
289
409
        for path, dir_entry in self.inventory.directories():
290
 
            mutter("search for unknowns in %r" % path)
 
410
            mutter("search for unknowns in %r", path)
291
411
            dirabs = self.abspath(path)
292
412
            if not isdir(dirabs):
293
413
                # e.g. directory deleted
366
486
                    return pat
367
487
        else:
368
488
            return None
 
489
 
 
490
    def kind(self, file_id):
 
491
        return file_kind(self.id2abspath(file_id))
 
492
 
 
493
    def lock_read(self):
 
494
        """See Branch.lock_read, and WorkingTree.unlock."""
 
495
        return self.branch.lock_read()
 
496
 
 
497
    def lock_write(self):
 
498
        """See Branch.lock_write, and WorkingTree.unlock."""
 
499
        return self.branch.lock_write()
 
500
 
 
501
    @needs_read_lock
 
502
    def read_working_inventory(self):
 
503
        """Read the working inventory."""
 
504
        # ElementTree does its own conversion from UTF-8, so open in
 
505
        # binary.
 
506
        f = self.branch.controlfile('inventory', 'rb')
 
507
        return bzrlib.xml5.serializer_v5.read_inventory(f)
 
508
 
 
509
    @needs_write_lock
 
510
    def remove(self, files, verbose=False):
 
511
        """Remove nominated files from the working inventory..
 
512
 
 
513
        This does not remove their text.  This does not run on XXX on what? RBC
 
514
 
 
515
        TODO: Refuse to remove modified files unless --force is given?
 
516
 
 
517
        TODO: Do something useful with directories.
 
518
 
 
519
        TODO: Should this remove the text or not?  Tough call; not
 
520
        removing may be useful and the user can just use use rm, and
 
521
        is the opposite of add.  Removing it is consistent with most
 
522
        other tools.  Maybe an option.
 
523
        """
 
524
        ## TODO: Normalize names
 
525
        ## TODO: Remove nested loops; better scalability
 
526
        if isinstance(files, basestring):
 
527
            files = [files]
 
528
 
 
529
        inv = self.inventory
 
530
 
 
531
        # do this before any modifications
 
532
        for f in files:
 
533
            fid = inv.path2id(f)
 
534
            if not fid:
 
535
                # TODO: Perhaps make this just a warning, and continue?
 
536
                # This tends to happen when 
 
537
                raise NotVersionedError(path=f)
 
538
            mutter("remove inventory entry %s {%s}", quotefn(f), fid)
 
539
            if verbose:
 
540
                # having remove it, it must be either ignored or unknown
 
541
                if self.is_ignored(f):
 
542
                    new_status = 'I'
 
543
                else:
 
544
                    new_status = '?'
 
545
                show_status(new_status, inv[fid].kind, quotefn(f))
 
546
            del inv[fid]
 
547
 
 
548
        self._write_inventory(inv)
 
549
 
 
550
    @needs_write_lock
 
551
    def revert(self, filenames, old_tree=None, backups=True):
 
552
        from bzrlib.merge import merge_inner
 
553
        if old_tree is None:
 
554
            old_tree = self.branch.basis_tree()
 
555
        merge_inner(self.branch, old_tree,
 
556
                    self, ignore_zero=True,
 
557
                    backup_files=backups, 
 
558
                    interesting_files=filenames)
 
559
        if not len(filenames):
 
560
            self.set_pending_merges([])
 
561
 
 
562
    @needs_write_lock
 
563
    def set_inventory(self, new_inventory_list):
 
564
        from bzrlib.inventory import (Inventory,
 
565
                                      InventoryDirectory,
 
566
                                      InventoryEntry,
 
567
                                      InventoryFile,
 
568
                                      InventoryLink)
 
569
        inv = Inventory(self.get_root_id())
 
570
        for path, file_id, parent, kind in new_inventory_list:
 
571
            name = os.path.basename(path)
 
572
            if name == "":
 
573
                continue
 
574
            # fixme, there should be a factory function inv,add_?? 
 
575
            if kind == 'directory':
 
576
                inv.add(InventoryDirectory(file_id, name, parent))
 
577
            elif kind == 'file':
 
578
                inv.add(InventoryFile(file_id, name, parent))
 
579
            elif kind == 'symlink':
 
580
                inv.add(InventoryLink(file_id, name, parent))
 
581
            else:
 
582
                raise BzrError("unknown kind %r" % kind)
 
583
        self._write_inventory(inv)
 
584
 
 
585
    @needs_write_lock
 
586
    def set_root_id(self, file_id):
 
587
        """Set the root id for this tree."""
 
588
        inv = self.read_working_inventory()
 
589
        orig_root_id = inv.root.file_id
 
590
        del inv._byid[inv.root.file_id]
 
591
        inv.root.file_id = file_id
 
592
        inv._byid[inv.root.file_id] = inv.root
 
593
        for fid in inv:
 
594
            entry = inv[fid]
 
595
            if entry.parent_id in (None, orig_root_id):
 
596
                entry.parent_id = inv.root.file_id
 
597
        self._write_inventory(inv)
 
598
 
 
599
    def unlock(self):
 
600
        """See Branch.unlock.
369
601
        
 
602
        WorkingTree locking just uses the Branch locking facilities.
 
603
        This is current because all working trees have an embedded branch
 
604
        within them. IF in the future, we were to make branch data shareable
 
605
        between multiple working trees, i.e. via shared storage, then we 
 
606
        would probably want to lock both the local tree, and the branch.
 
607
        """
 
608
        return self.branch.unlock()
 
609
 
 
610
    @needs_write_lock
 
611
    def _write_inventory(self, inv):
 
612
        """Write inventory as the current inventory."""
 
613
        from cStringIO import StringIO
 
614
        from bzrlib.atomicfile import AtomicFile
 
615
        sio = StringIO()
 
616
        bzrlib.xml5.serializer_v5.write_inventory(inv, sio)
 
617
        sio.seek(0)
 
618
        f = AtomicFile(self.branch.controlfilename('inventory'))
 
619
        try:
 
620
            pumpfile(sio, f)
 
621
            f.commit()
 
622
        finally:
 
623
            f.close()
 
624
        mutter('wrote working inventory')
 
625
            
 
626
 
 
627
CONFLICT_SUFFIXES = ('.THIS', '.BASE', '.OTHER')
 
628
def get_conflicted_stem(path):
 
629
    for suffix in CONFLICT_SUFFIXES:
 
630
        if path.endswith(suffix):
 
631
            return path[:-len(suffix)]