~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: abentley
  • Date: 2005-10-14 03:50:50 UTC
  • mto: (1185.25.1)
  • mto: This revision was merged to the branch mainline in revision 1460.
  • Revision ID: abentley@lappy-20051014035050-d779472ccb599a51
semi-broke merge

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
2
 
#
 
1
# Copyright (C) 2005 Canonical Ltd
 
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
5
5
# the Free Software Foundation; either version 2 of the License, or
6
6
# (at your option) any later version.
7
 
#
 
7
 
8
8
# This program is distributed in the hope that it will be useful,
9
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
11
# GNU General Public License for more details.
12
 
#
 
12
 
13
13
# You should have received a copy of the GNU General Public License
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
49
49
all the changes since the previous revision that touched hello.c.
50
50
"""
51
51
 
52
 
# TODO: option to show delta summaries for merged-in revisions
53
 
 
54
 
from itertools import izip
55
 
import re
56
 
 
57
 
from bzrlib import (
58
 
    registry,
59
 
    symbol_versioning,
60
 
    )
 
52
 
61
53
import bzrlib.errors as errors
62
 
from bzrlib.revisionspec import(
63
 
    RevisionInfo
64
 
    )
65
 
from bzrlib.symbol_versioning import (
66
 
    deprecated_method,
67
 
    zero_eleven,
68
 
    zero_seventeen,
69
 
    )
 
54
from bzrlib.tree import EmptyTree
 
55
from bzrlib.delta import compare_trees
70
56
from bzrlib.trace import mutter
71
 
from bzrlib.tsort import (
72
 
    merge_sort,
73
 
    topo_sort,
74
 
    )
 
57
import re
75
58
 
76
59
 
77
60
def find_touching_revisions(branch, file_id):
89
72
    last_path = None
90
73
    revno = 1
91
74
    for revision_id in branch.revision_history():
92
 
        this_inv = branch.repository.get_revision_inventory(revision_id)
 
75
        this_inv = branch.get_revision_inventory(revision_id)
93
76
        if file_id in this_inv:
94
77
            this_ie = this_inv[file_id]
95
78
            this_path = this_inv.id2path(file_id)
118
101
        revno += 1
119
102
 
120
103
 
 
104
 
121
105
def _enumerate_history(branch):
122
106
    rh = []
123
107
    revno = 1
127
111
    return rh
128
112
 
129
113
 
 
114
def _get_revision_delta(branch, revno):
 
115
    """Return the delta for a mainline revision.
 
116
    
 
117
    This is used to show summaries in verbose logs, and also for finding 
 
118
    revisions which touch a given file."""
 
119
    # XXX: What are we supposed to do when showing a summary for something 
 
120
    # other than a mainline revision.  The delta to it's first parent, or
 
121
    # (more useful) the delta to a nominated other revision.
 
122
    return branch.get_revision_delta(revno)
 
123
 
 
124
 
130
125
def show_log(branch,
131
126
             lf,
132
127
             specific_fileid=None,
134
129
             direction='reverse',
135
130
             start_revision=None,
136
131
             end_revision=None,
137
 
             search=None,
138
 
             limit=None):
 
132
             search=None):
139
133
    """Write out human-readable log of commits to this branch.
140
134
 
141
135
    lf
157
151
 
158
152
    end_revision
159
153
        If not None, only show revisions <= end_revision
160
 
 
161
 
    search
162
 
        If not None, only show revisions with matching commit messages
163
 
 
164
 
    limit
165
 
        If not None or 0, only show limit revisions
