/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/status.py

  • Committer: Robert Collins
  • Date: 2008-08-20 02:07:36 UTC
  • mfrom: (3640 +trunk)
  • mto: This revision was merged to the branch mainline in revision 3682.
  • Revision ID: robertc@robertcollins.net-20080820020736-g2xe4921zzxtymle
Merge bzr.dev

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006 Canonical Ltd
 
1
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
16
16
 
17
17
import sys
18
18
 
19
 
from bzrlib.delta import compare_trees
 
19
from bzrlib import (
 
20
    delta as _mod_delta,
 
21
    log,
 
22
    osutils,
 
23
    tree,
 
24
    tsort,
 
25
    revision as _mod_revision,
 
26
    )
20
27
from bzrlib.diff import _raise_if_nonexistent
21
 
from bzrlib.errors import NoSuchRevision
22
 
from bzrlib.log import line_log
 
28
import bzrlib.errors as errors
23
29
from bzrlib.osutils import is_inside_any
24
 
from bzrlib.symbol_versioning import *
 
30
from bzrlib.symbol_versioning import (deprecated_function,
 
31
        )
 
32
from bzrlib.trace import warning
25
33
 
26
34
# TODO: when showing single-line logs, truncate to the width of the terminal
27
35
# if known, but only if really going to the terminal (not into a file)
28
36
 
29
37
 
30
 
@deprecated_function(zero_eight)
31
 
def show_status(branch, show_unchanged=False,
32
 
                specific_files=None,
33
 
                show_ids=False,
34
 
                to_file=None,
35
 
                show_pending=True,
36
 
                revision=None):
37
 
    """Display summary of changes.
38
 
 
39
 
    Please use show_tree_status instead.
40
 
 
41
 
    By default this compares the working tree to a previous revision. 
42
 
    If the revision argument is given, summarizes changes between the 
43
 
    working tree and another, or between two revisions.
44
 
 
45
 
    The result is written out as Unicode and to_file should be able 
46
 
    to encode that.
47
 
 
48
 
    show_unchanged
49
 
        If set, includes unchanged files.
50
 
 
51
 
    specific_files
52
 
        If set, only show the status of files in this list.
53
 
 
54
 
    show_ids
55
 
        If set, includes each file's id.
56
 
 
57
 
    to_file
58
 
        If set, write to this file (default stdout.)
59
 
 
60
 
    show_pending
61
 
        If set, write pending merges.
62
 
 
63
 
    revision
64
 
        If None the compare latest revision with working tree
65
 
        If one revision show compared it with working tree.
66
 
        If two revisions show status between first and second.
67
 
    """
68
 
    show_tree_status(branch.bzrdir.open_workingtree(), show_unchanged, 
69
 
                     specific_files, show_ids, to_file, show_pending, revision)
70
 
 
71
 
 
72
 
def show_tree_status(wt, show_unchanged=False,
 
38
def show_tree_status(wt, show_unchanged=None,
73
39
                     specific_files=None,
74
40
                     show_ids=False,
75
41
                     to_file=None,
76
42
                     show_pending=True,
77
 
                     revision=None):
 
43
                     revision=None,
 
44
                     short=False,
 
45
                     versioned=False):
