/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: Aaron Bentley
  • Date: 2008-03-28 03:09:47 UTC
  • mto: This revision was merged to the branch mainline in revision 3371.
  • Revision ID: aaron@aaronbentley.com-20080328030947-57cfqi7to7k401wc
Have xml5 inherit from xml6 from xml8

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
import codecs
 
53
from itertools import (
 
54
    izip,
 
55
    )
 
56
import re
 
57
import sys
 
58
from warnings import (
 
59
    warn,
 
60
    )
 
61
 
 
62
from bzrlib import (
 
63
    config,
 
64
    lazy_regex,
 
65
    registry,
 
66
    )
 
67
from bzrlib.errors import (
 
68
    BzrCommandError,
 
69
    )
 
70
from bzrlib.osutils import (
 
71
    format_date,
 
72
    get_terminal_encoding,
 
73
    terminal_width,
 
74
    )
 
75
from bzrlib.revision import (
 
76
    NULL_REVISION,
 
77
    )
 
78
from bzrlib.revisionspec import (
 
79
    RevisionInfo,
 
80
    )
 
81
from bzrlib.trace import mutter
 
82
from bzrlib.tsort import (
 
83
    merge_sort,
 
84
    topo_sort,
 
85
    )
 
86
 
 
87
 
 
88
def find_touching_revisions(branch, file_id):
 
89
    """Yield a description of revisions which affect the file_id.
 
90
 
 
91
    Each returned element is (revno, revision_id, description)
 
92
 
 
93
    This is the list of revisions where the file is either added,
 
94
    modified, renamed or deleted.
 
95
 
 
96
    TODO: Perhaps some way to limit this to only particular revisions,
 
97
    or to traverse a non-mainline set of revisions?
 
98
    """
 
99
    last_ie = None
 
100
    last_path = None
 
101
    revno = 1
 
102
    for revision_id in branch.revision_history():
 
103
        this_inv = branch.repository.get_revision_inventory(revision_id)
 
104
        if file_id in this_inv:
 
105
            this_ie = this_inv[file_id]
 
106
            this_path = this_inv.id2path(file_id)
 
107
        else:
 
108
            this_ie = this_path = None
 
109
 
 
110
        # now we know how it was last time, and how it is in this revision.
 
111
        # are those two states effectively the same or not?
 
112
 
 
113
        if not this_ie and not last_ie:
 
114
            # not present in either
 
115
            pass
 
116
        elif this_ie and not last_ie:
 
117
            yield revno, revision_id, "added " + this_path
 
118
        elif not this_ie and last_ie:
 
119
            # deleted here
 
120
            yield revno, revision_id, "deleted " + last_path
 
121
        elif this_path != last_path:
 
122
            yield revno, revision_id, ("renamed %s => %s" % (last_path, this_path))
 
123
        elif (this_ie.text_size != last_ie.text_size
 
124
              or this_ie.text_sha1 != last_ie.text_sha1):
 
125
            yield revno, revision_id, "modified " + this_path
 
126
 
 
127
        last_ie = this_ie
 
128
        last_path = this_path
 
129
        revno += 1
 
130
 
 
131
 
 
132
def _enumerate_history(branch):
 
133
    rh = []
 
134
    revno = 1
 
135
    for rev_id in branch.revision_history():
 
136
        rh.append((revno, rev_id))
 
137
        revno += 1
 
138
    return rh
 
139
 
 
140
 
 
141
def show_log(branch,
 
142
             lf,
 
143
             specific_fileid=None,
 
144
             verbose=False,
 
145
             direction='reverse',
 
146
             start_revision=None,
 
147
             end_revision=None,
 
148
             search=None,
 
149
             limit=None):
 