166
154
    """
167
155
    branch.lock_read()
168
156
    try:
169
 
        if getattr(lf, 'begin_log', None):
170
 
            lf.begin_log()
171
 
 
172
157
        _show_log(branch, lf, specific_fileid, verbose, direction,
173
 
                  start_revision, end_revision, search, limit)
174
 
 
175
 
        if getattr(lf, 'end_log', None):
176
 
            lf.end_log()
 
158
                  start_revision, end_revision, search)
177
159
    finally:
178
160
        branch.unlock()
179
 
 
 
161
    
180
162
def _show_log(branch,
181
163
             lf,
182
164
             specific_fileid=None,
184
166
             direction='reverse',
185
167
             start_revision=None,
186
168
             end_revision=None,
187
 
             search=None,
188
 
             limit=None):
 
169
             search=None):
189
170
    """Worker function for show_log - see show_log."""
190
171
    from bzrlib.osutils import format_date
191
172
    from bzrlib.errors import BzrCheckError
 
173
    from bzrlib.textui import show_status
192
174
    
193
175
    from warnings import warn
194
176
 
196
178
        warn("not a LogFormatter instance: %r" % lf)
197
179
 
198
180
    if specific_fileid:
199
 
        mutter('get log for file_id %r', specific_fileid)
 
181
        mutter('get log for file_id %r' % specific_fileid)
200
182
 
201
183
    if search is not None:
202
184
        import re
204
186
    else:
205
187
        searchRE = None
206
188
 
207
 
    mainline_revs, rev_nos, start_rev_id, end_rev_id = \
208
 
        _get_mainline_revs(branch, start_revision, end_revision)
209
 
    if not mainline_revs:
210
 
        return
211
 
 
212
 
    if direction == 'reverse':
213
 
        start_rev_id, end_rev_id = end_rev_id, start_rev_id
214
 
        
215
 
    legacy_lf = getattr(lf, 'log_revision', None) is None
216
 
    if legacy_lf:
217
 
        # pre-0.17 formatters use show for mainline revisions.
218
 
        # how should we show merged revisions ?
219
 
        #   pre-0.11 api: show_merge
220
 
        #   0.11-0.16 api: show_merge_revno
221
 
        show_merge_revno = getattr(lf, 'show_merge_revno', None)
222
 
        show_merge = getattr(lf, 'show_merge', None)
223
 
        if show_merge is None and show_merge_revno is None:
224
 
            # no merged-revno support
225
 
            generate_merge_revisions = False
226
 
        else:
227
 
            generate_merge_revisions = True
228
 
        # tell developers to update their code
229
 
        symbol_versioning.warn('LogFormatters should provide log_revision '
230
 
            'instead of show and show_merge_revno since bzr 0.17.',
231
 
            DeprecationWarning, stacklevel=3)
232
 
    else:
233
 
        generate_merge_revisions = getattr(lf, 'supports_merge_revisions', 
234
 
                                           False)
235
 
    view_revs_iter = get_view_revisions(mainline_revs, rev_nos, branch,
236
 
                          direction, include_merges=generate_merge_revisions)
237
 
    view_revisions = _filter_revision_range(list(view_revs_iter),
238
 
                                            start_rev_id,
239
 
                                            end_rev_id)
240
 
    if specific_fileid:
241
 
        view_revisions = _filter_revisions_touching_file_id(branch,
242
 
                                                         specific_fileid,
243
 
                                                         mainline_revs,
244
 
                                                         view_revisions)
245
 
 
246
 
    rev_tag_dict = {}
247
 
    generate_tags = getattr(lf, 'supports_tags', False)
248
 
    if generate_tags:
249
 
        if branch.supports_tags():
250
 
            rev_tag_dict = branch.tags.get_reverse_tag_dict()
251
 
 
252
 
    generate_delta = verbose and getattr(lf, 'supports_delta', False)
253
 
 
254
 
    def iter_revisions():
255
 
        # r = revision, n = revno, d = merge depth
256
 
        revision_ids = [r for r, n, d in view_revisions]
257
 
        num = 9
258
 
        repository = branch.repository
259
 
        while revision_ids:
260
 
            cur_deltas = {}
261
 
            revisions = repository.get_revisions(revision_ids[:num])
262
 
            if generate_delta:
263
 
                deltas = repository.get_deltas_for_revisions(revisions)
264
 
                cur_deltas = dict(izip((r.revision_id for r in revisions),
265
 
                                       deltas))
266
 
            for revision in revisions:
267
 
                yield revision, cur_deltas.get(revision.revision_id)
268
 
            revision_ids  = revision_ids[num:]
269
 
            num = min(int(num * 1.5), 200)
270
 
 
271
 
    # now we just print all the revisions
272
 
    log_count = 0
273
 
    for ((rev_id, revno, merge_depth), (rev, delta)) in \
274
 
         izip(view_revisions, iter_revisions()):
275
 
 
276
 
        if searchRE:
277
 
            if not searchRE.search(rev.message):
278
 
                continue
279
 
 
280
 
        if not legacy_lf:
281
 
            lr = LogRevision(rev, revno, merge_depth, delta,
282
 
                             rev_tag_dict.get(rev_id))
283
 
            lf.log_revision(lr)
284
 
        else:
285
 
            # support for legacy (pre-0.17) LogFormatters
286
 
            if merge_depth == 0:
287
 
                if generate_tags:
288
 
                    lf.show(revno, rev, delta, rev_tag_dict.get(rev_id))
289
 
                else:
290
 
                    lf.show(revno, rev, delta)
291
 
            else:
292
 
                if show_merge_revno is None:
293
 
                    lf.show_merge(rev, merge_depth)
294
 
                else:
295
 
                    if generate_tags:
296
 
                        lf.show_merge_revno(rev, merge_depth, revno,
297
 
                                            rev_tag_dict.get(rev_id))
298
 
                    else:
299
 
                        lf.show_merge_revno(rev, merge_depth, revno)
300
 
        if limit:
301
 
            log_count += 1
302
 
            if log_count >= limit:
303
 
                break
304
 
 
305
 
 
306
 
def _get_mainline_revs(branch, start_revision, end_revision):
307
 
    """Get the mainline revisions from the branch.
308
 
    
309
 
    Generates the list of mainline revisions for the branch.
310
 
    
311
 
    :param  branch: The branch containing the revisions. 
312
 
 
313
 
    :param  start_revision: The first revision to be logged.
314
 
            For backwards compatibility this may be a mainline integer revno,
315
 
            but for merge revision support a RevisionInfo is expected.
316
 
 
317
 
    :param  end_revision: The last revision to be logged.
318
 
            For backwards compatibility this may be a mainline integer revno,
319
 
            but for merge revision support a RevisionInfo is expected.