78
46
    """Display summary of changes.
79
47
 
80
48
    By default this compares the working tree to a previous revision. 
87
55
    If showing the status of a working tree, extra information is included
88
56
    about unknown files, conflicts, and pending merges.
89
57
 
90
 
    show_unchanged
91
 
        If set, includes unchanged files.
92
 
 
93
 
    specific_files
94
 
        If set, a list of filenames whose status should be shown.
95
 
        It is an error to give a filename that is not in the working 
 
58
    :param show_unchanged: Deprecated parameter. If set, includes unchanged 
 
59
        files.
 
60
    :param specific_files: If set, a list of filenames whose status should be
 
61
        shown.  It is an error to give a filename that is not in the working 
96
62
        tree, or in the working inventory or in the basis inventory.
97
 
 
98
 
    show_ids
99
 
        If set, includes each file's id.
100
 
 
101
 
    to_file
102
 
        If set, write to this file (default stdout.)
103
 
 
104
 
    show_pending
105
 
        If set, write pending merges.
106
 
 
107
 
    revision
108
 
        If None the compare latest revision with working tree
109
 
        If one revision show compared it with working tree.
110
 
        If two revisions show status between first and second.
 
63
    :param show_ids: If set, includes each file's id.
 
64
    :param to_file: If set, write to this file (default stdout.)
 
65
    :param show_pending: If set, write pending merges.
 
66
    :param revision: If None, compare latest revision with working tree
 
67
        If not None, it must be a RevisionSpec list.
 
68
        If one revision, compare with working tree.
 
69
        If two revisions, show status between first and second.
 
70
    :param short: If True, gives short SVN-style status lines.
 
71
    :param versioned: If True, only shows versioned files.
111
72
    """
112
 
    if to_file == None:
 
73
    if show_unchanged is not None:
 
74
        warn("show_tree_status with show_unchanged has been deprecated "
 
75
             "since bzrlib 0.9", DeprecationWarning, stacklevel=2)
 
76
 
 
77
    if to_file is None:
113
78
        to_file = sys.stdout
114
79
    
115
80
    wt.lock_read()
116
81
    try:
117
82
        new_is_working_tree = True
118
83
        if revision is None:
 
84
            if wt.last_revision() != wt.branch.last_revision():
 
85
                warning("working tree is out of date, run 'bzr update'")
119
86
            new = wt
120
87
            old = new.basis_tree()
121
88
        elif len(revision) > 0:
122
89
            try:
123
 
                rev_id = revision[0].in_history(wt.branch).rev_id
 
90
                rev_id = revision[0].as_revision_id(wt.branch)
124
91
                old = wt.branch.repository.revision_tree(rev_id)
125
 
            except NoSuchRevision, e:
126
 
                raise BzrCommandError(str(e))
 
92
            except errors.NoSuchRevision, e:
 
93
                raise errors.BzrCommandError(str(e))
127
94
            if (len(revision) > 1) and (revision[1].spec is not None):
128
95
                try:
129
 
                    rev_id = revision[1].in_history(wt.branch).rev_id
 
96
                    rev_id = revision[1].as_revision_id(wt.branch)
130
97
                    new = wt.branch.repository.revision_tree(rev_id)
131
98
                    new_is_working_tree = False
132
 
                except NoSuchRevision, e:
133
 
                    raise BzrCommandError(str(e))
 
99
                except errors.NoSuchRevision, e:
 
100
                    raise errors.BzrCommandError(str(e))
134
101
            else:
135
102
                new = wt
136
 
        _raise_if_nonexistent(specific_files, old, new)
137
 
        delta = compare_trees(old, new, want_unchanged=show_unchanged,
138
 
                              specific_files=specific_files)
139
 
        delta.show(to_file,
140
 
                   show_ids=show_ids,
141
 
                   show_unchanged=show_unchanged)
142
 
 
143
 
        if new_is_working_tree:
144
 
            list_paths('unknown', new.unknowns(), specific_files, to_file)
145
 
            conflict_title = False
146
 
            for conflict in wt.conflicts():
147
 
                if conflict_title is False:
148
 
                    print >> to_file, "conflicts:"
149
 
                    conflict_title = True
150
 
                print >> to_file, "  %s" % conflict
151
 
        if new_is_working_tree and show_pending:
152
 
            show_pending_merges(new, to_file)
 
103
        old.lock_read()
 
104
        new.lock_read()
 
105
        try:
 
106
            _raise_if_nonexistent(specific_files, old, new)
 
107
            want_unversioned = not versioned
 
108
            if short:
 
109
                changes = new.iter_changes(old, show_unchanged, specific_files,
 
110
                    require_versioned=False, want_unversioned=want_unversioned)
 
111
                reporter = _mod_delta._ChangeReporter(output_file=to_file,
 
112
                    unversioned_filter=new.is_ignored)
 
