Extract ClusterWaitForAppInstallationWorker logic into a service

1 files changed, 1 insertions, 19 deletions

diff --git a/app/workers/cluster_wait_for_app_installation_worker.rb b/app/workers/cluster_wait_for_app_installation_worker.rb
index 21149cf2d19..7e480c42fd4 100644
--- a/app/workers/cluster_wait_for_app_installation_worker.rb
+++ b/app/workers/cluster_wait_for_app_installation_worker.rb
@@ -9,25 +9,7 @@ class ClusterWaitForAppInstallationWorker
 
   def perform(app_name, app_id)
     find_app(app_name, app_id) do |app|
-      Clusters::FetchAppInstallationStatusService.new(app).execute do |phase, log|
-        case phase
-        when 'Succeeded'
-          if app.make_installed
-            Clusters::FinalizeAppInstallationService.new(app).execute
-          else
-            app.make_errored!("Failed to update app record; #{app.errors}")
-          end
-        when 'Failed'
-          app.make_errored!(log || 'Installation silently failed')
-          Clusters::FinalizeAppInstallationService.new(app).execute
-        else
-          if Time.now.utc - app.updated_at.to_time.utc > TIMEOUT
-            app.make_errored!('App installation timeouted')
-          else
-            ClusterWaitForAppInstallationWorker.perform_in(EAGER_INTERVAL, app.name, app.id)
-          end
-        end
-      end
+      Clusters::CheckAppInstallationProgressService.new(app).execute
     end
   end
 end