320
 
 
321
 
    :return: A (mainline_revs, rev_nos, start_rev_id, end_rev_id) tuple.
322
 
    """
323
189
    which_revs = _enumerate_history(branch)
324
 
    if not which_revs:
325
 
        return None, None, None, None
326
 
 
327
 
    # For mainline generation, map start_revision and end_revision to 
328
 
    # mainline revnos. If the revision is not on the mainline choose the 
329
 
    # appropriate extreme of the mainline instead - the extra will be 
330
 
    # filtered later.
331
 
    # Also map the revisions to rev_ids, to be used in the later filtering
332
 
    # stage.
333
 
    start_rev_id = None 
 
190
    
334
191
    if start_revision is None:
335
 
        start_revno = 1
 
192
        start_revision = 1
336
193
    else:
337
 
        if isinstance(start_revision,RevisionInfo):
338
 
            start_rev_id = start_revision.rev_id
339
 
            start_revno = start_revision.revno or 1
340
 
        else:
341
 
            branch.check_real_revno(start_revision)
342
 
            start_revno = start_revision
 
194
        branch.check_real_revno(start_revision)
343
195
    
344
 
    end_rev_id = None
345
196
    if end_revision is None:
346
 
        end_revno = len(which_revs)
 
197
        end_revision = len(which_revs)
347
198
    else:
348
 
        if isinstance(end_revision,RevisionInfo):
349
 
            end_rev_id = end_revision.rev_id
350
 
            end_revno = end_revision.revno or len(which_revs)
351
 
        else:
352
 
            branch.check_real_revno(end_revision)
353
 
            end_revno = end_revision
354
 
 
355
 
    if start_revno > end_revno:
356
 
        from bzrlib.errors import BzrCommandError
357
 
        raise BzrCommandError("Start revision must be older than "
358
 
                              "the end revision.")
 
199
        branch.check_real_revno(end_revision)
359
200
 
360
201
    # list indexes are 0-based; revisions are 1-based
361
 
    cut_revs = which_revs[(start_revno-1):(end_revno)]
362
 
    if not cut_revs:
363
 
        return None, None, None, None
364
 
 
365
 
    # convert the revision history to a dictionary:
366
 
    rev_nos = dict((k, v) for v, k in cut_revs)
367
 
 
368
 
    # override the mainline to look like the revision history.
369
 
    mainline_revs = [revision_id for index, revision_id in cut_revs]
370
 
    if cut_revs[0][0] == 1:
371
 
        mainline_revs.insert(0, None)
 
202
    cut_revs = which_revs[(start_revision-1):(end_revision)]
 
203
 
 
204
    if direction == 'reverse':
 
205
        cut_revs.reverse()
 
206
    elif direction == 'forward':
 
207
        pass
372
208
    else:
373
 
        mainline_revs.insert(0, which_revs[start_revno-2][1])
374
 
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
375
 
 
376
 
 
377
 
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
378
 
    """Filter view_revisions based on revision ranges.
379
 
 
380
 
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth) 
381
 
            tuples to be filtered.
382
 
 
383
 
    :param start_rev_id: If not NONE specifies the first revision to be logged.
384
 
            If NONE then all revisions up to the end_rev_id are logged.
385
 
 
386
 
    :param end_rev_id: If not NONE specifies the last revision to be logged.
387
 
            If NONE then all revisions up to the end of the log are logged.
388
 
 
389
 
    :return: The filtered view_revisions.
390
 
    """
391
 
    if start_rev_id or end_rev_id: 
392
 
        revision_ids = [r for r, n, d in view_revisions]
393
 
        if start_rev_id:
394
 
            start_index = revision_ids.index(start_rev_id)
395
 
        else:
396
 
            start_index = 0
397
 
        if start_rev_id == end_rev_id:
398
 
            end_index = start_index
399
 
        else:
400
 
            if end_rev_id:
401
 
                end_index = revision_ids.index(end_rev_id)
402
 
            else:
403
 
                end_index = len(view_revisions) - 1
404
 
        # To include the revisions merged into the last revision, 
405
 
        # extend end_rev_id down to, but not including, the next rev
406
 
        # with the same or lesser merge_depth
407
 
        end_merge_depth = view_revisions[end_index][2]
408
 
        try:
409
 
            for index in xrange(end_index+1, len(view_revisions)+1):
410
 
                if view_revisions[index][2] <= end_merge_depth:
411
 
                    end_index = index - 1
412
 
                    break
413
 
        except IndexError:
414
 
            # if the search falls off the end then log to the end as well
415
 
            end_index = len(view_revisions) - 1
416
 
        view_revisions = view_revisions[start_index:end_index+1]
417
 
    return view_revisions
418
 
 
419
 
 
420
 
def _filter_revisions_touching_file_id(branch, file_id, mainline_revisions,
421
 
                                       view_revs_iter):
422
 
    """Return the list of revision ids which touch a given file id.
423
 
 
424
 
    The function filters view_revisions and returns a subset.
425
 
    This includes the revisions which directly change the file id,
426
 
    and the revisions which merge these changes. So if the
427
 
    revision graph is::
428
 
        A
429
 
        |\
