summaryrefslogtreecommitdiff
path: root/app/services/clusters/applications/check_uninstall_progress_service.rb
blob: 2a2594a30c885ddb13c84249377e588abd8f57e8 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
# frozen_string_literal: true

module Clusters
  module Applications
    class CheckUninstallProgressService < BaseHelmService
      def execute
        return unless app.uninstalling?

        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
        log_error(e)

        app.make_errored!("Kubernetes error: #{e.error_code}")
      end

      private

      def on_success
        app.make_uninstalled!
      ensure
        remove_installation_pod
      end

      def on_failed
        app.make_errored!("Operation failed. Check pod logs for #{pod_name} for more details.")
      end

      def check_timeout
        if timeouted?
          begin
            app.make_errored!("Operation timed out. Check pod logs for #{pod_name} for more details.")
          end
        else
          WaitForUninstallAppWorker.perform_in(WaitForUninstallAppWorker::INTERVAL, app.name, app.id)
        end
      end

      def pod_name
        app.uninstall_command.pod_name
      end

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

      def remove_installation_pod
        helm_api.delete_pod!(pod_name)
      end

      def installation_phase
        helm_api.status(pod_name)
      end
    end
  end
end