150
    """Write out human-readable log of commits to this branch.
 
151
 
 
152
    lf
 
153
        LogFormatter object to show the output.
 
154
 
 
155
    specific_fileid
 
156
        If true, list only the commits affecting the specified
 
157
        file, rather than all commits.
 
158
 
 
159
    verbose
 
160
        If true show added/changed/deleted/renamed files.
 
161
 
 
162
    direction
 
163
        'reverse' (default) is latest to earliest;
 
164
        'forward' is earliest to latest.
 
165
 
 
166
    start_revision
 
167
        If not None, only show revisions >= start_revision
 
168
 
 
169
    end_revision
 
170
        If not None, only show revisions <= end_revision
 
171
 
 
172
    search
 
173
        If not None, only show revisions with matching commit messages
 
174
 
 
175
    limit
 
176
        If not None or 0, only show limit revisions
 
177
    """
 
178
    branch.lock_read()
 
179
    try:
 
180
        if getattr(lf, 'begin_log', None):
 
181
            lf.begin_log()
 
182
 
 
183
        _show_log(branch, lf, specific_fileid, verbose, direction,
 
184
                  start_revision, end_revision, search, limit)
 
185
 
 
186
        if getattr(lf, 'end_log', None):
 
187
            lf.end_log()
 
188
    finally:
 
189
        branch.unlock()
 
190
 
 
191
 
 
192
def _show_log(branch,
 
193
             lf,
 
194
             specific_fileid=None,
 
195
             verbose=False,
 
196
             direction='reverse',
 
197
             start_revision=None,
 
198
             end_revision=None,
 
199
             search=None,
 
200
             limit=None):
 
201
    """Worker function for show_log - see show_log."""
 
202
    if not isinstance(lf, LogFormatter):
 
203
        warn("not a LogFormatter instance: %r" % lf)
 
204
 
 
205
    if specific_fileid:
 
206
        mutter('get log for file_id %r', specific_fileid)
 
207
    generate_merge_revisions = getattr(lf, 'supports_merge_revisions', False)
 
208
    allow_single_merge_revision = getattr(lf,
 
209
        'supports_single_merge_revision', False)
 
210
    view_revisions = calculate_view_revisions(branch, start_revision,
 
211
                                              end_revision, direction,
 
212
                                              specific_fileid,
 
213
                                              generate_merge_revisions,
 
214
                                              allow_single_merge_revision)
 
215
    if search is not None:
 
216
        searchRE = re.compile(search, re.IGNORECASE)
 
217
    else:
 
218
        searchRE = None
 
219
 
 
220
    rev_tag_dict = {}
 
221
    generate_tags = getattr(lf, 'supports_tags', False)
 
222
    if generate_tags:
 
223
        if branch.supports_tags():
 
224
            rev_tag_dict = branch.tags.get_reverse_tag_dict()
 
225
 
 
226
    generate_delta = verbose and getattr(lf, 'supports_delta', False)
 
227
 
 
228
    # now we just print all the revisions
 
229
    log_count = 0
 
230
    for (rev_id, revno, merge_depth), rev, delta in _iter_revisions(
 
231
        branch.repository, view_revisions, generate_delta):
 
232
        if searchRE:
 
233
            if not searchRE.search(rev.message):
 
234
                continue
 
235
 
 
236
        lr = LogRevision(rev, revno, merge_depth, delta,
 
237
                         rev_tag_dict.get(rev_id))
 
238
        lf.log_revision(lr)
 
239
        if limit:
 
240
            log_count += 1
 
241
            if log_count >= limit:
 
242
                break
 
243
 
 
244
 
 
245
def calculate_view_revisions(branch, start_revision, end_revision, direction,
 
246
                             specific_fileid, generate_merge_revisions,
 
247
                             allow_single_merge_revision):
 
248
    if (not generate_merge_revisions and start_revision is end_revision is
 
249
        None and direction == 'reverse' and specific_fileid is None):
 
250
        return _linear_view_revisions(branch)
 
251
 
 
252
    mainline_revs, rev_nos, start_rev_id, end_rev_id = \
 
253
        _get_mainline_revs(branch, start_revision, end_revision)
 
254
    if not mainline_revs:
 
255
        return []
 
256
 
 
257
    if direction == 'reverse':
 
258
        start_rev_id, end_rev_id = end_rev_id, start_rev_id
 
259
 
 
260
    generate_single_revision = False
 