430
 
        B C
431
 
        |/
432
 
        D
433
 
 
434
 
    And 'C' changes a file, then both C and D will be returned.
435
 
 
436
 
    This will also can be restricted based on a subset of the mainline.
437
 
 
438
 
    :return: A list of (revision_id, dotted_revno, merge_depth) tuples.
439
 
    """
440
 
    # find all the revisions that change the specific file
441
 
    file_weave = branch.repository.weave_store.get_weave(file_id,
442
 
                branch.repository.get_transaction())
443
 
    weave_modifed_revisions = set(file_weave.versions())
444
 
    # build the ancestry of each revision in the graph
445
 
    # - only listing the ancestors that change the specific file.
446
 
    rev_graph = branch.repository.get_revision_graph(mainline_revisions[-1])
447
 
    sorted_rev_list = topo_sort(rev_graph)
448
 
    ancestry = {}
449
 
    for rev in sorted_rev_list:
450
 
        parents = rev_graph[rev]
451
 
        if rev not in weave_modifed_revisions and len(parents) == 1:
452
 
            # We will not be adding anything new, so just use a reference to
453
 
            # the parent ancestry.
454
 
            rev_ancestry = ancestry[parents[0]]
455
 
        else:
456
 
            rev_ancestry = set()
457
 
            if rev in weave_modifed_revisions:
458
 
                rev_ancestry.add(rev)
459
 
            for parent in parents:
460
 
                rev_ancestry = rev_ancestry.union(ancestry[parent])
461
 
        ancestry[rev] = rev_ancestry
462
 
 
463
 
    def is_merging_rev(r):
464
 
        parents = rev_graph[r]
465
 
        if len(parents) > 1:
466
 
            leftparent = parents[0]
467
 
            for rightparent in parents[1:]:
468
 
                if not ancestry[leftparent].issuperset(
469
 
                        ancestry[rightparent]):
470
 
                    return True
471
 
        return False
472
 
 
473
 
    # filter from the view the revisions that did not change or merge 
474
 
    # the specific file
475
 
    return [(r, n, d) for r, n, d in view_revs_iter
476
 
            if r in weave_modifed_revisions or is_merging_rev(r)]
477
 
 
478
 
 
479
 
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
480
 
                       include_merges=True):
481
 
    """Produce an iterator of revisions to show
482
 
    :return: an iterator of (revision_id, revno, merge_depth)
483
 
    (if there is no revno for a revision, None is supplied)
484
 
    """
485
 
    if include_merges is False:
486
 
        revision_ids = mainline_revs[1:]
487
 
        if direction == 'reverse':
488
 
            revision_ids.reverse()
489
 
        for revision_id in revision_ids:
490
 
            yield revision_id, str(rev_nos[revision_id]), 0
491
 
        return
492
 
    merge_sorted_revisions = merge_sort(
493
 
        branch.repository.get_revision_graph(mainline_revs[-1]),
494
 
        mainline_revs[-1],
495
 
        mainline_revs,
496
 
        generate_revno=True)
497
 
 
498
 
    if direction == 'forward':
499
 
        # forward means oldest first.
500
 
        merge_sorted_revisions = reverse_by_depth(merge_sorted_revisions)
501
 
    elif direction != 'reverse':
502
209
        raise ValueError('invalid direction %r' % direction)
503
210
 
504
 
    for sequence, rev_id, merge_depth, revno, end_of_merge in merge_sorted_revisions:
505
 
        yield rev_id, '.'.join(map(str, revno)), merge_depth
506
 
 
507
 
 
508
 
def reverse_by_depth(merge_sorted_revisions, _depth=0):
509
 
    """Reverse revisions by depth.
510
 
 
511
 
    Revisions with a different depth are sorted as a group with the previous
512
 
    revision of that depth.  There may be no topological justification for this,
513
 
    but it looks much nicer.
514
 
    """
515
 
    zd_revisions = []
516
 
    for val in merge_sorted_revisions:
517
 
        if val[2] == _depth:
518
 
            zd_revisions.append([val])
 
211
    revision_history = branch.revision_history()
 
212
    for revno, rev_id in cut_revs:
 
213
        if verbose or specific_fileid:
 
214
            delta = _get_revision_delta(branch, revno)
 
215
            
 
216
        if specific_fileid:
 
217
            if not delta.touches_file_id(specific_fileid):
 
218
                continue
 
219
 
 
220
        if not verbose:
 
221
            # although we calculated it, throw it away without display
 
222
            delta = None
 
223
 
 
224
        rev = branch.get_revision(rev_id)
 
225
 
 
226
        if searchRE:
 
227
            if not searchRE.search(rev.message):
 
228
                continue
 
229
 
 
230
        lf.show(revno, rev, delta)
 
231
        if hasattr(lf, 'show_merge'):
 
232
            if revno == 1:
 
233
                excludes = set()
 
234
            else:
 
235
                # revno is 1 based, so -2 to get back 1 less.
 
236
                excludes = set(branch.get_ancestry(revision_history[revno - 2]))
 
237
            pending = list(rev.parent_ids)
 
238
            while pending:
 
239
                rev_id = pending.pop()
 
240
                if rev_id in excludes:
 
241
                    continue
 
242
                # prevent showing merged revs twice if they multi-path.
 
243
                excludes.add(rev_id)
 
244
                try:
 
245
                    rev = branch.get_revision(rev_id)
 
246
                except errors.NoSuchRevision:
 
247
                    continue
 
248
                pending.extend(rev.parent_ids)
 
249
                lf.show_merge(rev)
 
250
 
 
251
 
 
252
def deltas_for_log_dummy(branch, which_revs):
 
253
    """Return all the revisions without intermediate deltas.
 
