Show More
pullrequest.py
151 lines
| 5.1 KiB
| text/x-python
|
PythonLexer
r2487 | # Copyright (C) 2016-2018 RhodeCode GmbH | |||
r378 | # | |||
# This program is free software: you can redistribute it and/or modify | ||||
# it under the terms of the GNU Affero General Public License, version 3 | ||||
# (only), as published by the Free Software Foundation. | ||||
# | ||||
# 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 Affero General Public License | ||||
# along with this program. If not, see <http://www.gnu.org/licenses/>. | ||||
# | ||||
# This program is dual-licensed. If you wish to learn more about the | ||||
# RhodeCode Enterprise Edition, including its added features, Support services, | ||||
# and proprietary license terms, please see https://rhodecode.com/licenses/ | ||||
r1424 | import logging | |||
r379 | ||||
r411 | from rhodecode.translation import lazy_ugettext | |||
r514 | from rhodecode.events.repo import ( | |||
RepoEvent, _commits_as_dict, _issues_as_dict) | ||||
r378 | ||||
r1424 | log = logging.getLogger(__name__) | |||
r378 | ||||
class PullRequestEvent(RepoEvent): | ||||
""" | ||||
r379 | Base class for pull request events. | |||
r378 | ||||
r379 | :param pullrequest: a :class:`PullRequest` instance | |||
r378 | """ | |||
r379 | ||||
r378 | def __init__(self, pullrequest): | |||
super(PullRequestEvent, self).__init__(pullrequest.target_repo) | ||||
self.pullrequest = pullrequest | ||||
r411 | def as_dict(self): | |||
r2588 | from rhodecode.lib.utils2 import md5_safe | |||
r411 | from rhodecode.model.pull_request import PullRequestModel | |||
data = super(PullRequestEvent, self).as_dict() | ||||
r514 | commits = _commits_as_dict( | |||
r1789 | self, | |||
r514 | commit_ids=self.pullrequest.revisions, | |||
repos=[self.pullrequest.source_repo] | ||||
) | ||||
issues = _issues_as_dict(commits) | ||||
r2588 | # calculate hashes of all commits for unique identifier of commits | |||
# inside that pull request | ||||
commits_hash = md5_safe(':'.join(x.get('raw_id', '') for x in commits)) | ||||
r411 | ||||
data.update({ | ||||
'pullrequest': { | ||||
'title': self.pullrequest.title, | ||||
'issues': issues, | ||||
'pull_request_id': self.pullrequest.pull_request_id, | ||||
r1959 | 'url': PullRequestModel().get_url( | |||
self.pullrequest, request=self.request), | ||||
r1788 | 'permalink_url': PullRequestModel().get_url( | |||
r1959 | self.pullrequest, request=self.request, permalink=True), | |||
r2582 | 'shadow_url': PullRequestModel().get_shadow_clone_url( | |||
self.pullrequest, request=self.request), | ||||
r443 | 'status': self.pullrequest.calculated_review_status(), | |||
r2588 | 'commits_uid': commits_hash, | |||
r514 | 'commits': commits, | |||
r411 | } | |||
}) | ||||
return data | ||||
r378 | ||||
class PullRequestCreateEvent(PullRequestEvent): | ||||
""" | ||||
An instance of this class is emitted as an :term:`event` after a pull | ||||
request is created. | ||||
""" | ||||
name = 'pullrequest-create' | ||||
r411 | display_name = lazy_ugettext('pullrequest created') | |||
r378 | ||||
class PullRequestCloseEvent(PullRequestEvent): | ||||
""" | ||||
An instance of this class is emitted as an :term:`event` after a pull | ||||
request is closed. | ||||
""" | ||||
name = 'pullrequest-close' | ||||
r411 | display_name = lazy_ugettext('pullrequest closed') | |||
r378 | ||||
class PullRequestUpdateEvent(PullRequestEvent): | ||||
""" | ||||
An instance of this class is emitted as an :term:`event` after a pull | ||||
r443 | request's commits have been updated. | |||
r378 | """ | |||
name = 'pullrequest-update' | ||||
r443 | display_name = lazy_ugettext('pullrequest commits updated') | |||
class PullRequestReviewEvent(PullRequestEvent): | ||||
""" | ||||
An instance of this class is emitted as an :term:`event` after a pull | ||||
request review has changed. | ||||
""" | ||||
name = 'pullrequest-review' | ||||
display_name = lazy_ugettext('pullrequest review changed') | ||||
r378 | ||||
class PullRequestMergeEvent(PullRequestEvent): | ||||
""" | ||||
An instance of this class is emitted as an :term:`event` after a pull | ||||
request is merged. | ||||
""" | ||||
name = 'pullrequest-merge' | ||||
r411 | display_name = lazy_ugettext('pullrequest merged') | |||
r378 | ||||
r443 | class PullRequestCommentEvent(PullRequestEvent): | |||
r378 | """ | |||
An instance of this class is emitted as an :term:`event` after a pull | ||||
r443 | request comment is created. | |||
r378 | """ | |||
r443 | name = 'pullrequest-comment' | |||
display_name = lazy_ugettext('pullrequest commented') | ||||
def __init__(self, pullrequest, comment): | ||||
super(PullRequestCommentEvent, self).__init__(pullrequest) | ||||
self.comment = comment | ||||
def as_dict(self): | ||||
r1323 | from rhodecode.model.comment import CommentsModel | |||
r443 | data = super(PullRequestCommentEvent, self).as_dict() | |||
r378 | ||||
r443 | status = None | |||
if self.comment.status_change: | ||||
status = self.comment.status_change[0].status | ||||
r378 | ||||
r443 | data.update({ | |||
'comment': { | ||||
'status': status, | ||||
'text': self.comment.text, | ||||
r1467 | 'type': self.comment.comment_type, | |||
'file': self.comment.f_path, | ||||
'line': self.comment.line_no, | ||||
r1959 | 'url': CommentsModel().get_url( | |||
self.comment, request=self.request), | ||||
r1788 | 'permalink_url': CommentsModel().get_url( | |||
r1959 | self.comment, request=self.request, permalink=True), | |||
r443 | } | |||
}) | ||||
return data | ||||