/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/log.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2007-10-24 06:48:13 UTC
  • mfrom: (2592.3.241 mbp-packrepo-as-knits)
  • Revision ID: pqm@pqm.ubuntu.com-20071024064813-wjcmv8ofabf6kdrb
Pack repositories!

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
 
2
#
 
3
# This program is free software; you can redistribute it and/or modify
 
4
# it under the terms of the GNU General Public License as published by
 
5
# the Free Software Foundation; either version 2 of the License, or
 
6
# (at your option) any later version.
 
7
#
 
8
# This program is distributed in the hope that it will be useful,
 
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
# GNU General Public License for more details.
 
12
#
 
13
# You should have received a copy of the GNU General Public License
 
14
# along with this program; if not, write to the Free Software
 
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 
16
 
 
17
 
 
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
 
 
73
 
 
74
def find_touching_revisions(branch, file_id):
 
75
    """Yield a description of revisions which affect the file_id.
 
76
 
 
77
    Each returned element is (revno, revision_id, description)
 
78
 
 
79
    This is the list of revisions where the file is either added,
 
80
    modified, renamed or deleted.
 
81
 
 
82
    TODO: Perhaps some way to limit this to only particular revisions,
 
83
    or to traverse a non-mainline set of revisions?
 
84
    """
 
85
    last_ie = None
 
86
    last_path = None
 
87
    revno = 1
 
88
    for revision_id in branch.revision_history():
 
89
        this_inv = branch.repository.get_revision_inventory(revision_id)
 
90
        if file_id in this_inv:
 
91
            this_ie = this_inv[file_id]
 
92
            this_path = this_inv.id2path(file_id)
 
93
        else:
 
94
            this_ie = this_path = None
 
95
 
 
96
        # now we know how it was last time, and how it is in this revision.
 
97
        # are those two states effectively the same or not?
 
98
 
 
99
        if not this_ie and not last_ie:
 
100
            # not present in either
 
101
            pass
 
102
        elif this_ie and not last_ie:
 
103
            yield revno, revision_id, "added " + this_path
 
104
        elif not this_ie and last_ie:
 
105
            # deleted here
 
106
            yield revno, revision_id, "deleted " + last_path
 
107
        elif this_path != last_path:
 
108
            yield revno, revision_id, ("renamed %s => %s" % (last_path, this_path))
 
109
        elif (this_ie.text_size != last_ie.text_size
 
110
              or this_ie.text_sha1 != last_ie.text_sha1):
 
111
            yield revno, revision_id, "modified " + this_path
 
112
 
 
113
        last_ie = this_ie
 
114
        last_path = this_path
 
115
        revno += 1
 
116
 
 
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
 
 
127
def show_log(branch,
 
128
             lf,
 
129
             specific_fileid=None,
 
130
             verbose=False,
 
131
             direction='reverse',
 
132
             start_revision=None,
 
133
             end_revision=None,
 
134
             search=None,
 
135
             limit=None):
 