254
 
 
255
    Useful for log commands that won't need the delta information.
 
256
    """
 
257
    
 
258
    for revno, revision_id in which_revs:
 
259
        yield revno, branch.get_revision(revision_id), None
 
260
 
 
261
 
 
262
def deltas_for_log_reverse(branch, which_revs):
 
263
    """Compute deltas for display in latest-to-earliest order.
 
264
 
 
265
    branch
 
266
        Branch to traverse
 
267
 
 
268
    which_revs
 
269
        Sequence of (revno, revision_id) for the subset of history to examine
 
270
 
 
271
    returns 
 
272
        Sequence of (revno, rev, delta)
 
273
 
 
274
    The delta is from the given revision to the next one in the
 
275
    sequence, which makes sense if the log is being displayed from
 
276
    newest to oldest.
 
277
    """
 
278
    last_revno = last_revision_id = last_tree = None
 
279
    for revno, revision_id in which_revs:
 
280
        this_tree = branch.revision_tree(revision_id)
 
281
        this_revision = branch.get_revision(revision_id)
 
282
        
 
283
        if last_revno:
 
284
            yield last_revno, last_revision, compare_trees(this_tree, last_tree, False)
 
285
 
 
286
        this_tree = EmptyTree(branch.get_root_id())
 
287
 
 
288
        last_revno = revno
 
289
        last_revision = this_revision
 
290
        last_tree = this_tree
 
291
 
 
292
    if last_revno:
 
293
        if last_revno == 1:
 
294
            this_tree = EmptyTree(branch.get_root_id())
519
295
        else:
520
 
            assert val[2] > _depth
521
 
            zd_revisions[-1].append(val)
522
 
    for revisions in zd_revisions:
523
 
        if len(revisions) > 1:
524
 
            revisions[1:] = reverse_by_depth(revisions[1:], _depth + 1)
525
 
    zd_revisions.reverse()
526
 
    result = []
527
 
    for chunk in zd_revisions:
528
 
        result.extend(chunk)
529
 
    return result
530
 
 
531
 
 
532
 
class LogRevision(object):
533
 
    """A revision to be logged (by LogFormatter.log_revision).
534
 
 
535
 
    A simple wrapper for the attributes of a revision to be logged.
536
 
    The attributes may or may not be populated, as determined by the 
537
 
    logging options and the log formatter capabilities.
 
296
            this_revno = last_revno - 1
 
297
            this_revision_id = branch.revision_history()[this_revno]
 
298
            this_tree = branch.revision_tree(this_revision_id)
 
299
        yield last_revno, last_revision, compare_trees(this_tree, last_tree, False)
 
300
 
 
301
 
 
302
def deltas_for_log_forward(branch, which_revs):
 
303
    """Compute deltas for display in forward log.
 
304
 
 
305
    Given a sequence of (revno, revision_id) pairs, return
 
306
    (revno, rev, delta).
 
307
 
 
308
    The delta is from the given revision to the next one in the
 
309
    sequence, which makes sense if the log is being displayed from
 
310
    newest to oldest.
538
311
    """
539
 
 
540
 
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
541
 
                 tags=None):
542
 
        self.rev = rev
543
 
        self.revno = revno
544
 
        self.merge_depth = merge_depth
545
 
        self.delta = delta
546
 
        self.tags = tags
 
312
    last_revno = last_revision_id = last_tree = None
 
313
    prev_tree = EmptyTree(branch.get_root_id())
 
314
 
 
315
    for revno, revision_id in which_revs:
 
316
        this_tree = branch.revision_tree(revision_id)
 
317
        this_revision = branch.get_revision(revision_id)
 
318
 
 
319
        if not last_revno:
 
320
            if revno == 1:
 
321
                last_tree = EmptyTree(branch.get_root_id())
 
322
            else:
 
323
                last_revno = revno - 1
 
324
                last_revision_id = branch.revision_history()[last_revno]
 
325
                last_tree = branch.revision_tree(last_revision_id)
 
326
 
 
327
        yield revno, this_revision, compare_trees(last_tree, this_tree, False)
 
328
 
 
329
        last_revno = revno
 
330
        last_revision = this_revision
 
331
        last_tree = this_tree
547
332
 
548
333
 
