2
0

forward-merge 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. #!/usr/bin/ruby
  2. require 'json'
  3. require 'net/http'
  4. require 'yaml'
  5. require 'logger'
  6. $log = Logger.new(STDOUT)
  7. $log.level = Logger::WARN
  8. class ForwardMerge
  9. attr_reader :issue, :milestone, :message, :line
  10. def initialize(issue, milestone, message, line)
  11. @issue = issue
  12. @milestone = milestone
  13. @message = message
  14. @line = line
  15. end
  16. end
  17. def find_forward_merges(message_file)
  18. $log.debug "Searching for forward merge"
  19. rev=`git rev-parse -q --verify MERGE_HEAD`.strip
  20. $log.debug "Found #{rev} from git rev-parse"
  21. return nil unless rev
  22. message = File.read(message_file)
  23. forward_merges = []
  24. message.each_line do |line|
  25. $log.debug "Checking #{line} for message"
  26. match = /^(?:Fixes|Closes) gh-(\d+) in (\d\.\d\.[\dx](?:[\.\-](?:M|RC)\d)?)$/.match(line)
  27. if match then
  28. issue = match[1]
  29. milestone = match[2]
  30. $log.debug "Matched reference to issue #{issue} in milestone #{milestone}"
  31. forward_merges << ForwardMerge.new(issue, milestone, message, line)
  32. end
  33. end
  34. $log.debug "No match in merge message" unless forward_merges
  35. return forward_merges
  36. end
  37. def get_issue(username, password, repository, number)
  38. $log.debug "Getting issue #{number} from GitHub repository #{repository}"
  39. uri = URI("https://api.github.com/repos/#{repository}/issues/#{number}")
  40. http = Net::HTTP.new(uri.host, uri.port)
  41. http.use_ssl=true
  42. request = Net::HTTP::Get.new(uri.path)
  43. request.basic_auth(username, password)
  44. response = http.request(request)
  45. $log.debug "Get HTTP response #{response.code}"
  46. return JSON.parse(response.body) unless response.code != '200'
  47. puts "Failed to retrieve issue #{number}: #{response.message}"
  48. exit 1
  49. end
  50. def find_milestone(username, password, repository, title)
  51. $log.debug "Finding milestone #{title} from GitHub repository #{repository}"
  52. uri = URI("https://api.github.com/repos/#{repository}/milestones")
  53. http = Net::HTTP.new(uri.host, uri.port)
  54. http.use_ssl=true
  55. request = Net::HTTP::Get.new(uri.path)
  56. request.basic_auth(username, password)
  57. response = http.request(request)
  58. milestones = JSON.parse(response.body)
  59. if title.end_with?(".x")
  60. prefix = title.delete_suffix('.x')
  61. $log.debug "Finding nearest milestone from candidates starting with #{prefix}"
  62. titles = milestones.map { |milestone| milestone['title'] }
  63. titles = titles.select{ |title| title.start_with?(prefix) unless title.end_with?('.x')}
  64. titles = titles.sort_by { |v| Gem::Version.new(v) }
  65. $log.debug "Considering candidates #{titles}"
  66. if(titles.empty?)
  67. puts "Cannot find nearest milestone for prefix #{title}"
  68. exit 1
  69. end
  70. title = titles.first
  71. $log.debug "Found nearest milestone #{title}"
  72. end
  73. milestones.each do |milestone|
  74. $log.debug "Considering #{milestone['title']}"
  75. return milestone['number'] if milestone['title'] == title
  76. end
  77. puts "Milestone #{title} not found in #{repository}"
  78. exit 1
  79. end
  80. def create_issue(username, password, repository, original, title, labels, milestone, milestone_name, dry_run)
  81. $log.debug "Finding forward-merge issue in GitHub repository #{repository} for '#{title}'"
  82. uri = URI("https://api.github.com/repos/#{repository}/issues")
  83. http = Net::HTTP.new(uri.host, uri.port)
  84. http.use_ssl=true
  85. request = Net::HTTP::Post.new(uri.path, 'Content-Type' => 'application/json')
  86. request.basic_auth(username, password)
  87. request.body = {
  88. title: title,
  89. labels: labels,
  90. milestone: milestone.to_i,
  91. body: "Forward port of issue ##{original} to #{milestone_name}."
  92. }.to_json
  93. if dry_run then
  94. puts "Dry run"
  95. puts "POSTing to #{uri} with body #{request.body}"
  96. return "dry-run"
  97. end
  98. response = JSON.parse(http.request(request).body)
  99. $log.debug "Created new issue #{response['number']}"
  100. return response['number']
  101. end
  102. $log.debug "Running forward-merge hook script"
  103. message_file=ARGV[0]
  104. forward_merges = find_forward_merges(message_file)
  105. exit 0 unless forward_merges
  106. $log.debug "Loading config from ~/.spring-boot/forward_merge.yml"
  107. config = YAML.load_file(File.join(Dir.home, '.spring-boot', 'forward-merge.yml'))
  108. username = config['github']['credentials']['username']
  109. password = config['github']['credentials']['password']
  110. dry_run = config['dry_run']
  111. repository = 'spring-projects/spring-security'
  112. forward_merges.each do |forward_merge|
  113. existing_issue = get_issue(username, password, repository, forward_merge.issue)
  114. title = existing_issue['title']
  115. labels = existing_issue['labels'].map { |label| label['name'] }
  116. labels << "status: forward-port"
  117. $log.debug "Processing issue '#{title}'"
  118. milestone = find_milestone(username, password, repository, forward_merge.milestone)
  119. new_issue_number = create_issue(username, password, repository, forward_merge.issue, title, labels, milestone, forward_merge.milestone, dry_run)
  120. puts "Created gh-#{new_issue_number} for forward port of gh-#{forward_merge.issue} into #{forward_merge.milestone}"
  121. rewritten_message = forward_merge.message.sub(forward_merge.line, "Closes gh-#{new_issue_number}\n")
  122. File.write(message_file, rewritten_message)
  123. end