261
    if ((not generate_merge_revisions)
 
262
        and ((start_rev_id and (start_rev_id not in rev_nos))
 
263
            or (end_rev_id and (end_rev_id not in rev_nos)))):
 
264
        generate_single_revision = ((start_rev_id == end_rev_id)
 
265
            and allow_single_merge_revision)
 
266
        if not generate_single_revision:
 
267
            raise BzrCommandError('Selected log formatter only supports '
 
268
                'mainline revisions.')
 
269
        generate_merge_revisions = generate_single_revision
 
270
    view_revs_iter = get_view_revisions(mainline_revs, rev_nos, branch,
 
271
                          direction, include_merges=generate_merge_revisions)
 
272
    view_revisions = _filter_revision_range(list(view_revs_iter),
 
273
                                            start_rev_id,
 
274
                                            end_rev_id)
 
275
    if view_revisions and generate_single_revision:
 
276
        view_revisions = view_revisions[0:1]
 
277
    if specific_fileid:
 
278
        view_revisions = _filter_revisions_touching_file_id(branch,
 
279
                                                         specific_fileid,
 
280
                                                         mainline_revs,
 
281
                                                         view_revisions)
 
282
 
 
283
    # rebase merge_depth - unless there are no revisions or 
 
284
    # either the first or last revision have merge_depth = 0.
 
285
    if view_revisions and view_revisions[0][2] and view_revisions[-1][2]:
 
286
        min_depth = min([d for r,n,d in view_revisions])
 
287
        if min_depth != 0:
 
288
            view_revisions = [(r,n,d-min_depth) for r,n,d in view_revisions]
 
289
    return view_revisions
 
290
 
 
291
 
 
292
def _linear_view_revisions(branch):
 
293
    start_revno, start_revision_id = branch.last_revision_info()
 
294
    repo = branch.repository
 
295
    revision_ids = repo.iter_reverse_revision_history(start_revision_id)
 
296
    for num, revision_id in enumerate(revision_ids):
 
297
        yield revision_id, str(start_revno - num), 0
 
298
 
 
299
 
 
300
def _iter_revisions(repository, view_revisions, generate_delta):
 
301
    num = 9
 
302
    view_revisions = iter(view_revisions)
 
303
    while True:
 
304
        cur_view_revisions = [d for x, d in zip(range(num), view_revisions)]
 
305
        if len(cur_view_revisions) == 0:
 
306
            break
 
307
        cur_deltas = {}
 
308
        # r = revision, n = revno, d = merge depth
 
309
        revision_ids = [r for (r, n, d) in cur_view_revisions]
 
310
        revisions = repository.get_revisions(revision_ids)
 
311
        if generate_delta:
 
312
            deltas = repository.get_deltas_for_revisions(revisions)
 
313
            cur_deltas = dict(izip((r.revision_id for r in revisions),
 
314
                                   deltas))
 
315
        for view_data, revision in izip(cur_view_revisions, revisions):
 
316
            yield view_data, revision, cur_deltas.get(revision.revision_id)
 
317
        num = min(int(num * 1.5), 200)
 
318
 
 
319
 
 
320
def _get_mainline_revs(branch, start_revision, end_revision):
 
321
    """Get the mainline revisions from the branch.
 
322
    
 
323
    Generates the list of mainline revisions for the branch.
 
324
    
 
325
    :param  branch: The branch containing the revisions. 
 
326
 
 
327
    :param  start_revision: The first revision to be logged.
 
328
            For backwards compatibility this may be a mainline integer revno,
 
329
            but for merge revision support a RevisionInfo is expected.
 
330
 
 
331
    :param  end_revision: The last revision to be logged.
 
332
            For backwards compatibility this may be a mainline integer revno,
 
333
            but for merge revision support a RevisionInfo is expected.
 
334
 
 
335
    :return: A (mainline_revs, rev_nos, start_rev_id, end_rev_id) tuple.
 
336
    """
 
337
    which_revs = _enumerate_history(branch)
 
338
    if not which_revs:
 
339
        return None, None, None, None
 