113
                _mod_delta.report_changes(changes, reporter)
 
114
            else:
 
115
                delta = new.changes_from(old, want_unchanged=show_unchanged,
 
116
                                      specific_files=specific_files,
 
117
                                      want_unversioned=want_unversioned)
 
118
                # filter out unknown files. We may want a tree method for
 
119
                # this
 
120
                delta.unversioned = [unversioned for unversioned in
 
121
                    delta.unversioned if not new.is_ignored(unversioned[0])]
 
122
                delta.show(to_file,
 
123
                           show_ids=show_ids,
 
124
                           show_unchanged=show_unchanged,
 
125
                           short_status=False)
 
126
            # show the new conflicts only for now. XXX: get them from the
 
127
            # delta.
 
128
            conflicts = new.conflicts()
 
129
            if specific_files is not None:
 
130
                conflicts = conflicts.select_conflicts(new, specific_files,
 
131
                    ignore_misses=True, recurse=True)[1]
 
132
            if len(conflicts) > 0 and not short:
 
133
                to_file.write("conflicts:\n")
 
134
            for conflict in conflicts:
 
135
                if short:
 
136
                    prefix = 'C  '
 
137
                else:
 
138
                    prefix = ' '
 
139
                to_file.write("%s %s\n" % (prefix, conflict))
 
140
            if (new_is_working_tree and show_pending):
 
141
                show_pending_merges(new, to_file, short)
 
142
        finally:
 
143
            old.unlock()
 
144
            new.unlock()
153
145
    finally:
154
146
        wt.unlock()
155
147
 
156
 
def show_pending_merges(new, to_file):
 
148
 
 
149
def _get_sorted_revisions(tip_revision, revision_ids, parent_map):
 
150
    """Get an iterator which will return the revisions in merge sorted order.
 
151
 
 
152
    This will build up a list of all nodes, such that only nodes in the list
 
153
    are referenced. It then uses MergeSorter to return them in 'merge-sorted'
 
154
    order.
 
155
 
 
156
    :param revision_ids: A set of revision_ids
 
157
    :param parent_map: The parent information for each node. Revisions which
 
158
        are considered ghosts should not be present in the map.
 
159
    :return: iterator from MergeSorter.iter_topo_order()
 
160
    """
 
161
    # MergeSorter requires that all nodes be present in the graph, so get rid
 
162
    # of any references pointing outside of this graph.
 
163
    parent_graph = {}
 
164
    for revision_id in revision_ids:
 
165
        if revision_id not in parent_map: # ghost
 
166
            parent_graph[revision_id] = []
 
167
        else:
 
168
            # Only include parents which are in this sub-graph
 
169
            parent_graph[revision_id] = [p for p in parent_map[revision_id]
 
170
                                            if p in revision_ids]
 
171
    sorter = tsort.MergeSorter(parent_graph, tip_revision)
 
172
    return sorter.iter_topo_order()
 
173
 
 
174
 
 
175
def show_pending_merges(new, to_file, short=False):
157
176
    """Write out a display of pending merges in a working tree."""
158
 
    pending = new.pending_merges()
159
 
    branch = new.branch
160
 
    if len(pending) == 0:
 
177
    parents = new.get_parent_ids()
 
178
    if len(parents) < 2:
161
179
        return
162
 
    print >>to_file, 'pending merges:'
163
 
    last_revision = branch.last_revision()
164
 
    if last_revision is not None:
165
 
        ignore = set(branch.repository.get_ancestry(last_revision))
 
180
 
 
181
    # we need one extra space for terminals that wrap on last char
 
182
    term_width = osutils.terminal_width() - 1
 
183
    if short:
 
184
        first_prefix = 'P   '
 
185
        sub_prefix = 'P.   '
166
186
    else:
167
 
        ignore = set([None])
168
 
    for merge in new.pending_merges():
169
 
        ignore.add(merge)
 
187
        first_prefix = '  '
 
188
        sub_prefix = '    '
 
