diff --git a/app/services/gpx/track_importer.rb b/app/services/gpx/track_importer.rb index e1aa21fe..62f327cc 100644 --- a/app/services/gpx/track_importer.rb +++ b/app/services/gpx/track_importer.rb @@ -59,6 +59,8 @@ class Gpx::TrackImporter on_duplicate: :skip ) # rubocop:enable Rails/SkipsModelValidations + + broadcast_import_progress(import, unique_batch.size) rescue StandardError => e create_notification("Failed to process GPX track: #{e.message}") end diff --git a/spec/services/gpx/track_importer_spec.rb b/spec/services/gpx/track_importer_spec.rb index 3f46aaa1..bef491c9 100644 --- a/spec/services/gpx/track_importer_spec.rb +++ b/spec/services/gpx/track_importer_spec.rb @@ -17,7 +17,7 @@ RSpec.describe Gpx::TrackImporter do end it 'broadcasts importing progress' do - expect_any_instance_of(Imports::Broadcaster).to receive(:broadcast_import_progress).exactly(10).times + expect_any_instance_of(Imports::Broadcaster).to receive(:broadcast_import_progress).exactly(1).time parser end @@ -31,7 +31,7 @@ RSpec.describe Gpx::TrackImporter do end it 'broadcasts importing progress' do - expect_any_instance_of(Imports::Broadcaster).to receive(:broadcast_import_progress).exactly(43).times + expect_any_instance_of(Imports::Broadcaster).to receive(:broadcast_import_progress).exactly(1).time parser end @@ -45,7 +45,7 @@ RSpec.describe Gpx::TrackImporter do end it 'broadcasts importing progress' do - expect_any_instance_of(Imports::Broadcaster).to receive(:broadcast_import_progress).exactly(34).times + expect_any_instance_of(Imports::Broadcaster).to receive(:broadcast_import_progress).exactly(1).time parser end