2 files changed, 109 insertions, 0 deletions
diff --git a/app/services/parent_notifier.rb b/app/services/parent_notifier.rb
new file mode 100644
index 000000000..653c98aff
--- /dev/null
+++ b/app/services/parent_notifier.rb
@@ -0,0 +1,19 @@
+class ParentNotifier
+  def initialize(klass)
+    @klass = klass
+  end
+
+  def notify_when_finished(collection = nil)
+    collection ||= objects_pending_notification
+    collection.each(&:notify_parent)
+  end
+
+  def objects_pending_notification
+    @klass
+      .where(
+        notified_parent_at: nil,
+        status: @klass.finished_statuses
+      )
+      .where.not(parent: nil)
+  end
+end
diff --git a/spec/services/parent_notifier_spec.rb b/spec/services/parent_notifier_spec.rb
new file mode 100644
index 000000000..ecf508fcd
--- /dev/null
+++ b/spec/services/parent_notifier_spec.rb
@@ -0,0 +1,90 @@
+RSpec.describe ParentNotifier do
+  let(:workbench_import) { create(:workbench_import) }
+
+  describe ".notify_when_finished" do
+    it "calls #notify_parent on finished imports" do
+      workbench_import = build_stubbed(:workbench_import)
+
+      finished_statuses = [:failed, :successful, :aborted, :canceled]
+      netex_imports = []
+
+      finished_statuses.each do |status|
+        netex_imports << build_stubbed(
+          :netex_import,
+          parent: workbench_import,
+          status: status
+        )
+      end
+
+      netex_imports.each do |netex_import|
+        expect(netex_import).to receive(:notify_parent)
+      end
+
+      ParentNotifier.new(Import).notify_when_finished(netex_imports)
+    end
+
+    it "doesn't call #notify_parent if its `notified_parent_at` is set" do
+      netex_import = create(
+        :netex_import,
+        parent: workbench_import,
+        status: :failed,
+        notified_parent_at: DateTime.now
+      )
+
+      expect(netex_import).not_to receive(:notify_parent)
+
+      ParentNotifier.new(Import).notify_when_finished
+    end
+  end
+
+  describe ".objects_pending_notification" do
+    it "includes imports with a parent and `notified_parent_at` unset" do
+      netex_import = create(
+        :netex_import,
+        parent: workbench_import,
+        status: :successful,
+        notified_parent_at: nil
+      )
+
+      expect(
+        ParentNotifier.new(Import).objects_pending_notification
+      ).to eq([netex_import])
+    end
+
+    it "doesn't include imports without a parent" do
+      create(:import, parent: nil)
+
+      expect(
+        ParentNotifier.new(Import).objects_pending_notification
+      ).to be_empty
+    end
+
+    it "doesn't include imports that aren't finished" do
+      [:new, :pending, :running].each do |status|
+        create(
+          :netex_import,
+          parent: workbench_import,
+          status: status,
+          notified_parent_at: nil
+        )
+      end
+
+      expect(
+        ParentNotifier.new(Import).objects_pending_notification
+      ).to be_empty
+    end
+
+    it "doesn't include imports that have already notified their parent" do
+      create(
+        :netex_import,
+        parent: workbench_import,
+        status: :successful,
+        notified_parent_at: DateTime.now
+      )
+
+      expect(
+        ParentNotifier.new(Import).objects_pending_notification
+      ).to be_empty
+    end
+  end
+end