340
 
 
341
    # For mainline generation, map start_revision and end_revision to 
 
342
    # mainline revnos. If the revision is not on the mainline choose the 
 
343
    # appropriate extreme of the mainline instead - the extra will be 
 
344
    # filtered later.
 
345
    # Also map the revisions to rev_ids, to be used in the later filtering
 
346
    # stage.
 
347
    start_rev_id = None 
 
348
    if start_revision is None:
 
349
        start_revno = 1
 
350
    else:
 
351
        if isinstance(start_revision,RevisionInfo):
 
352
            start_rev_id = start_revision.rev_id
 
353
            start_revno = start_revision.revno or 1
 
354
        else:
 
355
            branch.check_real_revno(start_revision)
 
356
            start_revno = start_revision
 
357
    
 
358
    end_rev_id = None
 
359
    if end_revision is None:
 
360
        end_revno = len(which_revs)
 
361
    else:
 
362
        if isinstance(end_revision,RevisionInfo):
 
363
            end_rev_id = end_revision.rev_id
 
364
            end_revno = end_revision.revno or len(which_revs)
 
365
        else:
 
366
            branch.check_real_revno(end_revision)
 
367
            end_revno = end_revision
 
368
 
 
369
    if ((start_rev_id == NULL_REVISION)
 
370
        or (end_rev_id == NULL_REVISION)):
 
371
        raise BzrCommandError('Logging revision 0 is invalid.')
 
372
    if start_revno > end_revno:
 
373
        raise BzrCommandError("Start revision must be older than "
 
374
                              "the end revision.")
 
375
 
 
376
    # list indexes are 0-based; revisions are 1-based
 
377
    cut_revs = which_revs[(start_revno-1):(end_revno)]
 
378
    if not cut_revs:
 
379
        return None, None, None, None
 
380
 
 
381
    # convert the revision history to a dictionary:
 
382
    rev_nos = dict((k, v) for v, k in cut_revs)
 
383
 
 
384
    # override the mainline to look like the revision history.
 
385
    mainline_revs = [revision_id for index, revision_id in cut_revs]
 
386
    if cut_revs[0][0] == 1:
 
387
        mainline_revs.insert(0, None)
 
388
    else:
 
389
        mainline_revs.insert(0, which_revs[start_revno-2][1])
 
390
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
 
391
 
 
392
 
 
393
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
 
394
    """Filter view_revisions based on revision ranges.
 
395
 
 
396
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth) 
 
397
            tuples to be filtered.
 
398
 
 
399
    :param start_rev_id: If not NONE specifies the first revision to be logged.
 
400
            If NONE then all revisions up to the end_rev_id are logged.
 
401
 
 
402
    :param end_rev_id: If not NONE specifies the last revision to be logged.
 
403
            If NONE then all revisions up to the end of the log are logged.
 
404
 
 
405
    :return: The filtered view_revisions.
 
406
    """
 
407
    if start_rev_id or end_rev_id: 
 
408
        revision_ids = [r for r, n, d in view_revisions]
 
409
        if start_rev_id:
 
410
            start_index = revision_ids.index(start_rev_id)
 
411
        else:
 
412
            start_index = 0
 
413
        if start_rev_id == end_rev_id:
 
414
            end_index = start_index
 
415
        else:
 
416
            if end_rev_id:
 
417
                end_index = revision_ids.index(end_rev_id)
 
418
            else:
 
419
                end_index = len(view_revisions) - 1
 
420
        # To include the revisions merged into the last revision, 
 
421
        # extend end_rev_id down to, but not including, the next rev
 
422
        # with the same or lesser merge_depth
 
423
        end_merge_depth = view_revisions[end_index][2]
 
424
        try:
 
425
            for index in xrange(end_index+1, len(view_revisions)+1):
 
426
                if view_revisions[index][2] <= end_merge_depth:
 
427
                    end_index = index - 1
 
428
                    break
 
429
        except IndexError:
 
430
            # if the search falls off the end then log to the end as well
 
431
            end_index = len(view_revisions) - 1
 
432
        view_revisions = view_revisions[start_index:end_index+1]
 
