lib/tutter/action/sppuppet.rb in tutter-sppuppet-0.0.17 vs lib/tutter/action/sppuppet.rb in tutter-sppuppet-0.0.18
- old
+ new
@@ -11,111 +11,114 @@
@project = project
@data = data
@event = event
end
- def debug(message)
- puts message if @debug
- end
-
def run
- # If a new pull request is opened, comment with instructions
- if @data['action'] == 'opened' && @settings['post_instructions']
- issue = @data['number']
- comment = @settings['instructions'] || "To merge at least #{@settings['plus_ones_required']} person other than the submitter needs to write a comment with saying _+1_ or :+1:. Then write _!merge_ or :shipit: to trigger the merging."
- begin
- @client.add_comment(@project, issue, comment)
- return 200, "Commented!"
- rescue Octokit::NotFound
- return 404, "Octokit returned 404, this could be an issue with your access token"
- rescue Octokit::Unauthorized
- return 401, "Authorization to #{@project} failed, please verify your access token"
- rescue Octokit::TooManyLoginAttempts
- return 429, "Account for #{@project} has been temporary locked down due to to many failed login attempts"
+ case @event
+ when 'issue_comment'
+ if @data['action'] != 'created'
+ # Not a new comment, ignore
+ return 200, 'not a new comment, skipping'
end
- end
- if @data['action'] != 'created'
- # Not a new comment, ignore
- return 200, 'not a new comment, skipping'
- end
+ pull_request_id = @data['issue']['number']
+ pr = @client.pull_request @project, pull_request_id
+ plus_one = {}
- pull_request_id = @data['issue']['number']
- pr = @client.pull_request @project, pull_request_id
- plus_one = {}
- merge = false
+ unless pr.mergeable
+ return 200, "merge state for #{@project} #{pull_request_id} is not clean. Current state: #{pr.mergeable_state}"
+ end
- if pr.mergeable_state != 'clean'
- return 200, "merge state for #{@project} #{pull_request_id} is not clean. Current state: #{pr.mergeable_state}"
- end
+ # No comments, no need to go further.
+ return 200, 'no comments, skipping' if pr.comments == 0
- # No comments, no need to go further.
- if pr.comments == 0
- return 200, 'no comments, skipping'
- end
+ # We fetch the latest commit and it's date.
+ last_commit = @client.pull_request_commits(@project, pull_request_id).last
+ last_commit_date = last_commit.commit.committer.date
- # Don't care about code we can't merge
- return 200, 'merge state not clean' unless pr.mergeable
+ comments = @client.issue_comments(@project, pull_request_id)
- # We fetch the latest commit and it's date.
- last_commit = @client.pull_request_commits(@project, pull_request_id).last
- last_commit_date = last_commit.commit.committer.date
+ # Check each comment for +1 and merge comments
+ comments.each do |i|
- comments = @client.issue_comments(@project, pull_request_id)
+ # Comment is older than last commit. We only want to check for +1 in newer comments
+ next if last_commit_date > i.created_at
- # Check each comment for +1 and merge comments
- comments.each do |i|
+ if /^(\+1|:\+1)/.match i.body
+ # pull request submitter cant +1
+ unless pr.user.login == i.attrs[:user].attrs[:login]
+ plus_one[i.attrs[:user].attrs[:login]] = 1
+ end
+ end
- # Comment is older than last commit. We only want to check for +1 in newer comments
- next if last_commit_date > i.created_at
-
- if /^(\+1|:\+1)/.match i.body
- # pull request submitter cant +1
- unless pr.user.login == i.attrs[:user].attrs[:login]
- plus_one[i.attrs[:user].attrs[:login]] = 1
+ # TODO it should calculate the +1's - the -1's
+ # Never merge if someone says -1
+ if /^(\-1|:\-1:)/.match i.body
+ return 200, "#{@project} #{pull_request_id} has a -1. I will not take the blame"
end
end
- # TODO it should calculate the +1's - the -1's
- # Never merge if someone says -1
- if /^(\-1|:\-1:)/.match i.body
- return 200, "#{@project} #{pull_request_id} has a -1. I will not take the blame"
- end
- end
+ merge = (@data['comment']['body'] == '!merge' ||
+ @data['comment']['body'].start_with?(':shipit:'))
- merge = (comments.last.body == '!merge' || comments.last.body.start_with?(':shipit:'))
-
- if plus_one.count >= @settings['plus_ones_required'] && merge
- json = { url: pr.url,
- title: pr.title,
- author: pr.user.login,
- description: pr.body,
- commits: @client.pull_request_commits(@project, pr.number).map { |c| { author: c.author, message: c.commit.message, sha: c.commit.tree.sha } },
- head_sha: pr.head.sha,
- tests: @client.combined_status(@project, pr.head.sha).statuses.map { |s| {state: s.state, url: s.target_url, description: s.description } },
- reviewers: plus_one.keys,
- deployer: comments.last.user.login }
- # TODO: Word wrap description
- merge_msg = <<MERGE_MSG
+ if plus_one.count >= @settings['plus_ones_required'] && merge
+ json = { url: pr.url,
+ title: pr.title,
+ author: pr.user.login,
+ description: pr.body,
+ commits: @client.pull_request_commits(@project, pr.number).map { |c| { author: c.author, message: c.commit.message, sha: c.commit.tree.sha } },
+ head_sha: pr.head.sha,
+ tests: @client.combined_status(@project, pr.head.sha).statuses.map { |s| {state: s.state, url: s.target_url, description: s.description } },
+ reviewers: plus_one.keys,
+ deployer: comments.last.user.login }
+ # TODO: Word wrap description
+ merge_msg = <<MERGE_MSG
Title: #{pr.title}
Description: #{pr.body}
Author: #{pr.user.login}
Reviewers: #{plus_one.keys.join ', '}
Deployer: #{comments.last.user.login}
URL: #{pr.url}
MERGE_MSG
- merge_commit = @client.merge_pull_request(@project, pull_request_id, merge_msg)
- json[:merge_sha] = merge_commit.sha
- report_directory = "#{@settings['reports_dir']}/#{merge_commit.sha[0..1]}/#{merge_commit.sha[2..3]}"
- report_path = "#{report_directory}/#{merge_commit.sha}.json"
- if @settings['generate_reports']
- FileUtils.mkdir_p report_directory
- File.open(report_path, 'w') { |f| f.write(JSON.pretty_generate(json)) }
+ begin
+ merge_commit = @client.merge_pull_request(@project, pull_request_id, merge_msg)
+ rescue Octokit::MethodNotAllowed => e
+ return 200, "Pull request not mergeable: #{e.message}"
+ end
+ puts merge_commit.inspect
+ json[:merge_sha] = merge_commit.sha
+ report_directory = "#{@settings['reports_dir']}/#{merge_commit.sha[0..1]}/#{merge_commit.sha[2..3]}"
+ report_path = "#{report_directory}/#{merge_commit.sha}.json"
+ if @settings['generate_reports']
+ FileUtils.mkdir_p report_directory
+ File.open(report_path, 'w') { |f| f.write(JSON.pretty_generate(json)) }
+ end
+ return 200, "merging #{pull_request_id} #{@project}"
+ elsif plus_one.count >= @settings['plus_ones_required']
+ return 200, "have enough +1, but no merge command"
+ else
+ return 200, "not enough +1, have #{plus_one.count} but need #{@settings['plus_ones_required']}"
end
- return 200, "merging #{pull_request_id} #{@project}"
- elsif plus_one.count >= @settings['plus_ones_required']
- return 200, "have enough +1, but no merge command"
+ when 'pull_request'
+ # If a new pull request is opened, comment with instructions
+ if @data['action'] == 'opened' && @settings['post_instructions']
+ issue = @data['number']
+ comment = @settings['instructions'] || "To merge at least #{@settings['plus_ones_required']} person other than the submitter needs to write a comment with saying _+1_ or :+1:. Then write _!merge_ or :shipit: to trigger the merging."
+ begin
+ @client.add_comment(@project, issue, comment)
+ return 200, "Commented!"
+ rescue Octokit::NotFound
+ return 404, "Octokit returned 404, this could be an issue with your access token"
+ rescue Octokit::Unauthorized
+ return 401, "Authorization to #{@project} failed, please verify your access token"
+ rescue Octokit::TooManyLoginAttempts
+ return 429, "Account for #{@project} has been temporary locked down due to to many failed login attempts"
+ end
+ else
+ return 200, 'Not posting instructions'
+ end
else
- return 200, "not enough +1, have #{plus_one.count} but need #{@settings['plus_ones_required']}"
+ return 200, "Unhandled event type #{@event}"
end
end
end