kanbanworkflowstimelinescrumrubyroadmapproject-planningproject-managementopenprojectangularissue-trackerifcgantt-chartganttbug-trackerboardsbcf
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
165 lines
3.8 KiB
165 lines
3.8 KiB
#!/usr/bin/env ruby
|
|
|
|
require 'rubygems'
|
|
require 'bundler'
|
|
Bundler.setup(:default, :development)
|
|
|
|
require 'colored2'
|
|
require 'pathname'
|
|
require 'json'
|
|
require 'rest-client'
|
|
require 'pry'
|
|
|
|
GITHUB_API_OPENPROJECT_PREFIX = "https://api.github.com/repos/opf/openproject"
|
|
RAILS_ROOT = Pathname.new(__dir__).dirname
|
|
SPEC_PATTERN = %r{^\S+ (?:rspec (\S+) #.+|An error occurred while loading (\S+)\.\r?)$}
|
|
|
|
# current branch
|
|
branch_name = `git rev-parse --abbrev-ref HEAD`.strip
|
|
|
|
if !ENV['GITHUB_USERNAME']
|
|
raise "Missing GITHUB_USERNAME env"
|
|
elsif !ENV['GITHUB_TOKEN']
|
|
raise "Missing GITHUB_TOKEN env, go to https://github.com/settings/tokens and create one with 'repo' access"
|
|
end
|
|
|
|
def get_http(path)
|
|
url =
|
|
if path.start_with?('http')
|
|
path
|
|
else
|
|
"#{GITHUB_API_OPENPROJECT_PREFIX}/#{path}"
|
|
end
|
|
|
|
response = RestClient::Request.new(
|
|
method: :get,
|
|
url:,
|
|
user: ENV.fetch('GITHUB_USERNAME'),
|
|
password: ENV.fetch('GITHUB_TOKEN')
|
|
).execute
|
|
|
|
response.to_str
|
|
rescue StandardError => e
|
|
warn "Failed to perform API request #{url}: #{e} #{e.message}"
|
|
exit 1
|
|
end
|
|
|
|
def get_json(path)
|
|
JSON.parse(get_http(path))
|
|
end
|
|
|
|
def path_to_cache_key(path)
|
|
path
|
|
.gsub(/\?.*$/, '') # remove query parameter
|
|
.gsub(/^#{GITHUB_API_OPENPROJECT_PREFIX}\/?/, '') # remove https://.../
|
|
.gsub(/\W/, '_') # transform non alphanum chars
|
|
end
|
|
|
|
def commit_message(workflow_run)
|
|
workflow_run['head_commit']
|
|
.then { |commit| commit["message"] }
|
|
.then { |message| message.split("\n", 2).first }
|
|
end
|
|
|
|
def get_jobs(workflow_run)
|
|
workflow_run['jobs_url']
|
|
cache_key = [
|
|
path_to_cache_key(workflow_run['jobs_url']),
|
|
workflow_run['updated_at'].gsub(':', '')
|
|
].join('_')
|
|
cached(cache_key) { get_json(workflow_run['jobs_url']) }
|
|
end
|
|
|
|
def get_log(job)
|
|
cached("job_#{job['id']}.log") do
|
|
get_http("actions/jobs/#{job['id']}/logs")
|
|
end
|
|
end
|
|
|
|
def cached(unique_name)
|
|
cached_file = RAILS_ROOT.join("tmp/github_pr_errors/#{unique_name}")
|
|
if cached_file.file?
|
|
content = cached_file.read
|
|
content.start_with?("---") ? YAML::load(content) : content
|
|
else
|
|
content = yield
|
|
cached_file.dirname.mkpath
|
|
cached_file.write(content.is_a?(String) ? content : YAML::dump(content))
|
|
content
|
|
end
|
|
end
|
|
|
|
def status_icon(job)
|
|
case job['status']
|
|
when "queued", "in_progress"
|
|
"●".yellow
|
|
else
|
|
case job['conclusion']
|
|
when "success"
|
|
"✓".green
|
|
when "failure"
|
|
"✗".red
|
|
else
|
|
"-"
|
|
end
|
|
end
|
|
end
|
|
|
|
def status_url(job)
|
|
return if job['conclusion'] == "success"
|
|
|
|
job['html_url'].white.dark
|
|
end
|
|
|
|
def status_line(job)
|
|
[
|
|
"#{status_icon(job)} #{job['name']}: #{job['conclusion'] || job['status']}",
|
|
status_url(job)
|
|
].compact.join(" ")
|
|
end
|
|
|
|
##########
|
|
|
|
warn "Looking for the last 'Test suite' workflow run in branch #{branch_name}"
|
|
|
|
response = get_json "actions/runs?branch=#{CGI.escape(branch_name)}"
|
|
|
|
last_test_action =
|
|
response['workflow_runs']
|
|
.select { |entry| entry['name'] == 'Test suite' }
|
|
.reject { |entry| entry['status'] == 'in_progress' }
|
|
.max_by { |entry| entry['run_number'] }
|
|
|
|
raise "No action run found for branch #{branch_name}" unless last_test_action
|
|
|
|
warn " Commit SHA: #{last_test_action['head_sha']}"
|
|
warn " Commit message: #{commit_message(last_test_action)}"
|
|
|
|
errors = []
|
|
is_successful = true
|
|
warn " #{status_line(last_test_action)}"
|
|
get_jobs(last_test_action)
|
|
.then { |jobs_response| jobs_response['jobs'] }
|
|
.sort_by { _1['name'] }
|
|
.each { |job| warn " #{status_line(job)}" }
|
|
.select { _1['conclusion'] == 'failure' }
|
|
.each do |job|
|
|
is_successful = false
|
|
get_log(job)
|
|
.scan(SPEC_PATTERN)
|
|
.flatten
|
|
.compact
|
|
.uniq
|
|
.sort
|
|
.each do |match|
|
|
errors << match
|
|
end
|
|
end
|
|
|
|
if is_successful
|
|
warn "All jobs successful 🎉"
|
|
elsif errors.empty?
|
|
warn "No rspec errors found :-/"
|
|
else
|
|
puts errors.map { "'#{_1}'" }.join(" ")
|
|
end
|
|
|