OLD | NEW |
---|---|
1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
2 # Copyright (c) 2012 The Chromium Authors. All rights reserved. | 2 # Copyright (c) 2012 The Chromium Authors. All rights reserved. |
3 # Use of this source code is governed by a BSD-style license that can be | 3 # Use of this source code is governed by a BSD-style license that can be |
4 # found in the LICENSE file. | 4 # found in the LICENSE file. |
5 | 5 |
6 # Copyright (C) 2008 Evan Martin <martine@danga.com> | 6 # Copyright (C) 2008 Evan Martin <martine@danga.com> |
7 | 7 |
8 """A git-command for integrating reviews on Rietveld and Gerrit.""" | 8 """A git-command for integrating reviews on Rietveld and Gerrit.""" |
9 | 9 |
10 from distutils.version import LooseVersion | 10 from distutils.version import LooseVersion |
(...skipping 2500 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
2511 # whitespace. This code is not doing this, but it clearly won't decrease | 2511 # whitespace. This code is not doing this, but it clearly won't decrease |
2512 # entropy. | 2512 # entropy. |
2513 lines.append(message) | 2513 lines.append(message) |
2514 change_hash = RunCommand(['git', 'hash-object', '-t', 'commit', '--stdin'], | 2514 change_hash = RunCommand(['git', 'hash-object', '-t', 'commit', '--stdin'], |
2515 stdin='\n'.join(lines)) | 2515 stdin='\n'.join(lines)) |
2516 return 'I%s' % change_hash.strip() | 2516 return 'I%s' % change_hash.strip() |
2517 | 2517 |
2518 | 2518 |
2519 def GerritUpload(options, args, cl, change): | 2519 def GerritUpload(options, args, cl, change): |
2520 """upload the current branch to gerrit.""" | 2520 """upload the current branch to gerrit.""" |
2521 # TODO(tandrii): refactor this to be a method of _GerritChangelistImpl, | |
2522 # to avoid private members accessors below. | |
2523 | |
2521 # We assume the remote called "origin" is the one we want. | 2524 # We assume the remote called "origin" is the one we want. |
2522 # It is probably not worthwhile to support different workflows. | 2525 # It is probably not worthwhile to support different workflows. |
2523 gerrit_remote = 'origin' | 2526 gerrit_remote = 'origin' |
2524 | 2527 |
2525 remote, remote_branch = cl.GetRemoteBranch() | 2528 remote, remote_branch = cl.GetRemoteBranch() |
2526 branch = GetTargetRef(remote, remote_branch, options.target_branch, | 2529 branch = GetTargetRef(remote, remote_branch, options.target_branch, |
2527 pending_prefix='') | 2530 pending_prefix='') |
2528 | 2531 |
2529 change_desc = ChangeDescription( | |
2530 options.message or CreateDescriptionFromLog(args)) | |
2531 if not change_desc.description: | |
2532 print "\nDescription is empty. Aborting..." | |
2533 return 1 | |
2534 | |
2535 if options.title: | 2532 if options.title: |
2536 print "\nPatch titles (-t) are not supported in Gerrit. Aborting..." | 2533 print "\nPatch titles (-t) are not supported in Gerrit. Aborting..." |
2537 return 1 | 2534 return 1 |
2538 | 2535 |
2539 if options.squash: | 2536 if options.squash: |
2540 # Try to get the message from a previous upload. | 2537 if cl.GetIssue(): |
2541 shadow_branch = 'refs/heads/git_cl_uploads/' + cl.GetBranch() | 2538 # Try to get the message from a previous upload. |
2542 message = RunGitSilent(['show', '--format=%B', '-s', shadow_branch]) | 2539 message = cl.GetDescription() |
2543 if not message: | 2540 if not message: |
2541 DieWithError( | |
2542 'failed to fetch description from current Gerrit issue %d\n' | |
2543 '%s' % (cl.GetIssue(), cl.GetIssueURL())) | |
2544 change_id = cl._codereview_impl._GetChangeDetail([])['change_id'] | |
2545 footer_change_ids = git_footers.get_footer_change_id(message) | |
2546 if footer_change_ids != [change_id]: | |
2547 while footer_change_ids: | |
2548 # There is already a valid footer but with different or several ids. | |
2549 # Doing this automatically is non-trivial as we don't want to loose | |
2550 # existing other footers, yet we want to append just 1 desired | |
2551 # Change-Id. That's non-trival, so just create new footer, but let | |
2552 # user verify the new description. | |
2553 message = '%s\n\nChange-Id: %s' % (message, change_id) | |
2554 print(( | |
2555 'WARNING: issue %s has Change-Id footer(s):\n' | |
2556 ' %s\n' | |
2557 'but issue has Change-Id %s, according to Gerrit.\n' | |
2558 'Please, check the proposed correction to the description,\n' | |
2559 'and edit it if necessary but keep the "Change-Id: %s" footer\n' | |
2560 ) % (cl.GetIssue(), '\n '.join(footer_change_ids), change_id, | |
2561 change_id, cl.GetIssueUrl())) | |
2562 ask_for_data('Press enter to edit now, Ctrl+C to abort') | |
2563 if options.force: | |
Bernhard Bauer
2016/03/29 13:27:38
Why do we do this only if force is _set_?
tandrii(chromium)
2016/03/29 14:46:32
good catch, missing "not".
| |
2564 change_desc = ChangeDescription(message) | |
2565 change_desc.prompt() | |
2566 message = change_desc.description | |
2567 if not message: | |
2568 DieWithError("Description is empty. Aborting...") | |
2569 footer_change_ids = git_footers.get_footer_change_id(message) | |
2570 if footer_change_ids == [change_id] or not footer_change_ids: | |
2571 break | |
2572 continue | |
Bernhard Bauer
2016/03/29 13:27:38
This is the last statement in the body of a while
tandrii(chromium)
2016/03/29 14:46:32
Yep, but I thought reading is easier that way.
| |
2573 if not footer_change_ids: | |
2574 message = git_footers.add_footer_change_id(message, change_id) | |
2575 print('WARNING: appended missing Change-Id to issue description') | |
2576 # Sanity check of this code - we should end up with proper message footer. | |
2577 assert [change_id] == git_footers.get_footer_change_id(message) | |
2578 change_desc = ChangeDescription(message) | |
2579 else: | |
2580 change_desc = ChangeDescription( | |
2581 options.message or CreateDescriptionFromLog(args)) | |
2544 if not options.force: | 2582 if not options.force: |
2545 change_desc.prompt() | 2583 change_desc.prompt() |
2546 if not change_desc.description: | 2584 if not change_desc.description: |
2547 print "Description is empty; aborting." | 2585 DieWithError("Description is empty. Aborting...") |
2548 return 1 | |
2549 message = change_desc.description | 2586 message = change_desc.description |
2550 change_ids = git_footers.get_footer_change_id(message) | 2587 change_ids = git_footers.get_footer_change_id(message) |
2551 if len(change_ids) > 1: | 2588 if len(change_ids) > 1: |
2552 DieWithError('too many Change-Id footers in %s branch' % shadow_branch) | 2589 DieWithError('too many Change-Id footers, at most 1 allowed.') |
2553 if not change_ids: | 2590 if not change_ids: |
2591 # Generate the Change-Id automatically. | |
2554 message = git_footers.add_footer_change_id( | 2592 message = git_footers.add_footer_change_id( |
2555 message, GenerateGerritChangeId(message)) | 2593 message, GenerateGerritChangeId(message)) |
2556 change_desc.set_description(message) | 2594 change_desc.set_description(message) |
2557 change_ids = git_footers.get_footer_change_id(message) | 2595 change_ids = git_footers.get_footer_change_id(message) |
2558 assert len(change_ids) == 1 | 2596 assert len(change_ids) == 1 |
2559 | |
2560 change_id = change_ids[0] | 2597 change_id = change_ids[0] |
2561 | 2598 |
2562 remote, upstream_branch = cl.FetchUpstreamTuple(cl.GetBranch()) | 2599 remote, upstream_branch = cl.FetchUpstreamTuple(cl.GetBranch()) |
2563 if remote is '.': | 2600 if remote is '.': |
2564 # If our upstream branch is local, we base our squashed commit on its | 2601 # If our upstream branch is local, we base our squashed commit on its |
2565 # squashed version. | 2602 # squashed version. |
2566 parent = ('refs/heads/git_cl_uploads/' + | 2603 upstream_branch_name = scm.GIT.ShortBranchName(upstream_branch) |
2567 scm.GIT.ShortBranchName(upstream_branch)) | 2604 # Check the squashed hash of the parent. |
2568 | 2605 parent = RunGit(['config', |
2569 # Verify that the upstream branch has been uploaded too, otherwise Gerrit | 2606 'branch.%s.gerritsquashhash' % upstream_branch_name], |
2570 # will create additional CLs when uploading. | 2607 error_ok=True).strip() |
2571 if (RunGitSilent(['rev-parse', upstream_branch + ':']) != | 2608 # Verify that the upstream branch has been uploaded too, otherwise |
2572 RunGitSilent(['rev-parse', parent + ':'])): | 2609 # Gerrit will create additional CLs when uploading. |
2573 print 'Upload upstream branch ' + upstream_branch + ' first.' | 2610 if not parent or (RunGitSilent(['rev-parse', upstream_branch + ':']) != |
2574 return 1 | 2611 RunGitSilent(['rev-parse', parent + ':'])): |
2612 # TODO(tandrii): remove "old depot_tools" part on April 12, 2016. | |
2613 DieWithError( | |
2614 'Upload upstream branch %s first.\n' | |
2615 'Note: maybe you\'ve uploaded it with --no-squash or with an old\n' | |
2616 ' version of depot_tools. If so, then re-upload it with:\n' | |
2617 ' git cl upload --squash\n' % upstream_branch_name) | |
2575 else: | 2618 else: |
2576 parent = cl.GetCommonAncestorWithUpstream() | 2619 parent = cl.GetCommonAncestorWithUpstream() |
2577 | 2620 |
2578 tree = RunGit(['rev-parse', 'HEAD:']).strip() | 2621 tree = RunGit(['rev-parse', 'HEAD:']).strip() |
2579 ref_to_push = RunGit(['commit-tree', tree, '-p', parent, | 2622 ref_to_push = RunGit(['commit-tree', tree, '-p', parent, |
2580 '-m', message]).strip() | 2623 '-m', message]).strip() |
2581 else: | 2624 else: |
2625 change_desc = ChangeDescription( | |
2626 options.message or CreateDescriptionFromLog(args)) | |
2627 if not change_desc.description: | |
2628 DieWithError("Description is empty. Aborting...") | |
2629 | |
2582 if not git_footers.get_footer_change_id(change_desc.description): | 2630 if not git_footers.get_footer_change_id(change_desc.description): |
2583 DownloadGerritHook(False) | 2631 DownloadGerritHook(False) |
2584 change_desc.set_description(AddChangeIdToCommitMessage(options, args)) | 2632 change_desc.set_description(AddChangeIdToCommitMessage(options, args)) |
2585 ref_to_push = 'HEAD' | 2633 ref_to_push = 'HEAD' |
2586 parent = '%s/%s' % (gerrit_remote, branch) | 2634 parent = '%s/%s' % (gerrit_remote, branch) |
2587 change_id = git_footers.get_footer_change_id(change_desc.description)[0] | 2635 change_id = git_footers.get_footer_change_id(change_desc.description)[0] |
2588 | 2636 |
2637 assert change_desc | |
2589 commits = RunGitSilent(['rev-list', '%s..%s' % (parent, | 2638 commits = RunGitSilent(['rev-list', '%s..%s' % (parent, |
2590 ref_to_push)]).splitlines() | 2639 ref_to_push)]).splitlines() |
2591 if len(commits) > 1: | 2640 if len(commits) > 1: |
2592 print('WARNING: This will upload %d commits. Run the following command ' | 2641 print('WARNING: This will upload %d commits. Run the following command ' |
2593 'to see which commits will be uploaded: ' % len(commits)) | 2642 'to see which commits will be uploaded: ' % len(commits)) |
2594 print('git log %s..%s' % (parent, ref_to_push)) | 2643 print('git log %s..%s' % (parent, ref_to_push)) |
2595 print('You can also use `git squash-branch` to squash these into a single ' | 2644 print('You can also use `git squash-branch` to squash these into a single ' |
2596 'commit.') | 2645 'commit.') |
2597 ask_for_data('About to upload; enter to confirm.') | 2646 ask_for_data('About to upload; enter to confirm.') |
2598 | 2647 |
(...skipping 26 matching lines...) Expand all Loading... | |
2625 if options.squash: | 2674 if options.squash: |
2626 regex = re.compile(r'remote:\s+https?://[\w\-\.\/]*/(\d+)\s.*') | 2675 regex = re.compile(r'remote:\s+https?://[\w\-\.\/]*/(\d+)\s.*') |
2627 change_numbers = [m.group(1) | 2676 change_numbers = [m.group(1) |
2628 for m in map(regex.match, push_stdout.splitlines()) | 2677 for m in map(regex.match, push_stdout.splitlines()) |
2629 if m] | 2678 if m] |
2630 if len(change_numbers) != 1: | 2679 if len(change_numbers) != 1: |
2631 DieWithError( | 2680 DieWithError( |
2632 ('Created|Updated %d issues on Gerrit, but only 1 expected.\n' | 2681 ('Created|Updated %d issues on Gerrit, but only 1 expected.\n' |
2633 'Change-Id: %s') % (len(change_numbers), change_id)) | 2682 'Change-Id: %s') % (len(change_numbers), change_id)) |
2634 cl.SetIssue(change_numbers[0]) | 2683 cl.SetIssue(change_numbers[0]) |
2635 head = RunGit(['rev-parse', 'HEAD']).strip() | 2684 RunGit(['config', 'branch.%s.gerritsquashhash' % cl.GetBranch(), |
2636 RunGit(['update-ref', '-m', 'Uploaded ' + head, shadow_branch, ref_to_push]) | 2685 ref_to_push]) |
2637 return 0 | 2686 return 0 |
2638 | 2687 |
2639 | 2688 |
2640 def GetTargetRef(remote, remote_branch, target_branch, pending_prefix): | 2689 def GetTargetRef(remote, remote_branch, target_branch, pending_prefix): |
2641 """Computes the remote branch ref to use for the CL. | 2690 """Computes the remote branch ref to use for the CL. |
2642 | 2691 |
2643 Args: | 2692 Args: |
2644 remote (str): The git remote for the CL. | 2693 remote (str): The git remote for the CL. |
2645 remote_branch (str): The git remote branch for the CL. | 2694 remote_branch (str): The git remote branch for the CL. |
2646 target_branch (str): The target branch specified by the user. | 2695 target_branch (str): The target branch specified by the user. |
(...skipping 270 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
2917 auth.add_auth_options(parser) | 2966 auth.add_auth_options(parser) |
2918 (options, args) = parser.parse_args(args) | 2967 (options, args) = parser.parse_args(args) |
2919 auth_config = auth.extract_auth_config_from_options(options) | 2968 auth_config = auth.extract_auth_config_from_options(options) |
2920 | 2969 |
2921 if git_common.is_dirty_git_tree('upload'): | 2970 if git_common.is_dirty_git_tree('upload'): |
2922 return 1 | 2971 return 1 |
2923 | 2972 |
2924 options.reviewers = cleanup_list(options.reviewers) | 2973 options.reviewers = cleanup_list(options.reviewers) |
2925 options.cc = cleanup_list(options.cc) | 2974 options.cc = cleanup_list(options.cc) |
2926 | 2975 |
2976 # For sanity of test expectations, do this otherwise lazy-loading *now*. | |
2977 settings.GetIsGerrit() | |
2978 | |
2927 cl = Changelist(auth_config=auth_config) | 2979 cl = Changelist(auth_config=auth_config) |
2928 if args: | 2980 if args: |
2929 # TODO(ukai): is it ok for gerrit case? | 2981 # TODO(ukai): is it ok for gerrit case? |
2930 base_branch = args[0] | 2982 base_branch = args[0] |
2931 else: | 2983 else: |
2932 if cl.GetBranch() is None: | 2984 if cl.GetBranch() is None: |
2933 DieWithError('Can\'t upload from detached HEAD state. Get on a branch!') | 2985 DieWithError('Can\'t upload from detached HEAD state. Get on a branch!') |
2934 | 2986 |
2935 # Default to diffing against common ancestor of upstream branch | 2987 # Default to diffing against common ancestor of upstream branch |
2936 base_branch = cl.GetCommonAncestorWithUpstream() | 2988 base_branch = cl.GetCommonAncestorWithUpstream() |
(...skipping 1389 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
4326 if __name__ == '__main__': | 4378 if __name__ == '__main__': |
4327 # These affect sys.stdout so do it outside of main() to simplify mocks in | 4379 # These affect sys.stdout so do it outside of main() to simplify mocks in |
4328 # unit testing. | 4380 # unit testing. |
4329 fix_encoding.fix_encoding() | 4381 fix_encoding.fix_encoding() |
4330 colorama.init() | 4382 colorama.init() |
4331 try: | 4383 try: |
4332 sys.exit(main(sys.argv[1:])) | 4384 sys.exit(main(sys.argv[1:])) |
4333 except KeyboardInterrupt: | 4385 except KeyboardInterrupt: |
4334 sys.stderr.write('interrupted\n') | 4386 sys.stderr.write('interrupted\n') |
4335 sys.exit(1) | 4387 sys.exit(1) |
OLD | NEW |