[TAN-7137] Enqueue scheduled transition job from SideFx services

When a schedule is set via project or folder update, the `SideFx` service enqueues `ProcessScheduledPublicationTransitionJob` with `wait_until: scheduled_at`.

Author: adessy

back/app/services/project_folders/side_fx_project_folder_service.rb

@@ -38,6 +38,7 @@ def after_update(folder, user)
       payload[:change] = sanitize_change(change) if change.present?
 
       LogActivityJob.perform_later(folder, 'changed', user, folder.updated_at.to_i, payload: payload)
+      enqueue_scheduled_transition(folder.admin_publication, user)
     end
 
     def after_destroy(frozen_folder, user)
@@ -51,5 +52,16 @@ def after_destroy(frozen_folder, user)
         payload: { project_folder: serialized_folder }
       )
     end
+
+    private
+
+    def enqueue_scheduled_transition(admin_pub, user)
+      return unless admin_pub.saved_change_to_scheduled_at?
+      return unless admin_pub.scheduled_at.present?
+
+      ProcessScheduledPublicationTransitionJob
+        .set(wait_until: admin_pub.scheduled_at)
+        .perform_later(admin_pub.id, user&.id)
+    end
   end
 end

back/app/services/side_fx_project_service.rb

@@ -74,6 +74,7 @@ def after_update(project, user)
     after_folder_changed project, user if @folder_id_was != project.folder_id
     # We don't want to send out the "project published" campaign when e.g. changing from "archived" to "published"
     after_publish project, user if project.admin_publication.published? && @publication_status_was == 'draft'
+    enqueue_scheduled_transition(project.admin_publication, user)
   end
 
   def before_destroy(project, user); end
@@ -128,6 +129,15 @@ def after_publish(project, user)
     LogActivityJob.perform_later project, 'published', user, project.updated_at.to_i
   end
 
+  def enqueue_scheduled_transition(admin_pub, user)
+    return unless admin_pub.saved_change_to_scheduled_at?
+    return unless admin_pub.scheduled_at.present?
+
+    ProcessScheduledPublicationTransitionJob
+      .set(wait_until: admin_pub.scheduled_at)
+      .perform_later(admin_pub.id, user&.id)
+  end
+
   def after_folder_changed(project, current_user)
     # Defined in core app to eliminate dependency between
     # idea assignment and folder engine.

back/spec/services/project_folders/side_fx_project_folder_service_spec.rb

@@ -40,6 +40,25 @@
           }
         ).exactly(1).times
     end
+
+    it 'enqueues the transition job when a schedule is set' do
+      scheduled_at = 1.day.from_now
+      project_folder.assign_attributes(
+        admin_publication_attributes: { scheduled_status: 'archived', scheduled_at: scheduled_at }
+      )
+      project_folder.save!
+
+      expect { service.after_update(project_folder, user) }
+        .to have_enqueued_job(ProcessScheduledPublicationTransitionJob)
+        .with(project_folder.admin_publication.id, user.id)
+    end
+
+    it 'does not enqueue the transition job when no schedule is set' do
+      project_folder.update!(title_multiloc: { en: 'changed' })
+
+      expect { service.after_update(project_folder, user) }
+        .not_to have_enqueued_job(ProcessScheduledPublicationTransitionJob)
+    end
   end
 
   describe 'after_destroy' do

back/spec/services/side_fx_project_service_spec.rb

@@ -92,6 +92,28 @@
         .not_to have_enqueued_job(LogActivityJob)
         .with(project, 'published', user, project.updated_at.to_i, anything)
     end
+
+    it 'enqueues the transition job when a schedule is set' do
+      scheduled_at = 1.day.from_now
+      project.assign_attributes(
+        admin_publication_attributes: { scheduled_status: 'archived', scheduled_at: scheduled_at }
+      )
+      service.before_update(project, user)
+      project.save!
+
+      expect { service.after_update(project, user) }
+        .to have_enqueued_job(ProcessScheduledPublicationTransitionJob)
+        .with(project.admin_publication.id, user.id)
+    end
+
+    it 'does not enqueue the transition job when no schedule is set' do
+      project.assign_attributes(title_multiloc: { en: 'changed' })
+      service.before_update(project, user)
+      project.save!
+
+      expect { service.after_update(project, user) }
+        .not_to have_enqueued_job(ProcessScheduledPublicationTransitionJob)
+    end
   end
 
   describe 'after_destroy' do