136
    """Write out human-readable log of commits to this branch.
 
137
 
 
138
    lf
 
139
        LogFormatter object to show the output.
 
140
 
 
141
    specific_fileid
 
142
        If true, list only the commits affecting the specified
 
143
        file, rather than all commits.
 
144
 
 
145
    verbose
 
146
        If true show added/changed/deleted/renamed files.
 
147
 
 
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
    def short_author(self, rev):
 
596
        return re.sub('<.*@.*>', '', rev.get_apparent_author()).strip(' ')
 
597
 
 
598
 
 
599
class LongLogFormatter(LogFormatter):
 
600
 
 
601
    supports_merge_revisions = True
 
602
    supports_delta = True
 
603
    supports_tags = True
 
604
 
 
605
    @deprecated_method(zero_seventeen)
 
606
    def show(self, revno, rev, delta, tags=None):
 
607
        lr = LogRevision(rev, revno, 0, delta, tags)
 
608
        return self.log_revision(lr)
 
609
 
 
610
    @deprecated_method(zero_seventeen)
 
611
    def show_merge_revno(self, rev, merge_depth, revno, tags=None):
 
612
        """Show a merged revision rev, with merge_depth and a revno."""
 
613
        lr = LogRevision(rev, revno, merge_depth, tags=tags)
 
614
        return self.log_revision(lr)
 
615
 
 
616
    def log_revision(self, revision):
 
617
        """Log a revision, either merged or not."""
 
618
        from bzrlib.osutils import format_date
 
619
        indent = '    ' * revision.merge_depth
 
620
        to_file = self.to_file
 
621
        to_file.write(indent + '-' * 60 + '\n')
 
622
        if revision.revno is not None:
 
623
            to_file.write(indent + 'revno: %s\n' % (revision.revno,))
 
624
        if revision.tags:
 
625
            to_file.write(indent + 'tags: %s\n' % (', '.join(revision.tags)))
 
626
        if self.show_ids:
 
627
            to_file.write(indent + 'revision-id:' + revision.rev.revision_id)
 
628
            to_file.write('\n')
 
629
            for parent_id in revision.rev.parent_ids:
 
630
                to_file.write(indent + 'parent: %s\n' % (parent_id,))
 
631
 
 
632
        author = revision.rev.properties.get('author', None)
 
633
        if author is not None:
 
634
            to_file.write(indent + 'author: %s\n' % (author,))
 
635
        to_file.write(indent + 'committer: %s\n' % (revision.rev.committer,))
 
636
 
 
637
        branch_nick = revision.rev.properties.get('branch-nick', None)
 
638
        if branch_nick is not None:
 
639
            to_file.write(indent + 'branch nick: %s\n' % (branch_nick,))
 
640
 
 
641
        date_str = format_date(revision.rev.timestamp,
 
642
                               revision.rev.timezone or 0,
 
643
                               self.show_timezone)
 
644
        to_file.write(indent + 'timestamp: %s\n' % (date_str,))
 
645
 
 
646
        to_file.write(indent + 'message:\n')
 
647
        if not revision.rev.message:
 
648
            to_file.write(indent + '  (no message)\n')
 
649
        else:
 
650
            message = revision.rev.message.rstrip('\r\n')
 
651
            for l in message.split('\n'):
 
652
                to_file.write(indent + '  %s\n' % (l,))
 
653
        if revision.delta is not None:
 
654
            revision.delta.show(to_file, self.show_ids, indent=indent)
 
655
 
 
656
 
 
657
class ShortLogFormatter(LogFormatter):
 
658
 
 
659
    supports_delta = True
 
660
 
 
661
    @deprecated_method(zero_seventeen)
 
662
    def show(self, revno, rev, delta):
 
663
        lr = LogRevision(rev, revno, 0, delta)
 
664
        return self.log_revision(lr)
 
665
 
 
666
    def log_revision(self, revision):
 
667
        from bzrlib.osutils import format_date
 
668
 
 
669
        to_file = self.to_file
 
670
        date_str = format_date(revision.rev.timestamp,
 
671
                               revision.rev.timezone or 0,
 
672
                               self.show_timezone)
 
673
        is_merge = ''
 
674
        if len(revision.rev.parent_ids) > 1:
 
675
            is_merge = ' [merge]'
 
676
        to_file.write("%5s %s\t%s%s\n" % (revision.revno,
 
677
                self.short_author(revision.rev),
 
678
                format_date(revision.rev.timestamp,
 
679
                            revision.rev.timezone or 0,
 
680
                            self.show_timezone, date_fmt="%Y-%m-%d",
 
681
                            show_offset=False),
 
682
                is_merge))
 
683
        if self.show_ids:
 
684
            to_file.write('      revision-id:%s\n' % (revision.rev.revision_id,))
 
685
        if not revision.rev.message:
 
686
            to_file.write('      (no message)\n')
 
687
        else:
 
688
            message = revision.rev.message.rstrip('\r\n')
 
689
            for l in message.split('\n'):
 
690
                to_file.write('      %s\n' % (l,))
 
691
 
 
692
        # TODO: Why not show the modified files in a shorter form as
 
693
        # well? rewrap them single lines of appropriate length
 
694
        if revision.delta is not None:
 
695
            revision.delta.show(to_file, self.show_ids)
 
696
        to_file.write('\n')
 
697
 
 
698
 
 
699
class LineLogFormatter(LogFormatter):
 
700
 
 
701
    def __init__(self, *args, **kwargs):
 
702
        from bzrlib.osutils import terminal_width
 
703
        super(LineLogFormatter, self).__init__(*args, **kwargs)
 
704
        self._max_chars = terminal_width() - 1
 
705
 
 
706
    def truncate(self, str, max_len):
 
707
        if len(str) <= max_len:
 
708
            return str
 
709
        return str[:max_len-3]+'...'
 
710
 
 
711
    def date_string(self, rev):
 
712
        from bzrlib.osutils import format_date
 
713
        return format_date(rev.timestamp, rev.timezone or 0, 
 
714
                           self.show_timezone, date_fmt="%Y-%m-%d",
 
715
                           show_offset=False)
 
716
 
 
717
    def message(self, rev):
 
718
        if not rev.message:
 
719
            return '(no message)'
 
720
        else:
 
721
            return rev.message
 
722
 
 
723
    @deprecated_method(zero_seventeen)
 
724
    def show(self, revno, rev, delta):
 
725
        from bzrlib.osutils import terminal_width
 
726
        self.to_file.write(self.log_string(revno, rev, terminal_width()-1))
 
727
        self.to_file.write('\n')
 
728
 
 
729
    def log_revision(self, revision):
 
730
        self.to_file.write(self.log_string(revision.revno, revision.rev,
 
731
                                              self._max_chars))
 
732
        self.to_file.write('\n')
 
733
 
 
734
    def log_string(self, revno, rev, max_chars):
 
735
        """Format log info into one string. Truncate tail of string
 
736
        :param  revno:      revision number (int) or None.
 
737
                            Revision numbers counts from 1.
 
