38 lines
1.7 KiB
Ruby
38 lines
1.7 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require 'spec_helper'
|
|
require_migration!('schedule_cleanup_orphaned_lfs_objects_projects')
|
|
|
|
RSpec.describe ScheduleCleanupOrphanedLfsObjectsProjects, schema: 20210511165250 do
|
|
let(:lfs_objects_projects) { table(:lfs_objects_projects) }
|
|
let(:projects) { table(:projects) }
|
|
let(:namespaces) { table(:namespaces) }
|
|
let(:lfs_objects) { table(:lfs_objects) }
|
|
|
|
let(:namespace) { namespaces.create!(name: 'namespace', path: 'namespace') }
|
|
let(:project) { projects.create!(namespace_id: namespace.id) }
|
|
let(:another_project) { projects.create!(namespace_id: namespace.id) }
|
|
let(:lfs_object) { lfs_objects.create!(oid: 'abcdef', size: 1) }
|
|
let(:another_lfs_object) { lfs_objects.create!(oid: '1abcde', size: 2) }
|
|
|
|
describe '#up' do
|
|
it 'schedules CleanupOrphanedLfsObjectsProjects background jobs' do
|
|
stub_const("#{described_class}::BATCH_SIZE", 2)
|
|
|
|
lfs_objects_project1 = lfs_objects_projects.create!(project_id: project.id, lfs_object_id: lfs_object.id)
|
|
lfs_objects_project2 = lfs_objects_projects.create!(project_id: another_project.id, lfs_object_id: lfs_object.id)
|
|
lfs_objects_project3 = lfs_objects_projects.create!(project_id: project.id, lfs_object_id: another_lfs_object.id)
|
|
lfs_objects_project4 = lfs_objects_projects.create!(project_id: another_project.id, lfs_object_id: another_lfs_object.id)
|
|
|
|
freeze_time do
|
|
migrate!
|
|
|
|
expect(described_class::MIGRATION).to be_scheduled_delayed_migration(2.minutes, lfs_objects_project1.id, lfs_objects_project2.id)
|
|
expect(described_class::MIGRATION).to be_scheduled_delayed_migration(4.minutes, lfs_objects_project3.id, lfs_objects_project4.id)
|
|
|
|
expect(BackgroundMigrationWorker.jobs.size).to eq(2)
|
|
end
|
|
end
|
|
end
|
|
end
|