Show More
@@ -87,7 +87,7 b' class TestApi(object):' | |||||
87 | id_, params = build_data(self.apikey, 'comment', args='xx') |
|
87 | id_, params = build_data(self.apikey, 'comment', args='xx') | |
88 | response = api_call(self.app, params) |
|
88 | response = api_call(self.app, params) | |
89 | expected = 'No such method: comment. ' \ |
|
89 | expected = 'No such method: comment. ' \ | |
90 | 'Similar methods: changeset_comment, comment_pull_request, ' \ |
|
90 | 'Similar methods: changeset_comment, comment_pull_request, edit_comment, ' \ | |
91 | 'get_pull_request_comments, comment_commit, get_repo_comments' |
|
91 | 'get_pull_request_comments, comment_commit, get_repo_comments' | |
92 | assert_error(id_, expected, given=response.body) |
|
92 | assert_error(id_, expected, given=response.body) | |
93 |
|
93 |
@@ -21,7 +21,7 b'' | |||||
21 | import pytest |
|
21 | import pytest | |
22 |
|
22 | |||
23 | from rhodecode.model.comment import CommentsModel |
|
23 | from rhodecode.model.comment import CommentsModel | |
24 | from rhodecode.model.db import UserLog, User |
|
24 | from rhodecode.model.db import UserLog, User, ChangesetComment | |
25 | from rhodecode.model.pull_request import PullRequestModel |
|
25 | from rhodecode.model.pull_request import PullRequestModel | |
26 | from rhodecode.tests import TEST_USER_ADMIN_LOGIN |
|
26 | from rhodecode.tests import TEST_USER_ADMIN_LOGIN | |
27 | from rhodecode.api.tests.utils import ( |
|
27 | from rhodecode.api.tests.utils import ( | |
@@ -218,8 +218,20 b' class TestCommentPullRequest(object):' | |||||
218 | assert_error(id_, expected, given=response.body) |
|
218 | assert_error(id_, expected, given=response.body) | |
219 |
|
219 | |||
220 | @pytest.mark.backends("git", "hg") |
|
220 | @pytest.mark.backends("git", "hg") | |
221 | def test_api_comment_pull_request_non_admin_with_userid_error( |
|
221 | def test_api_comment_pull_request_non_admin_with_userid_error(self, pr_util): | |
222 | self, pr_util): |
|
222 | pull_request = pr_util.create_pull_request() | |
|
223 | id_, params = build_data( | |||
|
224 | self.apikey_regular, 'comment_pull_request', | |||
|
225 | repoid=pull_request.target_repo.repo_name, | |||
|
226 | pullrequestid=pull_request.pull_request_id, | |||
|
227 | userid=TEST_USER_ADMIN_LOGIN) | |||
|
228 | response = api_call(self.app, params) | |||
|
229 | ||||
|
230 | expected = 'userid is not the same as your user' | |||
|
231 | assert_error(id_, expected, given=response.body) | |||
|
232 | ||||
|
233 | @pytest.mark.backends("git", "hg") | |||
|
234 | def test_api_comment_pull_request_non_admin_with_userid_error(self, pr_util): | |||
223 | pull_request = pr_util.create_pull_request() |
|
235 | pull_request = pr_util.create_pull_request() | |
224 | id_, params = build_data( |
|
236 | id_, params = build_data( | |
225 | self.apikey_regular, 'comment_pull_request', |
|
237 | self.apikey_regular, 'comment_pull_request', | |
@@ -244,3 +256,135 b' class TestCommentPullRequest(object):' | |||||
244 |
|
256 | |||
245 | expected = 'Invalid commit_id `XXX` for this pull request.' |
|
257 | expected = 'Invalid commit_id `XXX` for this pull request.' | |
246 | assert_error(id_, expected, given=response.body) |
|
258 | assert_error(id_, expected, given=response.body) | |
|
259 | ||||
|
260 | @pytest.mark.backends("git", "hg") | |||
|
261 | def test_api_edit_comment(self, pr_util): | |||
|
262 | pull_request = pr_util.create_pull_request() | |||
|
263 | ||||
|
264 | id_, params = build_data( | |||
|
265 | self.apikey, | |||
|
266 | 'comment_pull_request', | |||
|
267 | repoid=pull_request.target_repo.repo_name, | |||
|
268 | pullrequestid=pull_request.pull_request_id, | |||
|
269 | message='test message', | |||
|
270 | ) | |||
|
271 | response = api_call(self.app, params) | |||
|
272 | json_response = response.json | |||
|
273 | comment_id = json_response['result']['comment_id'] | |||
|
274 | ||||
|
275 | message_after_edit = 'just message' | |||
|
276 | id_, params = build_data( | |||
|
277 | self.apikey, | |||
|
278 | 'edit_comment', | |||
|
279 | comment_id=comment_id, | |||
|
280 | message=message_after_edit, | |||
|
281 | version=0, | |||
|
282 | ) | |||
|
283 | response = api_call(self.app, params) | |||
|
284 | json_response = response.json | |||
|
285 | assert json_response['result']['version'] == 1 | |||
|
286 | ||||
|
287 | text_form_db = ChangesetComment.get(comment_id).text | |||
|
288 | assert message_after_edit == text_form_db | |||
|
289 | ||||
|
290 | @pytest.mark.backends("git", "hg") | |||
|
291 | def test_api_edit_comment_wrong_version(self, pr_util): | |||
|
292 | pull_request = pr_util.create_pull_request() | |||
|
293 | ||||
|
294 | id_, params = build_data( | |||
|
295 | self.apikey, 'comment_pull_request', | |||
|
296 | repoid=pull_request.target_repo.repo_name, | |||
|
297 | pullrequestid=pull_request.pull_request_id, | |||
|
298 | message='test message') | |||
|
299 | response = api_call(self.app, params) | |||
|
300 | json_response = response.json | |||
|
301 | comment_id = json_response['result']['comment_id'] | |||
|
302 | ||||
|
303 | message_after_edit = 'just message' | |||
|
304 | id_, params = build_data( | |||
|
305 | self.apikey_regular, | |||
|
306 | 'edit_comment', | |||
|
307 | comment_id=comment_id, | |||
|
308 | message=message_after_edit, | |||
|
309 | version=1, | |||
|
310 | ) | |||
|
311 | response = api_call(self.app, params) | |||
|
312 | expected = 'comment ({}) version ({}) mismatch'.format(comment_id, 1) | |||
|
313 | assert_error(id_, expected, given=response.body) | |||
|
314 | ||||
|
315 | @pytest.mark.backends("git", "hg") | |||
|
316 | def test_api_edit_comment_wrong_version(self, pr_util): | |||
|
317 | pull_request = pr_util.create_pull_request() | |||
|
318 | ||||
|
319 | id_, params = build_data( | |||
|
320 | self.apikey, 'comment_pull_request', | |||
|
321 | repoid=pull_request.target_repo.repo_name, | |||
|
322 | pullrequestid=pull_request.pull_request_id, | |||
|
323 | message='test message') | |||
|
324 | response = api_call(self.app, params) | |||
|
325 | json_response = response.json | |||
|
326 | comment_id = json_response['result']['comment_id'] | |||
|
327 | ||||
|
328 | id_, params = build_data( | |||
|
329 | self.apikey, | |||
|
330 | 'edit_comment', | |||
|
331 | comment_id=comment_id, | |||
|
332 | message='', | |||
|
333 | version=0, | |||
|
334 | ) | |||
|
335 | response = api_call(self.app, params) | |||
|
336 | expected = "comment ({}) can't be changed with empty string".format(comment_id, 1) | |||
|
337 | assert_error(id_, expected, given=response.body) | |||
|
338 | ||||
|
339 | @pytest.mark.backends("git", "hg") | |||
|
340 | def test_api_edit_comment_wrong_user_set_by_non_admin(self, pr_util): | |||
|
341 | pull_request = pr_util.create_pull_request() | |||
|
342 | pull_request_id = pull_request.pull_request_id | |||
|
343 | id_, params = build_data( | |||
|
344 | self.apikey, | |||
|
345 | 'comment_pull_request', | |||
|
346 | repoid=pull_request.target_repo.repo_name, | |||
|
347 | pullrequestid=pull_request_id, | |||
|
348 | message='test message' | |||
|
349 | ) | |||
|
350 | response = api_call(self.app, params) | |||
|
351 | json_response = response.json | |||
|
352 | comment_id = json_response['result']['comment_id'] | |||
|
353 | ||||
|
354 | id_, params = build_data( | |||
|
355 | self.apikey_regular, | |||
|
356 | 'edit_comment', | |||
|
357 | comment_id=comment_id, | |||
|
358 | message='just message', | |||
|
359 | version=0, | |||
|
360 | userid=TEST_USER_ADMIN_LOGIN | |||
|
361 | ) | |||
|
362 | response = api_call(self.app, params) | |||
|
363 | expected = 'userid is not the same as your user' | |||
|
364 | assert_error(id_, expected, given=response.body) | |||
|
365 | ||||
|
366 | @pytest.mark.backends("git", "hg") | |||
|
367 | def test_api_edit_comment_wrong_user_with_permissions_to_edit_comment(self, pr_util): | |||
|
368 | pull_request = pr_util.create_pull_request() | |||
|
369 | pull_request_id = pull_request.pull_request_id | |||
|
370 | id_, params = build_data( | |||
|
371 | self.apikey, | |||
|
372 | 'comment_pull_request', | |||
|
373 | repoid=pull_request.target_repo.repo_name, | |||
|
374 | pullrequestid=pull_request_id, | |||
|
375 | message='test message' | |||
|
376 | ) | |||
|
377 | response = api_call(self.app, params) | |||
|
378 | json_response = response.json | |||
|
379 | comment_id = json_response['result']['comment_id'] | |||
|
380 | ||||
|
381 | id_, params = build_data( | |||
|
382 | self.apikey_regular, | |||
|
383 | 'edit_comment', | |||
|
384 | comment_id=comment_id, | |||
|
385 | message='just message', | |||
|
386 | version=0, | |||
|
387 | ) | |||
|
388 | response = api_call(self.app, params) | |||
|
389 | expected = "you don't have access to edit this comment" | |||
|
390 | assert_error(id_, expected, given=response.body) |
@@ -37,7 +37,7 b' class TestGetMethod(object):' | |||||
37 | id_, params = build_data(self.apikey, 'get_method', pattern='*comment*') |
|
37 | id_, params = build_data(self.apikey, 'get_method', pattern='*comment*') | |
38 | response = api_call(self.app, params) |
|
38 | response = api_call(self.app, params) | |
39 |
|
39 | |||
40 | expected = ['changeset_comment', 'comment_pull_request', |
|
40 | expected = ['changeset_comment', 'comment_pull_request', 'edit_comment', | |
41 | 'get_pull_request_comments', 'comment_commit', 'get_repo_comments'] |
|
41 | 'get_pull_request_comments', 'comment_commit', 'get_repo_comments'] | |
42 | assert_ok(id_, expected, given=response.body) |
|
42 | assert_ok(id_, expected, given=response.body) | |
43 |
|
43 |
@@ -21,13 +21,13 b'' | |||||
21 |
|
21 | |||
22 | import logging |
|
22 | import logging | |
23 |
|
23 | |||
24 | from rhodecode import events |
|
|||
25 | from rhodecode.api import jsonrpc_method, JSONRPCError, JSONRPCValidationError |
|
24 | from rhodecode.api import jsonrpc_method, JSONRPCError, JSONRPCValidationError | |
26 | from rhodecode.api.utils import ( |
|
25 | from rhodecode.api.utils import ( | |
27 | has_superadmin_permission, Optional, OAttr, get_repo_or_error, |
|
26 | has_superadmin_permission, Optional, OAttr, get_repo_or_error, | |
28 | 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, | |
29 | validate_repo_permissions, resolve_ref_or_error, validate_set_owner_permissions) |
|
28 | validate_repo_permissions, resolve_ref_or_error, validate_set_owner_permissions) | |
30 | from rhodecode.lib.auth import (HasRepoPermissionAnyApi) |
|
29 | from rhodecode.lib.auth import (HasRepoPermissionAnyApi) | |
|
30 | from rhodecode.lib.exceptions import CommentVersionMismatch | |||
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 | |
@@ -292,10 +292,11 b' def merge_pull_request(' | |||||
292 | else: |
|
292 | else: | |
293 | repo = pull_request.target_repo |
|
293 | repo = pull_request.target_repo | |
294 | auth_user = apiuser |
|
294 | auth_user = apiuser | |
|
295 | ||||
295 | if not isinstance(userid, Optional): |
|
296 | if not isinstance(userid, Optional): | |
296 | if (has_superadmin_permission(apiuser) or |
|
297 | is_repo_admin = HasRepoPermissionAnyApi('repository.admin')( | |
297 | HasRepoPermissionAnyApi('repository.admin')( |
|
298 | user=apiuser, repo_name=repo.repo_name) | |
298 | user=apiuser, repo_name=repo.repo_name)): |
|
299 | if has_superadmin_permission(apiuser) or is_repo_admin: | |
299 | apiuser = get_user_or_error(userid) |
|
300 | apiuser = get_user_or_error(userid) | |
300 | auth_user = apiuser.AuthUser() |
|
301 | auth_user = apiuser.AuthUser() | |
301 | else: |
|
302 | else: | |
@@ -510,9 +511,9 b' def comment_pull_request(' | |||||
510 |
|
511 | |||
511 | auth_user = apiuser |
|
512 | auth_user = apiuser | |
512 | if not isinstance(userid, Optional): |
|
513 | if not isinstance(userid, Optional): | |
513 | if (has_superadmin_permission(apiuser) or |
|
514 | is_repo_admin = HasRepoPermissionAnyApi('repository.admin')( | |
514 | HasRepoPermissionAnyApi('repository.admin')( |
|
515 | user=apiuser, repo_name=repo.repo_name) | |
515 | user=apiuser, repo_name=repo.repo_name)): |
|
516 | if has_superadmin_permission(apiuser) or is_repo_admin: | |
516 | apiuser = get_user_or_error(userid) |
|
517 | apiuser = get_user_or_error(userid) | |
517 | auth_user = apiuser.AuthUser() |
|
518 | auth_user = apiuser.AuthUser() | |
518 | else: |
|
519 | else: | |
@@ -632,6 +633,79 b' def comment_pull_request(' | |||||
632 |
|
633 | |||
633 |
|
634 | |||
634 | @jsonrpc_method() |
|
635 | @jsonrpc_method() | |
|
636 | def edit_comment( | |||
|
637 | request, apiuser, message, comment_id, version, | |||
|
638 | userid=Optional(OAttr('apiuser')), | |||
|
639 | ): | |||
|
640 | """ | |||
|
641 | Edit comment on the pull request or commit, | |||
|
642 | specified by the `comment_id` and version. Initially version should be 0 | |||
|
643 | ||||
|
644 | :param apiuser: This is filled automatically from the |authtoken|. | |||
|
645 | :type apiuser: AuthUser | |||
|
646 | :param comment_id: Specify the comment_id for editing | |||
|
647 | :type comment_id: int | |||
|
648 | :param version: version of the comment that will be created, starts from 0 | |||
|
649 | :type version: int | |||
|
650 | :param message: The text content of the comment. | |||
|
651 | :type message: str | |||
|
652 | :param userid: Comment on the pull request as this user | |||
|
653 | :type userid: Optional(str or int) | |||
|
654 | ||||
|
655 | Example output: | |||
|
656 | ||||
|
657 | .. code-block:: bash | |||
|
658 | ||||
|
659 | id : <id_given_in_input> | |||
|
660 | result : { | |||
|
661 | "comment_history_id": "<Integer>", | |||
|
662 | "version": "<Integer>", | |||
|
663 | }, | |||
|
664 | error : null | |||
|
665 | """ | |||
|
666 | ||||
|
667 | auth_user = apiuser | |||
|
668 | comment = ChangesetComment.get(comment_id) | |||
|
669 | ||||
|
670 | is_super_admin = has_superadmin_permission(apiuser) | |||
|
671 | is_repo_admin = HasRepoPermissionAnyApi('repository.admin') \ | |||
|
672 | (user=apiuser, repo_name=comment.repo.repo_name) | |||
|
673 | ||||
|
674 | if not isinstance(userid, Optional): | |||
|
675 | if is_super_admin or is_repo_admin: | |||
|
676 | apiuser = get_user_or_error(userid) | |||
|
677 | auth_user = apiuser.AuthUser() | |||
|
678 | else: | |||
|
679 | raise JSONRPCError('userid is not the same as your user') | |||
|
680 | ||||
|
681 | comment_author = comment.author.user_id == auth_user.user_id | |||
|
682 | if not (comment.immutable is False and (is_super_admin or is_repo_admin) or comment_author): | |||
|
683 | raise JSONRPCError("you don't have access to edit this comment") | |||
|
684 | ||||
|
685 | try: | |||
|
686 | comment_history = CommentsModel().edit( | |||
|
687 | comment_id=comment_id, | |||
|
688 | text=message, | |||
|
689 | auth_user=auth_user, | |||
|
690 | version=version, | |||
|
691 | ) | |||
|
692 | Session().commit() | |||
|
693 | except CommentVersionMismatch: | |||
|
694 | raise JSONRPCError( | |||
|
695 | 'comment ({}) version ({}) mismatch'.format(comment_id, version) | |||
|
696 | ) | |||
|
697 | if not comment_history and not message: | |||
|
698 | raise JSONRPCError( | |||
|
699 | "comment ({}) can't be changed with empty string".format(comment_id) | |||
|
700 | ) | |||
|
701 | data = { | |||
|
702 | 'comment_history_id': comment_history.comment_history_id if comment_history else None, | |||
|
703 | 'version': comment_history.version if comment_history else None, | |||
|
704 | } | |||
|
705 | return data | |||
|
706 | ||||
|
707 | ||||
|
708 | @jsonrpc_method() | |||
635 | def create_pull_request( |
|
709 | def create_pull_request( | |
636 | request, apiuser, source_repo, target_repo, source_ref, target_ref, |
|
710 | request, apiuser, source_repo, target_repo, source_ref, target_ref, | |
637 | owner=Optional(OAttr('apiuser')), title=Optional(''), description=Optional(''), |
|
711 | owner=Optional(OAttr('apiuser')), title=Optional(''), description=Optional(''), | |
@@ -979,10 +1053,10 b' def close_pull_request(' | |||||
979 | else: |
|
1053 | else: | |
980 | repo = pull_request.target_repo |
|
1054 | repo = pull_request.target_repo | |
981 |
|
1055 | |||
|
1056 | is_repo_admin = HasRepoPermissionAnyApi('repository.admin')( | |||
|
1057 | user=apiuser, repo_name=repo.repo_name) | |||
982 | if not isinstance(userid, Optional): |
|
1058 | if not isinstance(userid, Optional): | |
983 |
if |
|
1059 | if has_superadmin_permission(apiuser) or is_repo_admin: | |
984 | HasRepoPermissionAnyApi('repository.admin')( |
|
|||
985 | user=apiuser, repo_name=repo.repo_name)): |
|
|||
986 | apiuser = get_user_or_error(userid) |
|
1060 | apiuser = get_user_or_error(userid) | |
987 | else: |
|
1061 | else: | |
988 | raise JSONRPCError('userid is not the same as your user') |
|
1062 | raise JSONRPCError('userid is not the same as your user') |
General Comments 0
You need to be logged in to leave comments.
Login now