ManageIQ/manageiq-providers-autosde

class ManageIQ::Providers::Autosde::StorageManager::PhysicalStorage < ::PhysicalStorage
  supports :create
  supports :update do
    _("The Physical Storage is not connected to an active Manager") if ext_management_system.nil?
  end
  supports :delete do
    _("The Physical Storage is not connected to an active Manager") if ext_management_system.nil?
  end
  supports :validate

  def raw_delete_physical_storage
    task_id = ext_management_system.autosde_client.StorageSystemApi.storage_systems_pk_delete(ems_ref).task_id
    options = {
      :target_id      => id,
      :target_class   => self.class.name,
      :ems_id         => ext_management_system.id,
      :native_task_id => task_id,
      :interval       => 20.seconds,
      :target_option  => "existing"
    }
    ext_management_system.class::EmsRefreshWorkflow.create_job(options).tap(&:signal_start)
  end

  def self.raw_validate_physical_storage(ext_management_system, options = {})
    validation_object = ext_management_system.autosde_client.StorageSystemCreate(
      :management_ip => options['management_ip'],
      :user          => options['user'],
      :password      => ManageIQ::Password.try_decrypt(options['password']),
      :system_type   => PhysicalStorageFamily.find(options['physical_storage_family_id']).name
    )
    ext_management_system.autosde_client.ValidateSystemApi.validate_system_post(validation_object)
  end

  def raw_update_physical_storage(options = {})
    update_details = ext_management_system.autosde_client.StorageSystemUpdate(
      :name          => options['name'],
      :password      => options['password'] || "",
      :user          => options['user'] || "",
      :management_ip => options['management_ip'] || ""
    )
    task_id = ext_management_system.autosde_client.StorageSystemApi.storage_systems_pk_put(ems_ref, update_details).task_id

    options = {
      :target_class   => self.class.name,
      :target_id      => id,
      :ems_id         => ext_management_system.id,
      :native_task_id => task_id,
      :interval       => 10.seconds,
      :target_option  => "existing"
    }
    ext_management_system.class::EmsRefreshWorkflow.create_job(options).tap(&:signal_start)
  end

  def self.raw_create_physical_storage(ext_management_system, options = {})
    sys_to_create = ext_management_system.autosde_client.StorageSystemCreate(
      :password                       => ManageIQ::Password.try_decrypt(options['password']),
      :user                           => options['user'],
      :system_type                    => PhysicalStorageFamily.find(options['physical_storage_family_id']).name,
      :management_ip                  => options['management_ip'],
      :storage_family                 => "ontap_7mode",
      :enabled_capability_values_list => options['enabled_capability_values']
    )

    begin
      task_id = ext_management_system.autosde_client.StorageSystemApi.storage_systems_post(sys_to_create).task_id
    ensure
      options = {
        :target_class   => :physical_storages,
        :target_id      => nil,
        :ems_id         => ext_management_system.id,
        :native_task_id => task_id,
        :interval       => 10.seconds,
        :target_option  => "new"
      }
      ext_management_system.class::EmsRefreshWorkflow.create_job(options).tap(&:signal_start)
    end
  end
end