189
 
 
190
    pending = parents[1:]
 
191
    branch = new.branch
 
192
    last_revision = parents[0]
 
193
    if not short:
 
194
        to_file.write('pending merges:\n')
 
195
    graph = branch.repository.get_graph()
 
196
    other_revisions = [last_revision]
 
197
    log_formatter = log.LineLogFormatter(to_file)
 
198
    for merge in pending:
170
199
        try:
171
 
            m_revision = branch.repository.get_revision(merge)
172
 
            print >> to_file, ' ', line_log(m_revision, 77)
173
 
            inner_merges = branch.repository.get_ancestry(merge)
174
 
            assert inner_merges[0] == None
175
 
            inner_merges.pop(0)
176
 
            inner_merges.reverse()
177
 
            for mmerge in inner_merges:
178
 
                if mmerge in ignore:
179
 
                    continue
180
 
                mm_revision = branch.repository.get_revision(mmerge)
181
 
                print >> to_file, '   ', line_log(mm_revision, 75)
182
 
                ignore.add(mmerge)
183
 
        except NoSuchRevision:
184
 
            print >> to_file, ' ', merge 
185
 
        
186
 
def list_paths(header, paths, specific_files, to_file):
187
 
    done_header = False
188
 
    for path in paths:
189
 
        if specific_files and not is_inside_any(specific_files, path):
 
200
            rev = branch.repository.get_revisions([merge])[0]
 
201
        except errors.NoSuchRevision:
 
202
            # If we are missing a revision, just print out the revision id
 
203
            to_file.write(first_prefix + '(ghost) ' + merge + '\n')
 
204
            other_revisions.append(merge)
190
205
            continue
191
 
        if not done_header:
192
 
            print >>to_file, '%s:' % header
193
 
            done_header = True
194
 
        print >>to_file, ' ', path
 
206
 
 
207
        # Log the merge, as it gets a slightly different formatting
 
208
        log_message = log_formatter.log_string(None, rev,
 
209
                        term_width - len(first_prefix))
 
210
        to_file.write(first_prefix + log_message + '\n')
 
211
        # Find all of the revisions in the merge source, which are not in the
 
212
        # last committed revision.
 
213
        merge_extra = graph.find_unique_ancestors(merge, other_revisions)
 
214
        other_revisions.append(merge)
 
215
        merge_extra.discard(_mod_revision.NULL_REVISION)
 
216
 
 
217
        # Get a handle to all of the revisions we will need
 
218
        try:
 
219
            revisions = dict((rev.revision_id, rev) for rev in
 
220
                             branch.repository.get_revisions(merge_extra))
 
221
        except errors.NoSuchRevision:
 
222
            # One of the sub nodes is a ghost, check each one
 
223
            revisions = {}
 
224
            for revision_id in merge_extra:
 
225
                try:
 
226
                    rev = branch.repository.get_revisions([revision_id])[0]
 
227
                except errors.NoSuchRevision:
 
228
                    revisions[revision_id] = None
 
229
                else:
 
230
                    revisions[revision_id] = rev
 
231
 
 
232
        # Display the revisions brought in by this merge.
 
233
        rev_id_iterator = _get_sorted_revisions(merge, merge_extra,
 
234
                            branch.repository.get_parent_map(merge_extra))
 
235
        # Skip the first node
 
236
        num, first, depth, eom = rev_id_iterator.next()
 
237
        if first != merge:
 
238
            raise AssertionError('Somehow we misunderstood how'
 
239
                ' iter_topo_order works %s != %s' % (first, merge))
 
240
        for num, sub_merge, depth, eom in rev_id_iterator:
 
241
            rev = revisions[sub_merge]
 
242
            if rev is None:
 
243
                to_file.write(sub_prefix + '(ghost) ' + sub_merge + '\n')
 
244
                continue
 
245
            log_message = log_formatter.log_string(None,
 
246
                            revisions[sub_merge],
 
247
                            term_width - len(sub_prefix))
 
248
            to_file.write(sub_prefix + log_message + '\n')