738
        :param  rev:        revision info object
 
739
        :param  max_chars:  maximum length of resulting string
 
740
        :return:            formatted truncated string
 
741
        """
 
742
        out = []
 
743
        if revno:
 
744
            # show revno only when is not None
 
745
            out.append("%s:" % revno)
 
746
        out.append(self.truncate(self.short_author(rev), 20))
 
747
        out.append(self.date_string(rev))
 
748
        out.append(rev.get_summary())
 
749
        return self.truncate(" ".join(out).rstrip('\n'), max_chars)
 
750
 
 
751
 
 
752
def line_log(rev, max_chars):
 
753
    lf = LineLogFormatter(None)
 
754
    return lf.log_string(None, rev, max_chars)
 
755
 
 
756
 
 
757
class LogFormatterRegistry(registry.Registry):
 
758
    """Registry for log formatters"""
 
759
 
 
760
    def make_formatter(self, name, *args, **kwargs):
 
761
        """Construct a formatter from arguments.
 
762
 
 
763
        :param name: Name of the formatter to construct.  'short', 'long' and
 
764
            'line' are built-in.
 
765
        """
 
766
        return self.get(name)(*args, **kwargs)
 
767
 
 
768
    def get_default(self, branch):
 
769
        return self.get(branch.get_config().log_format())
 
770
 
 
771
 
 
772
log_formatter_registry = LogFormatterRegistry()
 
773
 
 
774
 
 
775
log_formatter_registry.register('short', ShortLogFormatter,
 
776
                                'Moderately short log format')
 
777
log_formatter_registry.register('long', LongLogFormatter,
 
778
                                'Detailed log format')
 
779
log_formatter_registry.register('line', LineLogFormatter,
 
780
                                'Log format with one line per revision')
 
781
 
 
782
 
 
783
def register_formatter(name, formatter):
 
784
    log_formatter_registry.register(name, formatter)
 
785
 
 
786
 
 
787
def log_formatter(name, *args, **kwargs):
 
788
    """Construct a formatter from arguments.
 
789
 
 
790
    name -- Name of the formatter to construct; currently 'long', 'short' and
 
791
        'line' are supported.
 
792
    """
 
793
    from bzrlib.errors import BzrCommandError
 
794
    try:
 
795
        return log_formatter_registry.make_formatter(name, *args, **kwargs)
 
796
    except KeyError:
 
797
        raise BzrCommandError("unknown log formatter: %r" % name)
 
798
 
 
799
 
 
800
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
 
801
    # deprecated; for compatibility
 
802
    lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
 
803
    lf.show(revno, rev, delta)
 
804
 
 
805
 
 
806
def show_changed_revisions(branch, old_rh, new_rh, to_file=None,
 
807
                           log_format='long'):
 
808
    """Show the change in revision history comparing the old revision history to the new one.
 
809
 
 
810
    :param branch: The branch where the revisions exist
 
811
    :param old_rh: The old revision history
 
812
    :param new_rh: The new revision history
 
813
    :param to_file: A file to write the results to. If None, stdout will be used
 
814
    """
 
815
    if to_file is None:
 
816
        import sys
 
817
        import codecs
 
818
        import bzrlib
 
819
        to_file = codecs.getwriter(bzrlib.user_encoding)(sys.stdout,
 
820
                                                         errors='replace')
 
821
    lf = log_formatter(log_format,
 
822
                       show_ids=False,
 
823
                       to_file=to_file,
 
824
                       show_timezone='original')
 
825
 
 
826
    # This is the first index which is different between
 
827
    # old and new
 
828
    base_idx = None
 
829
    for i in xrange(max(len(new_rh),
 
830
                        len(old_rh))):
 
831
        if (len(new_rh) <= i
 
832
            or len(old_rh) <= i
 
833
            or new_rh[i] != old_rh[i]):
 
834
            base_idx = i
 
835
            break
 
836
 
 
837
    if base_idx is None:
 
838
        to_file.write('Nothing seems to have changed\n')
 
839
        return
 
840
    ## TODO: It might be nice to do something like show_log
 
841
    ##       and show the merged entries. But since this is the
 
842
    ##       removed revisions, it shouldn't be as important
 
843
    if base_idx < len(old_rh):
 
844
        to_file.write('*'*60)
 
845
        to_file.write('\nRemoved Revisions:\n')
 
846
        for i in range(base_idx, len(old_rh)):
 
847
            rev = branch.repository.get_revision(old_rh[i])
 
848
            lr = LogRevision(rev, i+1, 0, None)
 
849
            lf.log_revision(lr)
 
850
        to_file.write('*'*60)
 
851
        to_file.write('\n\n')
 
852
    if base_idx < len(new_rh):
 
853
        to_file.write('Added Revisions:\n')
 
854
        show_log(branch,
 
855
                 lf,
 
856
                 None,
 
857
                 verbose=False,
 
858
                 direction='forward',
 
859
                 start_revision=base_idx+1,
 
860
                 end_revision=len(new_rh),
 
861
                 search=None)
 
862