diff --git a/lib/tasks/server_recordings_sync.rake b/lib/tasks/server_recordings_sync.rake index e61903e47d..dc1df17da3 100644 --- a/lib/tasks/server_recordings_sync.rake +++ b/lib/tasks/server_recordings_sync.rake @@ -22,6 +22,10 @@ task :server_recordings_sync, %i[provider] => :environment do |_task, args| args.with_defaults(provider: 'greenlight') Room.includes(:user).select(:id, :meeting_id).with_provider(args[:provider]).in_batches(of: 25) do |rooms| + room_recordings = rooms.recordings + Format.where(recording: room_recordings).delete_all + room_recordings.delete_all + meeting_ids = rooms.pluck(:meeting_id) recordings = BigBlueButtonApi.new(provider: args[:provider]).get_recordings(meeting_ids:) @@ -30,14 +34,7 @@ task :server_recordings_sync, %i[provider] => :environment do |_task, args| next if recordings[:recordings].blank? - # Skip the entire batch if the first and last recordings exist - if Recording.exists?(record_id: recordings[:recordings][0][:recordID]) && Recording.exists?(record_id: recordings[:recordings][-1][:recordID]) - next - end - recordings[:recordings].each do |recording| - next if Recording.exists?(record_id: recording[:recordID]) - RecordingCreator.new(recording:).call success 'Successfully migrated Recording:' info "RecordID: #{recording[:recordID]}"