ManageIQ/manageiq-providers-amazon

class ManageIQ::Providers::Amazon::CloudManager::OrchestrationStack < ManageIQ::Providers::CloudManager::OrchestrationStack
  def self.raw_create_stack(orchestration_manager, stack_name, template, options = {})
    options = format_v2_options(options)
    orchestration_manager.with_provider_connection(:service => :CloudFormation) do |service|
      stack_options = options.merge(:stack_name => stack_name, :template_body => template.content)
      service.create_stack(stack_options).stack_id
    end
  rescue => err
    _log.error "stack=[#{stack_name}], error: #{err}"
    raise MiqException::MiqOrchestrationProvisionError, err.to_s, err.backtrace
  end

  def raw_update_stack(template, options)
    options = self.class.format_v2_options(options)
    update_options = {:template_body => template.content}.merge(options.except(:on_failure, :timeout_in_minutes))
    ext_management_system.with_provider_connection(:service => :CloudFormation) do |service|
      service.stack(name).update(update_options)
    end
  rescue => err
    _log.error "stack=[#{name}], error: #{err}"
    raise MiqException::MiqOrchestrationUpdateError, err.to_s, err.backtrace
  end

  def self.format_v2_options(options)
    # The old code was designed for aws sdk v1. Now v2 requires an Array of Hash
    return options if !options.key?(:parameters) || options[:parameters].kind_of?(Array)

    parameter_arr = options[:parameters].collect { |k, v| {:parameter_key => k, :parameter_value => v} }
    options.merge(:parameters => parameter_arr)
  end

  def raw_delete_stack
    ext_management_system.with_provider_connection(:service => :CloudFormation) do |service|
      service.stack(name).try!(:delete)
    end
  rescue => err
    _log.error "stack=[#{name}], error: #{err}"
    raise MiqException::MiqOrchestrationDeleteError, err.to_s, err.backtrace
  end

  def raw_status
    ext_management_system.with_provider_connection(:service => :CloudFormation) do |service|
      raw_stack = service.stack(name)
      Status.new(raw_stack.stack_status, raw_stack.stack_status_reason)
    end
  rescue => err
    if err.to_s =~ /[S|s]tack.+does not exist/
      raise MiqException::MiqOrchestrationStackNotExistError, "#{name} does not exist on #{ext_management_system.name}"
    end

    _log.error "stack=[#{name}], error: #{err}"
    raise MiqException::MiqOrchestrationStatusError, err.to_s, err.backtrace
  end

  def self.display_name(number = 1)
    n_('Orchestration Stack (Amazon)', 'Orchestration Stacks (Amazon)', number)
  end
end