take out the comments
This commit is contained in:
parent
d7ee8b4d3b
commit
d8674a3715
1
Procfile
1
Procfile
|
@ -1,3 +1,4 @@
|
||||||
web: bundle exec ./script/server
|
web: bundle exec ./script/server
|
||||||
console: bundle exec ./script/console
|
console: bundle exec ./script/console
|
||||||
sidekiq: bundle exec sidekiq -c 5 -r ./lib/travis/sidekiq.rb -q build_cancellations
|
sidekiq: bundle exec sidekiq -c 5 -r ./lib/travis/sidekiq.rb -q build_cancellations
|
||||||
|
sidekiq: bundle exec sidekiq -c 5 -r ./lib/travis/sidekiq.rb -q build_restart
|
||||||
|
|
|
@ -1,5 +1,6 @@
|
||||||
require 'travis/api/app'
|
require 'travis/api/app'
|
||||||
require 'travis/api/workers/build_cancellation'
|
require 'travis/api/workers/build_cancellation'
|
||||||
|
require 'travis/api/workers/build_restart'
|
||||||
|
|
||||||
class Travis::Api::App
|
class Travis::Api::App
|
||||||
class Endpoint
|
class Endpoint
|
||||||
|
@ -49,7 +50,9 @@ class Travis::Api::App
|
||||||
|
|
||||||
post '/:id/restart' do
|
post '/:id/restart' do
|
||||||
Metriks.meter("api.request.restart_build").mark
|
Metriks.meter("api.request.restart_build").mark
|
||||||
respond_with service(:reset_model, build_id: params[:id])
|
|
||||||
|
Travis::Sidekiq::BuildRestart.perform_async(id: params[:id], user_id: current_user.id)
|
||||||
|
#respond_with service(:reset_model, build_id: params[:id])
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -10,11 +10,7 @@ module Travis
|
||||||
sidekiq_options queue: :build_cancellations
|
sidekiq_options queue: :build_cancellations
|
||||||
|
|
||||||
def perform(data)
|
def perform(data)
|
||||||
p "#######################"
|
|
||||||
p data
|
|
||||||
user = User.find(data['user_id'])
|
user = User.find(data['user_id'])
|
||||||
test = { id: data['id'], source: data['source'] }
|
|
||||||
p test
|
|
||||||
Travis.service(:cancel_build, user, { id: data['id'], source: data['source'] }).run
|
Travis.service(:cancel_build, user, { id: data['id'], source: data['source'] }).run
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
19
lib/travis/api/workers/build_restart.rb
Normal file
19
lib/travis/api/workers/build_restart.rb
Normal file
|
@ -0,0 +1,19 @@
|
||||||
|
require 'sidekiq/worker'
|
||||||
|
require 'multi_json'
|
||||||
|
|
||||||
|
module Travis
|
||||||
|
module Sidekiq
|
||||||
|
class BuildRestart
|
||||||
|
class ProcessingError < StandardError; end
|
||||||
|
|
||||||
|
include ::Sidekiq::Worker
|
||||||
|
sidekiq_options queue: :build_restart
|
||||||
|
|
||||||
|
def perform(data)
|
||||||
|
user = User.find(data['user_id'])
|
||||||
|
Travis.service(:reset_model, user, build_id: data['id']).run
|
||||||
|
end
|
||||||
|
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
|
@ -2,6 +2,7 @@ $: << './lib'
|
||||||
require 'sidekiq'
|
require 'sidekiq'
|
||||||
require 'travis'
|
require 'travis'
|
||||||
require 'travis/api/workers/build_cancellation'
|
require 'travis/api/workers/build_cancellation'
|
||||||
|
require 'travis/api/workers/build_restart'
|
||||||
require 'travis/support/amqp'
|
require 'travis/support/amqp'
|
||||||
|
|
||||||
Travis::Database.connect
|
Travis::Database.connect
|
||||||
|
|
Loading…
Reference in New Issue
Block a user