Refacto endpoint
This commit is contained in:
parent
6de524d84c
commit
8655fd19ce
|
@ -51,26 +51,23 @@ class Travis::Api::App
|
||||||
Metriks.meter("api.request.restart_build").mark
|
Metriks.meter("api.request.restart_build").mark
|
||||||
if Travis::Features.owner_active?(:enqueue_to_hub, current_user)
|
if Travis::Features.owner_active?(:enqueue_to_hub, current_user)
|
||||||
service = Travis::Enqueue::Services::RestartModel.new(current_user, { build_id: params[:id] })
|
service = Travis::Enqueue::Services::RestartModel.new(current_user, { build_id: params[:id] })
|
||||||
if !service.accept?
|
|
||||||
status 400
|
|
||||||
result = false
|
|
||||||
else
|
|
||||||
payload = {id: params[:id], user_id: current_user.id}
|
|
||||||
service.push("build:restart", payload)
|
|
||||||
status 202
|
|
||||||
result = true
|
|
||||||
end
|
|
||||||
else
|
else
|
||||||
service = self.service(:reset_model, build_id: params[:id])
|
service = self.service(:reset_model, build_id: params[:id])
|
||||||
|
end
|
||||||
|
|
||||||
if !service.accept?
|
if !service.accept?
|
||||||
status 400
|
status 400
|
||||||
result = false
|
result = false
|
||||||
|
else
|
||||||
|
if service.respond_to?(:push)
|
||||||
|
payload = {id: params[:id], user_id: current_user.id}
|
||||||
|
service.push("build:restart", payload)
|
||||||
else
|
else
|
||||||
Travis::Sidekiq::BuildRestart.perform_async(id: params[:id], user_id: current_user.id)
|
Travis::Sidekiq::BuildRestart.perform_async(id: params[:id], user_id: current_user.id)
|
||||||
|
end
|
||||||
status 202
|
status 202
|
||||||
result = true
|
result = true
|
||||||
end
|
end
|
||||||
end
|
|
||||||
|
|
||||||
respond_with(result: result, flash: service.messages)
|
respond_with(result: result, flash: service.messages)
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in New Issue
Block a user