v3 update sidekiq payload for build restart and cancel
This commit is contained in:
parent
b73a5604d0
commit
5c6e705012
|
@ -8,13 +8,13 @@ module Travis::API::V3
|
||||||
end
|
end
|
||||||
|
|
||||||
def cancel(user)
|
def cancel(user)
|
||||||
payload = {build: {id: id, user_id: user.id, source: 'api'}}
|
payload = {id: id, user_id: user.id, source: 'api'}
|
||||||
perform_async(:build_cancellation, type: 'api'.freeze, payload: JSON.dump(payload))
|
perform_async(:build_cancellation, type: 'api'.freeze, payload: JSON.dump(payload))
|
||||||
payload
|
payload
|
||||||
end
|
end
|
||||||
|
|
||||||
def restart(user)
|
def restart(user)
|
||||||
payload = {build: {id: id, user_id: user.id, source: 'api'}}
|
payload = {id: id, user_id: user.id, source: 'api'}
|
||||||
perform_async(:build_restart, type: 'api'.freeze, payload: JSON.dump(payload))
|
perform_async(:build_restart, type: 'api'.freeze, payload: JSON.dump(payload))
|
||||||
payload
|
payload
|
||||||
end
|
end
|
||||||
|
|
|
@ -97,11 +97,10 @@ describe Travis::API::V3::Services::Build::Cancel do
|
||||||
}
|
}
|
||||||
|
|
||||||
example { expect(sidekiq_payload).to be == {
|
example { expect(sidekiq_payload).to be == {
|
||||||
"build" => {
|
"id" => "#{build.id}",
|
||||||
"id" => "#{build.id}",
|
"user_id"=> repo.owner_id,
|
||||||
"user_id"=> repo.owner_id,
|
"source" => "api"}
|
||||||
"source" => "api"}
|
}
|
||||||
}}
|
|
||||||
|
|
||||||
example { expect(Sidekiq::Client.last['queue']).to be == 'build_cancellations' }
|
example { expect(Sidekiq::Client.last['queue']).to be == 'build_cancellations' }
|
||||||
example { expect(Sidekiq::Client.last['class']).to be == 'Travis::Sidekiq::BuildCancellation' }
|
example { expect(Sidekiq::Client.last['class']).to be == 'Travis::Sidekiq::BuildCancellation' }
|
||||||
|
@ -109,11 +108,10 @@ describe Travis::API::V3::Services::Build::Cancel do
|
||||||
describe "setting id has no effect" do
|
describe "setting id has no effect" do
|
||||||
let(:params) {{ id: 42 }}
|
let(:params) {{ id: 42 }}
|
||||||
example { expect(sidekiq_payload).to be == {
|
example { expect(sidekiq_payload).to be == {
|
||||||
"build" => {
|
"id" => "#{build.id}",
|
||||||
"id" => "#{build.id}",
|
"user_id"=> repo.owner_id,
|
||||||
"user_id"=> repo.owner_id,
|
"source" => "api"}
|
||||||
"source" => "api"}
|
}
|
||||||
}}
|
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -98,11 +98,10 @@ describe Travis::API::V3::Services::Build::Restart do
|
||||||
}
|
}
|
||||||
|
|
||||||
example { expect(sidekiq_payload).to be == {
|
example { expect(sidekiq_payload).to be == {
|
||||||
"build" => {
|
"id" => "#{build.id}",
|
||||||
"id" => "#{build.id}",
|
"user_id"=> repo.owner_id,
|
||||||
"user_id"=> repo.owner_id,
|
"source" => "api"}
|
||||||
"source" => "api"}
|
}
|
||||||
}}
|
|
||||||
|
|
||||||
example { expect(Sidekiq::Client.last['queue']).to be == 'build_restarts' }
|
example { expect(Sidekiq::Client.last['queue']).to be == 'build_restarts' }
|
||||||
example { expect(Sidekiq::Client.last['class']).to be == 'Travis::Sidekiq::BuildRestart' }
|
example { expect(Sidekiq::Client.last['class']).to be == 'Travis::Sidekiq::BuildRestart' }
|
||||||
|
@ -110,11 +109,10 @@ describe Travis::API::V3::Services::Build::Restart do
|
||||||
describe "setting id has no effect" do
|
describe "setting id has no effect" do
|
||||||
let(:params) {{ id: 42 }}
|
let(:params) {{ id: 42 }}
|
||||||
example { expect(sidekiq_payload).to be == {
|
example { expect(sidekiq_payload).to be == {
|
||||||
"build" => {
|
"id" => "#{build.id}",
|
||||||
"id" => "#{build.id}",
|
"user_id"=> repo.owner_id,
|
||||||
"user_id"=> repo.owner_id,
|
"source" => "api"}
|
||||||
"source" => "api"}
|
}
|
||||||
}}
|
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user