~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: Martin Pool
  • Date: 2007-08-21 05:29:59 UTC
  • mto: This revision was merged to the branch mainline in revision 2779.
  • Revision ID: mbp@sourcefrog.net-20070821052959-5odvyjziwyuaeo3d
Move per-inventory tests from test_inv to tests.inventory_implementations

Show diffs side-by-side

added added

removed removed

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