Files @ fe7fa9942015
Branch filter:

Location: kallithea/rhodecode/controllers/changeset.py - annotation

Marcin Kuzminski
limited calculation of added/changed/removed files for large changesets, saving a lot of memory
30ad41c76fae
30ad41c76fae
30ad41c76fae
30ad41c76fae
30ad41c76fae
28524453bb76
28524453bb76
30ad41c76fae
30ad41c76fae
30ad41c76fae
07a6e8c65526
30ad41c76fae
30ad41c76fae
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
30ad41c76fae
30ad41c76fae
30ad41c76fae
1e757ac98988
1e757ac98988
1e757ac98988
30ad41c76fae
30ad41c76fae
1e757ac98988
3fc9183e05dd
3765f0f479a2
30ad41c76fae
6d2239363c81
6d2239363c81
1e757ac98988
1e757ac98988
28524453bb76
1e757ac98988
1e757ac98988
1e757ac98988
3fc9183e05dd
ffd07396d315
1e757ac98988
1e757ac98988
ffd07396d315
1e757ac98988
1e757ac98988
ffd07396d315
1e757ac98988
ffd07396d315
1e757ac98988
ffd07396d315
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
ffd07396d315
28524453bb76
28524453bb76
ccd323bfa121
1e757ac98988
28524453bb76
28524453bb76
28524453bb76
7bb902022d86
7bb902022d86
28524453bb76
899c19b0865c
57a2b792a3a1
57a2b792a3a1
57a2b792a3a1
6d2239363c81
1e757ac98988
c8bd0e6cc3da
ffd07396d315
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
ffd07396d315
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
1e757ac98988
28524453bb76
28524453bb76
7fcc539e20b1
1e757ac98988
1e757ac98988
1e757ac98988
1e757ac98988
30ad41c76fae
ce4287e3e3c9
ce4287e3e3c9
ffd07396d315
1e757ac98988
1e757ac98988
1e757ac98988
ffd07396d315
1e757ac98988
ffd07396d315
28524453bb76
ffd07396d315
28524453bb76
1e757ac98988
28524453bb76
28524453bb76
1e757ac98988
28524453bb76
1e757ac98988
7fcc539e20b1
ffd07396d315
1e757ac98988
1e757ac98988
1e757ac98988
ffd07396d315
30ad41c76fae
ce4287e3e3c9
ce4287e3e3c9
7fcc539e20b1
7fcc539e20b1
1e757ac98988
1e757ac98988
1e757ac98988
ffd07396d315
ffd07396d315
ffd07396d315
ffd07396d315
28524453bb76
ffd07396d315
28524453bb76
1e757ac98988
28524453bb76
28524453bb76
28524453bb76
ffd07396d315
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
28524453bb76
1e757ac98988
1e757ac98988
ffd07396d315
1e757ac98988
1e757ac98988
3fc9183e05dd
3fc9183e05dd
1e757ac98988
1e757ac98988
ffd07396d315
1e757ac98988
1e757ac98988
28524453bb76
1e757ac98988
28524453bb76
1e757ac98988
ffd07396d315
1e757ac98988
1e757ac98988
1e757ac98988
30ad41c76fae
ffd07396d315
ce4287e3e3c9
ce4287e3e3c9
1e757ac98988
1e757ac98988
ffd07396d315
1e757ac98988
ffd07396d315
1e757ac98988
28524453bb76
1e757ac98988
1e757ac98988
ffd07396d315
ce4287e3e3c9
ce4287e3e3c9
1e757ac98988
ffd07396d315
ffd07396d315
ffd07396d315
ffd07396d315
1e757ac98988
30ad41c76fae
1e757ac98988
ffd07396d315
30ad41c76fae
1e757ac98988
1e757ac98988
ffd07396d315
1e757ac98988
1e757ac98988
1e757ac98988
30ad41c76fae
1e757ac98988
# -*- coding: utf-8 -*-
"""
    rhodecode.controllers.changeset
    ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

    changeset controller for pylons showoing changes beetween 
    revisions
    
    :created_on: Apr 25, 2010
    :author: marcink
    :copyright: (C) 2009-2011 Marcin Kuzminski <marcin@python-works.com>    
    :license: GPLv3, see COPYING for more details.
"""
# This program is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public License
# as published by the Free Software Foundation; version 2
# of the License or (at your opinion) any later version of the license.
# 
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
# 
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
# MA  02110-1301, USA.
import logging
import traceback

from pylons import tmpl_context as c, url, request, response
from pylons.i18n.translation import _
from pylons.controllers.util import redirect

import rhodecode.lib.helpers as h
from rhodecode.lib.auth import LoginRequired, HasRepoPermissionAnyDecorator
from rhodecode.lib.base import BaseRepoController, render
from rhodecode.lib.utils import EmptyChangeset

from vcs.exceptions import RepositoryError, ChangesetError, \
ChangesetDoesNotExistError
from vcs.nodes import FileNode
from vcs.utils import diffs as differ
from vcs.utils.ordered_dict import OrderedDict

log = logging.getLogger(__name__)

