# frozen_string_literal: true

module Clusters
  module Applications
    class CheckInstallationProgressService < BaseHelmService
      def execute
        return unless app.installing?

        case installation_phase
        when Gitlab::Kubernetes::Pod::SUCCEEDED
          on_success
        when Gitlab::Kubernetes::Pod::FAILED
          on_failed
        else
          check_timeout
        end
      rescue Kubeclient::HttpError => e
        Rails.logger.error("Kubernetes error: #{e.error_code} #{e.message}")
        Gitlab::Sentry.track_acceptable_exception(e, extra: { scope: 'kubernetes', app_id: app.id })
        app.make_errored!("Kubernetes error: #{e.error_code}") unless app.errored?
      end

      private

      def on_success
        app.make_installed!
      ensure
        remove_installation_pod
      end

      def on_failed
        app.make_errored!('Installation failed')
      ensure
        remove_installation_pod
      end

      def check_timeout
        if timeouted?
          begin
            app.make_errored!('Installation timed out')
          ensure
            remove_installation_pod
          end
        else
          ClusterWaitForAppInstallationWorker.perform_in(
            ClusterWaitForAppInstallationWorker::INTERVAL, app.name, app.id)
        end
      end

      def timeouted?
        Time.now.utc - app.updated_at.to_time.utc > ClusterWaitForAppInstallationWorker::TIMEOUT
      end

      def remove_installation_pod
        helm_api.delete_pod!(install_command.pod_name)
      rescue => e
        Rails.logger.error("Kubernetes error: #{e.class.name} #{e.message}")
        # no-op
      end

      def installation_phase
        helm_api.status(install_command.pod_name)
      end

      def installation_errors
        helm_api.log(install_command.pod_name)
      end
    end
  end
end