require 'spec_helper'
require 'vagrant-openstack-cloud-provider/errors'
require 'vagrant-openstack-cloud-provider/action/create_server'

I18n.load_path << File.expand_path("locales/en.yml", Pathname.new(File.expand_path("../../../../", __FILE__)))
I18n.reload!

RSpec.describe VagrantPlugins::OpenStack::Action::CreateServer do
  describe '#server_to_be_available?' do
    subject {
      described_class.new(nil, nil)
    }

    let(:server) { double }

    it "returns true when server is active" do
      expect(server).to receive(:state).at_least(:once).and_return('ACTIVE')
      expect(subject.server_to_be_available?(server)).to eq(true)
    end

    it "should raise when the server state is ERROR" do
      expect(server).to receive(:state).at_least(:once).and_return('ERROR')
      expect { subject.server_to_be_available?(server) }.to raise_error(RuntimeError)
    end
  end

  describe '#ssh_is_responding?' do
    subject {
      described_class.new(nil, nil)
    }

    let(:ui) { double }
    let(:machine) { double }
    let(:communicate) { double }

    it "should continue if ssh is available" do
      expect(ui).to receive(:info).at_least(:once)
      expect(communicate).to receive(:ready?).twice.and_return(true)
      expect(machine).to receive(:communicate).at_least(:once).and_return(communicate)

      env = { :ui => ui, :interrupted => false, :machine => machine }
      subject.send('ssh_is_responding?', env, timeout=1, sleep_interval=0.001)
    end

    it "should raise if ssh isn't available" do
      expect(ui).to receive(:info).at_least(:once)
      expect(communicate).to receive(:ready?).exactly(6).times.and_return(false)
      expect(machine).to receive(:communicate).at_least(:once).and_return(communicate)

      env = { :ui => ui, :interrupted => false, :machine => machine }
      expect { subject.send('ssh_is_responding?', env, timeout=0.005, sleep_interval=0.001) }.
          to raise_error(VagrantPlugins::OpenStack::Errors::SshUnavailable).
              with_message(I18n.t('vagrant_openstack.errors.ssh_unavailable',
                                  :error => I18n.t('vagrant_openstack.errors.ssh_wait_timeout',
                                                   :seconds => 0.005)))
    end

    it 'should show any error raised' do
      expect(ui).to receive(:info).at_least(:once)
      expect(communicate).to receive(:ready?).once.and_raise(Exception.new("waaaat"))
      expect(machine).to receive(:communicate).at_least(:once).and_return(communicate)

      env = { :ui => ui, :interrupted => false, :machine => machine }
      expect { subject.send('ssh_is_responding?', env, timeout=0.005, sleep_interval=0.001) }.
          to raise_error(VagrantPlugins::OpenStack::Errors::SshUnavailable).
              with_message(I18n.t('vagrant_openstack.errors.ssh_unavailable',
                                  :error => 'waaaat'))
    end
  end

  describe '#find_matching' do
    subject {
      described_class.new(nil, nil)
    }

    it "returns a match for a list of hashes" do
      haystack = [{"status"=>"ACTIVE", "subnets"=>["d8908f8c-07f4-405b-bbab-e19c768f293f"], "name"=>"solidfire", "provider:physical_network"=>"physnet1", "admin_state_up"=>true, "tenant_id"=>"2c9fba23721f4126ab244020e641f5f5", "provider:network_type"=>"vlan", "router:external"=>false, "shared"=>true, "id"=>"192702e6-3444-4162-b244-3af8b50fbb45", "provider:segmentation_id"=>3999}, {"status"=>"ACTIVE", "subnets"=>["d4318e28-5acd-415f-b300-0502f33b0dea"], "name"=>"public", "provider:physical_network"=>"physnet0", "admin_state_up"=>true, "tenant_id"=>"2c9fba23721f4126ab244020e641f5f5", "provider:network_type"=>"vlan", "router:external"=>false, "shared"=>true, "id"=>"e44bf8cb-7326-4abc-b96d-5404d5ed7767", "provider:segmentation_id"=>2753}]
      needle = {"status"=>"ACTIVE", "subnets"=>["d4318e28-5acd-415f-b300-0502f33b0dea"], "name"=>"public", "provider:physical_network"=>"physnet0", "admin_state_up"=>true, "tenant_id"=>"2c9fba23721f4126ab244020e641f5f5", "provider:network_type"=>"vlan", "router:external"=>false, "shared"=>true, "id"=>"e44bf8cb-7326-4abc-b96d-5404d5ed7767", "provider:segmentation_id"=>2753}

      expect(subject.send('find_matching', haystack, needle['name'])).to eq(needle)
    end

    it "returns a match for a list of objects with matching id" do
      object1 = double(:object1,
                       :id => 'matching_value',
                       :name => 'not_this')

      haystack = [object1]
      expect(subject.send('find_matching', haystack, 'matching_value')).to equal(object1)
    end

    it "returns a match for a list of objects with matching name" do
      object1 = double(:object1,
                       :id => 'not_this',
                       :name => 'matching_value')

      haystack = [object1]
      expect(subject.send('find_matching', haystack, 'matching_value')).to equal(object1)
    end

    it "returns a match for a list of objects with a matching regexp" do
      object1 = double(:object1,
                       :id => 'not_this',
                       :name => '2020 des fin fin')

      haystack = [object1]
      expect(subject.send('find_matching', haystack, /des fin/)).to equal(object1)
    end
  end
end