include CompressedIds

describe EmsCloudController do
  let!(:server) { EvmSpecHelper.local_miq_server(:zone => zone) }
  let(:zone)   { FactoryGirl.build(:zone) }
  describe "#create" do
    before do
      allow(controller).to receive(:check_privileges).and_return(true)
      allow(controller).to receive(:assert_privileges).and_return(true)
      login_as FactoryGirl.create(:user, :features => "ems_cloud_new")
    end

    it "adds a new provider" do
      controller.instance_variable_set(:@breadcrumbs, [])
      get :new
      expect(response.status).to eq(200)
      expect(allow(controller).to receive(:edit)).to_not be_nil
    end

    render_views

    it 'shows the edit page' do
      get :edit, :params => { :id => FactoryGirl.create(:ems_amazon).id }
      expect(response.status).to eq(200)
    end

    it 'creates on post' do
      expect do
        post :create, :params => {
          "button"               => "add",
          "name"                 => "foo",
          "emstype"              => "ec2",
          "provider_region"      => "ap-southeast-1",
          "port"                 => "",
          "zone"                 => zone.name,
          "default_userid"       => "foo",
          "default_password"     => "[FILTERED]",
          "default_verify"       => "[FILTERED]",
          "metrics_userid"       => "",
          "metrics_password"     => "[FILTERED]",
          "metrics_verify"       => "[FILTERED]",
          "amqp_userid"          => "",
          "amqp_password"        => "[FILTERED]",
          "amqp_verify"          => "[FILTERED]",
          "ssh_keypair_userid"   => "",
          "ssh_keypair_password" => "[FILTERED]"
        }
      end.to change { ManageIQ::Providers::Amazon::CloudManager.count }.by(1)
    end

    it 'creates and updates an authentication record on post' do
      expect do
        post :create, :params => {
          "button"           => "add",
          "default_hostname" => "host_openstack",
          "name"             => "foo_openstack",
          "emstype"          => "openstack",
          "provider_region"  => "",
          "default_port"     => "5000",
          "zone"             => zone.name,
          "default_userid"   => "foo",
          "default_password" => "[FILTERED]",
          "default_verify"   => "[FILTERED]"
        }
      end.to change { Authentication.count }.by(1)

      expect(response.status).to eq(200)
      openstack = ManageIQ::Providers::Openstack::CloudManager.where(:name => "foo_openstack").first
      expect(openstack.authentications.size).to eq(1)

      expect do
        post :update, :params => {
          "id"               => openstack.id,
          "button"           => "save",
          "default_hostname" => "host_openstack_updated",
          "name"             => "foo_openstack",
          "emstype"          => "openstack",
          "provider_region"  => "",
          "default_port"     => "5000",
          "default_userid"   => "bar",
          "default_password" => "[FILTERED]",
          "default_verify"   => "[FILTERED]"
        }
      end.not_to change { Authentication.count }

      expect(response.status).to eq(200)
      expect(openstack.authentications.first).to have_attributes(:userid => "bar", :password => "[FILTERED]")
    end

    it "validates credentials for a new record" do
      post :create, :params => {
        "button"           => "validate",
        "cred_type"        => "default",
        "name"             => "foo_ec2",
        "emstype"          => "ec2",
        "provider_region"  => "ap-southeast-1",
        "zone"             => "default",
        "default_userid"   => "foo",
        "default_password" => "[FILTERED]",
        "default_verify"   => "[FILTERED]"
      }

      expect(response.status).to eq(200)
    end

    it "cancels a new record" do
      post :create, :params => {
        "button"           => "cancel",
        "cred_type"        => "default",
        "name"             => "foo_ec2",
        "emstype"          => "ec2",
        "provider_region"  => "ap-southeast-1",
        "zone"             => "default",
        "default_userid"   => "foo",
        "default_password" => "[FILTERED]",
        "default_verify"   => "[FILTERED]"
      }

      expect(response.status).to eq(200)
    end

    it "adds a record of type azure" do
      post :create, :params => {
        "button"           => "add",
        "azure_tenant_id"  => "azure",
        "name"             => "foo_azure",
        "emstype"          => "azure",
        "zone"             => zone.name,
        "default_userid"   => "foo",
        "default_password" => "[FILTERED]",
        "default_verify"   => "[FILTERED]"
      }

      expect(response.status).to eq(200)
      edit = controller.instance_variable_get(:@edit)
      expect(edit[:new][:azure_tenant_id]).to eq("azure")
    end
  end

  describe "#ems_cloud_form_fields" do
    before do
      allow_any_instance_of(described_class).to receive(:set_user_time_zone)
      allow(controller).to receive(:check_privileges).and_return(true)
      allow(controller).to receive(:assert_privileges).and_return(true)
    end

    it 'gets the ems cloud form fields on a get' do
      post :create, :params => {
        "button"           => "add",
        "default_hostname" => "host_openstack",
        "name"             => "foo_openstack",
        "emstype"          => "openstack",
        "provider_region"  => "",
        "default_port"     => "5000",
        "zone"             => zone.name,
        "default_userid"   => "foo",
        "default_password" => "[FILTERED]",
        "default_verify"   => "[FILTERED]"
      }

      expect(response.status).to eq(200)
      openstack = ManageIQ::Providers::Openstack::CloudManager.where(:name => "foo_openstack").first
      get :ems_cloud_form_fields, :params => { "id" => openstack.id }
      expect(response.status).to eq(200)
      expect(response.body).to include('"name":"foo_openstack"')
    end

    it 'strips whitespace from name, hostname and api_port form fields on create' do
      post :create, :params => {
        "button"           => "add",
        "default_hostname" => "  host_openstack     ",
        "name"             => "  foo_openstack     ",
        "emstype"          => "openstack",
        "provider_region"  => "",
        "default_api_port" => "   5000     ",
        "zone"             => zone.name,
        "default_userid"   => "foo",
        "default_password" => "[FILTERED]",
        "default_verify"   => "[FILTERED]"
      }

      expect(response.status).to eq(200)
      expect(ManageIQ::Providers::Openstack::CloudManager.with_hostname('host_openstack')
                                                         .with_port('5000')
                                                         .where(:name => 'foo_openstack')
                                                         .count).to eq(1)
    end
  end

  describe "#show_link" do
    before do
      allow_any_instance_of(described_class).to receive(:set_user_time_zone)
      allow(controller).to receive(:check_privileges).and_return(true)
      allow(controller).to receive(:assert_privileges).and_return(true)
    end

    it 'gets the restful show link and timeline link paths' do
      session[:settings] = {:views => {:vm_summary_cool => ""}}
      post :create, :params => {
        "button"           => "add",
        "default_hostname" => "host_openstack",
        "name"             => "foo_openstack",
        "emstype"          => "openstack",
        "provider_region"  => "",
        "default_port"     => "5000",
        "zone"             => zone.name,
        "default_userid"   => "foo",
        "default_password" => "[FILTERED]",
        "default_verify"   => "[FILTERED]"
      }

      expect(response.status).to eq(200)
      openstack = ManageIQ::Providers::Openstack::CloudManager.where(:name => "foo_openstack").first
      show_link_actual_path = controller.send(:show_link, openstack)
      expect(show_link_actual_path).to eq("/ems_cloud/#{openstack.id}")

      post :show, :params => {
        "button"  => "timeline",
        "display" => "timeline",
        "id"      => openstack.id
      }

      expect(response.status).to eq(200)
      show_link_actual_path = controller.send(:show_link, openstack, :display => "timeline")
      expect(show_link_actual_path).to eq("/ems_cloud/#{openstack.id}?display=timeline")
    end
  end

  context "#build_credentials only contains credentials that it supports and has a username for in params" do
    let(:mocked_ems)    { double(ManageIQ::Providers::Openstack::CloudManager) }
    let(:default_creds) { {:userid => "default_userid", :password => "default_password"} }
    let(:amqp_creds)    { {:userid => "amqp_userid",    :password => "amqp_password"} }

    it "uses the passwords from params for validation if they exist" do
      controller.instance_variable_set(:@_params,
                                       :default_userid   => default_creds[:userid],
                                       :default_password => default_creds[:password],
                                       :amqp_userid      => amqp_creds[:userid],
                                       :amqp_password    => amqp_creds[:password])
      expect(mocked_ems).to receive(:supports_authentication?).with(:amqp).and_return(true)
      expect(mocked_ems).to receive(:supports_authentication?).with(:oauth)
      expect(mocked_ems).to receive(:supports_authentication?).with(:auth_key)
      expect(controller.send(:build_credentials, mocked_ems, :validate)).to eq(:default => default_creds.merge!(:save => false), :amqp => amqp_creds.merge!(:save => false))
    end

    it "uses the stored passwords for validation if passwords dont exist in params" do
      controller.instance_variable_set(:@_params,
                                       :default_userid => default_creds[:userid],
                                       :amqp_userid    => amqp_creds[:userid])
      expect(mocked_ems).to receive(:authentication_password).and_return(default_creds[:password])
      expect(mocked_ems).to receive(:authentication_password).with(:amqp).and_return(amqp_creds[:password])
      expect(mocked_ems).to receive(:supports_authentication?).with(:amqp).and_return(true)
      expect(mocked_ems).to receive(:supports_authentication?).with(:oauth)
      expect(mocked_ems).to receive(:supports_authentication?).with(:auth_key)
      expect(controller.send(:build_credentials, mocked_ems, :validate)).to eq(:default => default_creds.merge!(:save => false), :amqp => amqp_creds.merge!(:save => false))
    end
  end

  context "#update_ems_button_validate" do
    let(:mocked_ems) { double(ManageIQ::Providers::Openstack::CloudManager, :id => 1) }
    it "calls authentication_check with save = false if validation is done for an existing record" do
      allow(controller).to receive(:set_ems_record_vars)
      allow(controller).to receive(:render)
      controller.instance_variable_set(:@_params,
                                       :button    => "validate",
                                       :id        => mocked_ems.id,
                                       :cred_type => "default")
      expect(mocked_ems).to receive(:authentication_check).with("default", :save => false)
      controller.send(:update_ems_button_validate, mocked_ems)
    end

    it "calls authentication_check with save = false if validation is done for a new record" do
      allow(controller).to receive(:set_ems_record_vars)
      allow(controller).to receive(:render)
      controller.instance_variable_set(:@_params,
                                       :button           => "validate",
                                       :default_password => "[FILTERED]",
                                       :cred_type        => "default")
      expect(mocked_ems).to receive(:authentication_check).with("default", :save => false)
      controller.send(:update_ems_button_validate, mocked_ems)
    end
  end
  describe "#test_toolbars" do
    before do
      allow(controller).to receive(:check_privileges).and_return(true)
      allow(controller).to receive(:assert_privileges).and_return(true)
      login_as FactoryGirl.create(:user, :features => "ems_cloud_new")
    end

    it "refresh relationships and power states" do
      ems = FactoryGirl.create(:ems_amazon)
      post :button, :params => { :id => ems.id, :pressed => "ems_cloud_refresh" }
      expect(response.status).to eq(200)
    end

    it "discover cloud providers" do
      get :discover, :params => { :discover_type => "ems" }
      expect(response.status).to eq(200)
      expect(response).to render_template('ems_cloud/discover')
    end

    it 'edit selected cloud provider' do
      ems = FactoryGirl.create(:ems_amazon)
      post :button, :params => { :miq_grid_checks => to_cid(ems.id), :pressed => "ems_cloud_edit" }
      expect(response.status).to eq(200)
    end

    it 'edit cloud provider tags' do
      ems = FactoryGirl.create(:ems_amazon)
      post :button, :params => { :miq_grid_checks => to_cid(ems.id), :pressed => "ems_cloud_tag" }
      expect(response.status).to eq(200)
    end

    it 'manage cloud provider policies' do
      ems = FactoryGirl.create(:ems_amazon)
      post :button, :params => { :miq_grid_checks => to_cid(ems.id), :pressed => "ems_cloud_protect" }
      expect(response.status).to eq(200)

      get :protect
      expect(response.status).to eq(200)
      expect(response).to render_template('shared/views/protect')
    end

    it 'edit cloud provider tags' do
      ems = FactoryGirl.create(:ems_amazon)
      post :button, :params => { :id => ems.id, :pressed => "ems_cloud_timeline" }
      expect(response.status).to eq(200)

      get :show, :params => { :display => "timeline", :id => ems.id }
      expect(response.status).to eq(200)
    end

    it 'edit cloud providers' do
      ems = FactoryGirl.create(:ems_amazon)
      post :button, :params => { :miq_grid_checks => to_cid(ems.id), :pressed => "ems_cloud_edit" }
      expect(response.status).to eq(200)
    end
  end

  describe "#show" do
    before do
      EvmSpecHelper.create_guid_miq_server_zone
      login_as FactoryGirl.create(:user)
      session[:settings] = {:views     => {:vm_summary_cool => "summary"},
                            :quadicons => {}}
      @ems = FactoryGirl.create(:ems_amazon)
    end

    subject { get :show, :id => @ems.id }

    context "render listnav partial" do
      render_views

      it do
        is_expected.to have_http_status 200
        is_expected.to render_template(:partial => "layouts/listnav/_ems_cloud")
      end
    end
  end

  describe "#dialog_form_button_pressed" do
    let(:dialog) { double("Dialog") }
    let(:wf) { double(:dialog => dialog) }

    before do
      @ems = FactoryGirl.create(:ems_amazon)
      edit = {:rec_id => 1, :wf => wf, :key => 'dialog_edit__foo', :target_id => @ems.id}
      controller.instance_variable_set(:@edit, edit)
      controller.instance_variable_set(:@sb, {})
      session[:edit] = edit
    end

    it "redirects to requests show list after dialog is submitted" do
      controller.instance_variable_set(:@_params, :button => 'submit', :id => 'foo')
      allow(controller).to receive(:role_allows).and_return(true)
      allow(wf).to receive(:submit_request).and_return({})
      page = double('page')
      allow(page).to receive(:<<).with(any_args)
      expect(page).to receive(:redirect_to).with("/ems_cloud/#{@ems.id}?flash_msg=Order+Request+was+Submitted")
      expect(controller).to receive(:render).with(:update).and_yield(page)
      controller.send(:dialog_form_button_pressed)
    end
  end

  describe "Ceilometer/AMQP Events" do
    before do
      @openstack = FactoryGirl.create(:ems_openstack)
      allow(controller).to receive(:check_privileges).and_return(true)
      allow(controller).to receive(:assert_privileges).and_return(true)
    end

    it "creates ceilometer endpoint and on update to AMQP deletes ceilometer endpoint" do
      post :create, :params => {
        "button"                    => "add",
        "default_hostname"          => "default_hostname",
        "default_userid"            => "",
        "default_password"          => "",
        "name"                      => "openstack_cloud",
        "emstype"                   => "openstack",
        "api_version"               => "v2",
        "provider_region"           => "",
        "zone"                      => zone.name,
        "default_api_port"          => "5000",
        "default_security_protocol" => "ssl-with-validation",
        "event_stream_selection"    => "ceilometer"
      }
      ems_openstack = EmsCloud.where(:name => "openstack_cloud").first
      amqp = Endpoint.where(:role => "amqp", :resource_id => ems_openstack.id).first
      amqp_auth = Authentication.where(:authtype => "amqp", :resource_id => ems_openstack.id).first
      ceilometer = Endpoint.where(:role => "ceilometer", :resource_id => ems_openstack.id).first
      ceilometer_auth = Authentication.where(:authtype => "ceilometer", :resource_id => ems_openstack.id).first
      expect(amqp).to be_nil
      expect(amqp_auth).to be_nil
      expect(ceilometer).not_to be_nil
      expect(ceilometer_auth).to be_nil

      post :update, :params => {
        "id"                        => ems_openstack.id,
        "button"                    => "save",
        "default_hostname"          => "default_hostname",
        "default_userid"            => "",
        "default_password"          => "",
        "name"                      => "openstack_cloud",
        "emstype"                   => "openstack",
        "provider_region"           => "",
        "zone"                      => zone.name,
        "default_api_port"          => "5000",
        "default_security_protocol" => "ssl-with-validation",
        "event_stream_selection"    => "amqp",
        "amqp_hostname"             => "amqp_hostname",
        "amqp_api_port"             => "5672",
        "amqp_security_protocol"    => "ssl",
        "amqp_userid"               => "",
        "amqp_password"             => ""
      }
      amqp = Endpoint.where(:role => "amqp", :resource_id => ems_openstack.id).first
      ceilometer = Endpoint.where(:role => "ceilometer", :resource_id => ems_openstack.id).first
      expect(amqp).not_to be_nil
      expect(ceilometer).to be_nil
    end

    it "restarts event monitor worker on endpoints or credentials change" do
      post :create, :params => {
        "button"                    => "add",
        "default_hostname"          => "default_hostname",
        "default_userid"            => "",
        "default_password"          => "",
        "name"                      => "openstack_cloud",
        "emstype"                   => "openstack",
        "api_version"               => "v2",
        "provider_region"           => "",
        "zone"                      => zone.name,
        "default_api_port"          => "5000",
        "default_security_protocol" => "ssl-with-validation",
        "event_stream_selection"    => "ceilometer"
      }

      # Change from ceilometer to amqp
      ems_openstack = EmsCloud.where(:name => "openstack_cloud").first
      allow(controller).to receive(:find_by_id_filtered).and_return(ems_openstack)
      expect(ems_openstack).to receive(:stop_event_monitor_queue).once

      post :update, :params => {
        "id"                        => ems_openstack.id,
        "button"                    => "save",
        "default_hostname"          => "default_hostname",
        "default_userid"            => "",
        "default_password"          => "",
        "name"                      => "openstack_cloud",
        "emstype"                   => "openstack",
        "provider_region"           => "",
        "zone"                      => zone.name,
        "default_api_port"          => "5000",
        "default_security_protocol" => "ssl-with-validation",
        "event_stream_selection"    => "amqp",
        "amqp_hostname"             => "amqp_hostname",
        "amqp_api_port"             => "5672",
        "amqp_security_protocol"    => "ssl",
        "amqp_userid"               => "",
        "amqp_password"             => ""
      }

      # Change of all endpoints and credentials
      ems_openstack = EmsCloud.where(:name => "openstack_cloud").first
      allow(controller).to receive(:find_by_id_filtered).and_return(ems_openstack)
      # This is a bug in ems saving mechanism, there are 3 saves now, 2 for each auth and one for ems. We need to fix
      # that, then stop_event_monitor_queue should be called once
      expect(ems_openstack).to receive(:stop_event_monitor_queue).exactly(3).times

      post :update, :params => {
        "id"                        => ems_openstack.id,
        "button"                    => "save",
        "default_hostname"          => "default_hostname_changed",
        "default_userid"            => "changed",
        "default_password"          => "changed",
        "name"                      => "openstack_cloud",
        "emstype"                   => "openstack",
        "provider_region"           => "",
        "zone"                      => zone.name,
        "default_api_port"          => "5000",
        "default_security_protocol" => "ssl-with-validation",
        "event_stream_selection"    => "amqp",
        "amqp_hostname"             => "amqp_hostname_changed",
        "amqp_api_port"             => "5672",
        "amqp_security_protocol"    => "ssl",
        "amqp_userid"               => "changed",
        "amqp_password"             => "changed"
      }

      # Change from amqp to ceilometer
      ems_openstack = EmsCloud.where(:name => "openstack_cloud").first
      allow(controller).to receive(:find_by_id_filtered).and_return(ems_openstack)
      expect(ems_openstack).to receive(:stop_event_monitor_queue).once

      post :update, :params => {
        "id"                        => ems_openstack.id,
        "button"                    => "save",
        "default_hostname"          => "default_hostname_changed",
        "default_userid"            => "changed",
        "default_password"          => "changed",
        "name"                      => "openstack_cloud",
        "emstype"                   => "openstack",
        "provider_region"           => "",
        "zone"                      => zone.name,
        "default_api_port"          => "5000",
        "default_security_protocol" => "ssl-with-validation",
        "event_stream_selection"    => "ceilometer"
      }
    end
  end
end