433
    return view_revisions
 
434
 
 
435
 
 
436
def _filter_revisions_touching_file_id(branch, file_id, mainline_revisions,
 
437
                                       view_revs_iter):
 
438
    """Return the list of revision ids which touch a given file id.
 
439
 
 
440
    The function filters view_revisions and returns a subset.
 
441
    This includes the revisions which directly change the file id,
 
442
    and the revisions which merge these changes. So if the
 
443
    revision graph is::
 
444
        A
 
445
        |\
 
446
        B C
 
447
        |/
 
448
        D
 
449
 
 
450
    And 'C' changes a file, then both C and D will be returned.
 
451
 
 
452
    This will also can be restricted based on a subset of the mainline.
 
453
 
 
454
    :return: A list of (revision_id, dotted_revno, merge_depth) tuples.
 
455
    """
 
456
    # find all the revisions that change the specific file
 
457
    file_weave = branch.repository.weave_store.get_weave(file_id,
 
458
                branch.repository.get_transaction())
 
459
    weave_modifed_revisions = set(file_weave.versions())
 
460
    # build the ancestry of each revision in the graph
 
461
    # - only listing the ancestors that change the specific file.
 
462
    rev_graph = branch.repository.get_revision_graph(mainline_revisions[-1])
 
463
    sorted_rev_list = topo_sort(rev_graph)
 
464
    ancestry = {}
 
465
    for rev in sorted_rev_list:
 
466
        parents = rev_graph[rev]
 
467
        if rev not in weave_modifed_revisions and len(parents) == 1:
 
468
            # We will not be adding anything new, so just use a reference to
 
469
            # the parent ancestry.
 
470
            rev_ancestry = ancestry[parents[0]]
 
471
        else:
 
472
            rev_ancestry = set()
 
473
            if rev in weave_modifed_revisions:
 
474
                rev_ancestry.add(rev)
 
475
            for parent in parents:
 
476
                rev_ancestry = rev_ancestry.union(ancestry[parent])
 
477
        ancestry[rev] = rev_ancestry
 
478
 
 
479
    def is_merging_rev(r):
 
480
        parents = rev_graph[r]
 
481
        if len(parents) > 1:
 
482
            leftparent = parents[0]
 
483
            for rightparent in parents[1:]:
 
484
                if not ancestry[leftparent].issuperset(
 
485
                        ancestry[rightparent]):
 
486
                    return True
 
487
        return False
 
488
 
 
489
    # filter from the view the revisions that did not change or merge 
 
490
    # the specific file
 
491
    return [(r, n, d) for r, n, d in view_revs_iter
 
492
            if r in weave_modifed_revisions or is_merging_rev(r)]
 
493
 
 
494
 
 
495
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
 
496
                       include_merges=True):
 
497
    """Produce an iterator of revisions to show
 
498
    :return: an iterator of (revision_id, revno, merge_depth)
 
499
    (if there is no revno for a revision, None is supplied)
 
500
    """
 
501
    if include_merges is False:
 
502
        revision_ids = mainline_revs[1:]
 
503
        if direction == 'reverse':
 
504
            revision_ids.reverse()
 
505
        for revision_id in revision_ids:
 
506
            yield revision_id, str(rev_nos[revision_id]), 0
 
507
        return
 
508
    merge_sorted_revisions = merge_sort(
 
509
        branch.repository.get_revision_graph(mainline_revs[-1]),
 
510
        mainline_revs[-1],
 
511
        mainline_revs,
 
512
        generate_revno=True)
 
513
 
 
514
    if direction == 'forward':
 
515
        # forward means oldest first.
 
516
        merge_sorted_revisions = reverse_by_depth(merge_sorted_revisions)
 
517
    elif direction != 'reverse':
 
518
        raise ValueError('invalid direction %r' % direction)
 
519
 
 
520
    for sequence, rev_id, merge_depth, revno, end_of_merge in merge_sorted_revisions:
 
521
        yield rev_id, '.'.join(map(str, revno)), merge_depth
 
