# frozen_string_literal: true

require 'spec_helper'

RSpec.describe Ci::BuildRunnerPresenter, feature_category: :continuous_integration do
  let(:presenter) { described_class.new(build) }
  let(:archive) { { paths: ['sample.txt'] } }

  let(:archive_expectation) do
    {
      artifact_type: :archive,
      artifact_format: :zip,
      paths: archive[:paths],
      untracked: archive[:untracked]
    }
  end

  describe '#set_queue_metrics' do
    let(:build) { create(:ci_build) }
    let(:size) { 10 }
    let(:depth) { 2 }

    subject(:executed) do
      presenter.set_queue_metrics(size: size, depth: depth)
      presenter
    end

    it 'tracks information about queue size and depth' do
      expect(executed.queue_size).to eq(10)
      expect(executed.queue_depth).to eq(2)
    end

    context 'when queue size or depth is negative' do
      let(:size) { -1 }
      let(:depth) { -1 }

      it 'sets queue size and depth to 0' do
        expect(executed.queue_size).to eq(0)
        expect(executed.queue_depth).to eq(0)
      end
    end
  end

  describe '#artifacts' do
    context "when option contains archive-type artifacts" do
      let(:build) { create(:ci_build, options: { artifacts: archive }) }

      it 'presents correct hash' do
        expect(presenter.artifacts.first).to include(archive_expectation)
      end

      context "when untracked is specified" do
        let(:archive) { { untracked: true } }

        it 'presents correct hash' do
          expect(presenter.artifacts.first).to include(archive_expectation)
        end
      end

      context "when untracked and paths are missing" do
        let(:archive) { { when: 'always' } }

        it 'does not present hash' do
          expect(presenter.artifacts).to be_empty
        end
      end

      context 'when artifacts exclude is defined' do
        let(:build) do
          create(:ci_build, options: { artifacts: { paths: %w[abc], exclude: %w[cde] } })
        end

        it 'includes the list of excluded paths' do
          expect(presenter.artifacts.first).to include(
            artifact_type: :archive,
            artifact_format: :zip,
            paths: %w[abc],
            exclude: %w[cde]
          )
        end
      end

      context 'when artifacts exclude is not defined' do
        let(:build) do
          create(:ci_build, options: { artifacts: { paths: %w[abc] } })
        end

        it 'does not include an empty list of excluded paths' do
          expect(presenter.artifacts.first).not_to have_key(:exclude)
        end
      end
    end

    context "with reports" do
      Enums::Ci::JobArtifact.default_file_names.each do |file_type, filename|
        context file_type.to_s do
          let(:report) { { "#{file_type}": [filename] } }
          let(:build) { create(:ci_build, options: { artifacts: { reports: report } }) }

          let(:report_expectation) do
            {
              name: filename,
              artifact_type: :"#{file_type}",
              artifact_format: Enums::Ci::JobArtifact.type_and_format_pairs.fetch(file_type),
              paths: [filename],
              when: 'always'
            }.compact
          end

          it 'presents correct hash' do
            expect(presenter.artifacts).to contain_exactly(report_expectation)
          end
        end
      end
    end

    context 'when a specific coverage_report type is given' do
      let(:coverage_format) { :cobertura }
      let(:filename) { 'cobertura-coverage.xml' }
      let(:coverage_report) { { path: filename, coverage_format: coverage_format } }
      let(:report) { { coverage_report: coverage_report } }
      let(:build) { create(:ci_build, options: { artifacts: { reports: report } }) }

      let(:expected_coverage_report) do
        {
          name: filename,
          artifact_type: coverage_format,
          artifact_format: Enums::Ci::JobArtifact.type_and_format_pairs.fetch(coverage_format),
          paths: [filename],
          when: 'always'
        }
      end

      it 'presents the coverage report hash with the coverage format' do
        expect(presenter.artifacts).to contain_exactly(expected_coverage_report)
      end
    end

    context 'when a specific coverage_report type is given with another report type' do
      let(:coverage_format) { :cobertura }
      let(:coverage_filename) { 'cobertura-coverage.xml' }
      let(:coverage_report) { { path: coverage_filename, coverage_format: coverage_format } }
      let(:ds_filename) { 'gl-dependency-scanning-report.json' }

      let(:report) { { coverage_report: coverage_report, dependency_scanning: [ds_filename] } }
      let(:build) { create(:ci_build, options: { artifacts: { reports: report } }) }

      let(:expected_coverage_report) do
        {
          name: coverage_filename,
          artifact_type: coverage_format,
          artifact_format: Enums::Ci::JobArtifact.type_and_format_pairs.fetch(coverage_format),
          paths: [coverage_filename],
          when: 'always'
        }
      end

      let(:expected_ds_report) do
        {
          name: ds_filename,
          artifact_type: :dependency_scanning,
          artifact_format: Enums::Ci::JobArtifact.type_and_format_pairs.fetch(:dependency_scanning),
          paths: [ds_filename],
          when: 'always'
        }
      end

      it 'presents both reports' do
        expect(presenter.artifacts).to contain_exactly(expected_coverage_report, expected_ds_report)
      end
    end

    context "when option has both archive and reports specification" do
      let(:report) { { junit: ['junit.xml'] } }
      let(:build) { create(:ci_build, options: { script: 'echo', artifacts: { **archive, reports: report } }) }

      let(:report_expectation) do
        {
          name: 'junit.xml',
          artifact_type: :junit,
          artifact_format: :gzip,
          paths: ['junit.xml'],
          when: 'always'
        }
      end

      it 'presents correct hash' do
        expect(presenter.artifacts.first).to include(archive_expectation)
        expect(presenter.artifacts.second).to include(report_expectation)
      end

      context "when archive specifies 'expire_in' keyword" do
        let(:archive) { { paths: ['sample.txt'], expire_in: '3 mins 4 sec' } }

        it 'inherits expire_in from archive' do
          expect(presenter.artifacts.first).to include({ **archive_expectation, expire_in: '3 mins 4 sec' })
          expect(presenter.artifacts.second).to include({ **report_expectation, expire_in: '3 mins 4 sec' })
        end
      end
    end

    context "when option has no artifact keywords" do
      let(:build) { create(:ci_build, :no_options) }

      it 'does not present hash' do
        expect(presenter.artifacts).to be_nil
      end
    end
  end

  describe '#ref_type' do
    subject { presenter.ref_type }

    let(:build) { create(:ci_build, tag: tag) }
    let(:tag) { true }

    it 'returns the correct ref type' do
      is_expected.to eq('tag')
    end

    context 'when tag is false' do
      let(:tag) { false }

      it 'returns the correct ref type' do
        is_expected.to eq('branch')
      end
    end
  end

  describe '#git_depth' do
    let(:build) { create(:ci_build) }

    subject(:git_depth) { presenter.git_depth }

    context 'when GIT_DEPTH variable is specified' do
      before do
        create(:ci_pipeline_variable, key: 'GIT_DEPTH', value: 1, pipeline: build.pipeline)
      end

      it 'returns its value' do
        expect(git_depth).to eq(1)
      end

      context 'when there are multiple GIT_DEPTH variables' do
        before do
          create(:ci_variable, key: 'GIT_DEPTH', value: 2, project: build.project)
        end

        # The need for this spec indicates an architectural problem with lib/gitlab/ci/variables/builder.rb
        # Tracked in https://gitlab.com/gitlab-org/gitlab/-/issues/567742
        it 'returns the higher precedence value' do
          expect(git_depth).to eq(1)
        end
      end
    end

    it 'defaults to git depth setting for the project' do
      expect(git_depth).to eq(build.project.ci_default_git_depth)
    end
  end

  describe '#repo_object_format' do
    let(:build) { create(:ci_build) }

    subject { presenter.repo_object_format }

    it 'delegates the call to #repository_object_format' do
      expect(build.project).to receive(:repository_object_format).and_return('object_format')

      is_expected.to eq 'object_format'
    end
  end

  describe '#refspecs' do
    subject { presenter.refspecs }

    let(:build) { create(:ci_build) }
    let(:pipeline) { build.pipeline }

    it 'returns the correct refspecs' do
      is_expected.to contain_exactly(
        "+refs/heads/#{build.ref}:refs/remotes/origin/#{build.ref}",
        "+refs/pipelines/#{pipeline.id}:refs/pipelines/#{pipeline.id}"
      )
    end

    context 'when ref is tag' do
      let(:build) { create(:ci_build, :tag) }

      it 'returns the correct refspecs' do
        is_expected.to contain_exactly(
          "+refs/tags/#{build.ref}:refs/tags/#{build.ref}",
          "+refs/pipelines/#{pipeline.id}:refs/pipelines/#{pipeline.id}"
        )
      end

      context 'when GIT_DEPTH is zero' do
        before do
          create(:ci_pipeline_variable, key: 'GIT_DEPTH', value: 0, pipeline: build.pipeline)
        end

        it 'returns the correct refspecs' do
          is_expected.to contain_exactly(
            '+refs/tags/*:refs/tags/*',
            '+refs/heads/*:refs/remotes/origin/*',
            "+refs/pipelines/#{pipeline.id}:refs/pipelines/#{pipeline.id}"
          )
        end
      end
    end

    context 'when pipeline is detached merge request pipeline' do
      let(:merge_request) { create(:merge_request, :with_detached_merge_request_pipeline) }
      let(:pipeline) { merge_request.all_pipelines.first }
      let(:build) { create(:ci_build, ref: pipeline.ref, pipeline: pipeline) }

      before do
        pipeline.persistent_ref.create # rubocop:disable Rails/SaveBang
      end

      it 'returns the correct refspecs' do
        is_expected
          .to contain_exactly("+refs/pipelines/#{pipeline.id}:refs/pipelines/#{pipeline.id}")
      end

      context 'when GIT_DEPTH is zero' do
        before do
          create(:ci_pipeline_variable, key: 'GIT_DEPTH', value: 0, pipeline: build.pipeline)
        end

        it 'returns the correct refspecs' do
          is_expected.to contain_exactly(
            "+refs/pipelines/#{pipeline.id}:refs/pipelines/#{pipeline.id}",
            '+refs/heads/*:refs/remotes/origin/*',
            '+refs/tags/*:refs/tags/*'
          )
        end
      end

      context 'when pipeline is legacy detached merge request pipeline' do
        let(:merge_request) { create(:merge_request, :with_legacy_detached_merge_request_pipeline) }

        it 'returns the correct refspecs' do
          is_expected.to contain_exactly(
            "+refs/pipelines/#{pipeline.id}:refs/pipelines/#{pipeline.id}",
            "+refs/heads/#{build.ref}:refs/remotes/origin/#{build.ref}"
          )
        end
      end
    end

    context 'when persistent pipeline ref exists' do
      let(:project) { create(:project, :repository) }
      let(:sha) { project.repository.commit.sha }
      let(:pipeline) { create(:ci_pipeline, sha: sha, project: project) }
      let(:build) { create(:ci_build, pipeline: pipeline) }

      before do
        pipeline.persistent_ref.create # rubocop:disable Rails/SaveBang
      end

      it 'exposes the persistent pipeline ref' do
        is_expected.to contain_exactly(
          "+refs/pipelines/#{pipeline.id}:refs/pipelines/#{pipeline.id}",
          "+refs/heads/#{build.ref}:refs/remotes/origin/#{build.ref}"
        )
      end
    end
  end

  describe '#runner_inputs' do
    let(:build) { create(:ci_build, options: { inputs: inputs_spec }) }

    let(:inputs_spec) do
      {
        string_input: {
          input_type: 'string',
          default: 'default value one'
        },
        array_input: {
          input_type: 'array',
          default: ['default array']
        },
        boolean_input: {
          input_type: 'boolean',
          default: false
        },
        number_input: {
          input_type: 'number',
          default: 666
        }
      }
    end

    before do
      create(:ci_job_input, job: build, project: build.project, name: 'string_input', value: 'not default')
    end

    it 'returns the inputs data structured for Runner' do
      expect(presenter.runner_inputs).to contain_exactly(
        { key: :string_input, value: { content: 'not default', type: 'string' } },
        { key: :array_input, value: { content: ['default array'], type: 'array' } },
        { key: :boolean_input, value: { content: false, type: 'boolean' } },
        { key: :number_input, value: { content: 666, type: 'number' } }
      )
    end

    context 'when the job has no inputs defined' do
      let(:build) { create(:ci_build, options: nil) }

      it 'returns an empty array' do
        expect(presenter.runner_inputs).to eq([])
      end
    end
  end

  describe '#runner_variables' do
    subject(:runner_variables) { presenter.runner_variables }

    let_it_be(:project) { create(:project, :repository) }

    let(:sha) { project.repository.commit.sha }
    let(:pipeline) { create(:ci_pipeline, sha: sha, project: project) }
    let(:build) { create(:ci_build, pipeline: pipeline) }

    it 'returns an array' do
      is_expected.to be_an_instance_of(Array)
    end

    it 'returns the expected variables' do
      is_expected.to eq(presenter.variables.to_runner_variables)
    end

    context 'when there is a file variable to expand' do
      before_all do
        create(:ci_variable, project: project, key: 'regular_var', value: 'value 1')
        create(:ci_variable, project: project, key: 'file_var', value: 'value 2', variable_type: :file)
        create(
          :ci_variable,
          project: project,
          key: 'var_with_variables',
          value: 'value 3 and $regular_var and $file_var and $undefined_var'
        )
      end

      it 'returns variables with expanded' do
        expect(runner_variables).to include(
          { key: 'regular_var', value: 'value 1',
            public: false, masked: false },
          { key: 'file_var', value: 'value 2',
            public: false, masked: false, file: true },
          { key: 'var_with_variables', value: 'value 3 and value 1 and $file_var and $undefined_var',
            public: false, masked: false }
        )
      end
    end

    context 'when there is a raw variable to expand' do
      before_all do
        create(:ci_variable, project: project, key: 'regular_var', value: 'value 1')
        create(:ci_variable, project: project, key: 'raw_var', value: 'value 2', raw: true)
        create(
          :ci_variable,
          project: project,
          key: 'var_with_variables',
          value: 'value 3 and $regular_var and $raw_var and $undefined_var'
        )
      end

      it 'returns expanded variables without expanding raws' do
        expect(runner_variables).to include(
          { key: 'regular_var', value: 'value 1',
            public: false, masked: false },
          { key: 'raw_var', value: 'value 2',
            public: false, masked: false, raw: true },
          { key: 'var_with_variables', value: 'value 3 and value 1 and $raw_var and $undefined_var',
            public: false, masked: false }
        )
      end
    end
  end

  describe '#runner_variables subset' do
    subject { presenter.runner_variables.select { |v| %w[A B C].include?(v.fetch(:key)) } }

    let(:build) { create(:ci_build) }

    context 'with references in pipeline variables' do
      before do
        create(:ci_pipeline_variable, key: 'A', value: 'refA-$B', pipeline: build.pipeline)
        create(:ci_pipeline_variable, key: 'B', value: 'refB-$C-$D', pipeline: build.pipeline)
        create(:ci_pipeline_variable, key: 'C', value: 'value', pipeline: build.pipeline)
      end

      it 'returns expanded and sorted variables' do
        is_expected.to eq [
          { key: 'C', value: 'value', public: false, masked: false },
          { key: 'B', value: 'refB-value-$D', public: false, masked: false },
          { key: 'A', value: 'refA-refB-value-$D', public: false, masked: false }
        ]
      end
    end
  end
end
