05a9c6b211
The original API that queries by label (`/rest/api/latest/result?label=#{sha1}`)
only works for results from main plans and not branch plans. The
`/rest/api/latest/result/byChangeset/#{sha1}` endpoint gives results from
branch plans but not for the first push to the branch. Subsequent pushes
work.
For more details, see https://jira.atlassian.com/browse/BAM-16121.
Closes #1355
132 lines
3.6 KiB
Ruby
132 lines
3.6 KiB
Ruby
class BambooService < CiService
|
|
include ReactiveService
|
|
|
|
prop_accessor :bamboo_url, :build_key, :username, :password
|
|
|
|
validates :bamboo_url, presence: true, public_url: true, if: :activated?
|
|
validates :build_key, presence: true, if: :activated?
|
|
validates :username,
|
|
presence: true,
|
|
if: ->(service) { service.activated? && service.password }
|
|
validates :password,
|
|
presence: true,
|
|
if: ->(service) { service.activated? && service.username }
|
|
|
|
attr_accessor :response
|
|
|
|
after_save :compose_service_hook, if: :activated?
|
|
before_update :reset_password
|
|
|
|
def compose_service_hook
|
|
hook = service_hook || build_service_hook
|
|
hook.save
|
|
end
|
|
|
|
def reset_password
|
|
if bamboo_url_changed? && !password_touched?
|
|
self.password = nil
|
|
end
|
|
end
|
|
|
|
def title
|
|
'Atlassian Bamboo CI'
|
|
end
|
|
|
|
def description
|
|
'A continuous integration and build server'
|
|
end
|
|
|
|
def help
|
|
'You must set up automatic revision labeling and a repository trigger in Bamboo.'
|
|
end
|
|
|
|
def self.to_param
|
|
'bamboo'
|
|
end
|
|
|
|
def fields
|
|
[
|
|
{ type: 'text', name: 'bamboo_url',
|
|
placeholder: 'Bamboo root URL like https://bamboo.example.com', required: true },
|
|
{ type: 'text', name: 'build_key',
|
|
placeholder: 'Bamboo build plan key like KEY', required: true },
|
|
{ type: 'text', name: 'username',
|
|
placeholder: 'A user with API access, if applicable' },
|
|
{ type: 'password', name: 'password' }
|
|
]
|
|
end
|
|
|
|
def build_page(sha, ref)
|
|
with_reactive_cache(sha, ref) {|cached| cached[:build_page] }
|
|
end
|
|
|
|
def commit_status(sha, ref)
|
|
with_reactive_cache(sha, ref) {|cached| cached[:commit_status] }
|
|
end
|
|
|
|
def execute(data)
|
|
return unless supported_events.include?(data[:object_kind])
|
|
|
|
get_path("updateAndBuild.action", { buildKey: build_key })
|
|
end
|
|
|
|
def calculate_reactive_cache(sha, ref)
|
|
response = get_path("rest/api/latest/result/byChangeset/#{sha}")
|
|
|
|
{ build_page: read_build_page(response), commit_status: read_commit_status(response) }
|
|
end
|
|
|
|
private
|
|
|
|
def read_build_page(response)
|
|
if response.code != 200 || response['results']['results']['size'] == '0'
|
|
# If actual build link can't be determined, send user to build summary page.
|
|
URI.join("#{bamboo_url}/", "browse/#{build_key}").to_s
|
|
else
|
|
# If actual build link is available, go to build result page.
|
|
result_key = response['results']['results']['result']['planResultKey']['key']
|
|
URI.join("#{bamboo_url}/", "browse/#{result_key}").to_s
|
|
end
|
|
end
|
|
|
|
def read_commit_status(response)
|
|
return :error unless response.code == 200 || response.code == 404
|
|
|
|
status = if response.code == 404 || response['results']['results']['size'] == '0'
|
|
'Pending'
|
|
else
|
|
response['results']['results']['result']['buildState']
|
|
end
|
|
|
|
if status.include?('Success')
|
|
'success'
|
|
elsif status.include?('Failed')
|
|
'failed'
|
|
elsif status.include?('Pending')
|
|
'pending'
|
|
else
|
|
:error
|
|
end
|
|
end
|
|
|
|
def build_url(path)
|
|
URI.join("#{bamboo_url}/", path).to_s
|
|
end
|
|
|
|
def get_path(path, query_params = {})
|
|
url = build_url(path)
|
|
|
|
if username.blank? && password.blank?
|
|
Gitlab::HTTP.get(url, verify: false, query: query_params)
|
|
else
|
|
query_params[:os_authType] = 'basic'
|
|
Gitlab::HTTP.get(url,
|
|
verify: false,
|
|
query: query_params,
|
|
basic_auth: {
|
|
username: username,
|
|
password: password
|
|
})
|
|
end
|
|
end
|
|
end
|