522
 
 
523
 
 
524
def reverse_by_depth(merge_sorted_revisions, _depth=0):
 
525
    """Reverse revisions by depth.
 
526
 
 
527
    Revisions with a different depth are sorted as a group with the previous
 
528
    revision of that depth.  There may be no topological justification for this,
 
529
    but it looks much nicer.
 
530
    """
 
531
    zd_revisions = []
 
532
    for val in merge_sorted_revisions:
 
533
        if val[2] == _depth:
 
534
            zd_revisions.append([val])
 
535
        else:
 
536
            assert val[2] > _depth
 
537
            zd_revisions[-1].append(val)
 
538
    for revisions in zd_revisions:
 
539
        if len(revisions) > 1:
 
540
            revisions[1:] = reverse_by_depth(revisions[1:], _depth + 1)
 
541
    zd_revisions.reverse()
 
542
    result = []
 
543
    for chunk in zd_revisions:
 
544
        result.extend(chunk)
 
545
    return result
 
546
 
 
547
 
 
548
class LogRevision(object):
 
549
    """A revision to be logged (by LogFormatter.log_revision).
 
550
 
 
551
    A simple wrapper for the attributes of a revision to be logged.
 
552
    The attributes may or may not be populated, as determined by the 
 
553
    logging options and the log formatter capabilities.
 
554
    """
 
555
 
 
556
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
 
557
                 tags=None):
 
558
        self.rev = rev
 
559
        self.revno = revno
 
560
        self.merge_depth = merge_depth
 
561
        self.delta = delta
 
562
        self.tags = tags
 
563
 
 
564
 
 
565
class LogFormatter(object):
 
566
    """Abstract class to display log messages.
 
567
 
 
568
    At a minimum, a derived class must implement the log_revision method.
 
569
 
 
570
    If the LogFormatter needs to be informed of the beginning or end of
 
571
    a log it should implement the begin_log and/or end_log hook methods.
 
572
 
 
573
    A LogFormatter should define the following supports_XXX flags 
 
574
    to indicate which LogRevision attributes it supports:
 
575
 
 
576
    - supports_delta must be True if this log formatter supports delta.
 
577
        Otherwise the delta attribute may not be populated.
 
578
    - supports_merge_revisions must be True if this log formatter supports 
 
579
        merge revisions.  If not, and if supports_single_merge_revisions is
 
580
        also not True, then only mainline revisions will be passed to the 
 
581
        formatter.
 
582
    - supports_single_merge_revision must be True if this log formatter
 
583
        supports logging only a single merge revision.  This flag is
 
584
        only relevant if supports_merge_revisions is not True.
 
585
    - supports_tags must be True if this log formatter supports tags.
 
586
        Otherwise the tags attribute may not be populated.
 
587
    """
 
588
 
 
589
    def __init__(self, to_file, show_ids=False, show_timezone='original'):
 
590
        self.to_file = to_file
 
591
        self.show_ids = show_ids
 
592
        self.show_timezone = show_timezone
 
593
 
 
594
# TODO: uncomment this block after show() has been removed.
 
595
# Until then defining log_revision would prevent _show_log calling show() 
 
596
# in legacy formatters.
 
597
#    def log_revision(self, revision):
 
598
#        """Log a revision.
 
599
#
 
600
#        :param  revision:   The LogRevision to be logged.
 
601
#        """
 
602
#        raise NotImplementedError('not implemented in abstract base')
 
603
 
 
604
    def short_committer(self, rev):
 
605
        name, address = config.parse_username(rev.committer)
 
606
        if name:
 
607
            return name
 
608
        return address
 
609
 
 
610
    def short_author(self, rev):
 
611
        name, address = config.parse_username(rev.get_apparent_author())
 
612
        if name:
 
613
            return name
 
614
        return address
 
615
 
 
616
 
 
617
class LongLogFormatter(LogFormatter):
 
618
 
 
619
    supports_merge_revisions = True
 
620
    supports_delta = True
 
621
    supports_tags = True
 
622
 
 
623
    def log_revision(self, revision):
 
624
        """Log a revision, either merged or not."""
 
