class VagrantPlugins::ProviderLibvirt::Action::HandleStoragePool

Public Class Methods

new(app, _env) click to toggle source
# File lib/vagrant-libvirt/action/handle_storage_pool.rb, line 14
def initialize(app, _env)
  @logger = Log4r::Logger.new('vagrant_libvirt::action::handle_storage_pool')
  @app = app
end

Public Instance Methods

call(env) click to toggle source
# File lib/vagrant-libvirt/action/handle_storage_pool.rb, line 19
def call(env)
  # Get config options.
  config = env[:machine].provider_config

  # while inside the synchronize block take care not to call the next
  # action in the chain, as must exit this block first to prevent
  # locking all subsequent actions as well.
  @@lock.synchronize do
    # Check for storage pool, where box image should be created
    break unless env[:machine].provider.driver.connection.pools.all(
      name: config.storage_pool_name
    ).empty?

    @logger.info("No storage pool '#{config.storage_pool_name}' is available.")

    # If user specified other pool than default, don't create default
    # storage pool, just write error message.
    raise Errors::NoStoragePool if config.storage_pool_name != 'default'

    @logger.info("Creating storage pool 'default'")

    # Fog Libvirt currently doesn't support creating pools. Use
    # ruby-libvirt client directly.
    begin
      @storage_pool_path = storage_pool_path(env)
      @storage_pool_uid = storage_uid(env)
      @storage_pool_gid = storage_gid(env)
      xml = to_xml('default_storage_pool')
      @logger.debug {
        "Creating Storage Pool with XML:\n#{xml}"
      }
      libvirt_pool = env[:machine].provider.driver.connection.client.define_storage_pool_xml(
        xml
      )
      libvirt_pool.build
      libvirt_pool.create
    rescue => e
      raise Errors::CreatingStoragePoolError,
            error_message: e.message
    end
    raise Errors::NoStoragePool unless libvirt_pool
  end

  @app.call(env)
end