##// END OF EJS Templates
tests: Adapt tests to return value change.
Martin Bornhold -
r1077:b67a4d33 default
parent child Browse files
Show More
@@ -1,691 +1,691 b''
1 # -*- coding: utf-8 -*-
1 # -*- coding: utf-8 -*-
2
2
3 # Copyright (C) 2011-2016 RhodeCode GmbH
3 # Copyright (C) 2011-2016 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.api import jsonrpc_method, JSONRPCError
24 from rhodecode.api import jsonrpc_method, JSONRPCError
25 from rhodecode.api.utils import (
25 from rhodecode.api.utils import (
26 has_superadmin_permission, Optional, OAttr, get_repo_or_error,
26 has_superadmin_permission, Optional, OAttr, get_repo_or_error,
27 get_pull_request_or_error, get_commit_or_error, get_user_or_error,
27 get_pull_request_or_error, get_commit_or_error, get_user_or_error,
28 has_repo_permissions, resolve_ref_or_error)
28 has_repo_permissions, resolve_ref_or_error)
29 from rhodecode.lib.auth import (HasRepoPermissionAnyApi)
29 from rhodecode.lib.auth import (HasRepoPermissionAnyApi)
30 from rhodecode.lib.base import vcs_operation_context
30 from rhodecode.lib.base import vcs_operation_context
31 from rhodecode.lib.utils2 import str2bool
31 from rhodecode.lib.utils2 import str2bool
32 from rhodecode.model.changeset_status import ChangesetStatusModel
32 from rhodecode.model.changeset_status import ChangesetStatusModel
33 from rhodecode.model.comment import ChangesetCommentsModel
33 from rhodecode.model.comment import ChangesetCommentsModel
34 from rhodecode.model.db import Session, ChangesetStatus
34 from rhodecode.model.db import Session, ChangesetStatus
35 from rhodecode.model.pull_request import PullRequestModel
35 from rhodecode.model.pull_request import PullRequestModel
36 from rhodecode.model.settings import SettingsModel
36 from rhodecode.model.settings import SettingsModel
37
37
38 log = logging.getLogger(__name__)
38 log = logging.getLogger(__name__)
39
39
40
40
41 @jsonrpc_method()
41 @jsonrpc_method()
42 def get_pull_request(request, apiuser, repoid, pullrequestid):
42 def get_pull_request(request, apiuser, repoid, pullrequestid):
43 """
43 """
44 Get a pull request based on the given ID.
44 Get a pull request based on the given ID.
45
45
46 :param apiuser: This is filled automatically from the |authtoken|.
46 :param apiuser: This is filled automatically from the |authtoken|.
47 :type apiuser: AuthUser
47 :type apiuser: AuthUser
48 :param repoid: Repository name or repository ID from where the pull
48 :param repoid: Repository name or repository ID from where the pull
49 request was opened.
49 request was opened.
50 :type repoid: str or int
50 :type repoid: str or int
51 :param pullrequestid: ID of the requested pull request.
51 :param pullrequestid: ID of the requested pull request.
52 :type pullrequestid: int
52 :type pullrequestid: int
53
53
54 Example output:
54 Example output:
55
55
56 .. code-block:: bash
56 .. code-block:: bash
57
57
58 "id": <id_given_in_input>,
58 "id": <id_given_in_input>,
59 "result":
59 "result":
60 {
60 {
61 "pull_request_id": "<pull_request_id>",
61 "pull_request_id": "<pull_request_id>",
62 "url": "<url>",
62 "url": "<url>",
63 "title": "<title>",
63 "title": "<title>",
64 "description": "<description>",
64 "description": "<description>",
65 "status" : "<status>",
65 "status" : "<status>",
66 "created_on": "<date_time_created>",
66 "created_on": "<date_time_created>",
67 "updated_on": "<date_time_updated>",
67 "updated_on": "<date_time_updated>",
68 "commit_ids": [
68 "commit_ids": [
69 ...
69 ...
70 "<commit_id>",
70 "<commit_id>",
71 "<commit_id>",
71 "<commit_id>",
72 ...
72 ...
73 ],
73 ],
74 "review_status": "<review_status>",
74 "review_status": "<review_status>",
75 "mergeable": {
75 "mergeable": {
76 "status": "<bool>",
76 "status": "<bool>",
77 "message": "<message>",
77 "message": "<message>",
78 },
78 },
79 "source": {
79 "source": {
80 "clone_url": "<clone_url>",
80 "clone_url": "<clone_url>",
81 "repository": "<repository_name>",
81 "repository": "<repository_name>",
82 "reference":
82 "reference":
83 {
83 {
84 "name": "<name>",
84 "name": "<name>",
85 "type": "<type>",
85 "type": "<type>",
86 "commit_id": "<commit_id>",
86 "commit_id": "<commit_id>",
87 }
87 }
88 },
88 },
89 "target": {
89 "target": {
90 "clone_url": "<clone_url>",
90 "clone_url": "<clone_url>",
91 "repository": "<repository_name>",
91 "repository": "<repository_name>",
92 "reference":
92 "reference":
93 {
93 {
94 "name": "<name>",
94 "name": "<name>",
95 "type": "<type>",
95 "type": "<type>",
96 "commit_id": "<commit_id>",
96 "commit_id": "<commit_id>",
97 }
97 }
98 },
98 },
99 "merge": {
99 "merge": {
100 "clone_url": "<clone_url>",
100 "clone_url": "<clone_url>",
101 "reference":
101 "reference":
102 {
102 {
103 "name": "<name>",
103 "name": "<name>",
104 "type": "<type>",
104 "type": "<type>",
105 "commit_id": "<commit_id>",
105 "commit_id": "<commit_id>",
106 }
106 }
107 },
107 },
108 "author": <user_obj>,
108 "author": <user_obj>,
109 "reviewers": [
109 "reviewers": [
110 ...
110 ...
111 {
111 {
112 "user": "<user_obj>",
112 "user": "<user_obj>",
113 "review_status": "<review_status>",
113 "review_status": "<review_status>",
114 }
114 }
115 ...
115 ...
116 ]
116 ]
117 },
117 },
118 "error": null
118 "error": null
119 """
119 """
120 get_repo_or_error(repoid)
120 get_repo_or_error(repoid)
121 pull_request = get_pull_request_or_error(pullrequestid)
121 pull_request = get_pull_request_or_error(pullrequestid)
122 if not PullRequestModel().check_user_read(
122 if not PullRequestModel().check_user_read(
123 pull_request, apiuser, api=True):
123 pull_request, apiuser, api=True):
124 raise JSONRPCError('repository `%s` does not exist' % (repoid,))
124 raise JSONRPCError('repository `%s` does not exist' % (repoid,))
125 data = pull_request.get_api_data()
125 data = pull_request.get_api_data()
126 return data
126 return data
127
127
128
128
129 @jsonrpc_method()
129 @jsonrpc_method()
130 def get_pull_requests(request, apiuser, repoid, status=Optional('new')):
130 def get_pull_requests(request, apiuser, repoid, status=Optional('new')):
131 """
131 """
132 Get all pull requests from the repository specified in `repoid`.
132 Get all pull requests from the repository specified in `repoid`.
133
133
134 :param apiuser: This is filled automatically from the |authtoken|.
134 :param apiuser: This is filled automatically from the |authtoken|.
135 :type apiuser: AuthUser
135 :type apiuser: AuthUser
136 :param repoid: Repository name or repository ID.
136 :param repoid: Repository name or repository ID.
137 :type repoid: str or int
137 :type repoid: str or int
138 :param status: Only return pull requests with the specified status.
138 :param status: Only return pull requests with the specified status.
139 Valid options are.
139 Valid options are.
140 * ``new`` (default)
140 * ``new`` (default)
141 * ``open``
141 * ``open``
142 * ``closed``
142 * ``closed``
143 :type status: str
143 :type status: str
144
144
145 Example output:
145 Example output:
146
146
147 .. code-block:: bash
147 .. code-block:: bash
148
148
149 "id": <id_given_in_input>,
149 "id": <id_given_in_input>,
150 "result":
150 "result":
151 [
151 [
152 ...
152 ...
153 {
153 {
154 "pull_request_id": "<pull_request_id>",
154 "pull_request_id": "<pull_request_id>",
155 "url": "<url>",
155 "url": "<url>",
156 "title" : "<title>",
156 "title" : "<title>",
157 "description": "<description>",
157 "description": "<description>",
158 "status": "<status>",
158 "status": "<status>",
159 "created_on": "<date_time_created>",
159 "created_on": "<date_time_created>",
160 "updated_on": "<date_time_updated>",
160 "updated_on": "<date_time_updated>",
161 "commit_ids": [
161 "commit_ids": [
162 ...
162 ...
163 "<commit_id>",
163 "<commit_id>",
164 "<commit_id>",
164 "<commit_id>",
165 ...
165 ...
166 ],
166 ],
167 "review_status": "<review_status>",
167 "review_status": "<review_status>",
168 "mergeable": {
168 "mergeable": {
169 "status": "<bool>",
169 "status": "<bool>",
170 "message: "<message>",
170 "message: "<message>",
171 },
171 },
172 "source": {
172 "source": {
173 "clone_url": "<clone_url>",
173 "clone_url": "<clone_url>",
174 "reference":
174 "reference":
175 {
175 {
176 "name": "<name>",
176 "name": "<name>",
177 "type": "<type>",
177 "type": "<type>",
178 "commit_id": "<commit_id>",
178 "commit_id": "<commit_id>",
179 }
179 }
180 },
180 },
181 "target": {
181 "target": {
182 "clone_url": "<clone_url>",
182 "clone_url": "<clone_url>",
183 "reference":
183 "reference":
184 {
184 {
185 "name": "<name>",
185 "name": "<name>",
186 "type": "<type>",
186 "type": "<type>",
187 "commit_id": "<commit_id>",
187 "commit_id": "<commit_id>",
188 }
188 }
189 },
189 },
190 "merge": {
190 "merge": {
191 "clone_url": "<clone_url>",
191 "clone_url": "<clone_url>",
192 "reference":
192 "reference":
193 {
193 {
194 "name": "<name>",
194 "name": "<name>",
195 "type": "<type>",
195 "type": "<type>",
196 "commit_id": "<commit_id>",
196 "commit_id": "<commit_id>",
197 }
197 }
198 },
198 },
199 "author": <user_obj>,
199 "author": <user_obj>,
200 "reviewers": [
200 "reviewers": [
201 ...
201 ...
202 {
202 {
203 "user": "<user_obj>",
203 "user": "<user_obj>",
204 "review_status": "<review_status>",
204 "review_status": "<review_status>",
205 }
205 }
206 ...
206 ...
207 ]
207 ]
208 }
208 }
209 ...
209 ...
210 ],
210 ],
211 "error": null
211 "error": null
212
212
213 """
213 """
214 repo = get_repo_or_error(repoid)
214 repo = get_repo_or_error(repoid)
215 if not has_superadmin_permission(apiuser):
215 if not has_superadmin_permission(apiuser):
216 _perms = (
216 _perms = (
217 'repository.admin', 'repository.write', 'repository.read',)
217 'repository.admin', 'repository.write', 'repository.read',)
218 has_repo_permissions(apiuser, repoid, repo, _perms)
218 has_repo_permissions(apiuser, repoid, repo, _perms)
219
219
220 status = Optional.extract(status)
220 status = Optional.extract(status)
221 pull_requests = PullRequestModel().get_all(repo, statuses=[status])
221 pull_requests = PullRequestModel().get_all(repo, statuses=[status])
222 data = [pr.get_api_data() for pr in pull_requests]
222 data = [pr.get_api_data() for pr in pull_requests]
223 return data
223 return data
224
224
225
225
226 @jsonrpc_method()
226 @jsonrpc_method()
227 def merge_pull_request(request, apiuser, repoid, pullrequestid,
227 def merge_pull_request(request, apiuser, repoid, pullrequestid,
228 userid=Optional(OAttr('apiuser'))):
228 userid=Optional(OAttr('apiuser'))):
229 """
229 """
230 Merge the pull request specified by `pullrequestid` into its target
230 Merge the pull request specified by `pullrequestid` into its target
231 repository.
231 repository.
232
232
233 :param apiuser: This is filled automatically from the |authtoken|.
233 :param apiuser: This is filled automatically from the |authtoken|.
234 :type apiuser: AuthUser
234 :type apiuser: AuthUser
235 :param repoid: The Repository name or repository ID of the
235 :param repoid: The Repository name or repository ID of the
236 target repository to which the |pr| is to be merged.
236 target repository to which the |pr| is to be merged.
237 :type repoid: str or int
237 :type repoid: str or int
238 :param pullrequestid: ID of the pull request which shall be merged.
238 :param pullrequestid: ID of the pull request which shall be merged.
239 :type pullrequestid: int
239 :type pullrequestid: int
240 :param userid: Merge the pull request as this user.
240 :param userid: Merge the pull request as this user.
241 :type userid: Optional(str or int)
241 :type userid: Optional(str or int)
242
242
243 Example output:
243 Example output:
244
244
245 .. code-block:: bash
245 .. code-block:: bash
246
246
247 "id": <id_given_in_input>,
247 "id": <id_given_in_input>,
248 "result":
248 "result":
249 {
249 {
250 "executed": "<bool>",
250 "executed": "<bool>",
251 "failure_reason": "<int>",
251 "failure_reason": "<int>",
252 "merge_commit_id": "<merge_commit_id>",
252 "merge_commit_id": "<merge_commit_id>",
253 "possible": "<bool>",
253 "possible": "<bool>",
254 "merge_ref": {
254 "merge_ref": {
255 "commit_id": "<commit_id>",
255 "commit_id": "<commit_id>",
256 "type": "<type>",
256 "type": "<type>",
257 "name": "<name>"
257 "name": "<name>"
258 }
258 }
259 },
259 },
260 "error": null
260 "error": null
261
261
262 """
262 """
263 repo = get_repo_or_error(repoid)
263 repo = get_repo_or_error(repoid)
264 if not isinstance(userid, Optional):
264 if not isinstance(userid, Optional):
265 if (has_superadmin_permission(apiuser) or
265 if (has_superadmin_permission(apiuser) or
266 HasRepoPermissionAnyApi('repository.admin')(
266 HasRepoPermissionAnyApi('repository.admin')(
267 user=apiuser, repo_name=repo.repo_name)):
267 user=apiuser, repo_name=repo.repo_name)):
268 apiuser = get_user_or_error(userid)
268 apiuser = get_user_or_error(userid)
269 else:
269 else:
270 raise JSONRPCError('userid is not the same as your user')
270 raise JSONRPCError('userid is not the same as your user')
271
271
272 pull_request = get_pull_request_or_error(pullrequestid)
272 pull_request = get_pull_request_or_error(pullrequestid)
273 if not PullRequestModel().check_user_merge(
273 if not PullRequestModel().check_user_merge(
274 pull_request, apiuser, api=True):
274 pull_request, apiuser, api=True):
275 raise JSONRPCError('repository `%s` does not exist' % (repoid,))
275 raise JSONRPCError('repository `%s` does not exist' % (repoid,))
276 if pull_request.is_closed():
276 if pull_request.is_closed():
277 raise JSONRPCError(
277 raise JSONRPCError(
278 'pull request `%s` merge failed, pull request is closed' % (
278 'pull request `%s` merge failed, pull request is closed' % (
279 pullrequestid,))
279 pullrequestid,))
280
280
281 target_repo = pull_request.target_repo
281 target_repo = pull_request.target_repo
282 extras = vcs_operation_context(
282 extras = vcs_operation_context(
283 request.environ, repo_name=target_repo.repo_name,
283 request.environ, repo_name=target_repo.repo_name,
284 username=apiuser.username, action='push',
284 username=apiuser.username, action='push',
285 scm=target_repo.repo_type)
285 scm=target_repo.repo_type)
286 merge_response = PullRequestModel().merge(
286 merge_response = PullRequestModel().merge(
287 pull_request, apiuser, extras=extras)
287 pull_request, apiuser, extras=extras)
288 if merge_response.executed:
288 if merge_response.executed:
289 PullRequestModel().close_pull_request(
289 PullRequestModel().close_pull_request(
290 pull_request.pull_request_id, apiuser)
290 pull_request.pull_request_id, apiuser)
291
291
292 Session().commit()
292 Session().commit()
293
293
294 # In previous versions the merge response directly contained the merge
294 # In previous versions the merge response directly contained the merge
295 # commit id. It is now contained in the merge reference object. To be
295 # commit id. It is now contained in the merge reference object. To be
296 # backwards compatible we have to extract it again.
296 # backwards compatible we have to extract it again.
297 merge_response = merge_response._asdict()
297 merge_response = merge_response._asdict()
298 merge_response['merge_commit_id'] = merge_response['merge_ref'].commit_id
298 merge_response['merge_commit_id'] = merge_response['merge_ref'].commit_id
299
299
300 return merge_response
300 return merge_response
301
301
302
302
303 @jsonrpc_method()
303 @jsonrpc_method()
304 def close_pull_request(request, apiuser, repoid, pullrequestid,
304 def close_pull_request(request, apiuser, repoid, pullrequestid,
305 userid=Optional(OAttr('apiuser'))):
305 userid=Optional(OAttr('apiuser'))):
306 """
306 """
307 Close the pull request specified by `pullrequestid`.
307 Close the pull request specified by `pullrequestid`.
308
308
309 :param apiuser: This is filled automatically from the |authtoken|.
309 :param apiuser: This is filled automatically from the |authtoken|.
310 :type apiuser: AuthUser
310 :type apiuser: AuthUser
311 :param repoid: Repository name or repository ID to which the pull
311 :param repoid: Repository name or repository ID to which the pull
312 request belongs.
312 request belongs.
313 :type repoid: str or int
313 :type repoid: str or int
314 :param pullrequestid: ID of the pull request to be closed.
314 :param pullrequestid: ID of the pull request to be closed.
315 :type pullrequestid: int
315 :type pullrequestid: int
316 :param userid: Close the pull request as this user.
316 :param userid: Close the pull request as this user.
317 :type userid: Optional(str or int)
317 :type userid: Optional(str or int)
318
318
319 Example output:
319 Example output:
320
320
321 .. code-block:: bash
321 .. code-block:: bash
322
322
323 "id": <id_given_in_input>,
323 "id": <id_given_in_input>,
324 "result":
324 "result":
325 {
325 {
326 "pull_request_id": "<int>",
326 "pull_request_id": "<int>",
327 "closed": "<bool>"
327 "closed": "<bool>"
328 },
328 },
329 "error": null
329 "error": null
330
330
331 """
331 """
332 repo = get_repo_or_error(repoid)
332 repo = get_repo_or_error(repoid)
333 if not isinstance(userid, Optional):
333 if not isinstance(userid, Optional):
334 if (has_superadmin_permission(apiuser) or
334 if (has_superadmin_permission(apiuser) or
335 HasRepoPermissionAnyApi('repository.admin')(
335 HasRepoPermissionAnyApi('repository.admin')(
336 user=apiuser, repo_name=repo.repo_name)):
336 user=apiuser, repo_name=repo.repo_name)):
337 apiuser = get_user_or_error(userid)
337 apiuser = get_user_or_error(userid)
338 else:
338 else:
339 raise JSONRPCError('userid is not the same as your user')
339 raise JSONRPCError('userid is not the same as your user')
340
340
341 pull_request = get_pull_request_or_error(pullrequestid)
341 pull_request = get_pull_request_or_error(pullrequestid)
342 if not PullRequestModel().check_user_update(
342 if not PullRequestModel().check_user_update(
343 pull_request, apiuser, api=True):
343 pull_request, apiuser, api=True):
344 raise JSONRPCError(
344 raise JSONRPCError(
345 'pull request `%s` close failed, no permission to close.' % (
345 'pull request `%s` close failed, no permission to close.' % (
346 pullrequestid,))
346 pullrequestid,))
347 if pull_request.is_closed():
347 if pull_request.is_closed():
348 raise JSONRPCError(
348 raise JSONRPCError(
349 'pull request `%s` is already closed' % (pullrequestid,))
349 'pull request `%s` is already closed' % (pullrequestid,))
350
350
351 PullRequestModel().close_pull_request(
351 PullRequestModel().close_pull_request(
352 pull_request.pull_request_id, apiuser)
352 pull_request.pull_request_id, apiuser)
353 Session().commit()
353 Session().commit()
354 data = {
354 data = {
355 'pull_request_id': pull_request.pull_request_id,
355 'pull_request_id': pull_request.pull_request_id,
356 'closed': True,
356 'closed': True,
357 }
357 }
358 return data
358 return data
359
359
360
360
361 @jsonrpc_method()
361 @jsonrpc_method()
362 def comment_pull_request(request, apiuser, repoid, pullrequestid,
362 def comment_pull_request(request, apiuser, repoid, pullrequestid,
363 message=Optional(None), status=Optional(None),
363 message=Optional(None), status=Optional(None),
364 userid=Optional(OAttr('apiuser'))):
364 userid=Optional(OAttr('apiuser'))):
365 """
365 """
366 Comment on the pull request specified with the `pullrequestid`,
366 Comment on the pull request specified with the `pullrequestid`,
367 in the |repo| specified by the `repoid`, and optionally change the
367 in the |repo| specified by the `repoid`, and optionally change the
368 review status.
368 review status.
369
369
370 :param apiuser: This is filled automatically from the |authtoken|.
370 :param apiuser: This is filled automatically from the |authtoken|.
371 :type apiuser: AuthUser
371 :type apiuser: AuthUser
372 :param repoid: The repository name or repository ID.
372 :param repoid: The repository name or repository ID.
373 :type repoid: str or int
373 :type repoid: str or int
374 :param pullrequestid: The pull request ID.
374 :param pullrequestid: The pull request ID.
375 :type pullrequestid: int
375 :type pullrequestid: int
376 :param message: The text content of the comment.
376 :param message: The text content of the comment.
377 :type message: str
377 :type message: str
378 :param status: (**Optional**) Set the approval status of the pull
378 :param status: (**Optional**) Set the approval status of the pull
379 request. Valid options are:
379 request. Valid options are:
380 * not_reviewed
380 * not_reviewed
381 * approved
381 * approved
382 * rejected
382 * rejected
383 * under_review
383 * under_review
384 :type status: str
384 :type status: str
385 :param userid: Comment on the pull request as this user
385 :param userid: Comment on the pull request as this user
386 :type userid: Optional(str or int)
386 :type userid: Optional(str or int)
387
387
388 Example output:
388 Example output:
389
389
390 .. code-block:: bash
390 .. code-block:: bash
391
391
392 id : <id_given_in_input>
392 id : <id_given_in_input>
393 result :
393 result :
394 {
394 {
395 "pull_request_id": "<Integer>",
395 "pull_request_id": "<Integer>",
396 "comment_id": "<Integer>"
396 "comment_id": "<Integer>"
397 }
397 }
398 error : null
398 error : null
399 """
399 """
400 repo = get_repo_or_error(repoid)
400 repo = get_repo_or_error(repoid)
401 if not isinstance(userid, Optional):
401 if not isinstance(userid, Optional):
402 if (has_superadmin_permission(apiuser) or
402 if (has_superadmin_permission(apiuser) or
403 HasRepoPermissionAnyApi('repository.admin')(
403 HasRepoPermissionAnyApi('repository.admin')(
404 user=apiuser, repo_name=repo.repo_name)):
404 user=apiuser, repo_name=repo.repo_name)):
405 apiuser = get_user_or_error(userid)
405 apiuser = get_user_or_error(userid)
406 else:
406 else:
407 raise JSONRPCError('userid is not the same as your user')
407 raise JSONRPCError('userid is not the same as your user')
408
408
409 pull_request = get_pull_request_or_error(pullrequestid)
409 pull_request = get_pull_request_or_error(pullrequestid)
410 if not PullRequestModel().check_user_read(
410 if not PullRequestModel().check_user_read(
411 pull_request, apiuser, api=True):
411 pull_request, apiuser, api=True):
412 raise JSONRPCError('repository `%s` does not exist' % (repoid,))
412 raise JSONRPCError('repository `%s` does not exist' % (repoid,))
413 message = Optional.extract(message)
413 message = Optional.extract(message)
414 status = Optional.extract(status)
414 status = Optional.extract(status)
415 if not message and not status:
415 if not message and not status:
416 raise JSONRPCError('message and status parameter missing')
416 raise JSONRPCError('message and status parameter missing')
417
417
418 if (status not in (st[0] for st in ChangesetStatus.STATUSES) and
418 if (status not in (st[0] for st in ChangesetStatus.STATUSES) and
419 status is not None):
419 status is not None):
420 raise JSONRPCError('unknown comment status`%s`' % status)
420 raise JSONRPCError('unknown comment status`%s`' % status)
421
421
422 allowed_to_change_status = PullRequestModel().check_user_change_status(
422 allowed_to_change_status = PullRequestModel().check_user_change_status(
423 pull_request, apiuser)
423 pull_request, apiuser)
424 text = message
424 text = message
425 if status and allowed_to_change_status:
425 if status and allowed_to_change_status:
426 st_message = (('Status change %(transition_icon)s %(status)s')
426 st_message = (('Status change %(transition_icon)s %(status)s')
427 % {'transition_icon': '>',
427 % {'transition_icon': '>',
428 'status': ChangesetStatus.get_status_lbl(status)})
428 'status': ChangesetStatus.get_status_lbl(status)})
429 text = message or st_message
429 text = message or st_message
430
430
431 rc_config = SettingsModel().get_all_settings()
431 rc_config = SettingsModel().get_all_settings()
432 renderer = rc_config.get('rhodecode_markup_renderer', 'rst')
432 renderer = rc_config.get('rhodecode_markup_renderer', 'rst')
433 comment = ChangesetCommentsModel().create(
433 comment = ChangesetCommentsModel().create(
434 text=text,
434 text=text,
435 repo=pull_request.target_repo.repo_id,
435 repo=pull_request.target_repo.repo_id,
436 user=apiuser.user_id,
436 user=apiuser.user_id,
437 pull_request=pull_request.pull_request_id,
437 pull_request=pull_request.pull_request_id,
438 f_path=None,
438 f_path=None,
439 line_no=None,
439 line_no=None,
440 status_change=(ChangesetStatus.get_status_lbl(status)
440 status_change=(ChangesetStatus.get_status_lbl(status)
441 if status and allowed_to_change_status else None),
441 if status and allowed_to_change_status else None),
442 status_change_type=(status
442 status_change_type=(status
443 if status and allowed_to_change_status else None),
443 if status and allowed_to_change_status else None),
444 closing_pr=False,
444 closing_pr=False,
445 renderer=renderer
445 renderer=renderer
446 )
446 )
447
447
448 if allowed_to_change_status and status:
448 if allowed_to_change_status and status:
449 ChangesetStatusModel().set_status(
449 ChangesetStatusModel().set_status(
450 pull_request.target_repo.repo_id,
450 pull_request.target_repo.repo_id,
451 status,
451 status,
452 apiuser.user_id,
452 apiuser.user_id,
453 comment,
453 comment,
454 pull_request=pull_request.pull_request_id
454 pull_request=pull_request.pull_request_id
455 )
455 )
456 Session().flush()
456 Session().flush()
457
457
458 Session().commit()
458 Session().commit()
459 data = {
459 data = {
460 'pull_request_id': pull_request.pull_request_id,
460 'pull_request_id': pull_request.pull_request_id,
461 'comment_id': comment.comment_id,
461 'comment_id': comment.comment_id,
462 'status': status
462 'status': status
463 }
463 }
464 return data
464 return data
465
465
466
466
467 @jsonrpc_method()
467 @jsonrpc_method()
468 def create_pull_request(
468 def create_pull_request(
469 request, apiuser, source_repo, target_repo, source_ref, target_ref,
469 request, apiuser, source_repo, target_repo, source_ref, target_ref,
470 title, description=Optional(''), reviewers=Optional(None)):
470 title, description=Optional(''), reviewers=Optional(None)):
471 """
471 """
472 Creates a new pull request.
472 Creates a new pull request.
473
473
474 Accepts refs in the following formats:
474 Accepts refs in the following formats:
475
475
476 * branch:<branch_name>:<sha>
476 * branch:<branch_name>:<sha>
477 * branch:<branch_name>
477 * branch:<branch_name>
478 * bookmark:<bookmark_name>:<sha> (Mercurial only)
478 * bookmark:<bookmark_name>:<sha> (Mercurial only)
479 * bookmark:<bookmark_name> (Mercurial only)
479 * bookmark:<bookmark_name> (Mercurial only)
480
480
481 :param apiuser: This is filled automatically from the |authtoken|.
481 :param apiuser: This is filled automatically from the |authtoken|.
482 :type apiuser: AuthUser
482 :type apiuser: AuthUser
483 :param source_repo: Set the source repository name.
483 :param source_repo: Set the source repository name.
484 :type source_repo: str
484 :type source_repo: str
485 :param target_repo: Set the target repository name.
485 :param target_repo: Set the target repository name.
486 :type target_repo: str
486 :type target_repo: str
487 :param source_ref: Set the source ref name.
487 :param source_ref: Set the source ref name.
488 :type source_ref: str
488 :type source_ref: str
489 :param target_ref: Set the target ref name.
489 :param target_ref: Set the target ref name.
490 :type target_ref: str
490 :type target_ref: str
491 :param title: Set the pull request title.
491 :param title: Set the pull request title.
492 :type title: str
492 :type title: str
493 :param description: Set the pull request description.
493 :param description: Set the pull request description.
494 :type description: Optional(str)
494 :type description: Optional(str)
495 :param reviewers: Set the new pull request reviewers list.
495 :param reviewers: Set the new pull request reviewers list.
496 :type reviewers: Optional(list)
496 :type reviewers: Optional(list)
497 Accepts username strings or objects of the format:
497 Accepts username strings or objects of the format:
498 {
498 {
499 'username': 'nick', 'reasons': ['original author']
499 'username': 'nick', 'reasons': ['original author']
500 }
500 }
501 """
501 """
502
502
503 source = get_repo_or_error(source_repo)
503 source = get_repo_or_error(source_repo)
504 target = get_repo_or_error(target_repo)
504 target = get_repo_or_error(target_repo)
505 if not has_superadmin_permission(apiuser):
505 if not has_superadmin_permission(apiuser):
506 _perms = ('repository.admin', 'repository.write', 'repository.read',)
506 _perms = ('repository.admin', 'repository.write', 'repository.read',)
507 has_repo_permissions(apiuser, source_repo, source, _perms)
507 has_repo_permissions(apiuser, source_repo, source, _perms)
508
508
509 full_source_ref = resolve_ref_or_error(source_ref, source)
509 full_source_ref = resolve_ref_or_error(source_ref, source)
510 full_target_ref = resolve_ref_or_error(target_ref, target)
510 full_target_ref = resolve_ref_or_error(target_ref, target)
511 source_commit = get_commit_or_error(full_source_ref, source)
511 source_commit = get_commit_or_error(full_source_ref, source)
512 target_commit = get_commit_or_error(full_target_ref, target)
512 target_commit = get_commit_or_error(full_target_ref, target)
513 source_scm = source.scm_instance()
513 source_scm = source.scm_instance()
514 target_scm = target.scm_instance()
514 target_scm = target.scm_instance()
515
515
516 commit_ranges = target_scm.compare(
516 commit_ranges = target_scm.compare(
517 target_commit.raw_id, source_commit.raw_id, source_scm,
517 target_commit.raw_id, source_commit.raw_id, source_scm,
518 merge=True, pre_load=[])
518 merge=True, pre_load=[])
519
519
520 ancestor = target_scm.get_common_ancestor(
520 ancestor = target_scm.get_common_ancestor(
521 target_commit.raw_id, source_commit.raw_id, source_scm)
521 target_commit.raw_id, source_commit.raw_id, source_scm)
522
522
523 if not commit_ranges:
523 if not commit_ranges:
524 raise JSONRPCError('no commits found')
524 raise JSONRPCError('no commits found')
525
525
526 if not ancestor:
526 if not ancestor:
527 raise JSONRPCError('no common ancestor found')
527 raise JSONRPCError('no common ancestor found')
528
528
529 reviewer_objects = Optional.extract(reviewers) or []
529 reviewer_objects = Optional.extract(reviewers) or []
530 if not isinstance(reviewer_objects, list):
530 if not isinstance(reviewer_objects, list):
531 raise JSONRPCError('reviewers should be specified as a list')
531 raise JSONRPCError('reviewers should be specified as a list')
532
532
533 reviewers_reasons = []
533 reviewers_reasons = []
534 for reviewer_object in reviewer_objects:
534 for reviewer_object in reviewer_objects:
535 reviewer_reasons = []
535 reviewer_reasons = []
536 if isinstance(reviewer_object, (basestring, int)):
536 if isinstance(reviewer_object, (basestring, int)):
537 reviewer_username = reviewer_object
537 reviewer_username = reviewer_object
538 else:
538 else:
539 reviewer_username = reviewer_object['username']
539 reviewer_username = reviewer_object['username']
540 reviewer_reasons = reviewer_object.get('reasons', [])
540 reviewer_reasons = reviewer_object.get('reasons', [])
541
541
542 user = get_user_or_error(reviewer_username)
542 user = get_user_or_error(reviewer_username)
543 reviewers_reasons.append((user.user_id, reviewer_reasons))
543 reviewers_reasons.append((user.user_id, reviewer_reasons))
544
544
545 pull_request_model = PullRequestModel()
545 pull_request_model = PullRequestModel()
546 pull_request = pull_request_model.create(
546 pull_request = pull_request_model.create(
547 created_by=apiuser.user_id,
547 created_by=apiuser.user_id,
548 source_repo=source_repo,
548 source_repo=source_repo,
549 source_ref=full_source_ref,
549 source_ref=full_source_ref,
550 target_repo=target_repo,
550 target_repo=target_repo,
551 target_ref=full_target_ref,
551 target_ref=full_target_ref,
552 revisions=reversed(
552 revisions=reversed(
553 [commit.raw_id for commit in reversed(commit_ranges)]),
553 [commit.raw_id for commit in reversed(commit_ranges)]),
554 reviewers=reviewers_reasons,
554 reviewers=reviewers_reasons,
555 title=title,
555 title=title,
556 description=Optional.extract(description)
556 description=Optional.extract(description)
557 )
557 )
558
558
559 Session().commit()
559 Session().commit()
560 data = {
560 data = {
561 'msg': 'Created new pull request `{}`'.format(title),
561 'msg': 'Created new pull request `{}`'.format(title),
562 'pull_request_id': pull_request.pull_request_id,
562 'pull_request_id': pull_request.pull_request_id,
563 }
563 }
564 return data
564 return data
565
565
566
566
567 @jsonrpc_method()
567 @jsonrpc_method()
568 def update_pull_request(
568 def update_pull_request(
569 request, apiuser, repoid, pullrequestid, title=Optional(''),
569 request, apiuser, repoid, pullrequestid, title=Optional(''),
570 description=Optional(''), reviewers=Optional(None),
570 description=Optional(''), reviewers=Optional(None),
571 update_commits=Optional(None), close_pull_request=Optional(None)):
571 update_commits=Optional(None), close_pull_request=Optional(None)):
572 """
572 """
573 Updates a pull request.
573 Updates a pull request.
574
574
575 :param apiuser: This is filled automatically from the |authtoken|.
575 :param apiuser: This is filled automatically from the |authtoken|.
576 :type apiuser: AuthUser
576 :type apiuser: AuthUser
577 :param repoid: The repository name or repository ID.
577 :param repoid: The repository name or repository ID.
578 :type repoid: str or int
578 :type repoid: str or int
579 :param pullrequestid: The pull request ID.
579 :param pullrequestid: The pull request ID.
580 :type pullrequestid: int
580 :type pullrequestid: int
581 :param title: Set the pull request title.
581 :param title: Set the pull request title.
582 :type title: str
582 :type title: str
583 :param description: Update pull request description.
583 :param description: Update pull request description.
584 :type description: Optional(str)
584 :type description: Optional(str)
585 :param reviewers: Update pull request reviewers list with new value.
585 :param reviewers: Update pull request reviewers list with new value.
586 :type reviewers: Optional(list)
586 :type reviewers: Optional(list)
587 :param update_commits: Trigger update of commits for this pull request
587 :param update_commits: Trigger update of commits for this pull request
588 :type: update_commits: Optional(bool)
588 :type: update_commits: Optional(bool)
589 :param close_pull_request: Close this pull request with rejected state
589 :param close_pull_request: Close this pull request with rejected state
590 :type: close_pull_request: Optional(bool)
590 :type: close_pull_request: Optional(bool)
591
591
592 Example output:
592 Example output:
593
593
594 .. code-block:: bash
594 .. code-block:: bash
595
595
596 id : <id_given_in_input>
596 id : <id_given_in_input>
597 result :
597 result :
598 {
598 {
599 "msg": "Updated pull request `63`",
599 "msg": "Updated pull request `63`",
600 "pull_request": <pull_request_object>,
600 "pull_request": <pull_request_object>,
601 "updated_reviewers": {
601 "updated_reviewers": {
602 "added": [
602 "added": [
603 "username"
603 "username"
604 ],
604 ],
605 "removed": []
605 "removed": []
606 },
606 },
607 "updated_commits": {
607 "updated_commits": {
608 "added": [
608 "added": [
609 "<sha1_hash>"
609 "<sha1_hash>"
610 ],
610 ],
611 "common": [
611 "common": [
612 "<sha1_hash>",
612 "<sha1_hash>",
613 "<sha1_hash>",
613 "<sha1_hash>",
614 ],
614 ],
615 "removed": []
615 "removed": []
616 }
616 }
617 }
617 }
618 error : null
618 error : null
619 """
619 """
620
620
621 repo = get_repo_or_error(repoid)
621 repo = get_repo_or_error(repoid)
622 pull_request = get_pull_request_or_error(pullrequestid)
622 pull_request = get_pull_request_or_error(pullrequestid)
623 if not PullRequestModel().check_user_update(
623 if not PullRequestModel().check_user_update(
624 pull_request, apiuser, api=True):
624 pull_request, apiuser, api=True):
625 raise JSONRPCError(
625 raise JSONRPCError(
626 'pull request `%s` update failed, no permission to update.' % (
626 'pull request `%s` update failed, no permission to update.' % (
627 pullrequestid,))
627 pullrequestid,))
628 if pull_request.is_closed():
628 if pull_request.is_closed():
629 raise JSONRPCError(
629 raise JSONRPCError(
630 'pull request `%s` update failed, pull request is closed' % (
630 'pull request `%s` update failed, pull request is closed' % (
631 pullrequestid,))
631 pullrequestid,))
632
632
633 reviewer_objects = Optional.extract(reviewers) or []
633 reviewer_objects = Optional.extract(reviewers) or []
634 if not isinstance(reviewer_objects, list):
634 if not isinstance(reviewer_objects, list):
635 raise JSONRPCError('reviewers should be specified as a list')
635 raise JSONRPCError('reviewers should be specified as a list')
636
636
637 reviewers_reasons = []
637 reviewers_reasons = []
638 reviewer_ids = set()
638 reviewer_ids = set()
639 for reviewer_object in reviewer_objects:
639 for reviewer_object in reviewer_objects:
640 reviewer_reasons = []
640 reviewer_reasons = []
641 if isinstance(reviewer_object, (int, basestring)):
641 if isinstance(reviewer_object, (int, basestring)):
642 reviewer_username = reviewer_object
642 reviewer_username = reviewer_object
643 else:
643 else:
644 reviewer_username = reviewer_object['username']
644 reviewer_username = reviewer_object['username']
645 reviewer_reasons = reviewer_object.get('reasons', [])
645 reviewer_reasons = reviewer_object.get('reasons', [])
646
646
647 user = get_user_or_error(reviewer_username)
647 user = get_user_or_error(reviewer_username)
648 reviewer_ids.add(user.user_id)
648 reviewer_ids.add(user.user_id)
649 reviewers_reasons.append((user.user_id, reviewer_reasons))
649 reviewers_reasons.append((user.user_id, reviewer_reasons))
650
650
651 title = Optional.extract(title)
651 title = Optional.extract(title)
652 description = Optional.extract(description)
652 description = Optional.extract(description)
653 if title or description:
653 if title or description:
654 PullRequestModel().edit(
654 PullRequestModel().edit(
655 pull_request, title or pull_request.title,
655 pull_request, title or pull_request.title,
656 description or pull_request.description)
656 description or pull_request.description)
657 Session().commit()
657 Session().commit()
658
658
659 commit_changes = {"added": [], "common": [], "removed": []}
659 commit_changes = {"added": [], "common": [], "removed": []}
660 if str2bool(Optional.extract(update_commits)):
660 if str2bool(Optional.extract(update_commits)):
661 if PullRequestModel().has_valid_update_type(pull_request):
661 if PullRequestModel().has_valid_update_type(pull_request):
662 _version, _commit_changes = PullRequestModel().update_commits(
662 update_response = PullRequestModel().update_commits(
663 pull_request)
663 pull_request)
664 commit_changes = _commit_changes or commit_changes
664 commit_changes = update_response.changes or commit_changes
665 Session().commit()
665 Session().commit()
666
666
667 reviewers_changes = {"added": [], "removed": []}
667 reviewers_changes = {"added": [], "removed": []}
668 if reviewer_ids:
668 if reviewer_ids:
669 added_reviewers, removed_reviewers = \
669 added_reviewers, removed_reviewers = \
670 PullRequestModel().update_reviewers(pull_request, reviewers_reasons)
670 PullRequestModel().update_reviewers(pull_request, reviewers_reasons)
671
671
672 reviewers_changes['added'] = sorted(
672 reviewers_changes['added'] = sorted(
673 [get_user_or_error(n).username for n in added_reviewers])
673 [get_user_or_error(n).username for n in added_reviewers])
674 reviewers_changes['removed'] = sorted(
674 reviewers_changes['removed'] = sorted(
675 [get_user_or_error(n).username for n in removed_reviewers])
675 [get_user_or_error(n).username for n in removed_reviewers])
676 Session().commit()
676 Session().commit()
677
677
678 if str2bool(Optional.extract(close_pull_request)):
678 if str2bool(Optional.extract(close_pull_request)):
679 PullRequestModel().close_pull_request_with_comment(
679 PullRequestModel().close_pull_request_with_comment(
680 pull_request, apiuser, repo)
680 pull_request, apiuser, repo)
681 Session().commit()
681 Session().commit()
682
682
683 data = {
683 data = {
684 'msg': 'Updated pull request `{}`'.format(
684 'msg': 'Updated pull request `{}`'.format(
685 pull_request.pull_request_id),
685 pull_request.pull_request_id),
686 'pull_request': pull_request.get_api_data(),
686 'pull_request': pull_request.get_api_data(),
687 'updated_commits': commit_changes,
687 'updated_commits': commit_changes,
688 'updated_reviewers': reviewers_changes
688 'updated_reviewers': reviewers_changes
689 }
689 }
690
690 return data
691 return data
691
@@ -1,178 +1,178 b''
1 # -*- coding: utf-8 -*-
1 # -*- coding: utf-8 -*-
2
2
3 # Copyright (C) 2010-2016 RhodeCode GmbH
3 # Copyright (C) 2010-2016 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 import pytest
21 import pytest
22
22
23 from rhodecode.model import db
23 from rhodecode.model import db
24 from rhodecode.model.changeset_status import ChangesetStatusModel
24 from rhodecode.model.changeset_status import ChangesetStatusModel
25 from rhodecode.model.pull_request import PullRequestModel
25 from rhodecode.model.pull_request import PullRequestModel
26
26
27
27
28 pytestmark = [
28 pytestmark = [
29 pytest.mark.backends("git", "hg"),
29 pytest.mark.backends("git", "hg"),
30 ]
30 ]
31
31
32
32
33 def test_new_pull_request_is_under_review(pr_util):
33 def test_new_pull_request_is_under_review(pr_util):
34 pull_request = pr_util.create_pull_request()
34 pull_request = pr_util.create_pull_request()
35
35
36 # Expect that review status "Under Review"
36 # Expect that review status "Under Review"
37 expected_review_status = db.ChangesetStatus.STATUS_UNDER_REVIEW
37 expected_review_status = db.ChangesetStatus.STATUS_UNDER_REVIEW
38 assert pull_request.calculated_review_status() == expected_review_status
38 assert pull_request.calculated_review_status() == expected_review_status
39
39
40
40
41 @pytest.mark.parametrize("voted_status", [
41 @pytest.mark.parametrize("voted_status", [
42 db.ChangesetStatus.STATUS_APPROVED,
42 db.ChangesetStatus.STATUS_APPROVED,
43 db.ChangesetStatus.STATUS_REJECTED,
43 db.ChangesetStatus.STATUS_REJECTED,
44 db.ChangesetStatus.STATUS_UNDER_REVIEW,
44 db.ChangesetStatus.STATUS_UNDER_REVIEW,
45 ])
45 ])
46 def test_pull_request_under_review_if_one_reviewer_voted(
46 def test_pull_request_under_review_if_one_reviewer_voted(
47 pr_util, voted_status):
47 pr_util, voted_status):
48 pull_request = pr_util.create_pull_request()
48 pull_request = pr_util.create_pull_request()
49 pr_util.create_status_votes(
49 pr_util.create_status_votes(
50 voted_status, pull_request.reviewers[0])
50 voted_status, pull_request.reviewers[0])
51
51
52 # Expect that review status "Under Review"
52 # Expect that review status "Under Review"
53 expected_review_status = db.ChangesetStatus.STATUS_UNDER_REVIEW
53 expected_review_status = db.ChangesetStatus.STATUS_UNDER_REVIEW
54 assert pull_request.calculated_review_status() == expected_review_status
54 assert pull_request.calculated_review_status() == expected_review_status
55
55
56
56
57 @pytest.mark.parametrize("voted_status", [
57 @pytest.mark.parametrize("voted_status", [
58 db.ChangesetStatus.STATUS_APPROVED,
58 db.ChangesetStatus.STATUS_APPROVED,
59 db.ChangesetStatus.STATUS_REJECTED,
59 db.ChangesetStatus.STATUS_REJECTED,
60 db.ChangesetStatus.STATUS_UNDER_REVIEW,
60 db.ChangesetStatus.STATUS_UNDER_REVIEW,
61 ])
61 ])
62 def test_pull_request_has_voted_status_if_all_voted(pr_util, voted_status):
62 def test_pull_request_has_voted_status_if_all_voted(pr_util, voted_status):
63 pull_request = pr_util.create_pull_request()
63 pull_request = pr_util.create_pull_request()
64 pr_util.create_status_votes(
64 pr_util.create_status_votes(
65 voted_status, *pull_request.reviewers)
65 voted_status, *pull_request.reviewers)
66
66
67 # Expect that review status is the voted_status
67 # Expect that review status is the voted_status
68 expected_review_status = voted_status
68 expected_review_status = voted_status
69 assert pull_request.calculated_review_status() == expected_review_status
69 assert pull_request.calculated_review_status() == expected_review_status
70
70
71
71
72 @pytest.mark.parametrize("voted_status", [
72 @pytest.mark.parametrize("voted_status", [
73 db.ChangesetStatus.STATUS_APPROVED,
73 db.ChangesetStatus.STATUS_APPROVED,
74 db.ChangesetStatus.STATUS_REJECTED,
74 db.ChangesetStatus.STATUS_REJECTED,
75 db.ChangesetStatus.STATUS_UNDER_REVIEW,
75 db.ChangesetStatus.STATUS_UNDER_REVIEW,
76 ])
76 ])
77 def test_pull_request_stays_if_update_without_change(pr_util, voted_status):
77 def test_pull_request_stays_if_update_without_change(pr_util, voted_status):
78 pull_request = pr_util.create_pull_request()
78 pull_request = pr_util.create_pull_request()
79 pr_util.create_status_votes(
79 pr_util.create_status_votes(
80 voted_status, *pull_request.reviewers)
80 voted_status, *pull_request.reviewers)
81
81
82 # Update, without change
82 # Update, without change
83 version, changes = PullRequestModel().update_commits(pull_request)
83 PullRequestModel().update_commits(pull_request)
84
84
85 # Expect that review status is the voted_status
85 # Expect that review status is the voted_status
86 expected_review_status = voted_status
86 expected_review_status = voted_status
87 assert pull_request.calculated_review_status() == expected_review_status
87 assert pull_request.calculated_review_status() == expected_review_status
88
88
89
89
90 @pytest.mark.parametrize("voted_status", [
90 @pytest.mark.parametrize("voted_status", [
91 db.ChangesetStatus.STATUS_APPROVED,
91 db.ChangesetStatus.STATUS_APPROVED,
92 db.ChangesetStatus.STATUS_REJECTED,
92 db.ChangesetStatus.STATUS_REJECTED,
93 db.ChangesetStatus.STATUS_UNDER_REVIEW,
93 db.ChangesetStatus.STATUS_UNDER_REVIEW,
94 ])
94 ])
95 def test_pull_request_under_review_if_update(pr_util, voted_status):
95 def test_pull_request_under_review_if_update(pr_util, voted_status):
96 pull_request = pr_util.create_pull_request()
96 pull_request = pr_util.create_pull_request()
97 pr_util.create_status_votes(
97 pr_util.create_status_votes(
98 voted_status, *pull_request.reviewers)
98 voted_status, *pull_request.reviewers)
99
99
100 # Update, with change
100 # Update, with change
101 pr_util.update_source_repository()
101 pr_util.update_source_repository()
102 version, changes = PullRequestModel().update_commits(pull_request)
102 PullRequestModel().update_commits(pull_request)
103
103
104 # Expect that review status is the voted_status
104 # Expect that review status is the voted_status
105 expected_review_status = db.ChangesetStatus.STATUS_UNDER_REVIEW
105 expected_review_status = db.ChangesetStatus.STATUS_UNDER_REVIEW
106 assert pull_request.calculated_review_status() == expected_review_status
106 assert pull_request.calculated_review_status() == expected_review_status
107
107
108
108
109 def test_commit_under_review_if_part_of_new_pull_request(pr_util):
109 def test_commit_under_review_if_part_of_new_pull_request(pr_util):
110 pull_request = pr_util.create_pull_request()
110 pull_request = pr_util.create_pull_request()
111 for commit_id in pull_request.revisions:
111 for commit_id in pull_request.revisions:
112 status = ChangesetStatusModel().get_status(
112 status = ChangesetStatusModel().get_status(
113 repo=pr_util.source_repository, revision=commit_id)
113 repo=pr_util.source_repository, revision=commit_id)
114 assert status == db.ChangesetStatus.STATUS_UNDER_REVIEW
114 assert status == db.ChangesetStatus.STATUS_UNDER_REVIEW
115
115
116
116
117 @pytest.mark.parametrize("voted_status", [
117 @pytest.mark.parametrize("voted_status", [
118 db.ChangesetStatus.STATUS_APPROVED,
118 db.ChangesetStatus.STATUS_APPROVED,
119 db.ChangesetStatus.STATUS_REJECTED,
119 db.ChangesetStatus.STATUS_REJECTED,
120 db.ChangesetStatus.STATUS_UNDER_REVIEW,
120 db.ChangesetStatus.STATUS_UNDER_REVIEW,
121 ])
121 ])
122 def test_commit_has_voted_status_after_vote_on_pull_request(
122 def test_commit_has_voted_status_after_vote_on_pull_request(
123 pr_util, voted_status):
123 pr_util, voted_status):
124 pull_request = pr_util.create_pull_request()
124 pull_request = pr_util.create_pull_request()
125 pr_util.create_status_votes(
125 pr_util.create_status_votes(
126 voted_status, pull_request.reviewers[0])
126 voted_status, pull_request.reviewers[0])
127 for commit_id in pull_request.revisions:
127 for commit_id in pull_request.revisions:
128 status = ChangesetStatusModel().get_status(
128 status = ChangesetStatusModel().get_status(
129 repo=pr_util.source_repository, revision=commit_id)
129 repo=pr_util.source_repository, revision=commit_id)
130 assert status == voted_status
130 assert status == voted_status
131
131
132
132
133 def test_commit_under_review_if_added_to_pull_request(pr_util):
133 def test_commit_under_review_if_added_to_pull_request(pr_util):
134 pull_request = pr_util.create_pull_request()
134 pull_request = pr_util.create_pull_request()
135 pr_util.create_status_votes(
135 pr_util.create_status_votes(
136 db.ChangesetStatus.STATUS_APPROVED, pull_request.reviewers[0])
136 db.ChangesetStatus.STATUS_APPROVED, pull_request.reviewers[0])
137 added_commit_id = pr_util.add_one_commit()
137 added_commit_id = pr_util.add_one_commit()
138
138
139 status = ChangesetStatusModel().get_status(
139 status = ChangesetStatusModel().get_status(
140 repo=pr_util.source_repository, revision=added_commit_id)
140 repo=pr_util.source_repository, revision=added_commit_id)
141 assert status == db.ChangesetStatus.STATUS_UNDER_REVIEW
141 assert status == db.ChangesetStatus.STATUS_UNDER_REVIEW
142
142
143
143
144 @pytest.mark.parametrize("voted_status", [
144 @pytest.mark.parametrize("voted_status", [
145 db.ChangesetStatus.STATUS_APPROVED,
145 db.ChangesetStatus.STATUS_APPROVED,
146 db.ChangesetStatus.STATUS_REJECTED,
146 db.ChangesetStatus.STATUS_REJECTED,
147 db.ChangesetStatus.STATUS_UNDER_REVIEW,
147 db.ChangesetStatus.STATUS_UNDER_REVIEW,
148 ])
148 ])
149 def test_commit_keeps_status_if_removed_from_pull_request(
149 def test_commit_keeps_status_if_removed_from_pull_request(
150 pr_util, voted_status):
150 pr_util, voted_status):
151 pull_request = pr_util.create_pull_request()
151 pull_request = pr_util.create_pull_request()
152 pr_util.add_one_commit()
152 pr_util.add_one_commit()
153 pr_util.create_status_votes(voted_status, pull_request.reviewers[0])
153 pr_util.create_status_votes(voted_status, pull_request.reviewers[0])
154
154
155 removed_commit_id = pr_util.remove_one_commit()
155 removed_commit_id = pr_util.remove_one_commit()
156
156
157 status = ChangesetStatusModel().get_status(
157 status = ChangesetStatusModel().get_status(
158 repo=pr_util.source_repository, revision=removed_commit_id)
158 repo=pr_util.source_repository, revision=removed_commit_id)
159 assert status == voted_status
159 assert status == voted_status
160
160
161
161
162 @pytest.mark.parametrize("voted_status", [
162 @pytest.mark.parametrize("voted_status", [
163 db.ChangesetStatus.STATUS_APPROVED,
163 db.ChangesetStatus.STATUS_APPROVED,
164 db.ChangesetStatus.STATUS_REJECTED,
164 db.ChangesetStatus.STATUS_REJECTED,
165 db.ChangesetStatus.STATUS_UNDER_REVIEW,
165 db.ChangesetStatus.STATUS_UNDER_REVIEW,
166 ])
166 ])
167 def test_commit_keeps_status_if_unchanged_after_update_of_pull_request(
167 def test_commit_keeps_status_if_unchanged_after_update_of_pull_request(
168 pr_util, voted_status):
168 pr_util, voted_status):
169 pull_request = pr_util.create_pull_request()
169 pull_request = pr_util.create_pull_request()
170 commit_id = pull_request.revisions[-1]
170 commit_id = pull_request.revisions[-1]
171 pr_util.create_status_votes(voted_status, pull_request.reviewers[0])
171 pr_util.create_status_votes(voted_status, pull_request.reviewers[0])
172 pr_util.update_source_repository()
172 pr_util.update_source_repository()
173 PullRequestModel().update_commits(pull_request)
173 PullRequestModel().update_commits(pull_request)
174 assert pull_request.revisions[-1] == commit_id
174 assert pull_request.revisions[-1] == commit_id
175
175
176 status = ChangesetStatusModel().get_status(
176 status = ChangesetStatusModel().get_status(
177 repo=pr_util.source_repository, revision=commit_id)
177 repo=pr_util.source_repository, revision=commit_id)
178 assert status == voted_status
178 assert status == voted_status
General Comments 0
You need to be logged in to leave comments. Login now