549
334
class LogFormatter(object):
550
 
    """Abstract class to display log messages.
551
 
 
552
 
    At a minimum, a derived class must implement the log_revision method.
553
 
 
554
 
    If the LogFormatter needs to be informed of the beginning or end of
555
 
    a log it should implement the begin_log and/or end_log hook methods.
556
 
 
557
 
    A LogFormatter should define the following supports_XXX flags 
558
 
    to indicate which LogRevision attributes it supports:
559
 
 
560
 
    - supports_delta must be True if this log formatter supports delta.
561
 
        Otherwise the delta attribute may not be populated.
562
 
    - supports_merge_revisions must be True if this log formatter supports 
563
 
        merge revisions.  If not, only revisions mainline revisions (those 
564
 
        with merge_depth == 0) will be passed to the formatter.
565
 
    - supports_tags must be True if this log formatter supports tags.
566
 
        Otherwise the tags attribute may not be populated.
567
 
    """
568
 
 
 
335
    """Abstract class to display log messages."""
569
336
    def __init__(self, to_file, show_ids=False, show_timezone='original'):
570
337
        self.to_file = to_file
571
338
        self.show_ids = show_ids
572
339
        self.show_timezone = show_timezone
573
340
 
574
 
# TODO: uncomment this block after show() has been removed.
575
 
# Until then defining log_revision would prevent _show_log calling show() 
576
 
# in legacy formatters.
577
 
#    def log_revision(self, revision):
578
 
#        """Log a revision.
579
 
#
580
 
#        :param  revision:   The LogRevision to be logged.
581
 
#        """
582
 
#        raise NotImplementedError('not implemented in abstract base')
583
341
 
584
 
    @deprecated_method(zero_seventeen)
585
342
    def show(self, revno, rev, delta):
586
343
        raise NotImplementedError('not implemented in abstract base')
587
344
 
588
 
    def short_committer(self, rev):
589
 
        return re.sub('<.*@.*>', '', rev.committer).strip(' ')
590
 
 
591
 
 
 
345
    
592
346
class LongLogFormatter(LogFormatter):
593
 
 
594
 
    supports_merge_revisions = True
595
 
    supports_delta = True
596
 
    supports_tags = True
597
 
 
598
 
    @deprecated_method(zero_seventeen)
599
 
    def show(self, revno, rev, delta, tags=None):
600
 
        lr = LogRevision(rev, revno, 0, delta, tags)
601
 
        return self.log_revision(lr)
602
 
 
603
 
    @deprecated_method(zero_eleven)
604
 
    def show_merge(self, rev, merge_depth):
605
 
        lr = LogRevision(rev, merge_depth=merge_depth)
606
 
        return self.log_revision(lr)
607
 
 
608
 
    @deprecated_method(zero_seventeen)
609
 
    def show_merge_revno(self, rev, merge_depth, revno, tags=None):
610
 
        """Show a merged revision rev, with merge_depth and a revno."""
611
 
        lr = LogRevision(rev, revno, merge_depth, tags=tags)
612
 
        return self.log_revision(lr)
613
 
 
614
 
    def log_revision(self, revision):
615
 
        """Log a revision, either merged or not."""
616
 
        from bzrlib.osutils import format_date
617
 
        indent = '    '*revision.merge_depth
618
 
        to_file = self.to_file
 
347
    def show(self, revno, rev, delta):
 
348
        from osutils import format_date
 
349
 
 
350
        to_file = self.to_file
 
351
 
 
352
        print >>to_file,  '-' * 60
 
353
        print >>to_file,  'revno:', revno
 
354
        if self.show_ids:
 
355
            print >>to_file,  'revision-id:', rev.revision_id
 
356
 
 
357
            for parent_id in rev.parent_ids:
 
358
                print >>to_file, 'parent:', parent_id
 
359
            
 
360
        print >>to_file,  'committer:', rev.committer
 
361
 
 
362
        date_str = format_date(rev.timestamp,
 
363
                               rev.timezone or 0,
 
364
                               self.show_timezone)
 
365
        print >>to_file,  'timestamp: %s' % date_str
 
366
 
 
367
        print >>to_file,  'message:'
 
368
        if not rev.message:
 
369
            print >>to_file,  '  (no message)'
 
370
        else:
 
371
            for l in rev.message.split('\n'):
 
372
                print >>to_file,  '  ' + l
 
373
 
 
374
        if delta != None:
 
375
            delta.show(to_file, self.show_ids)
 
376
 
 
377
    def show_merge(self, rev):
 
378
        from osutils import format_date
 
379
 
 
380
        to_file = self.to_file
 
381
 
 
382
        indent = '    '
 
383
 
619
384
        print >>to_file,  indent+'-' * 60
620
 
        if revision.revno is not None:
621
 
            print >>to_file,  indent+'revno:', revision.revno
622
 
        if revision.tags:
623
 
            print >>to_file, indent+'tags: %s' % (', '.join(revision.tags))
 
385
        print >>to_file,  indent+'merged:', rev.revision_id
624
386
        if self.show_ids:
625
 
            print >>to_file, indent+'revision-id:', revision.rev.revision_id
626
 
            for parent_id in revision.rev.parent_ids:
 
387
            for parent_id in rev.parent_ids:
627
388
                print >>to_file, indent+'parent:', parent_id
628
 
        print >>to_file, indent+'committer:', revision.rev.committer
 
389
            
 
390
        print >>to_file,  indent+'committer:', rev.committer
629
391
 
630
 
        try:
