# frozen_string_literal: true

require 'spec_helper'

RSpec.describe Ci::CreatePipelineService do
  include AfterNextHelpers

  subject(:execute) { service.execute(:push) }

  let(:project) { create(:project, :repository, name: 'website') }
  let(:user) { project.owner }
  let(:compliance_group) { create(:group, :private, name: "compliance") }
  let(:compliance_project) { create(:project, :repository, namespace: compliance_group, name: "hippa") }
  let(:framework) { create(:compliance_framework, namespace_id: compliance_group.id, pipeline_configuration_full_path: ".compliance-gitlab-ci.yml@compliance/hippa") }
  let!(:framework_project_setting) { create(:compliance_framework_project_setting, project: project, framework_id: framework.id) }
  let!(:ref_sha) { compliance_project.commit('HEAD').sha }
  let(:compliance_config) do
    <<~EOY
    ---
    compliance_build:
      stage: build
      script:
        - echo 'hello from compliance build'
    compliance_test:
      stage: test
      script:
        - echo 'hello from compliance test'
    EOY
  end

  let(:service) { described_class.new(project, user, { ref: 'master' }) }

  before do
    stub_feature_flags(ff_evaluate_group_level_compliance_pipeline: true)
    stub_licensed_features(evaluate_group_level_compliance_pipeline: true)
    allow_next(Repository).to receive(:blob_data_at).with(ref_sha, '.compliance-gitlab-ci.yml').and_return(compliance_config)
  end

  context 'when user has access to compliance project' do
    before do
      compliance_project.add_maintainer(project.owner)
    end

    it 'persists pipeline' do
      is_expected.to be_persisted
    end

    it 'sets the correct source' do
      expect(execute.config_source).to eq("compliance_source")
    end

    it 'persists jobs' do
      expect { execute }.to change(Ci::Build, :count).from(0).to(2)
    end

    it do
      expect(execute.processables.map(&:name)).to contain_exactly('compliance_build', 'compliance_test')
    end
  end

  context 'when user does not have access to compliance project' do
    it 'includes access denied error' do
      expect(execute.yaml_errors).to eq "Project `compliance/hippa` not found or access denied!"
    end

    it 'does not persist jobs' do
      expect { execute }.not_to change(Ci::Build, :count).from(0)
    end
  end
end
