diff options
Diffstat (limited to 'spec/workers/cleanup_container_repository_worker_spec.rb')
-rw-r--r-- | spec/workers/cleanup_container_repository_worker_spec.rb | 39 |
1 files changed, 2 insertions, 37 deletions
diff --git a/spec/workers/cleanup_container_repository_worker_spec.rb b/spec/workers/cleanup_container_repository_worker_spec.rb index 6723ea2049d..edb815f426d 100644 --- a/spec/workers/cleanup_container_repository_worker_spec.rb +++ b/spec/workers/cleanup_container_repository_worker_spec.rb @@ -13,11 +13,11 @@ RSpec.describe CleanupContainerRepositoryWorker, :clean_gitlab_redis_shared_stat let(:service) { instance_double(Projects::ContainerRepository::CleanupTagsService) } context 'bulk delete api' do - let(:params) { { key: 'value', 'container_expiration_policy' => false } } + let(:params) { { key: 'value' } } it 'executes the destroy service' do expect(Projects::ContainerRepository::CleanupTagsService).to receive(:new) - .with(repository, user, params.merge('container_expiration_policy' => false)) + .with(repository, user, params) .and_return(service) expect(service).to receive(:execute) @@ -36,40 +36,5 @@ RSpec.describe CleanupContainerRepositoryWorker, :clean_gitlab_redis_shared_stat end.not_to raise_error end end - - context 'container expiration policy' do - let(:params) { { key: 'value', 'container_expiration_policy' => true } } - - before do - allow(ContainerRepository) - .to receive(:find_by_id).with(repository.id).and_return(repository) - end - - it 'executes the destroy service' do - expect(repository).to receive(:start_expiration_policy!).and_call_original - expect(repository).to receive(:reset_expiration_policy_started_at!).and_call_original - expect(Projects::ContainerRepository::CleanupTagsService).to receive(:new) - .with(repository, nil, params.merge('container_expiration_policy' => true)) - .and_return(service) - - expect(service).to receive(:execute).and_return(status: :success) - - subject.perform(nil, repository.id, params) - expect(repository.reload.expiration_policy_started_at).to be_nil - end - - it "doesn't reset the expiration policy started at if the destroy service returns an error" do - expect(repository).to receive(:start_expiration_policy!).and_call_original - expect(repository).not_to receive(:reset_expiration_policy_started_at!) - expect(Projects::ContainerRepository::CleanupTagsService).to receive(:new) - .with(repository, nil, params.merge('container_expiration_policy' => true)) - .and_return(service) - - expect(service).to receive(:execute).and_return(status: :error, message: 'timeout while deleting tags') - - subject.perform(nil, repository.id, params) - expect(repository.reload.expiration_policy_started_at).not_to be_nil - end - end end end |