631
 
            print >>to_file, indent+'branch nick: %s' % \
632
 
                revision.rev.properties['branch-nick']
633
 
        except KeyError:
634
 
            pass
635
 
        date_str = format_date(revision.rev.timestamp,
636
 
                               revision.rev.timezone or 0,
 
392
        date_str = format_date(rev.timestamp,
 
393
                               rev.timezone or 0,
637
394
                               self.show_timezone)
638
395
        print >>to_file,  indent+'timestamp: %s' % date_str
639
396
 
640
397
        print >>to_file,  indent+'message:'
641
 
        if not revision.rev.message:
 
398
        if not rev.message:
642
399
            print >>to_file,  indent+'  (no message)'
643
400
        else:
644
 
            message = revision.rev.message.rstrip('\r\n')
645
 
            for l in message.split('\n'):
 
401
            for l in rev.message.split('\n'):
646
402
                print >>to_file,  indent+'  ' + l
647
 
        if revision.delta is not None:
648
 
            revision.delta.show(to_file, self.show_ids, indent=indent)
649
403
 
650
404
 
651
405
class ShortLogFormatter(LogFormatter):
652
 
 
653
 
    supports_delta = True
654
 
 
655
 
    @deprecated_method(zero_seventeen)
656
406
    def show(self, revno, rev, delta):
657
 
        lr = LogRevision(rev, revno, 0, delta)
658
 
        return self.log_revision(lr)
659
 
 
660
 
    def log_revision(self, revision):
661
407
        from bzrlib.osutils import format_date
662
408
 
663
409
        to_file = self.to_file
664
 
        date_str = format_date(revision.rev.timestamp,
665
 
                               revision.rev.timezone or 0,
666
 
                               self.show_timezone)
667
 
        is_merge = ''
668
 
        if len(revision.rev.parent_ids) > 1:
669
 
            is_merge = ' [merge]'
670
 
        print >>to_file, "%5s %s\t%s%s" % (revision.revno,
671
 
                self.short_committer(revision.rev),
672
 
                format_date(revision.rev.timestamp,
673
 
                            revision.rev.timezone or 0,
674
 
                            self.show_timezone, date_fmt="%Y-%m-%d",
675
 
                            show_offset=False),
676
 
                is_merge)
 
410
        date_str = format_date(rev.timestamp, rev.timezone or 0,
 
411
                            self.show_timezone)
 
412
        print >>to_file, "%5d %s\t%s" % (revno, rev.committer,
 
413
                format_date(rev.timestamp, rev.timezone or 0,
 
414
                            self.show_timezone))
677
415
        if self.show_ids:
678
 
            print >>to_file,  '      revision-id:', revision.rev.revision_id
679
 
        if not revision.rev.message:
 
416
            print >>to_file,  '      revision-id:', rev.revision_id
 
417
        if not rev.message:
680
418
            print >>to_file,  '      (no message)'
681
419
        else:
682
 
            message = revision.rev.message.rstrip('\r\n')
683
 
            for l in message.split('\n'):
 
420
            for l in rev.message.split('\n'):
684
421
                print >>to_file,  '      ' + l
685
422
 
686
423
        # TODO: Why not show the modified files in a shorter form as
687
424
        # well? rewrap them single lines of appropriate length
688
 
        if revision.delta is not None:
689
 
            revision.delta.show(to_file, self.show_ids)
690
 
        print >>to_file, ''
691
 
 
 
425
        if delta != None:
 
426
            delta.show(to_file, self.show_ids)
 
427
        print
692
428
 
693
429
class LineLogFormatter(LogFormatter):
694
 
 
695
 
    def __init__(self, *args, **kwargs):
696
 
        from bzrlib.osutils import terminal_width
697
 
        super(LineLogFormatter, self).__init__(*args, **kwargs)
698
 
        self._max_chars = terminal_width() - 1
699
 
 
700
430
    def truncate(self, str, max_len):
701
431
        if len(str) <= max_len:
702
432
            return str
714
444
        else:
715
445
            return rev.message
716
446
 
717
 
    @deprecated_method(zero_seventeen)
 
447
    def short_committer(self, rev):
 
448
        return re.sub('<.*@.*>', '', rev.committer).strip(' ')
 
449
    
718
450
    def show(self, revno, rev, delta):
719
 
        from bzrlib.osutils import terminal_width
720
 
        print >> self.to_file, self.log_string(revno, rev, terminal_width()-1)
721
 
 
722
 
    def log_revision(self, revision):
723
 
        print >>self.to_file, self.log_string(revision.revno, revision.rev,
724
 
                                              self._max_chars)
725
 
 
726
 
    def log_string(self, revno, rev, max_chars):
727
 
        """Format log info into one string. Truncate tail of string
728
 
        :param  revno:      revision number (int) or None.
729
 
                            Revision numbers counts from 1.
730
 
        :param  rev:        revision info object
731
 
        :param  max_chars:  maximum length of resulting string
732
 
        :return:            formatted truncated string
733
 
        """
734
 
        out = []
735
 
        if revno:
736
 
            # show revno only when is not None
737
 
            out.append("%s:" % revno)
738
 
        out.append(self.truncate(self.short_committer(rev), 20))
 
451
        print >> self.to_file, self.log_string(rev, 79) 
 
452
 
 
453
    def log_string(self, rev, max_chars):
 
454
        out = [self.truncate(self.short_committer(rev), 20)]
739
455
        out.append(self.date_string(rev))
740
 
        out.append(rev.get_summary())
 
456
        out.append(self.message(rev).replace('\n', ' '))
741
457
        return self.truncate(" ".join(out).rstrip('\n'), max_chars)
742
458
 
743
 
 
744
459
def line_log(rev, max_chars):
745
460
    lf = LineLogFormatter(None)
746
 
    return lf.log_string(None, rev, max_chars)
747
 
 
748
 
 
749
 
class LogFormatterRegistry(registry.Registry):
750
 
    """Registry for log formatters"""
751
 
 
752
 
    def make_formatter(self, name, *args, **kwargs):
753
 
        """Construct a formatter from arguments.
754
 
 
755
 
        :param name: Name of the formatter to construct.  'short', 'long' and
756
 
            'line' are built-in.
757
 
        """
758
 
        return self.get(name)(*args, **kwargs)
759
 
 
760
 
    def get_default(self, branch):
761
 
        return self.get(branch.get_config().log_format())
762
 
 
763
 
 
764
 
log_formatter_registry = LogFormatterRegistry()
765
 
 
766
 
 
767
 
log_formatter_registry.register('short', ShortLogFormatter,
768
 
                                'Moderately short log format')
769
 
log_formatter_registry.register('long', LongLogFormatter,
770
 
                                'Detailed log format')
771
 
log_formatter_registry.register('line', LineLogFormatter,
772
 
                                'Log format with one line per revision')
773
 
 
774
 
 
775
 
def register_formatter(name, formatter):
776
 
    log_formatter_registry.register(name, formatter)
 
461
    return lf.log_string(rev, max_chars)
 
462
 
 
463
FORMATTERS = {'long': LongLogFormatter,
 
464
              'short': ShortLogFormatter,
 
465
              'line': LineLogFormatter,
 
466
              }
777
467
 
778
468
 
779
469
def log_formatter(name, *args, **kwargs):
784
474
    """
785
475
    from bzrlib.errors import BzrCommandError
786
476
    try:
787
 
        return log_formatter_registry.make_formatter(name, *args, **kwargs)
788
 
    except KeyError:
 
477
        return FORMATTERS[name](*args, **kwargs)
 
478
    except IndexError:
789
479
        raise BzrCommandError("unknown log formatter: %r" % name)
790
480
 
791
 
 
792
481
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
793
 
    # deprecated; for compatibility
 
482
    # deprecated; for compatability
794
483
    lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
795
484
    lf.show(revno, rev, delta)
796
 
 
797
 
 
798
 
def show_changed_revisions(branch, old_rh, new_rh, to_file=None, log_format='long'):
799
 
    """Show the change in revision history comparing the old revision history to the new one.
800
 
 
801
 
    :param branch: The branch where the revisions exist
802
 
    :param old_rh: The old revision history
803
 
    :param new_rh: The new revision history
804
 
    :param to_file: A file to write the results to. If None, stdout will be used
805
 
    """
806
 
    if to_file is None:
807
 
        import sys
808
 
        import codecs
809
 
        import bzrlib
810
 
        to_file = codecs.getwriter(bzrlib.user_encoding)(sys.stdout, errors='replace')
811
 
    lf = log_formatter(log_format,
812
 
                       show_ids=False,
813
 
                       to_file=to_file,
814
 
                       show_timezone='original')
815
 
 
816
 
    # This is the first index which is different between
817
 
    # old and new
818
 
    base_idx = None
819
 
    for i in xrange(max(len(new_rh),
820
 
                        len(old_rh))):
821
 
        if (len(new_rh) <= i
822
 
            or len(old_rh) <= i
823
 
            or new_rh[i] != old_rh[i]):
824
 
            base_idx = i
825
 
            break
826
 
 
827
 
    if base_idx is None:
828
 
        to_file.write('Nothing seems to have changed\n')
829
 
        return
830
 
    ## TODO: It might be nice to do something like show_log
831
 
    ##       and show the merged entries. But since this is the
832
 
    ##       removed revisions, it shouldn't be as important
833
 
    if base_idx < len(old_rh):
834
 
        to_file.write('*'*60)
835
 
        to_file.write('\nRemoved Revisions:\n')
836
 
        for i in range(base_idx, len(old_rh)):
837
 
            rev = branch.repository.get_revision(old_rh[i])
838
 
            lr = LogRevision(rev, i+1, 0, None)
839
 
            lf.log_revision(lr)
840
 
        to_file.write('*'*60)
841
 
        to_file.write('\n\n')
842
 
    if base_idx < len(new_rh):
843
 
        to_file.write('Added Revisions:\n')
844
 
        show_log(branch,
845
 
                 lf,
846
 
                 None,
847
 
                 verbose=True,
848
 
                 direction='forward',
849
 
                 start_revision=base_idx+1,
850
 
                 end_revision=len(new_rh),
851
 
                 search=None)
852