mirror of
https://github.com/vagrant-libvirt/vagrant-libvirt.git
synced 2025-02-25 18:55:27 -06:00
0b53be59cf
Add a unit test for the prepare nfs settings action to act as a regression test for the recent fix to avoiding modifying a frozen string literal. As part of this fix how the communicator is returned via a call to a machine for testing purposes and remove an obsolete expect from the wait till up tests as the code that would result in the communicator being called has been removed. Ensure that nfsd is not required to run the tests by mocking out the host capability check.
130 lines
4.6 KiB
Ruby
130 lines
4.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require 'vagrant-libvirt/action/wait_till_up'
|
|
require 'vagrant-libvirt/errors'
|
|
|
|
require 'spec_helper'
|
|
require 'support/sharedcontext'
|
|
require 'support/libvirt_context'
|
|
|
|
describe VagrantPlugins::ProviderLibvirt::Action::WaitTillUp do
|
|
subject { described_class.new(app, env) }
|
|
|
|
include_context 'vagrant-unit'
|
|
include_context 'libvirt'
|
|
include_context 'unit'
|
|
|
|
let (:driver) { VagrantPlugins::ProviderLibvirt::Driver.new env[:machine] }
|
|
|
|
describe '#call' do
|
|
before do
|
|
allow_any_instance_of(VagrantPlugins::ProviderLibvirt::Provider).to receive(:driver)
|
|
.and_return(driver)
|
|
allow(driver).to receive(:get_domain).and_return(domain)
|
|
allow(driver).to receive(:state).and_return(:running)
|
|
end
|
|
|
|
context 'when machine does not exist' do
|
|
before do
|
|
allow(driver).to receive(:get_domain).and_return(nil)
|
|
end
|
|
|
|
it 'raises exception' do
|
|
expect(app).to_not receive(:call)
|
|
expect { subject.call(env) }.to raise_error(::VagrantPlugins::ProviderLibvirt::Errors::NoDomainError,
|
|
/No domain found. Domain dummy-vagrant_dummy not found/)
|
|
end
|
|
end
|
|
|
|
context 'when machine is booting' do
|
|
context 'if interrupted looking for IP' do
|
|
before do
|
|
env[:interrupted] = true
|
|
end
|
|
it 'should exit' do
|
|
expect(app).to_not receive(:call)
|
|
expect(ui).to receive(:info).with('Waiting for domain to get an IP address...')
|
|
expect(logger).to receive(:debug).with(/Searching for IP for MAC address: .*/)
|
|
expect(subject.call(env)).to be_nil
|
|
end
|
|
end
|
|
|
|
context 'multiple timeouts waiting for IP' do
|
|
before do
|
|
allow(env).to receive(:[]).and_call_original
|
|
allow(env).to receive(:[]).with(:interrupted).and_return(false)
|
|
allow(logger).to receive(:debug)
|
|
allow(logger).to receive(:info)
|
|
end
|
|
|
|
it 'should abort after hitting limit' do
|
|
expect(domain).to receive(:wait_for).at_least(300).times.and_raise(::Fog::Errors::TimeoutError)
|
|
expect(app).to_not receive(:call)
|
|
expect(ui).to receive(:info).with('Waiting for domain to get an IP address...')
|
|
expect(ui).to_not receive(:info).with('Waiting for SSH to become available...')
|
|
expect {subject.call(env) }.to raise_error(::Fog::Errors::TimeoutError)
|
|
end
|
|
end
|
|
end
|
|
|
|
context 'when machine boots and ip available' do
|
|
before do
|
|
allow(domain).to receive(:wait_for).and_return(true)
|
|
allow(env).to receive(:[]).and_call_original
|
|
allow(env).to receive(:[]).with(:interrupted).and_return(false)
|
|
allow(driver).to receive(:get_domain_ipaddress).and_return('192.168.121.2')
|
|
end
|
|
it 'should call the next hook' do
|
|
expect(app).to receive(:call)
|
|
expect(ui).to receive(:info).with('Waiting for domain to get an IP address...')
|
|
expect(logger).to receive(:debug).with(/Searching for IP for MAC address: .*/)
|
|
expect(logger).to receive(:info).with('Got IP address 192.168.121.2')
|
|
expect(logger).to receive(:info).with(/Time for getting IP: .*/)
|
|
expect(subject.call(env)).to be_nil
|
|
end
|
|
end
|
|
end
|
|
|
|
describe '#recover' do
|
|
before do
|
|
allow_any_instance_of(VagrantPlugins::ProviderLibvirt::Driver).to receive(:get_domain).and_return(machine)
|
|
allow_any_instance_of(VagrantPlugins::ProviderLibvirt::Driver).to receive(:state)
|
|
.and_return(:not_created)
|
|
allow(env).to receive(:[]).and_call_original
|
|
end
|
|
|
|
it 'should do nothing by default' do
|
|
expect(env).to_not receive(:[]).with(:action_runner) # cleanup
|
|
expect(subject.recover(env)).to be_nil
|
|
end
|
|
|
|
context 'with machine coming up' do
|
|
before do
|
|
allow_any_instance_of(VagrantPlugins::ProviderLibvirt::Driver).to receive(:state)
|
|
.and_return(:running)
|
|
env[:destroy_on_error] = true
|
|
end
|
|
|
|
context 'and user has disabled destroy on failure' do
|
|
before do
|
|
env[:destroy_on_error] = false
|
|
end
|
|
|
|
it 'skips terminate on failure' do
|
|
expect(env).to_not receive(:[]).with(:action_runner) # cleanup
|
|
expect(subject.recover(env)).to be_nil
|
|
end
|
|
end
|
|
|
|
context 'and using default settings' do
|
|
let(:runner) { double('runner') }
|
|
it 'deletes VM on failure' do
|
|
expect(env).to receive(:[]).with(:action_runner).and_return(runner) # cleanup
|
|
expect(runner).to receive(:run)
|
|
expect(subject.recover(env)).to be_nil
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|