gitlab-org--gitlab-foss/spec/migrations/migrate_k8s_service_integration_spec.rb

# frozen_string_literal: true

require 'spec_helper'
require_migration!

RSpec.describe MigrateK8sServiceIntegration do
  context 'template service' do
    context 'with namespace' do
      let!(:service) do
        MigrateK8sServiceIntegration::Service.create!(
          active: true,
          template: true,
          category: 'deployment',
          type: 'KubernetesService',
          properties: "{\"namespace\":\"prod\",\"api_url\":\"https://sample.kubernetes.com\",\"ca_pem\":\"ca_pem-sample\",\"token\":\"token-sample\"}"
        )
      end

      let(:cluster) { MigrateK8sServiceIntegration::Cluster.instance_type.last! }
      let(:platform) { cluster.platform_kubernetes }

      it 'migrates the KubernetesService template to Platform::Kubernetes' do
        expect { migrate! }.to change { MigrateK8sServiceIntegration::Cluster.count }.by(1)

        expect(cluster).to be_enabled
        expect(cluster).to be_user
        expect(cluster).not_to be_managed
        expect(cluster.environment_scope).to eq('*')
        expect(platform.api_url).to eq('https://sample.kubernetes.com')
        expect(platform.ca_cert).to eq('ca_pem-sample')
        expect(platform.namespace).to eq('prod')
        expect(platform.token).to eq('token-sample')
      end
    end

    context 'without namespace' do
      let!(:service) do
        MigrateK8sServiceIntegration::Service.create!(
          active: true,
          template: true,
          category: 'deployment',
          type: 'KubernetesService',
          properties: "{\"namespace\":\"\",\"api_url\":\"https://sample.kubernetes.com\",\"ca_pem\":\"ca_pem-sample\",\"token\":\"token-sample\"}"
        )
      end

      let(:cluster) { MigrateK8sServiceIntegration::Cluster.instance_type.last! }
      let(:platform) { cluster.platform_kubernetes }

      it 'migrates the KubernetesService template to Platform::Kubernetes' do
        expect { migrate! }.to change { MigrateK8sServiceIntegration::Cluster.count }.by(1)

        expect(cluster).to be_enabled
        expect(cluster).to be_user
        expect(cluster).not_to be_managed
        expect(cluster.environment_scope).to eq('*')
        expect(platform.api_url).to eq('https://sample.kubernetes.com')
        expect(platform.ca_cert).to eq('ca_pem-sample')
        expect(platform.namespace).to be_nil
        expect(platform.token).to eq('token-sample')
      end
    end

    context 'with nullified parameters' do
      let!(:service) do
        MigrateK8sServiceIntegration::Service.create!(
          active: true,
          template: true,
          category: 'deployment',
          type: 'KubernetesService',
          properties: "{}"
        )
      end

      it 'does not migrate the KubernetesService' do
        expect { migrate! }.not_to change { MigrateK8sServiceIntegration::Cluster.count }
      end
    end

    context 'when disabled' do
      let!(:service) do
        MigrateK8sServiceIntegration::Service.create!(
          active: false,
          template: true,
          category: 'deployment',
          type: 'KubernetesService',
          properties: "{\"namespace\":\"prod\",\"api_url\":\"https://sample.kubernetes.com\",\"ca_pem\":\"ca_pem-sample\",\"token\":\"token-sample\"}"
        )
      end

      let(:cluster) { MigrateK8sServiceIntegration::Cluster.instance_type.last! }
      let(:platform) { cluster.platform_kubernetes }

      it 'migrates the KubernetesService template to Platform::Kubernetes' do
        expect { migrate! }.to change { MigrateK8sServiceIntegration::Cluster.count }.by(1)

        expect(cluster).not_to be_enabled
        expect(cluster).to be_user
        expect(cluster).not_to be_managed
        expect(cluster.environment_scope).to eq('*')
        expect(platform.api_url).to eq('https://sample.kubernetes.com')
        expect(platform.ca_cert).to eq('ca_pem-sample')
        expect(platform.namespace).to eq('prod')
        expect(platform.token).to eq('token-sample')
      end
    end

    context 'when an instance cluster already exists' do
      let!(:service) do
        MigrateK8sServiceIntegration::Service.create!(
          active: true,
          template: true,
          category: 'deployment',
          type: 'KubernetesService',
          properties: "{\"namespace\":\"prod\",\"api_url\":\"https://sample.kubernetes.com\",\"ca_pem\":\"ca_pem-sample\",\"token\":\"token-sample\"}"
        )
      end

      let!(:existing_cluster) do
        MigrateK8sServiceIntegration::Cluster.create!(
          name: 'test-cluster',
          cluster_type: :instance_type,
          managed: true,
          provider_type: :user,
          platform_type: :kubernetes
        )
      end

      let(:new_cluster) { MigrateK8sServiceIntegration::Cluster.instance_type.last! }
      let(:platform) { new_cluster.platform_kubernetes }

      it 'migrates the KubernetesService template to disabled Platform::Kubernetes' do
        expect { migrate! }.to change { MigrateK8sServiceIntegration::Cluster.count }.by(1)

        expect(new_cluster).not_to be_enabled
        expect(new_cluster).to be_user
        expect(new_cluster).not_to be_managed
        expect(new_cluster.environment_scope).to eq('*')
        expect(platform.api_url).to eq('https://sample.kubernetes.com')
        expect(platform.ca_cert).to eq('ca_pem-sample')
        expect(platform.namespace).to eq('prod')
        expect(platform.token).to eq('token-sample')
      end
    end
  end

  context 'non-template service' do
    let!(:service) do
      MigrateK8sServiceIntegration::Service.create!(
        active: true,
        template: false,
        category: 'deployment',
        type: 'KubernetesService',
        properties: "{\"namespace\":\"prod\",\"api_url\":\"https://sample.kubernetes.com\",\"ca_pem\":\"ca_pem-sample\",\"token\":\"token-sample\"}"
      )
    end

    it 'does not migrate the KubernetesService' do
      expect { migrate! }.not_to change { MigrateK8sServiceIntegration::Cluster.count }
    end
  end
end