changelog.py
214 lines
| 8.2 KiB
| text/x-python
|
PythonLexer
r861 | # -*- coding: utf-8 -*- | |||
""" | ||||
rhodecode.controllers.changelog | ||||
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ | ||||
changelog controller for rhodecode | ||||
r1130 | ||||
r861 | :created_on: Apr 21, 2010 | |||
:author: marcink | ||||
r1824 | :copyright: (C) 2010-2012 Marcin Kuzminski <marcin@python-works.com> | |||
r861 | :license: GPLv3, see COPYING for more details. | |||
""" | ||||
r1206 | # 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, either version 3 of the License, or | ||||
# (at your option) any later version. | ||||
r1203 | # | |||
r547 | # 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. | ||||
r1203 | # | |||
r547 | # You should have received a copy of the GNU General Public License | |||
r1206 | # along with this program. If not, see <http://www.gnu.org/licenses/>. | |||
r861 | ||||
import logging | ||||
r1656 | import traceback | |||
r592 | ||||
r1656 | from pylons import request, url, session, tmpl_context as c | |||
from pylons.controllers.util import redirect | ||||
from pylons.i18n.translation import _ | ||||
r3996 | from webob.exc import HTTPNotFound, HTTPBadRequest | |||
r861 | ||||
r1656 | import rhodecode.lib.helpers as h | |||
r547 | from rhodecode.lib.auth import LoginRequired, HasRepoPermissionAnyDecorator | |||
r1045 | from rhodecode.lib.base import BaseRepoController, render | |||
r1098 | from rhodecode.lib.helpers import RepoPage | |||
r1514 | from rhodecode.lib.compat import json | |||
r2380 | from rhodecode.lib.graphmod import _colored, _dagwalker | |||
r3760 | from rhodecode.lib.vcs.exceptions import RepositoryError, ChangesetDoesNotExistError,\ | |||
r3794 | ChangesetError, NodeDoesNotExistError, EmptyRepositoryError | |||
r2845 | from rhodecode.lib.utils2 import safe_int | |||
r3996 | ||||
r1656 | ||||
r547 | log = logging.getLogger(__name__) | |||
r1212 | ||||
r3764 | def _load_changelog_summary(): | |||
p = safe_int(request.GET.get('page'), 1) | ||||
size = safe_int(request.GET.get('size'), 10) | ||||
def url_generator(**kw): | ||||
return url('changelog_summary_home', | ||||
repo_name=c.rhodecode_db_repo.repo_name, size=size, **kw) | ||||
collection = c.rhodecode_repo | ||||
c.repo_changesets = RepoPage(collection, page=p, | ||||
items_per_page=size, | ||||
url=url_generator) | ||||
page_revisions = [x.raw_id for x in list(c.repo_changesets)] | ||||
c.comments = c.rhodecode_db_repo.get_comments(page_revisions) | ||||
c.statuses = c.rhodecode_db_repo.statuses(page_revisions) | ||||
r1045 | class ChangelogController(BaseRepoController): | |||
r636 | ||||
r547 | def __before__(self): | |||
super(ChangelogController, self).__before__() | ||||
r1130 | c.affected_files_cut_off = 60 | |||
r636 | ||||
r3996 | def __get_cs_or_redirect(self, rev, repo, redirect_after=True, | |||
partial=False): | ||||
""" | ||||
Safe way to get changeset if error occur it redirects to changeset with | ||||
proper message. If partial is set then don't do redirect raise Exception | ||||
instead | ||||
:param rev: revision to fetch | ||||
:param repo: repo instance | ||||
""" | ||||
try: | ||||
return c.rhodecode_repo.get_changeset(rev) | ||||
except EmptyRepositoryError, e: | ||||
if not redirect_after: | ||||
return None | ||||
h.flash(h.literal(_('There are no changesets yet')), | ||||
category='warning') | ||||
redirect(url('changelog_home', repo_name=repo.repo_name)) | ||||
except RepositoryError, e: | ||||
log.error(traceback.format_exc()) | ||||
h.flash(str(e), category='warning') | ||||
if not partial: | ||||
redirect(h.url('changelog_home', repo_name=repo.repo_name)) | ||||
raise HTTPBadRequest() | ||||
r3749 | def _graph(self, repo, revs_int, repo_size, size, p): | |||
""" | ||||
Generates a DAG graph for repo | ||||
:param repo: | ||||
:param revs_int: | ||||
:param repo_size: | ||||
:param size: | ||||
:param p: | ||||
""" | ||||
if not revs_int: | ||||
c.jsdata = json.dumps([]) | ||||
return | ||||
data = [] | ||||
revs = revs_int | ||||
dag = _dagwalker(repo, revs, repo.alias) | ||||
dag = _colored(dag) | ||||
r4036 | for (_id, _type, ctx, vtx, edges) in dag: | |||
r3749 | data.append(['', vtx, edges]) | |||
c.jsdata = json.dumps(data) | ||||
@LoginRequired() | ||||
@HasRepoPermissionAnyDecorator('repository.read', 'repository.write', | ||||
'repository.admin') | ||||
r3760 | def index(self, repo_name, revision=None, f_path=None): | |||
r547 | limit = 100 | |||
r1864 | default = 20 | |||
r3748 | if request.GET.get('size'): | |||
c.size = max(min(safe_int(request.GET.get('size')), limit), 1) | ||||
r547 | session['changelog_size'] = c.size | |||
session.save() | ||||
else: | ||||
c.size = int(session.get('changelog_size', default)) | ||||
r2628 | # min size must be 1 | |||
c.size = max(c.size, 1) | ||||
r3748 | p = safe_int(request.GET.get('page', 1), 1) | |||
branch_name = request.GET.get('branch', None) | ||||
|
r4022 | if (branch_name and | ||
branch_name not in c.rhodecode_repo.branches and | ||||
branch_name not in c.rhodecode_repo.closed_branches and | ||||
not revision): | ||||
return redirect(url('changelog_file_home', repo_name=c.repo_name, | ||||
revision=branch_name, f_path=f_path or '')) | ||||
r3760 | c.changelog_for_path = f_path | |||
r1656 | try: | |||
r3760 | ||||
if f_path: | ||||
log.debug('generating changelog for path %s' % f_path) | ||||
# get the history for the file ! | ||||
tip_cs = c.rhodecode_repo.get_changeset() | ||||
try: | ||||
collection = tip_cs.get_file_history(f_path) | ||||
except (NodeDoesNotExistError, ChangesetError): | ||||
#this node is not present at tip ! | ||||
try: | ||||
r4035 | cs = self.__get_cs_or_redirect(revision, repo_name) | |||
r3760 | collection = cs.get_file_history(f_path) | |||
except RepositoryError, e: | ||||
h.flash(str(e), category='warning') | ||||
redirect(h.url('changelog_home', repo_name=repo_name)) | ||||
collection = list(reversed(collection)) | ||||
else: | ||||
collection = c.rhodecode_repo.get_changesets(start=0, | ||||
branch_name=branch_name) | ||||
r3747 | c.total_cs = len(collection) | |||
r636 | ||||
r1656 | c.pagination = RepoPage(collection, page=p, item_count=c.total_cs, | |||
r3915 | items_per_page=c.size, branch=branch_name,) | |||
r1884 | collection = list(c.pagination) | |||
r3747 | page_revisions = [x.raw_id for x in c.pagination] | |||
r2520 | c.comments = c.rhodecode_db_repo.get_comments(page_revisions) | |||
r2215 | c.statuses = c.rhodecode_db_repo.statuses(page_revisions) | |||
r3794 | except (EmptyRepositoryError), e: | |||
h.flash(str(e), category='warning') | ||||
return redirect(url('summary_home', repo_name=c.repo_name)) | ||||
r1656 | except (RepositoryError, ChangesetDoesNotExistError, Exception), e: | |||
log.error(traceback.format_exc()) | ||||
|
r3573 | h.flash(str(e), category='error') | ||
return redirect(url('changelog_home', repo_name=c.repo_name)) | ||||
r1656 | ||||
c.branch_name = branch_name | ||||
r1884 | c.branch_filters = [('', _('All Branches'))] + \ | |||
[(k, k) for k in c.rhodecode_repo.branches.keys()] | ||||
|
r4020 | if c.rhodecode_repo.closed_branches: | ||
prefix = _('(closed)') + ' ' | ||||
c.branch_filters += [('-', '-')] + \ | ||||
[(k, prefix + k) for k in c.rhodecode_repo.closed_branches.keys()] | ||||
r3760 | _revs = [] | |||
if not f_path: | ||||
_revs = [x.revision for x in c.pagination] | ||||
self._graph(c.rhodecode_repo, _revs, c.total_cs, c.size, p) | ||||
r3747 | ||||
r547 | return render('changelog/changelog.html') | |||
r3749 | @LoginRequired() | |||
@HasRepoPermissionAnyDecorator('repository.read', 'repository.write', | ||||
'repository.admin') | ||||
r1431 | def changelog_details(self, cs): | |||
if request.environ.get('HTTP_X_PARTIAL_XHR'): | ||||
c.cs = c.rhodecode_repo.get_changeset(cs) | ||||
return render('changelog/changelog_details.html') | ||||
r3764 | raise HTTPNotFound() | |||
@LoginRequired() | ||||
@HasRepoPermissionAnyDecorator('repository.read', 'repository.write', | ||||
'repository.admin') | ||||
def changelog_summary(self, repo_name): | ||||
if request.environ.get('HTTP_X_PARTIAL_XHR'): | ||||
_load_changelog_summary() | ||||
return render('changelog/changelog_summary_data.html') | ||||
raise HTTPNotFound() | ||||