##// END OF EJS Templates
api: allow updates and setting description renderer for pull requests via the API.
marcink -
r2904:930fb0cb default
parent child Browse files
Show More
@@ -1,919 +1,937 b''
1 # -*- coding: utf-8 -*-
1 # -*- coding: utf-8 -*-
2
2
3 # Copyright (C) 2011-2018 RhodeCode GmbH
3 # Copyright (C) 2011-2018 RhodeCode GmbH
4 #
4 #
5 # This program is free software: you can redistribute it and/or modify
5 # This program is free software: you can redistribute it and/or modify
6 # it under the terms of the GNU Affero General Public License, version 3
6 # it under the terms of the GNU Affero General Public License, version 3
7 # (only), as published by the Free Software Foundation.
7 # (only), as published by the Free Software Foundation.
8 #
8 #
9 # This program is distributed in the hope that it will be useful,
9 # This program is distributed in the hope that it will be useful,
10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 # GNU General Public License for more details.
12 # GNU General Public License for more details.
13 #
13 #
14 # You should have received a copy of the GNU Affero General Public License
14 # You should have received a copy of the GNU Affero General Public License
15 # along with this program. If not, see <http://www.gnu.org/licenses/>.
15 # along with this program. If not, see <http://www.gnu.org/licenses/>.
16 #
16 #
17 # This program is dual-licensed. If you wish to learn more about the
17 # This program is dual-licensed. If you wish to learn more about the
18 # RhodeCode Enterprise Edition, including its added features, Support services,
18 # RhodeCode Enterprise Edition, including its added features, Support services,
19 # and proprietary license terms, please see https://rhodecode.com/licenses/
19 # and proprietary license terms, please see https://rhodecode.com/licenses/
20
20
21
21
22 import logging
22 import logging
23
23
24 from rhodecode import events
24 from rhodecode import events
25 from rhodecode.api import jsonrpc_method, JSONRPCError, JSONRPCValidationError
25 from rhodecode.api import jsonrpc_method, JSONRPCError, JSONRPCValidationError
26 from rhodecode.api.utils import (
26 from rhodecode.api.utils import (
27 has_superadmin_permission, Optional, OAttr, get_repo_or_error,
27 has_superadmin_permission, Optional, OAttr, get_repo_or_error,
28 get_pull_request_or_error, get_commit_or_error, get_user_or_error,
28 get_pull_request_or_error, get_commit_or_error, get_user_or_error,
29 validate_repo_permissions, resolve_ref_or_error)
29 validate_repo_permissions, resolve_ref_or_error)
30 from rhodecode.lib.auth import (HasRepoPermissionAnyApi)
30 from rhodecode.lib.auth import (HasRepoPermissionAnyApi)
31 from rhodecode.lib.base import vcs_operation_context
31 from rhodecode.lib.base import vcs_operation_context
32 from rhodecode.lib.utils2 import str2bool
32 from rhodecode.lib.utils2 import str2bool
33 from rhodecode.model.changeset_status import ChangesetStatusModel
33 from rhodecode.model.changeset_status import ChangesetStatusModel
34 from rhodecode.model.comment import CommentsModel
34 from rhodecode.model.comment import CommentsModel
35 from rhodecode.model.db import Session, ChangesetStatus, ChangesetComment
35 from rhodecode.model.db import Session, ChangesetStatus, ChangesetComment
36 from rhodecode.model.pull_request import PullRequestModel, MergeCheck
36 from rhodecode.model.pull_request import PullRequestModel, MergeCheck
37 from rhodecode.model.settings import SettingsModel
37 from rhodecode.model.settings import SettingsModel
38 from rhodecode.model.validation_schema import Invalid
38 from rhodecode.model.validation_schema import Invalid
39 from rhodecode.model.validation_schema.schemas.reviewer_schema import(
39 from rhodecode.model.validation_schema.schemas.reviewer_schema import(
40 ReviewerListSchema)
40 ReviewerListSchema)
41
41
42 log = logging.getLogger(__name__)
42 log = logging.getLogger(__name__)
43
43
44
44
45 @jsonrpc_method()
45 @jsonrpc_method()
46 def get_pull_request(request, apiuser, pullrequestid, repoid=Optional(None)):
46 def get_pull_request(request, apiuser, pullrequestid, repoid=Optional(None)):
47 """
47 """
48 Get a pull request based on the given ID.
48 Get a pull request based on the given ID.
49
49
50 :param apiuser: This is filled automatically from the |authtoken|.
50 :param apiuser: This is filled automatically from the |authtoken|.
51 :type apiuser: AuthUser
51 :type apiuser: AuthUser
52 :param repoid: Optional, repository name or repository ID from where
52 :param repoid: Optional, repository name or repository ID from where
53 the pull request was opened.
53 the pull request was opened.
54 :type repoid: str or int
54 :type repoid: str or int
55 :param pullrequestid: ID of the requested pull request.
55 :param pullrequestid: ID of the requested pull request.
56 :type pullrequestid: int
56 :type pullrequestid: int
57
57
58 Example output:
58 Example output:
59
59
60 .. code-block:: bash
60 .. code-block:: bash
61
61
62 "id": <id_given_in_input>,
62 "id": <id_given_in_input>,
63 "result":
63 "result":
64 {
64 {
65 "pull_request_id": "<pull_request_id>",
65 "pull_request_id": "<pull_request_id>",
66 "url": "<url>",
66 "url": "<url>",
67 "title": "<title>",
67 "title": "<title>",
68 "description": "<description>",
68 "description": "<description>",
69 "status" : "<status>",
69 "status" : "<status>",
70 "created_on": "<date_time_created>",
70 "created_on": "<date_time_created>",
71 "updated_on": "<date_time_updated>",
71 "updated_on": "<date_time_updated>",
72 "commit_ids": [
72 "commit_ids": [
73 ...
73 ...
74 "<commit_id>",
74 "<commit_id>",
75 "<commit_id>",
75 "<commit_id>",
76 ...
76 ...
77 ],
77 ],
78 "review_status": "<review_status>",
78 "review_status": "<review_status>",
79 "mergeable": {
79 "mergeable": {
80 "status": "<bool>",
80 "status": "<bool>",
81 "message": "<message>",
81 "message": "<message>",
82 },
82 },
83 "source": {
83 "source": {
84 "clone_url": "<clone_url>",
84 "clone_url": "<clone_url>",
85 "repository": "<repository_name>",
85 "repository": "<repository_name>",
86 "reference":
86 "reference":
87 {
87 {
88 "name": "<name>",
88 "name": "<name>",
89 "type": "<type>",
89 "type": "<type>",
90 "commit_id": "<commit_id>",
90 "commit_id": "<commit_id>",
91 }
91 }
92 },
92 },
93 "target": {
93 "target": {
94 "clone_url": "<clone_url>",
94 "clone_url": "<clone_url>",
95 "repository": "<repository_name>",
95 "repository": "<repository_name>",
96 "reference":
96 "reference":
97 {
97 {
98 "name": "<name>",
98 "name": "<name>",
99 "type": "<type>",
99 "type": "<type>",
100 "commit_id": "<commit_id>",
100 "commit_id": "<commit_id>",
101 }
101 }
102 },
102 },
103 "merge": {
103 "merge": {
104 "clone_url": "<clone_url>",
104 "clone_url": "<clone_url>",
105 "reference":
105 "reference":
106 {
106 {
107 "name": "<name>",
107 "name": "<name>",
108 "type": "<type>",
108 "type": "<type>",
109 "commit_id": "<commit_id>",
109 "commit_id": "<commit_id>",
110 }
110 }
111 },
111 },
112 "author": <user_obj>,
112 "author": <user_obj>,
113 "reviewers": [
113 "reviewers": [
114 ...
114 ...
115 {
115 {
116 "user": "<user_obj>",
116 "user": "<user_obj>",
117 "review_status": "<review_status>",
117 "review_status": "<review_status>",
118 }
118 }
119 ...
119 ...
120 ]
120 ]
121 },
121 },
122 "error": null
122 "error": null
123 """
123 """
124
124
125 pull_request = get_pull_request_or_error(pullrequestid)
125 pull_request = get_pull_request_or_error(pullrequestid)
126 if Optional.extract(repoid):
126 if Optional.extract(repoid):
127 repo = get_repo_or_error(repoid)
127 repo = get_repo_or_error(repoid)
128 else:
128 else:
129 repo = pull_request.target_repo
129 repo = pull_request.target_repo
130
130
131 if not PullRequestModel().check_user_read(
131 if not PullRequestModel().check_user_read(
132 pull_request, apiuser, api=True):
132 pull_request, apiuser, api=True):
133 raise JSONRPCError('repository `%s` or pull request `%s` '
133 raise JSONRPCError('repository `%s` or pull request `%s` '
134 'does not exist' % (repoid, pullrequestid))
134 'does not exist' % (repoid, pullrequestid))
135 data = pull_request.get_api_data()
135 data = pull_request.get_api_data()
136 return data
136 return data
137
137
138
138
139 @jsonrpc_method()
139 @jsonrpc_method()
140 def get_pull_requests(request, apiuser, repoid, status=Optional('new')):
140 def get_pull_requests(request, apiuser, repoid, status=Optional('new')):
141 """
141 """
142 Get all pull requests from the repository specified in `repoid`.
142 Get all pull requests from the repository specified in `repoid`.
143
143
144 :param apiuser: This is filled automatically from the |authtoken|.
144 :param apiuser: This is filled automatically from the |authtoken|.
145 :type apiuser: AuthUser
145 :type apiuser: AuthUser
146 :param repoid: Optional repository name or repository ID.
146 :param repoid: Optional repository name or repository ID.
147 :type repoid: str or int
147 :type repoid: str or int
148 :param status: Only return pull requests with the specified status.
148 :param status: Only return pull requests with the specified status.
149 Valid options are.
149 Valid options are.
150 * ``new`` (default)
150 * ``new`` (default)
151 * ``open``
151 * ``open``
152 * ``closed``
152 * ``closed``
153 :type status: str
153 :type status: str
154
154
155 Example output:
155 Example output:
156
156
157 .. code-block:: bash
157 .. code-block:: bash
158
158
159 "id": <id_given_in_input>,
159 "id": <id_given_in_input>,
160 "result":
160 "result":
161 [
161 [
162 ...
162 ...
163 {
163 {
164 "pull_request_id": "<pull_request_id>",
164 "pull_request_id": "<pull_request_id>",
165 "url": "<url>",
165 "url": "<url>",
166 "title" : "<title>",
166 "title" : "<title>",
167 "description": "<description>",
167 "description": "<description>",
168 "status": "<status>",
168 "status": "<status>",
169 "created_on": "<date_time_created>",
169 "created_on": "<date_time_created>",
170 "updated_on": "<date_time_updated>",
170 "updated_on": "<date_time_updated>",
171 "commit_ids": [
171 "commit_ids": [
172 ...
172 ...
173 "<commit_id>",
173 "<commit_id>",
174 "<commit_id>",
174 "<commit_id>",
175 ...
175 ...
176 ],
176 ],
177 "review_status": "<review_status>",
177 "review_status": "<review_status>",
178 "mergeable": {
178 "mergeable": {
179 "status": "<bool>",
179 "status": "<bool>",
180 "message: "<message>",
180 "message: "<message>",
181 },
181 },
182 "source": {
182 "source": {
183 "clone_url": "<clone_url>",
183 "clone_url": "<clone_url>",
184 "reference":
184 "reference":
185 {
185 {
186 "name": "<name>",
186 "name": "<name>",
187 "type": "<type>",
187 "type": "<type>",
188 "commit_id": "<commit_id>",
188 "commit_id": "<commit_id>",
189 }
189 }
190 },
190 },
191 "target": {
191 "target": {
192 "clone_url": "<clone_url>",
192 "clone_url": "<clone_url>",
193 "reference":
193 "reference":
194 {
194 {
195 "name": "<name>",
195 "name": "<name>",
196 "type": "<type>",
196 "type": "<type>",
197 "commit_id": "<commit_id>",
197 "commit_id": "<commit_id>",
198 }
198 }
199 },
199 },
200 "merge": {
200 "merge": {
201 "clone_url": "<clone_url>",
201 "clone_url": "<clone_url>",
202 "reference":
202 "reference":
203 {
203 {
204 "name": "<name>",
204 "name": "<name>",
205 "type": "<type>",
205 "type": "<type>",
206 "commit_id": "<commit_id>",
206 "commit_id": "<commit_id>",
207 }
207 }
208 },
208 },
209 "author": <user_obj>,
209 "author": <user_obj>,
210 "reviewers": [
210 "reviewers": [
211 ...
211 ...
212 {
212 {
213 "user": "<user_obj>",
213 "user": "<user_obj>",
214 "review_status": "<review_status>",
214 "review_status": "<review_status>",
215 }
215 }
216 ...
216 ...
217 ]
217 ]
218 }
218 }
219 ...
219 ...
220 ],
220 ],
221 "error": null
221 "error": null
222
222
223 """
223 """
224 repo = get_repo_or_error(repoid)
224 repo = get_repo_or_error(repoid)
225 if not has_superadmin_permission(apiuser):
225 if not has_superadmin_permission(apiuser):
226 _perms = (
226 _perms = (
227 'repository.admin', 'repository.write', 'repository.read',)
227 'repository.admin', 'repository.write', 'repository.read',)
228 validate_repo_permissions(apiuser, repoid, repo, _perms)
228 validate_repo_permissions(apiuser, repoid, repo, _perms)
229
229
230 status = Optional.extract(status)
230 status = Optional.extract(status)
231 pull_requests = PullRequestModel().get_all(repo, statuses=[status])
231 pull_requests = PullRequestModel().get_all(repo, statuses=[status])
232 data = [pr.get_api_data() for pr in pull_requests]
232 data = [pr.get_api_data() for pr in pull_requests]
233 return data
233 return data
234
234
235
235
236 @jsonrpc_method()
236 @jsonrpc_method()
237 def merge_pull_request(
237 def merge_pull_request(
238 request, apiuser, pullrequestid, repoid=Optional(None),
238 request, apiuser, pullrequestid, repoid=Optional(None),
239 userid=Optional(OAttr('apiuser'))):
239 userid=Optional(OAttr('apiuser'))):
240 """
240 """
241 Merge the pull request specified by `pullrequestid` into its target
241 Merge the pull request specified by `pullrequestid` into its target
242 repository.
242 repository.
243
243
244 :param apiuser: This is filled automatically from the |authtoken|.
244 :param apiuser: This is filled automatically from the |authtoken|.
245 :type apiuser: AuthUser
245 :type apiuser: AuthUser
246 :param repoid: Optional, repository name or repository ID of the
246 :param repoid: Optional, repository name or repository ID of the
247 target repository to which the |pr| is to be merged.
247 target repository to which the |pr| is to be merged.
248 :type repoid: str or int
248 :type repoid: str or int
249 :param pullrequestid: ID of the pull request which shall be merged.
249 :param pullrequestid: ID of the pull request which shall be merged.
250 :type pullrequestid: int
250 :type pullrequestid: int
251 :param userid: Merge the pull request as this user.
251 :param userid: Merge the pull request as this user.
252 :type userid: Optional(str or int)
252 :type userid: Optional(str or int)
253
253
254 Example output:
254 Example output:
255
255
256 .. code-block:: bash
256 .. code-block:: bash
257
257
258 "id": <id_given_in_input>,
258 "id": <id_given_in_input>,
259 "result": {
259 "result": {
260 "executed": "<bool>",
260 "executed": "<bool>",
261 "failure_reason": "<int>",
261 "failure_reason": "<int>",
262 "merge_commit_id": "<merge_commit_id>",
262 "merge_commit_id": "<merge_commit_id>",
263 "possible": "<bool>",
263 "possible": "<bool>",
264 "merge_ref": {
264 "merge_ref": {
265 "commit_id": "<commit_id>",
265 "commit_id": "<commit_id>",
266 "type": "<type>",
266 "type": "<type>",
267 "name": "<name>"
267 "name": "<name>"
268 }
268 }
269 },
269 },
270 "error": null
270 "error": null
271 """
271 """
272 pull_request = get_pull_request_or_error(pullrequestid)
272 pull_request = get_pull_request_or_error(pullrequestid)
273 if Optional.extract(repoid):
273 if Optional.extract(repoid):
274 repo = get_repo_or_error(repoid)
274 repo = get_repo_or_error(repoid)
275 else:
275 else:
276 repo = pull_request.target_repo
276 repo = pull_request.target_repo
277
277
278 if not isinstance(userid, Optional):
278 if not isinstance(userid, Optional):
279 if (has_superadmin_permission(apiuser) or
279 if (has_superadmin_permission(apiuser) or
280 HasRepoPermissionAnyApi('repository.admin')(
280 HasRepoPermissionAnyApi('repository.admin')(
281 user=apiuser, repo_name=repo.repo_name)):
281 user=apiuser, repo_name=repo.repo_name)):
282 apiuser = get_user_or_error(userid)
282 apiuser = get_user_or_error(userid)
283 else:
283 else:
284 raise JSONRPCError('userid is not the same as your user')
284 raise JSONRPCError('userid is not the same as your user')
285
285
286 check = MergeCheck.validate(
286 check = MergeCheck.validate(
287 pull_request, user=apiuser, translator=request.translate)
287 pull_request, user=apiuser, translator=request.translate)
288 merge_possible = not check.failed
288 merge_possible = not check.failed
289
289
290 if not merge_possible:
290 if not merge_possible:
291 error_messages = []
291 error_messages = []
292 for err_type, error_msg in check.errors:
292 for err_type, error_msg in check.errors:
293 error_msg = request.translate(error_msg)
293 error_msg = request.translate(error_msg)
294 error_messages.append(error_msg)
294 error_messages.append(error_msg)
295
295
296 reasons = ','.join(error_messages)
296 reasons = ','.join(error_messages)
297 raise JSONRPCError(
297 raise JSONRPCError(
298 'merge not possible for following reasons: {}'.format(reasons))
298 'merge not possible for following reasons: {}'.format(reasons))
299
299
300 target_repo = pull_request.target_repo
300 target_repo = pull_request.target_repo
301 extras = vcs_operation_context(
301 extras = vcs_operation_context(
302 request.environ, repo_name=target_repo.repo_name,
302 request.environ, repo_name=target_repo.repo_name,
303 username=apiuser.username, action='push',
303 username=apiuser.username, action='push',
304 scm=target_repo.repo_type)
304 scm=target_repo.repo_type)
305 merge_response = PullRequestModel().merge_repo(
305 merge_response = PullRequestModel().merge_repo(
306 pull_request, apiuser, extras=extras)
306 pull_request, apiuser, extras=extras)
307 if merge_response.executed:
307 if merge_response.executed:
308 PullRequestModel().close_pull_request(
308 PullRequestModel().close_pull_request(
309 pull_request.pull_request_id, apiuser)
309 pull_request.pull_request_id, apiuser)
310
310
311 Session().commit()
311 Session().commit()
312
312
313 # In previous versions the merge response directly contained the merge
313 # In previous versions the merge response directly contained the merge
314 # commit id. It is now contained in the merge reference object. To be
314 # commit id. It is now contained in the merge reference object. To be
315 # backwards compatible we have to extract it again.
315 # backwards compatible we have to extract it again.
316 merge_response = merge_response._asdict()
316 merge_response = merge_response._asdict()
317 merge_response['merge_commit_id'] = merge_response['merge_ref'].commit_id
317 merge_response['merge_commit_id'] = merge_response['merge_ref'].commit_id
318
318
319 return merge_response
319 return merge_response
320
320
321
321
322 @jsonrpc_method()
322 @jsonrpc_method()
323 def get_pull_request_comments(
323 def get_pull_request_comments(
324 request, apiuser, pullrequestid, repoid=Optional(None)):
324 request, apiuser, pullrequestid, repoid=Optional(None)):
325 """
325 """
326 Get all comments of pull request specified with the `pullrequestid`
326 Get all comments of pull request specified with the `pullrequestid`
327
327
328 :param apiuser: This is filled automatically from the |authtoken|.
328 :param apiuser: This is filled automatically from the |authtoken|.
329 :type apiuser: AuthUser
329 :type apiuser: AuthUser
330 :param repoid: Optional repository name or repository ID.
330 :param repoid: Optional repository name or repository ID.
331 :type repoid: str or int
331 :type repoid: str or int
332 :param pullrequestid: The pull request ID.
332 :param pullrequestid: The pull request ID.
333 :type pullrequestid: int
333 :type pullrequestid: int
334
334
335 Example output:
335 Example output:
336
336
337 .. code-block:: bash
337 .. code-block:: bash
338
338
339 id : <id_given_in_input>
339 id : <id_given_in_input>
340 result : [
340 result : [
341 {
341 {
342 "comment_author": {
342 "comment_author": {
343 "active": true,
343 "active": true,
344 "full_name_or_username": "Tom Gore",
344 "full_name_or_username": "Tom Gore",
345 "username": "admin"
345 "username": "admin"
346 },
346 },
347 "comment_created_on": "2017-01-02T18:43:45.533",
347 "comment_created_on": "2017-01-02T18:43:45.533",
348 "comment_f_path": null,
348 "comment_f_path": null,
349 "comment_id": 25,
349 "comment_id": 25,
350 "comment_lineno": null,
350 "comment_lineno": null,
351 "comment_status": {
351 "comment_status": {
352 "status": "under_review",
352 "status": "under_review",
353 "status_lbl": "Under Review"
353 "status_lbl": "Under Review"
354 },
354 },
355 "comment_text": "Example text",
355 "comment_text": "Example text",
356 "comment_type": null,
356 "comment_type": null,
357 "pull_request_version": null
357 "pull_request_version": null
358 }
358 }
359 ],
359 ],
360 error : null
360 error : null
361 """
361 """
362
362
363 pull_request = get_pull_request_or_error(pullrequestid)
363 pull_request = get_pull_request_or_error(pullrequestid)
364 if Optional.extract(repoid):
364 if Optional.extract(repoid):
365 repo = get_repo_or_error(repoid)
365 repo = get_repo_or_error(repoid)
366 else:
366 else:
367 repo = pull_request.target_repo
367 repo = pull_request.target_repo
368
368
369 if not PullRequestModel().check_user_read(
369 if not PullRequestModel().check_user_read(
370 pull_request, apiuser, api=True):
370 pull_request, apiuser, api=True):
371 raise JSONRPCError('repository `%s` or pull request `%s` '
371 raise JSONRPCError('repository `%s` or pull request `%s` '
372 'does not exist' % (repoid, pullrequestid))
372 'does not exist' % (repoid, pullrequestid))
373
373
374 (pull_request_latest,
374 (pull_request_latest,
375 pull_request_at_ver,
375 pull_request_at_ver,
376 pull_request_display_obj,
376 pull_request_display_obj,
377 at_version) = PullRequestModel().get_pr_version(
377 at_version) = PullRequestModel().get_pr_version(
378 pull_request.pull_request_id, version=None)
378 pull_request.pull_request_id, version=None)
379
379
380 versions = pull_request_display_obj.versions()
380 versions = pull_request_display_obj.versions()
381 ver_map = {
381 ver_map = {
382 ver.pull_request_version_id: cnt
382 ver.pull_request_version_id: cnt
383 for cnt, ver in enumerate(versions, 1)
383 for cnt, ver in enumerate(versions, 1)
384 }
384 }
385
385
386 # GENERAL COMMENTS with versions #
386 # GENERAL COMMENTS with versions #
387 q = CommentsModel()._all_general_comments_of_pull_request(pull_request)
387 q = CommentsModel()._all_general_comments_of_pull_request(pull_request)
388 q = q.order_by(ChangesetComment.comment_id.asc())
388 q = q.order_by(ChangesetComment.comment_id.asc())
389 general_comments = q.all()
389 general_comments = q.all()
390
390
391 # INLINE COMMENTS with versions #
391 # INLINE COMMENTS with versions #
392 q = CommentsModel()._all_inline_comments_of_pull_request(pull_request)
392 q = CommentsModel()._all_inline_comments_of_pull_request(pull_request)
393 q = q.order_by(ChangesetComment.comment_id.asc())
393 q = q.order_by(ChangesetComment.comment_id.asc())
394 inline_comments = q.all()
394 inline_comments = q.all()
395
395
396 data = []
396 data = []
397 for comment in inline_comments + general_comments:
397 for comment in inline_comments + general_comments:
398 full_data = comment.get_api_data()
398 full_data = comment.get_api_data()
399 pr_version_id = None
399 pr_version_id = None
400 if comment.pull_request_version_id:
400 if comment.pull_request_version_id:
401 pr_version_id = 'v{}'.format(
401 pr_version_id = 'v{}'.format(
402 ver_map[comment.pull_request_version_id])
402 ver_map[comment.pull_request_version_id])
403
403
404 # sanitize some entries
404 # sanitize some entries
405
405
406 full_data['pull_request_version'] = pr_version_id
406 full_data['pull_request_version'] = pr_version_id
407 full_data['comment_author'] = {
407 full_data['comment_author'] = {
408 'username': full_data['comment_author'].username,
408 'username': full_data['comment_author'].username,
409 'full_name_or_username': full_data['comment_author'].full_name_or_username,
409 'full_name_or_username': full_data['comment_author'].full_name_or_username,
410 'active': full_data['comment_author'].active,
410 'active': full_data['comment_author'].active,
411 }
411 }
412
412
413 if full_data['comment_status']:
413 if full_data['comment_status']:
414 full_data['comment_status'] = {
414 full_data['comment_status'] = {
415 'status': full_data['comment_status'][0].status,
415 'status': full_data['comment_status'][0].status,
416 'status_lbl': full_data['comment_status'][0].status_lbl,
416 'status_lbl': full_data['comment_status'][0].status_lbl,
417 }
417 }
418 else:
418 else:
419 full_data['comment_status'] = {}
419 full_data['comment_status'] = {}
420
420
421 data.append(full_data)
421 data.append(full_data)
422 return data
422 return data
423
423
424
424
425 @jsonrpc_method()
425 @jsonrpc_method()
426 def comment_pull_request(
426 def comment_pull_request(
427 request, apiuser, pullrequestid, repoid=Optional(None),
427 request, apiuser, pullrequestid, repoid=Optional(None),
428 message=Optional(None), commit_id=Optional(None), status=Optional(None),
428 message=Optional(None), commit_id=Optional(None), status=Optional(None),
429 comment_type=Optional(ChangesetComment.COMMENT_TYPE_NOTE),
429 comment_type=Optional(ChangesetComment.COMMENT_TYPE_NOTE),
430 resolves_comment_id=Optional(None),
430 resolves_comment_id=Optional(None),
431 userid=Optional(OAttr('apiuser'))):
431 userid=Optional(OAttr('apiuser'))):
432 """
432 """
433 Comment on the pull request specified with the `pullrequestid`,
433 Comment on the pull request specified with the `pullrequestid`,
434 in the |repo| specified by the `repoid`, and optionally change the
434 in the |repo| specified by the `repoid`, and optionally change the
435 review status.
435 review status.
436
436
437 :param apiuser: This is filled automatically from the |authtoken|.
437 :param apiuser: This is filled automatically from the |authtoken|.
438 :type apiuser: AuthUser
438 :type apiuser: AuthUser
439 :param repoid: Optional repository name or repository ID.
439 :param repoid: Optional repository name or repository ID.
440 :type repoid: str or int
440 :type repoid: str or int
441 :param pullrequestid: The pull request ID.
441 :param pullrequestid: The pull request ID.
442 :type pullrequestid: int
442 :type pullrequestid: int
443 :param commit_id: Specify the commit_id for which to set a comment. If
443 :param commit_id: Specify the commit_id for which to set a comment. If
444 given commit_id is different than latest in the PR status
444 given commit_id is different than latest in the PR status
445 change won't be performed.
445 change won't be performed.
446 :type commit_id: str
446 :type commit_id: str
447 :param message: The text content of the comment.
447 :param message: The text content of the comment.
448 :type message: str
448 :type message: str
449 :param status: (**Optional**) Set the approval status of the pull
449 :param status: (**Optional**) Set the approval status of the pull
450 request. One of: 'not_reviewed', 'approved', 'rejected',
450 request. One of: 'not_reviewed', 'approved', 'rejected',
451 'under_review'
451 'under_review'
452 :type status: str
452 :type status: str
453 :param comment_type: Comment type, one of: 'note', 'todo'
453 :param comment_type: Comment type, one of: 'note', 'todo'
454 :type comment_type: Optional(str), default: 'note'
454 :type comment_type: Optional(str), default: 'note'
455 :param userid: Comment on the pull request as this user
455 :param userid: Comment on the pull request as this user
456 :type userid: Optional(str or int)
456 :type userid: Optional(str or int)
457
457
458 Example output:
458 Example output:
459
459
460 .. code-block:: bash
460 .. code-block:: bash
461
461
462 id : <id_given_in_input>
462 id : <id_given_in_input>
463 result : {
463 result : {
464 "pull_request_id": "<Integer>",
464 "pull_request_id": "<Integer>",
465 "comment_id": "<Integer>",
465 "comment_id": "<Integer>",
466 "status": {"given": <given_status>,
466 "status": {"given": <given_status>,
467 "was_changed": <bool status_was_actually_changed> },
467 "was_changed": <bool status_was_actually_changed> },
468 },
468 },
469 error : null
469 error : null
470 """
470 """
471 pull_request = get_pull_request_or_error(pullrequestid)
471 pull_request = get_pull_request_or_error(pullrequestid)
472 if Optional.extract(repoid):
472 if Optional.extract(repoid):
473 repo = get_repo_or_error(repoid)
473 repo = get_repo_or_error(repoid)
474 else:
474 else:
475 repo = pull_request.target_repo
475 repo = pull_request.target_repo
476
476
477 if not isinstance(userid, Optional):
477 if not isinstance(userid, Optional):
478 if (has_superadmin_permission(apiuser) or
478 if (has_superadmin_permission(apiuser) or
479 HasRepoPermissionAnyApi('repository.admin')(
479 HasRepoPermissionAnyApi('repository.admin')(
480 user=apiuser, repo_name=repo.repo_name)):
480 user=apiuser, repo_name=repo.repo_name)):
481 apiuser = get_user_or_error(userid)
481 apiuser = get_user_or_error(userid)
482 else:
482 else:
483 raise JSONRPCError('userid is not the same as your user')
483 raise JSONRPCError('userid is not the same as your user')
484
484
485 if not PullRequestModel().check_user_read(
485 if not PullRequestModel().check_user_read(
486 pull_request, apiuser, api=True):
486 pull_request, apiuser, api=True):
487 raise JSONRPCError('repository `%s` does not exist' % (repoid,))
487 raise JSONRPCError('repository `%s` does not exist' % (repoid,))
488 message = Optional.extract(message)
488 message = Optional.extract(message)
489 status = Optional.extract(status)
489 status = Optional.extract(status)
490 commit_id = Optional.extract(commit_id)
490 commit_id = Optional.extract(commit_id)
491 comment_type = Optional.extract(comment_type)
491 comment_type = Optional.extract(comment_type)
492 resolves_comment_id = Optional.extract(resolves_comment_id)
492 resolves_comment_id = Optional.extract(resolves_comment_id)
493
493
494 if not message and not status:
494 if not message and not status:
495 raise JSONRPCError(
495 raise JSONRPCError(
496 'Both message and status parameters are missing. '
496 'Both message and status parameters are missing. '
497 'At least one is required.')
497 'At least one is required.')
498
498
499 if (status not in (st[0] for st in ChangesetStatus.STATUSES) and
499 if (status not in (st[0] for st in ChangesetStatus.STATUSES) and
500 status is not None):
500 status is not None):
501 raise JSONRPCError('Unknown comment status: `%s`' % status)
501 raise JSONRPCError('Unknown comment status: `%s`' % status)
502
502
503 if commit_id and commit_id not in pull_request.revisions:
503 if commit_id and commit_id not in pull_request.revisions:
504 raise JSONRPCError(
504 raise JSONRPCError(
505 'Invalid commit_id `%s` for this pull request.' % commit_id)
505 'Invalid commit_id `%s` for this pull request.' % commit_id)
506
506
507 allowed_to_change_status = PullRequestModel().check_user_change_status(
507 allowed_to_change_status = PullRequestModel().check_user_change_status(
508 pull_request, apiuser)
508 pull_request, apiuser)
509
509
510 # if commit_id is passed re-validated if user is allowed to change status
510 # if commit_id is passed re-validated if user is allowed to change status
511 # based on latest commit_id from the PR
511 # based on latest commit_id from the PR
512 if commit_id:
512 if commit_id:
513 commit_idx = pull_request.revisions.index(commit_id)
513 commit_idx = pull_request.revisions.index(commit_id)
514 if commit_idx != 0:
514 if commit_idx != 0:
515 allowed_to_change_status = False
515 allowed_to_change_status = False
516
516
517 if resolves_comment_id:
517 if resolves_comment_id:
518 comment = ChangesetComment.get(resolves_comment_id)
518 comment = ChangesetComment.get(resolves_comment_id)
519 if not comment:
519 if not comment:
520 raise JSONRPCError(
520 raise JSONRPCError(
521 'Invalid resolves_comment_id `%s` for this pull request.'
521 'Invalid resolves_comment_id `%s` for this pull request.'
522 % resolves_comment_id)
522 % resolves_comment_id)
523 if comment.comment_type != ChangesetComment.COMMENT_TYPE_TODO:
523 if comment.comment_type != ChangesetComment.COMMENT_TYPE_TODO:
524 raise JSONRPCError(
524 raise JSONRPCError(
525 'Comment `%s` is wrong type for setting status to resolved.'
525 'Comment `%s` is wrong type for setting status to resolved.'
526 % resolves_comment_id)
526 % resolves_comment_id)
527
527
528 text = message
528 text = message
529 status_label = ChangesetStatus.get_status_lbl(status)
529 status_label = ChangesetStatus.get_status_lbl(status)
530 if status and allowed_to_change_status:
530 if status and allowed_to_change_status:
531 st_message = ('Status change %(transition_icon)s %(status)s'
531 st_message = ('Status change %(transition_icon)s %(status)s'
532 % {'transition_icon': '>', 'status': status_label})
532 % {'transition_icon': '>', 'status': status_label})
533 text = message or st_message
533 text = message or st_message
534
534
535 rc_config = SettingsModel().get_all_settings()
535 rc_config = SettingsModel().get_all_settings()
536 renderer = rc_config.get('rhodecode_markup_renderer', 'rst')
536 renderer = rc_config.get('rhodecode_markup_renderer', 'rst')
537
537
538 status_change = status and allowed_to_change_status
538 status_change = status and allowed_to_change_status
539 comment = CommentsModel().create(
539 comment = CommentsModel().create(
540 text=text,
540 text=text,
541 repo=pull_request.target_repo.repo_id,
541 repo=pull_request.target_repo.repo_id,
542 user=apiuser.user_id,
542 user=apiuser.user_id,
543 pull_request=pull_request.pull_request_id,
543 pull_request=pull_request.pull_request_id,
544 f_path=None,
544 f_path=None,
545 line_no=None,
545 line_no=None,
546 status_change=(status_label if status_change else None),
546 status_change=(status_label if status_change else None),
547 status_change_type=(status if status_change else None),
547 status_change_type=(status if status_change else None),
548 closing_pr=False,
548 closing_pr=False,
549 renderer=renderer,
549 renderer=renderer,
550 comment_type=comment_type,
550 comment_type=comment_type,
551 resolves_comment_id=resolves_comment_id,
551 resolves_comment_id=resolves_comment_id,
552 auth_user=apiuser
552 auth_user=apiuser
553 )
553 )
554
554
555 if allowed_to_change_status and status:
555 if allowed_to_change_status and status:
556 ChangesetStatusModel().set_status(
556 ChangesetStatusModel().set_status(
557 pull_request.target_repo.repo_id,
557 pull_request.target_repo.repo_id,
558 status,
558 status,
559 apiuser.user_id,
559 apiuser.user_id,
560 comment,
560 comment,
561 pull_request=pull_request.pull_request_id
561 pull_request=pull_request.pull_request_id
562 )
562 )
563 Session().flush()
563 Session().flush()
564
564
565 Session().commit()
565 Session().commit()
566 data = {
566 data = {
567 'pull_request_id': pull_request.pull_request_id,
567 'pull_request_id': pull_request.pull_request_id,
568 'comment_id': comment.comment_id if comment else None,
568 'comment_id': comment.comment_id if comment else None,
569 'status': {'given': status, 'was_changed': status_change},
569 'status': {'given': status, 'was_changed': status_change},
570 }
570 }
571 return data
571 return data
572
572
573
573
574 @jsonrpc_method()
574 @jsonrpc_method()
575 def create_pull_request(
575 def create_pull_request(
576 request, apiuser, source_repo, target_repo, source_ref, target_ref,
576 request, apiuser, source_repo, target_repo, source_ref, target_ref,
577 title=Optional(''), description=Optional(''), reviewers=Optional(None)):
577 title=Optional(''), description=Optional(''), description_renderer=Optional(''),
578 reviewers=Optional(None)):
578 """
579 """
579 Creates a new pull request.
580 Creates a new pull request.
580
581
581 Accepts refs in the following formats:
582 Accepts refs in the following formats:
582
583
583 * branch:<branch_name>:<sha>
584 * branch:<branch_name>:<sha>
584 * branch:<branch_name>
585 * branch:<branch_name>
585 * bookmark:<bookmark_name>:<sha> (Mercurial only)
586 * bookmark:<bookmark_name>:<sha> (Mercurial only)
586 * bookmark:<bookmark_name> (Mercurial only)
587 * bookmark:<bookmark_name> (Mercurial only)
587
588
588 :param apiuser: This is filled automatically from the |authtoken|.
589 :param apiuser: This is filled automatically from the |authtoken|.
589 :type apiuser: AuthUser
590 :type apiuser: AuthUser
590 :param source_repo: Set the source repository name.
591 :param source_repo: Set the source repository name.
591 :type source_repo: str
592 :type source_repo: str
592 :param target_repo: Set the target repository name.
593 :param target_repo: Set the target repository name.
593 :type target_repo: str
594 :type target_repo: str
594 :param source_ref: Set the source ref name.
595 :param source_ref: Set the source ref name.
595 :type source_ref: str
596 :type source_ref: str
596 :param target_ref: Set the target ref name.
597 :param target_ref: Set the target ref name.
597 :type target_ref: str
598 :type target_ref: str
598 :param title: Optionally Set the pull request title, it's generated otherwise
599 :param title: Optionally Set the pull request title, it's generated otherwise
599 :type title: str
600 :type title: str
600 :param description: Set the pull request description.
601 :param description: Set the pull request description.
601 :type description: Optional(str)
602 :type description: Optional(str)
603 :type description_renderer: Optional(str)
604 :param description_renderer: Set pull request renderer for the description.
605 It should be 'rst', 'markdown' or 'plain'. If not give default
606 system renderer will be used
602 :param reviewers: Set the new pull request reviewers list.
607 :param reviewers: Set the new pull request reviewers list.
603 Reviewer defined by review rules will be added automatically to the
608 Reviewer defined by review rules will be added automatically to the
604 defined list.
609 defined list.
605 :type reviewers: Optional(list)
610 :type reviewers: Optional(list)
606 Accepts username strings or objects of the format:
611 Accepts username strings or objects of the format:
607
612
608 [{'username': 'nick', 'reasons': ['original author'], 'mandatory': <bool>}]
613 [{'username': 'nick', 'reasons': ['original author'], 'mandatory': <bool>}]
609 """
614 """
610
615
611 source_db_repo = get_repo_or_error(source_repo)
616 source_db_repo = get_repo_or_error(source_repo)
612 target_db_repo = get_repo_or_error(target_repo)
617 target_db_repo = get_repo_or_error(target_repo)
613 if not has_superadmin_permission(apiuser):
618 if not has_superadmin_permission(apiuser):
614 _perms = ('repository.admin', 'repository.write', 'repository.read',)
619 _perms = ('repository.admin', 'repository.write', 'repository.read',)
615 validate_repo_permissions(apiuser, source_repo, source_db_repo, _perms)
620 validate_repo_permissions(apiuser, source_repo, source_db_repo, _perms)
616
621
617 full_source_ref = resolve_ref_or_error(source_ref, source_db_repo)
622 full_source_ref = resolve_ref_or_error(source_ref, source_db_repo)
618 full_target_ref = resolve_ref_or_error(target_ref, target_db_repo)
623 full_target_ref = resolve_ref_or_error(target_ref, target_db_repo)
619
624
620 source_scm = source_db_repo.scm_instance()
625 source_scm = source_db_repo.scm_instance()
621 target_scm = target_db_repo.scm_instance()
626 target_scm = target_db_repo.scm_instance()
622
627
623 source_commit = get_commit_or_error(full_source_ref, source_db_repo)
628 source_commit = get_commit_or_error(full_source_ref, source_db_repo)
624 target_commit = get_commit_or_error(full_target_ref, target_db_repo)
629 target_commit = get_commit_or_error(full_target_ref, target_db_repo)
625
630
626 ancestor = source_scm.get_common_ancestor(
631 ancestor = source_scm.get_common_ancestor(
627 source_commit.raw_id, target_commit.raw_id, target_scm)
632 source_commit.raw_id, target_commit.raw_id, target_scm)
628 if not ancestor:
633 if not ancestor:
629 raise JSONRPCError('no common ancestor found')
634 raise JSONRPCError('no common ancestor found')
630
635
631 # recalculate target ref based on ancestor
636 # recalculate target ref based on ancestor
632 target_ref_type, target_ref_name, __ = full_target_ref.split(':')
637 target_ref_type, target_ref_name, __ = full_target_ref.split(':')
633 full_target_ref = ':'.join((target_ref_type, target_ref_name, ancestor))
638 full_target_ref = ':'.join((target_ref_type, target_ref_name, ancestor))
634
639
635 commit_ranges = target_scm.compare(
640 commit_ranges = target_scm.compare(
636 target_commit.raw_id, source_commit.raw_id, source_scm,
641 target_commit.raw_id, source_commit.raw_id, source_scm,
637 merge=True, pre_load=[])
642 merge=True, pre_load=[])
638
643
639 if not commit_ranges:
644 if not commit_ranges:
640 raise JSONRPCError('no commits found')
645 raise JSONRPCError('no commits found')
641
646
642 reviewer_objects = Optional.extract(reviewers) or []
647 reviewer_objects = Optional.extract(reviewers) or []
643
648
644 # serialize and validate passed in given reviewers
649 # serialize and validate passed in given reviewers
645 if reviewer_objects:
650 if reviewer_objects:
646 schema = ReviewerListSchema()
651 schema = ReviewerListSchema()
647 try:
652 try:
648 reviewer_objects = schema.deserialize(reviewer_objects)
653 reviewer_objects = schema.deserialize(reviewer_objects)
649 except Invalid as err:
654 except Invalid as err:
650 raise JSONRPCValidationError(colander_exc=err)
655 raise JSONRPCValidationError(colander_exc=err)
651
656
652 # validate users
657 # validate users
653 for reviewer_object in reviewer_objects:
658 for reviewer_object in reviewer_objects:
654 user = get_user_or_error(reviewer_object['username'])
659 user = get_user_or_error(reviewer_object['username'])
655 reviewer_object['user_id'] = user.user_id
660 reviewer_object['user_id'] = user.user_id
656
661
657 get_default_reviewers_data, validate_default_reviewers = \
662 get_default_reviewers_data, validate_default_reviewers = \
658 PullRequestModel().get_reviewer_functions()
663 PullRequestModel().get_reviewer_functions()
659
664
660 # recalculate reviewers logic, to make sure we can validate this
665 # recalculate reviewers logic, to make sure we can validate this
661 reviewer_rules = get_default_reviewers_data(
666 reviewer_rules = get_default_reviewers_data(
662 apiuser.get_instance(), source_db_repo,
667 apiuser.get_instance(), source_db_repo,
663 source_commit, target_db_repo, target_commit)
668 source_commit, target_db_repo, target_commit)
664
669
665 # now MERGE our given with the calculated
670 # now MERGE our given with the calculated
666 reviewer_objects = reviewer_rules['reviewers'] + reviewer_objects
671 reviewer_objects = reviewer_rules['reviewers'] + reviewer_objects
667
672
668 try:
673 try:
669 reviewers = validate_default_reviewers(
674 reviewers = validate_default_reviewers(
670 reviewer_objects, reviewer_rules)
675 reviewer_objects, reviewer_rules)
671 except ValueError as e:
676 except ValueError as e:
672 raise JSONRPCError('Reviewers Validation: {}'.format(e))
677 raise JSONRPCError('Reviewers Validation: {}'.format(e))
673
678
674 title = Optional.extract(title)
679 title = Optional.extract(title)
675 if not title:
680 if not title:
676 title_source_ref = source_ref.split(':', 2)[1]
681 title_source_ref = source_ref.split(':', 2)[1]
677 title = PullRequestModel().generate_pullrequest_title(
682 title = PullRequestModel().generate_pullrequest_title(
678 source=source_repo,
683 source=source_repo,
679 source_ref=title_source_ref,
684 source_ref=title_source_ref,
680 target=target_repo
685 target=target_repo
681 )
686 )
687 # fetch renderer, if set fallback to plain in case of PR
688 rc_config = SettingsModel().get_all_settings()
689 default_system_renderer = rc_config.get('rhodecode_markup_renderer', 'plain')
682 description = Optional.extract(description)
690 description = Optional.extract(description)
691 description_renderer = Optional.extract(description_renderer) or default_system_renderer
683
692
684 pull_request = PullRequestModel().create(
693 pull_request = PullRequestModel().create(
685 created_by=apiuser.user_id,
694 created_by=apiuser.user_id,
686 source_repo=source_repo,
695 source_repo=source_repo,
687 source_ref=full_source_ref,
696 source_ref=full_source_ref,
688 target_repo=target_repo,
697 target_repo=target_repo,
689 target_ref=full_target_ref,
698 target_ref=full_target_ref,
690 revisions=[commit.raw_id for commit in reversed(commit_ranges)],
699 revisions=[commit.raw_id for commit in reversed(commit_ranges)],
691 reviewers=reviewers,
700 reviewers=reviewers,
692 title=title,
701 title=title,
693 description=description,
702 description=description,
703 description_renderer=description_renderer,
694 reviewer_data=reviewer_rules,
704 reviewer_data=reviewer_rules,
695 auth_user=apiuser
705 auth_user=apiuser
696 )
706 )
697
707
698 Session().commit()
708 Session().commit()
699 data = {
709 data = {
700 'msg': 'Created new pull request `{}`'.format(title),
710 'msg': 'Created new pull request `{}`'.format(title),
701 'pull_request_id': pull_request.pull_request_id,
711 'pull_request_id': pull_request.pull_request_id,
702 }
712 }
703 return data
713 return data
704
714
705
715
706 @jsonrpc_method()
716 @jsonrpc_method()
707 def update_pull_request(
717 def update_pull_request(
708 request, apiuser, pullrequestid, repoid=Optional(None),
718 request, apiuser, pullrequestid, repoid=Optional(None),
709 title=Optional(''), description=Optional(''), reviewers=Optional(None),
719 title=Optional(''), description=Optional(''), description_renderer=Optional(''),
710 update_commits=Optional(None)):
720 reviewers=Optional(None), update_commits=Optional(None)):
711 """
721 """
712 Updates a pull request.
722 Updates a pull request.
713
723
714 :param apiuser: This is filled automatically from the |authtoken|.
724 :param apiuser: This is filled automatically from the |authtoken|.
715 :type apiuser: AuthUser
725 :type apiuser: AuthUser
716 :param repoid: Optional repository name or repository ID.
726 :param repoid: Optional repository name or repository ID.
717 :type repoid: str or int
727 :type repoid: str or int
718 :param pullrequestid: The pull request ID.
728 :param pullrequestid: The pull request ID.
719 :type pullrequestid: int
729 :type pullrequestid: int
720 :param title: Set the pull request title.
730 :param title: Set the pull request title.
721 :type title: str
731 :type title: str
722 :param description: Update pull request description.
732 :param description: Update pull request description.
723 :type description: Optional(str)
733 :type description: Optional(str)
734 :type description_renderer: Optional(str)
735 :param description_renderer: Update pull request renderer for the description.
736 It should be 'rst', 'markdown' or 'plain'
724 :param reviewers: Update pull request reviewers list with new value.
737 :param reviewers: Update pull request reviewers list with new value.
725 :type reviewers: Optional(list)
738 :type reviewers: Optional(list)
726 Accepts username strings or objects of the format:
739 Accepts username strings or objects of the format:
727
740
728 [{'username': 'nick', 'reasons': ['original author'], 'mandatory': <bool>}]
741 [{'username': 'nick', 'reasons': ['original author'], 'mandatory': <bool>}]
729
742
730 :param update_commits: Trigger update of commits for this pull request
743 :param update_commits: Trigger update of commits for this pull request
731 :type: update_commits: Optional(bool)
744 :type: update_commits: Optional(bool)
732
745
733 Example output:
746 Example output:
734
747
735 .. code-block:: bash
748 .. code-block:: bash
736
749
737 id : <id_given_in_input>
750 id : <id_given_in_input>
738 result : {
751 result : {
739 "msg": "Updated pull request `63`",
752 "msg": "Updated pull request `63`",
740 "pull_request": <pull_request_object>,
753 "pull_request": <pull_request_object>,
741 "updated_reviewers": {
754 "updated_reviewers": {
742 "added": [
755 "added": [
743 "username"
756 "username"
744 ],
757 ],
745 "removed": []
758 "removed": []
746 },
759 },
747 "updated_commits": {
760 "updated_commits": {
748 "added": [
761 "added": [
749 "<sha1_hash>"
762 "<sha1_hash>"
750 ],
763 ],
751 "common": [
764 "common": [
752 "<sha1_hash>",
765 "<sha1_hash>",
753 "<sha1_hash>",
766 "<sha1_hash>",
754 ],
767 ],
755 "removed": []
768 "removed": []
756 }
769 }
757 }
770 }
758 error : null
771 error : null
759 """
772 """
760
773
761 pull_request = get_pull_request_or_error(pullrequestid)
774 pull_request = get_pull_request_or_error(pullrequestid)
762 if Optional.extract(repoid):
775 if Optional.extract(repoid):
763 repo = get_repo_or_error(repoid)
776 repo = get_repo_or_error(repoid)
764 else:
777 else:
765 repo = pull_request.target_repo
778 repo = pull_request.target_repo
766
779
767 if not PullRequestModel().check_user_update(
780 if not PullRequestModel().check_user_update(
768 pull_request, apiuser, api=True):
781 pull_request, apiuser, api=True):
769 raise JSONRPCError(
782 raise JSONRPCError(
770 'pull request `%s` update failed, no permission to update.' % (
783 'pull request `%s` update failed, no permission to update.' % (
771 pullrequestid,))
784 pullrequestid,))
772 if pull_request.is_closed():
785 if pull_request.is_closed():
773 raise JSONRPCError(
786 raise JSONRPCError(
774 'pull request `%s` update failed, pull request is closed' % (
787 'pull request `%s` update failed, pull request is closed' % (
775 pullrequestid,))
788 pullrequestid,))
776
789
777 reviewer_objects = Optional.extract(reviewers) or []
790 reviewer_objects = Optional.extract(reviewers) or []
778
791
779 if reviewer_objects:
792 if reviewer_objects:
780 schema = ReviewerListSchema()
793 schema = ReviewerListSchema()
781 try:
794 try:
782 reviewer_objects = schema.deserialize(reviewer_objects)
795 reviewer_objects = schema.deserialize(reviewer_objects)
783 except Invalid as err:
796 except Invalid as err:
784 raise JSONRPCValidationError(colander_exc=err)
797 raise JSONRPCValidationError(colander_exc=err)
785
798
786 # validate users
799 # validate users
787 for reviewer_object in reviewer_objects:
800 for reviewer_object in reviewer_objects:
788 user = get_user_or_error(reviewer_object['username'])
801 user = get_user_or_error(reviewer_object['username'])
789 reviewer_object['user_id'] = user.user_id
802 reviewer_object['user_id'] = user.user_id
790
803
791 get_default_reviewers_data, get_validated_reviewers = \
804 get_default_reviewers_data, get_validated_reviewers = \
792 PullRequestModel().get_reviewer_functions()
805 PullRequestModel().get_reviewer_functions()
793
806
794 # re-use stored rules
807 # re-use stored rules
795 reviewer_rules = pull_request.reviewer_data
808 reviewer_rules = pull_request.reviewer_data
796 try:
809 try:
797 reviewers = get_validated_reviewers(
810 reviewers = get_validated_reviewers(
798 reviewer_objects, reviewer_rules)
811 reviewer_objects, reviewer_rules)
799 except ValueError as e:
812 except ValueError as e:
800 raise JSONRPCError('Reviewers Validation: {}'.format(e))
813 raise JSONRPCError('Reviewers Validation: {}'.format(e))
801 else:
814 else:
802 reviewers = []
815 reviewers = []
803
816
804 title = Optional.extract(title)
817 title = Optional.extract(title)
805 description = Optional.extract(description)
818 description = Optional.extract(description)
819 description_renderer = Optional.extract(description_renderer)
820
806 if title or description:
821 if title or description:
807 PullRequestModel().edit(
822 PullRequestModel().edit(
808 pull_request, title or pull_request.title,
823 pull_request,
809 description or pull_request.description, apiuser)
824 title or pull_request.title,
825 description or pull_request.description,
826 description_renderer or pull_request.description_renderer,
827 apiuser)
810 Session().commit()
828 Session().commit()
811
829
812 commit_changes = {"added": [], "common": [], "removed": []}
830 commit_changes = {"added": [], "common": [], "removed": []}
813 if str2bool(Optional.extract(update_commits)):
831 if str2bool(Optional.extract(update_commits)):
814 if PullRequestModel().has_valid_update_type(pull_request):
832 if PullRequestModel().has_valid_update_type(pull_request):
815 update_response = PullRequestModel().update_commits(
833 update_response = PullRequestModel().update_commits(
816 pull_request)
834 pull_request)
817 commit_changes = update_response.changes or commit_changes
835 commit_changes = update_response.changes or commit_changes
818 Session().commit()
836 Session().commit()
819
837
820 reviewers_changes = {"added": [], "removed": []}
838 reviewers_changes = {"added": [], "removed": []}
821 if reviewers:
839 if reviewers:
822 added_reviewers, removed_reviewers = \
840 added_reviewers, removed_reviewers = \
823 PullRequestModel().update_reviewers(pull_request, reviewers, apiuser)
841 PullRequestModel().update_reviewers(pull_request, reviewers, apiuser)
824
842
825 reviewers_changes['added'] = sorted(
843 reviewers_changes['added'] = sorted(
826 [get_user_or_error(n).username for n in added_reviewers])
844 [get_user_or_error(n).username for n in added_reviewers])
827 reviewers_changes['removed'] = sorted(
845 reviewers_changes['removed'] = sorted(
828 [get_user_or_error(n).username for n in removed_reviewers])
846 [get_user_or_error(n).username for n in removed_reviewers])
829 Session().commit()
847 Session().commit()
830
848
831 data = {
849 data = {
832 'msg': 'Updated pull request `{}`'.format(
850 'msg': 'Updated pull request `{}`'.format(
833 pull_request.pull_request_id),
851 pull_request.pull_request_id),
834 'pull_request': pull_request.get_api_data(),
852 'pull_request': pull_request.get_api_data(),
835 'updated_commits': commit_changes,
853 'updated_commits': commit_changes,
836 'updated_reviewers': reviewers_changes
854 'updated_reviewers': reviewers_changes
837 }
855 }
838
856
839 return data
857 return data
840
858
841
859
842 @jsonrpc_method()
860 @jsonrpc_method()
843 def close_pull_request(
861 def close_pull_request(
844 request, apiuser, pullrequestid, repoid=Optional(None),
862 request, apiuser, pullrequestid, repoid=Optional(None),
845 userid=Optional(OAttr('apiuser')), message=Optional('')):
863 userid=Optional(OAttr('apiuser')), message=Optional('')):
846 """
864 """
847 Close the pull request specified by `pullrequestid`.
865 Close the pull request specified by `pullrequestid`.
848
866
849 :param apiuser: This is filled automatically from the |authtoken|.
867 :param apiuser: This is filled automatically from the |authtoken|.
850 :type apiuser: AuthUser
868 :type apiuser: AuthUser
851 :param repoid: Repository name or repository ID to which the pull
869 :param repoid: Repository name or repository ID to which the pull
852 request belongs.
870 request belongs.
853 :type repoid: str or int
871 :type repoid: str or int
854 :param pullrequestid: ID of the pull request to be closed.
872 :param pullrequestid: ID of the pull request to be closed.
855 :type pullrequestid: int
873 :type pullrequestid: int
856 :param userid: Close the pull request as this user.
874 :param userid: Close the pull request as this user.
857 :type userid: Optional(str or int)
875 :type userid: Optional(str or int)
858 :param message: Optional message to close the Pull Request with. If not
876 :param message: Optional message to close the Pull Request with. If not
859 specified it will be generated automatically.
877 specified it will be generated automatically.
860 :type message: Optional(str)
878 :type message: Optional(str)
861
879
862 Example output:
880 Example output:
863
881
864 .. code-block:: bash
882 .. code-block:: bash
865
883
866 "id": <id_given_in_input>,
884 "id": <id_given_in_input>,
867 "result": {
885 "result": {
868 "pull_request_id": "<int>",
886 "pull_request_id": "<int>",
869 "close_status": "<str:status_lbl>,
887 "close_status": "<str:status_lbl>,
870 "closed": "<bool>"
888 "closed": "<bool>"
871 },
889 },
872 "error": null
890 "error": null
873
891
874 """
892 """
875 _ = request.translate
893 _ = request.translate
876
894
877 pull_request = get_pull_request_or_error(pullrequestid)
895 pull_request = get_pull_request_or_error(pullrequestid)
878 if Optional.extract(repoid):
896 if Optional.extract(repoid):
879 repo = get_repo_or_error(repoid)
897 repo = get_repo_or_error(repoid)
880 else:
898 else:
881 repo = pull_request.target_repo
899 repo = pull_request.target_repo
882
900
883 if not isinstance(userid, Optional):
901 if not isinstance(userid, Optional):
884 if (has_superadmin_permission(apiuser) or
902 if (has_superadmin_permission(apiuser) or
885 HasRepoPermissionAnyApi('repository.admin')(
903 HasRepoPermissionAnyApi('repository.admin')(
886 user=apiuser, repo_name=repo.repo_name)):
904 user=apiuser, repo_name=repo.repo_name)):
887 apiuser = get_user_or_error(userid)
905 apiuser = get_user_or_error(userid)
888 else:
906 else:
889 raise JSONRPCError('userid is not the same as your user')
907 raise JSONRPCError('userid is not the same as your user')
890
908
891 if pull_request.is_closed():
909 if pull_request.is_closed():
892 raise JSONRPCError(
910 raise JSONRPCError(
893 'pull request `%s` is already closed' % (pullrequestid,))
911 'pull request `%s` is already closed' % (pullrequestid,))
894
912
895 # only owner or admin or person with write permissions
913 # only owner or admin or person with write permissions
896 allowed_to_close = PullRequestModel().check_user_update(
914 allowed_to_close = PullRequestModel().check_user_update(
897 pull_request, apiuser, api=True)
915 pull_request, apiuser, api=True)
898
916
899 if not allowed_to_close:
917 if not allowed_to_close:
900 raise JSONRPCError(
918 raise JSONRPCError(
901 'pull request `%s` close failed, no permission to close.' % (
919 'pull request `%s` close failed, no permission to close.' % (
902 pullrequestid,))
920 pullrequestid,))
903
921
904 # message we're using to close the PR, else it's automatically generated
922 # message we're using to close the PR, else it's automatically generated
905 message = Optional.extract(message)
923 message = Optional.extract(message)
906
924
907 # finally close the PR, with proper message comment
925 # finally close the PR, with proper message comment
908 comment, status = PullRequestModel().close_pull_request_with_comment(
926 comment, status = PullRequestModel().close_pull_request_with_comment(
909 pull_request, apiuser, repo, message=message)
927 pull_request, apiuser, repo, message=message)
910 status_lbl = ChangesetStatus.get_status_lbl(status)
928 status_lbl = ChangesetStatus.get_status_lbl(status)
911
929
912 Session().commit()
930 Session().commit()
913
931
914 data = {
932 data = {
915 'pull_request_id': pull_request.pull_request_id,
933 'pull_request_id': pull_request.pull_request_id,
916 'close_status': status_lbl,
934 'close_status': status_lbl,
917 'closed': True,
935 'closed': True,
918 }
936 }
919 return data
937 return data
General Comments 0
You need to be logged in to leave comments. Login now