require 'json'
require 'open3'
require 'shellwords'
require 'kubernetes-deploy/kubectl'

module KubernetesDeploy
  class KubernetesResource
    def self.logger=(value)
      @logger = value
    end

    def self.logger
      @logger ||= begin
        l = ::Logger.new($stderr)
        l.formatter = proc do |_severity, datetime, _progname, msg|
          "[KUBESTATUS][#{datetime}]\t#{msg}\n"
        end
        l
      end
    end

    attr_reader :name, :namespace, :file, :context
    attr_writer :type, :deploy_started

    TIMEOUT = 5.minutes

    def self.for_type(type, name, namespace, context, file)
      case type
      when 'cloudsql' then Cloudsql.new(name, namespace, context, file)
      when 'configmap' then ConfigMap.new(name, namespace, context, file)
      when 'deployment' then Deployment.new(name, namespace, context, file)
      when 'pod' then Pod.new(name, namespace, context, file)
      when 'redis' then Redis.new(name, namespace, context, file)
      when 'bugsnag' then Bugsnag.new(name, namespace, context, file)
      when 'ingress' then Ingress.new(name, namespace, context, file)
      when 'persistentvolumeclaim' then PersistentVolumeClaim.new(name, namespace, context, file)
      when 'service' then Service.new(name, namespace, context, file)
      when 'podtemplate' then PodTemplate.new(name, namespace, context, file)
      else self.new(name, namespace, context, file).tap { |r| r.type = type }
      end
    end

    def self.timeout
      self::TIMEOUT
    end

    def timeout
      self.class.timeout
    end

    def initialize(name, namespace, context, file)
      # subclasses must also set these
      @name, @namespace, @context, @file = name, namespace, context, file
    end

    def id
      "#{type}/#{name}"
    end

    def sync
      log_status
    end

    def deploy_failed?
      false
    end

    def deploy_succeeded?
      if @deploy_started && !@success_assumption_warning_shown
        KubernetesDeploy.logger.warn("Don't know how to monitor resources of type #{type}. Assuming #{id} deployed successfully.")
        @success_assumption_warning_shown = true
      end
      true
    end

    def exists?
      nil
    end

    def status
      @status ||= "Unknown"
      deploy_timed_out? ? "Timed out with status #{@status}" : @status
    end

    def type
      @type || self.class.name.split('::').last
    end

    def deploy_finished?
      deploy_failed? || deploy_succeeded? || deploy_timed_out?
    end

    def deploy_timed_out?
      return false unless @deploy_started
      !deploy_succeeded? && !deploy_failed? && (Time.now.utc - @deploy_started > timeout)
    end

    def tpr?
      false
    end

    def status_data
      {
        group: group_name,
        name: name,
        status_string: status,
        exists: exists?,
        succeeded: deploy_succeeded?,
        failed: deploy_failed?,
        timed_out: deploy_timed_out?
      }
    end

    def group_name
      type.downcase.pluralize
    end

    def log_status
      KubernetesResource.logger.info("[#{@context}][#{@namespace}] #{JSON.dump(status_data)}")
    end

    def run_kubectl(*args)
      raise FatalDeploymentError, "Namespace missing for namespaced command" if @namespace.blank?
      raise KubectlError, "Explicit context is required to run this command" if @context.blank?

      Kubectl.run_kubectl(*args, namespace: @namespace, context: @context, log_failure: false)
    end
  end
end