<commit_before>describe MiqProvision do
  context "::StateMachine" do
    let(:req_user) { FactoryBot.create(:user_with_group) }
    let(:ems)      { FactoryBot.create(:ems_openstack_with_authentication) }
    let(:flavor)   { FactoryBot.create(:flavor_openstack, :ems_ref => 24) }
    let(:options)  { {:src_vm_id => template.id, :vm_target_name => "test_vm_1"} }
    let(:template) { FactoryBot.create(:template_openstack, :ext_management_system => ems, :ems_ref => SecureRandom.uuid) }
    let(:vm)       { FactoryBot.create(:vm_openstack, :ext_management_system => ems) }

    let(:task) do
      FactoryBot.create(:miq_provision_openstack,
                         :source      => template,
                         :destination => vm,
                         :state       => 'pending',
                         :status      => 'Ok',
                         :userid      => req_user.userid,
                         :options     => options)
    end

    context "#prepare_provision" do
      before do
        allow(task).to receive(:update_and_notify_parent)
        allow(task).to receive_messages(:instance_type => flavor)
      end

      it "sets default :clone_options" do
        expect(task).to receive(:signal).with(:prepare_provision).and_call_original
        expect(task).to receive(:signal).with(:start_clone_task)

        task.signal(:prepare_provision)

        expect(task.phase_context[:clone_options]).to eq(
          :flavor_ref      => flavor.ems_ref,
          :image_ref       => template.ems_ref,
          :name            => options[:vm_target_name],
          :security_groups => [],
        )
      end

      it "merges :clone_options from automate" do
        options[:clone_options] = {:security_groups => ["test_sg"], :test_key => "test_value"}
        task.update(:options => options)

        expect(task).to receive(:signal).with(:prepare_provision).and_call_original
        expect(task).to receive(:signal).with(:start_clone_task)

        task.signal(:prepare_provision)

        expect(task.phase_context[:clone_options]).to eq(
          :flavor_ref      => flavor.ems_ref,
          :image_ref       => template.ems_ref,
          :name            => options[:vm_target_name],
          :security_groups => ["test_sg"],
          :test_key        => "test_value"
        )
      end

      it "handles deleting nils when merging :clone_options from automate" do
        options[:clone_options] = {:image_ref => nil, :test_key => "test_value"}
        task.update(:options => options)

        expect(task).to receive(:signal).with(:prepare_provision).and_call_original
        expect(task).to receive(:signal).with(:start_clone_task)

        task.signal(:prepare_provision)

        expect(task.phase_context[:clone_options]).to eq(
          :flavor_ref      => flavor.ems_ref,
          :name            => options[:vm_target_name],
          :security_groups => [],
          :test_key        => "test_value"
        )
      end
    end

    context "#post_create_destination" do
      let(:user) { FactoryBot.create(:user_with_email_and_group) }

      it "sets description" do
        options[:vm_description] = description = "foo bar"
        task.update(:options => options)

        expect(task).to receive(:mark_as_completed)

        task.signal(:post_create_destination)

        expect(task.destination.description).to eq(description)
        expect(vm.reload.description).to        eq(description)
      end

      it "sets ownership" do
        group_owner = FactoryBot.create(:miq_group, :description => "desired")
        group_current = FactoryBot.create(:miq_group, :description => "current")
        user.update!(:miq_groups => [group_owner, group_current], :current_group => group_current)
        options[:owner_email] = user.email
        options[:owner_group] = group_owner.description
        task.update(:options => options)

        expect(task).to receive(:mark_as_completed)

        task.signal(:post_create_destination)

        expect(task.destination.evm_owner).to eq(user)
        vm.reload
        expect(vm.evm_owner).to eq(user)
        expect(vm.miq_group).to eq(group_owner)
      end

      context "sets retirement" do
        it "with :retirement option" do
          options[:retirement] = retirement = 2.days.to_i
          retires_on           = Time.now.utc + retirement
          task.update(:options => options)

          expect(task).to receive(:mark_as_completed)

          task.signal(:post_create_destination)

          expect(task.destination.retires_on).to be_between(retires_on - 1.second, retires_on + 1.second)
          expect(vm.reload.retires_on).to        be_between(retires_on - 1.second, retires_on + 1.second)
          expect(vm.retirement_warn).to          eq(0)
          expect(vm.retired).to                  be_falsey
        end

        it "with :retirement_time option" do
          retirement_warn_days      = 7
          options[:retirement]      = 2.days.to_i
          options[:retirement_time] = retirement_time = Time.now.utc + 3.days  # This setting overrides the :retirement setting
          options[:retirement_warn] = retirement_warn_days.days.to_i
          retires_on                = retirement_time
          task.update(:options => options)

          expect(task).to receive(:mark_as_completed)

          task.signal(:post_create_destination)

          expect(task.destination.retires_on).to eq(retires_on)
          expect(vm.reload.retires_on).to        be_between(retires_on - 1.second, retires_on + 1.second)
          expect(vm.retirement_warn).to          eq(retirement_warn_days)
          expect(vm.retired).to                  be_falsey
        end
      end

      it "sets genealogy" do
        expect(task).to receive(:mark_as_completed)

        task.signal(:post_create_destination)

        task.destination.with_relationship_type("genealogy") { |v| expect(v.parent).to   eq(template) }
        vm.reload.with_relationship_type("genealogy")        { |v| expect(v.parent).to   eq(template) }
        template.reload.with_relationship_type("genealogy")  { |v| expect(v.children).to eq([vm]) }
      end
    end<commit_msg>fix sporadic test with state_machine_spec<commit_after>describe MiqProvision do
  context "::StateMachine" do
    let(:req_user) { FactoryBot.create(:user_with_group) }
    let(:ems)      { FactoryBot.create(:ems_openstack_with_authentication) }
    let(:flavor)   { FactoryBot.create(:flavor_openstack, :ems_ref => 24) }
    let(:options)  { {:src_vm_id => template.id, :vm_target_name => "test_vm_1"} }
    let(:template) { FactoryBot.create(:template_openstack, :ext_management_system => ems, :ems_ref => SecureRandom.uuid) }
    let(:vm)       { FactoryBot.create(:vm_openstack, :ext_management_system => ems) }

    let(:task) do
      FactoryBot.create(:miq_provision_openstack,
                         :source      => template,
                         :destination => vm,
                         :state       => 'pending',
                         :status      => 'Ok',
                         :userid      => req_user.userid,
                         :options     => options)
    end

    context "#prepare_provision" do
      before do
        allow(task).to receive(:update_and_notify_parent)
        allow(task).to receive_messages(:instance_type => flavor)
      end

      it "sets default :clone_options" do
        expect(task).to receive(:signal).with(:prepare_provision).and_call_original
        expect(task).to receive(:signal).with(:start_clone_task)

        task.signal(:prepare_provision)

        expect(task.phase_context[:clone_options]).to eq(
          :flavor_ref      => flavor.ems_ref,
          :image_ref       => template.ems_ref,
          :name            => options[:vm_target_name],
          :security_groups => [],
        )
      end

      it "merges :clone_options from automate" do
        options[:clone_options] = {:security_groups => ["test_sg"], :test_key => "test_value"}
        task.update(:options => options)

        expect(task).to receive(:signal).with(:prepare_provision).and_call_original
        expect(task).to receive(:signal).with(:start_clone_task)

        task.signal(:prepare_provision)

        expect(task.phase_context[:clone_options]).to eq(
          :flavor_ref      => flavor.ems_ref,
          :image_ref       => template.ems_ref,
          :name            => options[:vm_target_name],
          :security_groups => ["test_sg"],
          :test_key        => "test_value"
        )
      end

      it "handles deleting nils when merging :clone_options from automate" do
        options[:clone_options] = {:image_ref => nil, :test_key => "test_value"}
        task.update(:options => options)

        expect(task).to receive(:signal).with(:prepare_provision).and_call_original
        expect(task).to receive(:signal).with(:start_clone_task)

        task.signal(:prepare_provision)

        expect(task.phase_context[:clone_options]).to eq(
          :flavor_ref      => flavor.ems_ref,
          :name            => options[:vm_target_name],
          :security_groups => [],
          :test_key        => "test_value"
        )
      end
    end

    context "#post_create_destination" do
      let(:user) { FactoryBot.create(:user_with_email_and_group) }

      it "sets description" do
        options[:vm_description] = description = "foo bar"
        task.update(:options => options)

        expect(task).to receive(:mark_as_completed)

        task.signal(:post_create_destination)

        expect(task.destination.description).to eq(description)
        expect(vm.reload.description).to        eq(description)
      end

      it "sets ownership" do
        group_owner = FactoryBot.create(:miq_group, :description => "desired")
        group_current = FactoryBot.create(:miq_group, :description => "current")
        user.update!(:miq_groups => [group_owner, group_current], :current_group => group_current)
        options[:owner_email] = user.email
        options[:owner_group] = group_owner.description
        task.update(:options => options)

        expect(task).to receive(:mark_as_completed)

        task.signal(:post_create_destination)

        expect(task.destination.evm_owner).to eq(user)
        vm.reload
        expect(vm.evm_owner).to eq(user)
        expect(vm.miq_group).to eq(group_owner)
      end

      context "sets retirement" do
        it "with :retirement option" do
          options[:retirement] = retirement = 2.days.to_i
          retires_on           = Time.now.utc + retirement
          task.update(:options => options)

          expect(task).to receive(:mark_as_completed)

          task.signal(:post_create_destination)

          expect(task.destination.retires_on).to be_between(retires_on - 2.seconds, retires_on + 2.seconds)
          expect(vm.reload.retires_on).to        be_between(retires_on - 2.seconds, retires_on + 2.seconds)
          expect(vm.retirement_warn).to          eq(0)
          expect(vm.retired).to                  be_falsey
        end

        it "with :retirement_time option" do
          retirement_warn_days      = 7
          options[:retirement]      = 2.days.to_i
          options[:retirement_time] = retirement_time = Time.now.utc + 3.days  # This setting overrides the :retirement setting
          options[:retirement_warn] = retirement_warn_days.days.to_i
          retires_on                = retirement_time
          task.update(:options => options)

          expect(task).to receive(:mark_as_completed)

          task.signal(:post_create_destination)

          expect(task.destination.retires_on).to eq(retires_on)
          expect(vm.reload.retires_on).to        be_between(retires_on - 2.seconds, retires_on + 2.seconds)
          expect(vm.retirement_warn).to          eq(retirement_warn_days)
          expect(vm.retired).to                  be_falsey
        end
      end

      it "sets genealogy" do
        expect(task).to receive(:mark_as_completed)

        task.signal(:post_create_destination)

        task.destination.with_relationship_type("genealogy") { |v| expect(v.parent).to   eq(template) }
        vm.reload.with_relationship_type("genealogy")        { |v| expect(v.parent).to   eq(template) }
        template.reload.with_relationship_type("genealogy")  { |v| expect(v.children).to eq([vm]) }
      end
    end
{'fraction_non_alphanumeric': 0.11426726920593931, 'fraction_numerical': 0.0022595222724338285, 'mean_word_length': 2.4168734491315136, 'pattern_counts': {'":': 2, '<': 3, '<?xml version=': 0, '>': 83, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6337795', 'n_tokens_mistral': 3694, 'n_tokens_neox': 3546, 'n_words': 591}