gitlab-org--gitlab-foss/spec/lib/gitlab/kubernetes/namespace_spec.rb

# frozen_string_literal: true

require 'spec_helper'

describe Gitlab::Kubernetes::Namespace do
  let(:name) { 'a_namespace' }
  let(:client) { double('kubernetes client') }
  let(:labels) { nil }

  subject { described_class.new(name, client, labels: labels) }

  it { expect(subject.name).to eq(name) }

  describe '#exists?' do
    context 'when namespace do not exits' do
      let(:exception) { ::Kubeclient::ResourceNotFoundError.new(404, "namespace #{name} not found", nil) }

      it 'returns false' do
        expect(client).to receive(:get_namespace).with(name).once.and_raise(exception)

        expect(subject.exists?).to be_falsey
      end
    end

    context 'when namespace exits' do
      let(:namespace) { ::Kubeclient::Resource.new(kind: 'Namespace', metadata: { name: name }) } # partial representation

      it 'returns true' do
        expect(client).to receive(:get_namespace).with(name).once.and_return(namespace)

        expect(subject.exists?).to be_truthy
      end
    end

    context 'when cluster cannot be reached' do
      let(:exception) { Errno::ECONNREFUSED.new }

      it 'raises exception' do
        expect(client).to receive(:get_namespace).with(name).once.and_raise(exception)

        expect { subject.exists? }.to raise_error(exception)
      end
    end
  end

  describe '#create!' do
    it 'creates a namespace' do
      matcher = have_attributes(metadata: have_attributes(name: name))
      expect(client).to receive(:create_namespace).with(matcher).once

      expect { subject.create! }.not_to raise_error
    end

    context 'with labels' do
      let(:labels) { { foo: :bar } }

      it 'creates a namespace with labels' do
        matcher = have_attributes(metadata: have_attributes(name: name, labels: have_attributes(foo: :bar)))
        expect(client).to receive(:create_namespace).with(matcher).once

        expect { subject.create! }.not_to raise_error
      end
    end
  end

  describe '#ensure_exists!' do
    it 'checks for existing namespace before creating' do
      expect(subject).to receive(:exists?).once.ordered.and_return(false)
      expect(subject).to receive(:create!).once.ordered

      subject.ensure_exists!
    end

    it 'do not re-create an existing namespace' do
      expect(subject).to receive(:exists?).once.and_return(true)
      expect(subject).not_to receive(:create!)

      subject.ensure_exists!
    end

    context 'when client errors' do
      let(:exception) { Kubeclient::HttpError.new(500, 'system failure', nil) }

      before do
        allow(client).to receive(:get_namespace).with(name).once.and_raise(exception)
      end

      it 'raises the exception' do
        expect { subject.ensure_exists! }.to raise_error(exception)
      end

      it 'logs the error' do
        expect(subject.send(:logger)).to receive(:error).with(
          hash_including(
            exception: {
              class: 'Kubeclient::HttpError',
              message: 'system failure'
            },
            status_code: 500,
            namespace: 'a_namespace',
            class_name: 'Gitlab::Kubernetes::Namespace',
            event: :failed_to_create_namespace
          )
        )

        expect { subject.ensure_exists! }.to raise_error(exception)
      end
    end
  end
end