require_relative '../../spec_helper'

def upload_fake_errand_release
  FileUtils.cp_r(FAKE_ERRAND_RELEASE_TEMPLATE, ClientSandbox.fake_errand_release_dir, preserve: true)
  bosh_runner.run_in_dir('create-release --force', ClientSandbox.fake_errand_release_dir)
  bosh_runner.run_in_dir('upload-release', ClientSandbox.fake_errand_release_dir)
end

describe 'run release job errand', type: :integration, with_tmp_dir: true do
  let(:deployment_name) { manifest_hash['name'] }

  let(:service_instance_group_with_errand) do
    instance_group = Bosh::Spec::NewDeployments.service_instance_group_with_errand
    instance_group['instances'] = 2
    instance_group
  end

  let(:emoji_errand_job) do
    { 'release' => 'bosh-release', 'name' => 'emoji-errand' }
  end

  shared_examples_for 'a config that works with the --when-changed flag' do
    let(:manifest_hash) do
      hash = Bosh::Spec::NewDeployments.manifest_with_errand
      hash['instance_groups'] << service_instance_group_with_errand
      hash
    end

    before do
      deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)
    end

    it 'does not run the errand on the second invocation if nothing has changed' do
      output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name)
      expect(output).to match(/job=service_with_errand index=0/)
      expect(output).to match(/job=service_with_errand index=1/)
      expect(output).to match(/job=fake-errand-name index=0/)

      output = bosh_runner.run('run-errand errand1 --when-changed', deployment_name: deployment_name)
      expect(output).to_not match(/job=service_with_errand/)
      expect(output).to_not match(/job=service_with_errand/)
      expect(output).to_not match(/job=fake-errand-name/)
    end

    it 'runs the errand if the instances selected change' do
      output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name)
      expect(output).to match(/job=service_with_errand index=0/)
      expect(output).to match(/job=service_with_errand index=1/)
      expect(output).to match(/job=fake-errand-name index=0/)

      output = bosh_runner.run('run-errand errand1 --instance service_with_errand/0 --when-changed', deployment_name: deployment_name)
      expect(output).to match(/job=service_with_errand index=0/)
    end

    it 'runs the errand if the configuration on the selected instances change' do
      output = bosh_runner.run('run-errand errand1 --when-changed', deployment_name: deployment_name)
      expect(output).to match(/job=service_with_errand index=0/)
      expect(output).to match(/job=service_with_errand index=1/)
      expect(output).to match(/job=fake-errand-name index=0/)

      manifest_hash['instance_groups'][1]['jobs'] << emoji_errand_job
      deploy_simple_manifest(manifest_hash: manifest_hash)

      output = bosh_runner.run('run-errand errand1 --when-changed', deployment_name: deployment_name)
      expect(output).to match(/job=service_with_errand index=0/)
      expect(output).to match(/job=service_with_errand index=1/)
      expect(output).to match(/job=fake-errand-name index=0/)
    end

    it 'runs the errand if the errand failed on any of the selected instances' do
      manifest_hash['instance_groups'][1]['jobs'][0]['properties']['errand1']['exit_code'] = 1
      deploy_simple_manifest(manifest_hash: manifest_hash)

      output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name, failure_expected: true)
      expect(output).to match(/job=service_with_errand index=0/)
      expect(output).to match(/job=service_with_errand index=1/)
      expect(output).to match(/job=fake-errand-name index=0/)

      output = bosh_runner.run('run-errand errand1 --when-changed', deployment_name: deployment_name, failure_expected: true)
      expect(output).to match(/job=service_with_errand index=0/)
      expect(output).to match(/job=service_with_errand index=1/)
      expect(output).to match(/job=fake-errand-name index=0/)
    end
  end

  context 'when persisting rendered job templates in blobstore' do
    with_reset_sandbox_before_each

    it_behaves_like 'a config that works with the --when-changed flag'

    context 'when running errands on service instances' do
      let(:manifest_hash) { Bosh::Spec::NewDeployments.manifest_with_errand_on_service_instance }

      it 'runs the errand referenced by the job name on a service lifecycle instance' do
        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

        output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name)

        expect(output).to match(/fake-errand-stdout-service/)
        expect(output).to match(/Succeeded/)
      end

      it 'runs the errand referenced by the job name on multiple service lifecycle instances' do
        manifest_hash['instance_groups'][0]['instances'] = 2

        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

        output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name)

        expect(output).to match(/job=service_with_errand index=0/)
        expect(output).to match(/job=service_with_errand index=1/)
        expect(output.scan('fake-errand-stdout-service').size).to eq(2)
        expect(output.scan('stdout-from-errand1-package').size).to eq(2)

        expect(output).to match(/Succeeded/)
      end

      context 'when running an errand that conflicts with a non-errand job from a different release' do
        before do
          upload_fake_errand_release
        end

        it 'runs the errand successfully and fails to run the non-errand job' do
          manifest_hash['instance_groups'][1] = {
            'instances' => 1,
            'name' => 'fake-errand-group',
            'networks' => ['name' => 'a'],
            'stemcell' => 'default',
            'vm_type' => 'a',
            'jobs' => [{
              'release' => 'fake-errand-release',
              'name' => 'errand1',
              'properties' => {},
            }],
          }
          manifest_hash['releases'] << { 'name' => 'fake-errand-release', 'version' => 'latest' }

          deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

          output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name, failure_expected: true)

          expect(output).to match(/Running errand: service_with_errand/)
          expect(output).to match(/Running errand: fake-errand-group/)
          expect(output).to match(/Fetching logs for service_with_errand/)
          expect(output).to match(%r{Error: Action Failed get_task:.*bin\/run: no such file or directory})
        end
      end
    end

    context 'when there are multiple errand jobs on the instance group' do
      let(:manifest_hash) do
        hash = Bosh::Spec::NewDeployments.manifest_with_errand_on_service_instance
        hash['instance_groups'][0]['jobs'] << emoji_errand_job
        hash
      end

      it 'is able to run the first errand' do
        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

        output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name)

        expect(output).to match(/job=service_with_errand index=0/)
        expect(output.scan(/fake-errand-stdout-service/).size).to eq(1)
      end

      it 'is able to run the second errand' do
        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

        output = bosh_runner.run('run-errand emoji-errand', deployment_name: deployment_name)

        expect(output.scan(/errand is/).size).to eq(1)
      end
    end

    context 'when lifecycle service instance groups and lifecycle errand instance groups have the errand job' do
      let(:manifest_hash) do
        hash = Bosh::Spec::NewDeployments.manifest_with_errand
        hash['instance_groups'] << service_instance_group_with_errand
        hash['instance_groups'] << second_service_instance_group_with_errand
        hash
      end

      let(:second_service_instance_group_with_errand) do
        instance_group = Bosh::Spec::NewDeployments.service_instance_group_with_errand
        instance_group['name'] = 'second_service_with_errand'
        instance_group
      end

      it 'runs the errand on all instances' do
        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

        output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name)

        expect(output).to match(/job=service_with_errand index=0/)
        expect(output).to match(/job=service_with_errand index=1/)
        expect(output).to match(/job=second_service_with_errand index=0/)
        expect(output).to match(/job=fake-errand-name index=0/)
        expect(output.scan(/fake-errand-stdout-service/).size).to eq(3)
        expect(output.scan(/fake-errand-stdout[^\-]/).size).to eq(1)

        expect(output).to match(/Succeeded/)
      end
    end

    context 'when starting a vm for an errand lifecycle group fails' do
      let(:manifest_hash) do
        hash = Bosh::Spec::NewDeployments.manifest_with_errand_on_service_instance
        hash['instance_groups'] << Bosh::Spec::NewDeployments.simple_errand_instance_group
        hash
      end

      it 'does not run the errand on service instances' do
        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)
        current_sandbox.cpi.commands.make_create_vm_always_fail

        output = bosh_runner.run('run-errand errand1', deployment_name: deployment_name, failure_expected: true)
        expect(output).to_not match(/Running errand: service_with_errand/)
        expect(output).to match(/Creating vm failed/)
      end
    end

    context 'when filtering to a particular set of instances' do
      let(:manifest_hash) do
        hash = Bosh::Spec::NewDeployments.manifest_with_errand
        hash['instance_groups'] << service_instance_group_with_errand
        hash['instance_groups'] << second_service_instance_group_with_errand
        hash
      end

      let(:second_service_instance_group_with_errand) do
        instance_group = Bosh::Spec::NewDeployments.service_instance_group_with_errand
        instance_group['instances'] = 2
        instance_group['name'] = 'second_service_with_errand'
        instance_group
      end

      it 'runs all in an instance group or on specific instances' do
        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

        output = bosh_runner.run('run-errand errand1 --instance second_service_with_errand', deployment_name: deployment_name)

        expect(output).to match(/job=second_service_with_errand index=0/)
        expect(output).to match(/job=second_service_with_errand index=1/)

        expect(output).to_not match(/job=service_with_errand/)
        expect(output).to_not match(/job=fake-errand-name/)

        output = bosh_runner.run('run-errand errand1 --instance second_service_with_errand/0 --instance service_with_errand/1', deployment_name: deployment_name)

        expect(output).to match(/job=service_with_errand index=1/)
        expect(output).to match(/job=second_service_with_errand index=0/)

        expect(output).to_not match(/job=service_with_errand index=0/)
        expect(output).to_not match(/job=second_service_with_errand index=1/)
        expect(output).to_not match(/job=fake-errand-name/)
      end

      it 'can proceed even if an instance is missing a VM reference' do
        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

        original_instance = director.instance('service_with_errand', '0', deployment_name: deployment_name)
        original_instance.kill_agent

        output = bosh_runner.run('cck --resolution delete_vm_reference', deployment_name: deployment_name)

        output = bosh_runner.run('run-errand errand1 --instance service_with_errand', deployment_name: deployment_name)

        expect(output).to match(/job=service_with_errand index=1/)
      end

      it 'can proceed even if an instance outside of the selection is unresponsive' do
        deploy_from_scratch(manifest_hash: manifest_hash, cloud_config_hash: Bosh::Spec::NewDeployments.simple_cloud_config)

        original_instance = director.instance('service_with_errand', '0', deployment_name: deployment_name)
        original_instance.kill_agent

        output = bosh_runner.run('run-errand errand1 --instance service_with_errand/1', deployment_name: deployment_name)

        expect(output).to match(/job=service_with_errand index=1/)
      end
    end
  end

  context 'when sending rendered templates to agents via nats' do
    with_reset_sandbox_before_each(enable_nats_delivered_templates: true)

    it_behaves_like 'a config that works with the --when-changed flag'
  end
end
