Merge branch 'migrate_k8s_service_integration' into 'master'

Migrate Kubernetes service integration templates to clusters

See merge request gitlab-org/gitlab-ce!28534

2 files changed, 190 insertions, 5 deletions

diff --git a/spec/migrations/migrate_k8s_service_integration_spec.rb b/spec/migrations/migrate_k8s_service_integration_spec.rb
new file mode 100644
index 00000000000..4dd0c09632a
--- /dev/null
+++ b/spec/migrations/migrate_k8s_service_integration_spec.rb
@@ -0,0 +1,161 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+require Rails.root.join('db', 'post_migrate', '20190517153211_migrate_k8s_service_integration.rb')
+
+describe MigrateK8sServiceIntegration, :migration 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
diff --git a/spec/models/clusters/cluster_spec.rb b/spec/models/clusters/cluster_spec.rb
index c302b7a15f4..52661178d76 100644
--- a/spec/models/clusters/cluster_spec.rb
+++ b/spec/models/clusters/cluster_spec.rb
@@ -514,19 +514,43 @@ describe Clusters::Cluster, :use_clean_rails_memory_store_caching do
     subject { cluster.allow_user_defined_namespace? }
 
     context 'project type cluster' do
-      it { is_expected.to be_truthy }
+      context 'gitlab managed' do
+        it { is_expected.to be_truthy }
+      end
+
+      context 'not managed' do
+        let(:cluster) { create(:cluster, :provided_by_gcp, managed: false) }
+
+        it { is_expected.to be_truthy }
+      end
     end
 
     context 'group type cluster' do
-      let(:cluster) { create(:cluster, :provided_by_gcp, :group) }
+      context 'gitlab managed' do
+        let(:cluster) { create(:cluster, :provided_by_gcp, :group) }
+
+        it { is_expected.to be_falsey }
+      end
 
-      it { is_expected.to be_falsey }
+      context 'not managed' do
+        let(:cluster) { create(:cluster, :provided_by_gcp, :group, managed: false) }
+
+        it { is_expected.to be_truthy }
+      end
     end
 
     context 'instance type cluster' do
-      let(:cluster) { create(:cluster, :provided_by_gcp, :instance) }
+      context 'gitlab managed' do
+        let(:cluster) { create(:cluster, :provided_by_gcp, :instance) }
+
+        it { is_expected.to be_falsey }
+      end
+
+      context 'not managed' do
+        let(:cluster) { create(:cluster, :provided_by_gcp, :instance, managed: false) }
 
-      it { is_expected.to be_falsey }
+        it { is_expected.to be_truthy }
+      end
     end
   end