class ChangesetController(BaseRepoController):

    @LoginRequired()
    @HasRepoPermissionAnyDecorator('repository.read', 'repository.write',
                                   'repository.admin')
    def __before__(self):
        super(ChangesetController, self).__before__()

    def index(self, revision):

        def wrap_to_table(str):

            return '''<table class="code-difftable">
                        <tr class="line">
                        <td class="lineno new"></td>
                        <td class="code"><pre>%s</pre></td>
                        </tr>
                      </table>''' % str

        #get ranges of revisions if preset
        rev_range = revision.split('...')[:2]
        range_limit = 50
        try:
            if len(rev_range) == 2:
                rev_start = rev_range[0]
                rev_end = rev_range[1]
                rev_ranges = c.rhodecode_repo.get_changesets(start=rev_start,
                                                            end=rev_end)
            else:
                rev_ranges = [c.rhodecode_repo.get_changeset(revision)]

            c.cs_ranges = list(rev_ranges)

        except (RepositoryError, ChangesetDoesNotExistError, Exception), e:
            log.error(traceback.format_exc())
            h.flash(str(e), category='warning')
            return redirect(url('home'))

        c.changes = OrderedDict()
        c.sum_added = 0
        c.sum_removed = 0


        for changeset in c.cs_ranges:
            c.changes[changeset.raw_id] = []
            try:
                changeset_parent = changeset.parents[0]
            except IndexError:
                changeset_parent = None


            #==================================================================
            # ADDED FILES
            #==================================================================
            for node in changeset.added:
                filenode_old = FileNode(node.path, '', EmptyChangeset())
                if filenode_old.is_binary or node.is_binary:
                    diff = wrap_to_table(_('binary file'))
                else:
                    c.sum_added += node.size
                    if c.sum_added < self.cut_off_limit:
                        f_gitdiff = differ.get_gitdiff(filenode_old, node)
                        diff = differ.DiffProcessor(f_gitdiff, format='gitdiff').as_html()

                    else:
                        diff = wrap_to_table(_('Changeset is to big and was cut'
                                            ' off, see raw changeset instead'))

                cs1 = None
                cs2 = node.last_changeset.raw_id
                c.changes[changeset.raw_id].append(('added', node, diff, cs1, cs2))

            #==================================================================
            # CHANGED FILES
            #==================================================================
            for node in changeset.changed:
                try:
                    filenode_old = changeset_parent.get_node(node.path)
                except ChangesetError:
                    filenode_old = FileNode(node.path, '', EmptyChangeset())

                if filenode_old.is_binary or node.is_binary:
                    diff = wrap_to_table(_('binary file'))
                else:

                    if c.sum_removed < self.cut_off_limit:
                        f_gitdiff = differ.get_gitdiff(filenode_old, node)
                        diff = differ.DiffProcessor(f_gitdiff, format='gitdiff').as_html()
                        if diff:
                            c.sum_removed += len(diff)
                    else:
                        diff = wrap_to_table(_('Changeset is to big and was cut'
                                            ' off, see raw changeset instead'))


                cs1 = filenode_old.last_changeset.raw_id
                cs2 = node.last_changeset.raw_id
                c.changes[changeset.raw_id].append(('changed', node, diff, cs1, cs2))

            #==================================================================
            # REMOVED FILES    
            #==================================================================
            for node in changeset.removed:
                c.changes[changeset.raw_id].append(('removed', node, None, None, None))

        if len(c.cs_ranges) == 1:
            c.changeset = c.cs_ranges[0]
            c.changes = c.changes[c.changeset.raw_id]

            return render('changeset/changeset.html')
        else:
            return render('changeset/changeset_range.html')

    def raw_changeset(self, revision):

        method = request.GET.get('diff', 'show')
        try:
            c.scm_type = c.rhodecode_repo.alias
            c.changeset = c.rhodecode_repo.get_changeset(revision)
        except RepositoryError:
            log.error(traceback.format_exc())
            return redirect(url('home'))
        else:
            try:
                c.changeset_parent = c.changeset.parents[0]
            except IndexError:
                c.changeset_parent = None
            c.changes = []

            for node in c.changeset.added:
                filenode_old = FileNode(node.path, '')
                if filenode_old.is_binary or node.is_binary:
                    diff = _('binary file') + '\n'
                else:
                    f_gitdiff = differ.get_gitdiff(filenode_old, node)
                    diff = differ.DiffProcessor(f_gitdiff).raw_diff()

                cs1 = None
                cs2 = node.last_changeset.raw_id
                c.changes.append(('added', node, diff, cs1, cs2))

            for node in c.changeset.changed:
                filenode_old = c.changeset_parent.get_node(node.path)
                if filenode_old.is_binary or node.is_binary:
                    diff = _('binary file')
                else:
                    f_gitdiff = differ.get_gitdiff(filenode_old, node)
                    diff = differ.DiffProcessor(f_gitdiff).raw_diff()

                cs1 = filenode_old.last_changeset.raw_id
                cs2 = node.last_changeset.raw_id
                c.changes.append(('changed', node, diff, cs1, cs2))

        response.content_type = 'text/plain'

        if method == 'download':
            response.content_disposition = 'attachment; filename=%s.patch' % revision

        parent = True if len(c.changeset.parents) > 0 else False
        c.parent_tmpl = 'Parent  %s' % c.changeset.parents[0].raw_id if parent else ''

        c.diffs = ''
        for x in c.changes:
            c.diffs += x[2]

        return render('changeset/raw_changeset.html')