625
        indent = '    ' * revision.merge_depth
 
626
        to_file = self.to_file
 
627
        to_file.write(indent + '-' * 60 + '\n')
 
628
        if revision.revno is not None:
 
629
            to_file.write(indent + 'revno: %s\n' % (revision.revno,))
 
630
        if revision.tags:
 
631
            to_file.write(indent + 'tags: %s\n' % (', '.join(revision.tags)))
 
632
        if self.show_ids:
 
633
            to_file.write(indent + 'revision-id: ' + revision.rev.revision_id)
 
634
            to_file.write('\n')
 
635
            for parent_id in revision.rev.parent_ids:
 
636
                to_file.write(indent + 'parent: %s\n' % (parent_id,))
 
637
 
 
638
        author = revision.rev.properties.get('author', None)
 
639
        if author is not None:
 
640
            to_file.write(indent + 'author: %s\n' % (author,))
 
641
        to_file.write(indent + 'committer: %s\n' % (revision.rev.committer,))
 
642
 
 
643
        branch_nick = revision.rev.properties.get('branch-nick', None)
 
644
        if branch_nick is not None:
 
645
            to_file.write(indent + 'branch nick: %s\n' % (branch_nick,))
 
646
 
 
647
        date_str = format_date(revision.rev.timestamp,
 
648
                               revision.rev.timezone or 0,
 
649
                               self.show_timezone)
 
650
        to_file.write(indent + 'timestamp: %s\n' % (date_str,))
 
651
 
 
652
        to_file.write(indent + 'message:\n')
 
653
        if not revision.rev.message:
 
654
            to_file.write(indent + '  (no message)\n')
 
655
        else:
 
656
            message = revision.rev.message.rstrip('\r\n')
 
657
            for l in message.split('\n'):
 
658
                to_file.write(indent + '  %s\n' % (l,))
 
659
        if revision.delta is not None:
 
660
            revision.delta.show(to_file, self.show_ids, indent=indent)
 
661
 
 
662
 
 
663
class ShortLogFormatter(LogFormatter):
 
664
 
 
665
    supports_delta = True
 
666
    supports_single_merge_revision = True
 
667
 
 
668
    def log_revision(self, revision):
 
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
    supports_single_merge_revision = True
 
702
 
 
703
    def __init__(self, *args, **kwargs):
 
704
        super(LineLogFormatter, self).__init__(*args, **kwargs)
 
705
        self._max_chars = terminal_width() - 1
 
706
 
 
707
    def truncate(self, str, max_len):
 
708
        if len(str) <= max_len:
 
709
            return str
 
710
        return str[:max_len-3]+'...'
 
711
 
 
712
    def date_string(self, rev):
 
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
    def log_revision(self, revision):
 
724
        self.to_file.write(self.log_string(revision.revno, revision.rev,
 
725
                                              self._max_chars))
 
726
        self.to_file.write('\n')
 
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_author(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
    try:
 
788
        return log_formatter_registry.make_formatter(name, *args, **kwargs)
 
789
    except KeyError:
 
790
        raise BzrCommandError("unknown log formatter: %r" % name)
 
791
 
 
792
 
 
793
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
 
794
    # deprecated; for compatibility
 
795
    lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
 
796
    lf.show(revno, rev, delta)
 
797
 
 
798
 
 
799
def show_changed_revisions(branch, old_rh, new_rh, to_file=None,
 
800
                           log_format='long'):
 
801
    """Show the change in revision history comparing the old revision history to the new one.
 
802
 
 
803
    :param branch: The branch where the revisions exist
 
804
    :param old_rh: The old revision history
 
805
    :param new_rh: The new revision history
 
806
    :param to_file: A file to write the results to. If None, stdout will be used
 
807
    """
 
808
    if to_file is None:
 
809
        to_file = codecs.getwriter(get_terminal_encoding())(sys.stdout,
 
810
            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=False,
 
848
                 direction='forward',
 
849
                 start_revision=base_idx+1,
 
850
                 end_revision=len(new_rh),
 
851
                 search=None)
 
852