Skip to content

G
gitlab-ce
Commit 27111e29 authored by Shinya Maeda's avatar Shinya Maeda
Browse files
Options

Restructure spec

parent 40c6af54
Hide whitespace changes
Inline Side-by-side
Showing with 229 additions and 160 deletions
spec/migrations/migrate_kubernetes_service_to_new_clusters_architectures_spec.rb
View file @ 27111e29
...@@ -2,188 +2,257 @@ require 'spec_helper' ...@@ -2,188 +2,257 @@ require 'spec_helper'
require Rails.root.join('db', 'post_migrate', '20171124104327_migrate_kubernetes_service_to_new_clusters_architectures.rb') require Rails.root.join('db', 'post_migrate', '20171124104327_migrate_kubernetes_service_to_new_clusters_architectures.rb')
describe MigrateKubernetesServiceToNewClustersArchitectures, :migration do describe MigrateKubernetesServiceToNewClustersArchitectures, :migration do
context 'when user configured kubernetes from CI/CD > Clusters' do context 'when unique KubernetesService exists' do
let(:project) { create(:project) } shared_examples 'KubernetesService migration' do
let(:user) { create(:user) } let(:sample_num) { 2 }
let(:projects) { create_list(:project, sample_num) }
# Platforms::Kubernetes (New archtecture)
let!(:cluster) do let!(:kubernetes_services) do
create(:cluster, projects.map do |project|
projects: [project], create(:kubernetes_service,
user: user, project: project,
provider_type: :gcp, active: active,
platform_type: :kubernetes, api_url: "https://kubernetes#{project.id}.com",
provider_gcp: provider_gcp, token: defined?(token) ? token : "token#{project.id}",
platform_kubernetes: platform_kubernetes) ca_pem: "ca_pem#{project.id}")
end
let(:provider_gcp) { create(:cluster_provider_gcp, :created) }
let(:platform_kubernetes) { create(:cluster_platform_kubernetes, :configured) }
# KubernetesService (Automatically synchronized when Platforms::Kubernetes created)
let!(:kubernetes_service) { create(:kubernetes_service, project: project) }
context 'when user is using the cluster' do
it 'migrates' do
expect{ migrate! }.not_to change { Clusters::Cluster.count }
expect(cluster).to be_active
expect(kubernetes_service).not_to be_active
end
end
context 'when user disabled cluster' do
before do
disable_cluster!
end
context 'when user configured kubernetes from Integration > Kubernetes' do
before do
kubernetes_service.update(
active: true,
api_url: 'http://new.kube.com',
ca_pem: nil,
token: 'z' * 40).reload
end end
end
context 'when user is using the kubernetes service' do it 'migrates the KubernetesService to Platform::Kubernetes' do
it 'migrates' do expect{ migrate! }.to change { Clusters::Cluster.count }.by(sample_num)
expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
projects.each do |project|
Clusters::Cluster.last.tap do |c| project.clusters.last.tap do |cluster|
expect(c).to be_active expect(cluster.enabled).to eq(active)
expect(c.platform_kubernetes.api_url).to eq(kubernetes_service.api_url) expect(cluster.platform_kubernetes.api_url).to eq(project.kubernetes_service.api_url)
expect(c.platform_kubernetes.ca_pem).to eq(kubernetes_service.ca_pem) expect(cluster.platform_kubernetes.ca_pem).to eq(project.kubernetes_service.ca_pem)
expect(c.platform_kubernetes.token).to eq(kubernetes_service.token) expect(cluster.platform_kubernetes.token).to eq(project.kubernetes_service.token)
end expect(project.kubernetes_service).not_to be_active
expect(project.kubernetes_service.properties['migrated']).to be_truthy
expect(kubernetes_service).not_to be_active
end
end
context 'when user stopped using the kubernetes service' do
before do
kubernetes_service.update(active: false)
end
it 'migrates' do
expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
Clusters::Cluster.last.tap do |c|
expect(c).not_to be_active
expect(c.platform_kubernetes.api_url).to eq(kubernetes_service.api_url)
expect(c.platform_kubernetes.ca_pem).to eq(kubernetes_service.ca_pem)
expect(c.platform_kubernetes.token).to eq(kubernetes_service.token)
end
expect(kubernetes_service).not_to be_active
end end
end end
end end
end end
context 'when user deleted cluster' do context 'when KubernetesService is active' do
before do let(:active) { true }
destory_cluster!
end
context 'when user configured kubernetes from Integration > Kubernetes' do
let!(:new_kubernetes_service) do
project.create_kubernetes_service(
active: true,
api_url: 'http://123.123.123.123',
ca_pem: nil,
token: 'a' * 40)
end
context 'when user is using the kubernetes service' do
it 'migrates' do
expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
Clusters::Cluster.last.tap do |c| it_behaves_like 'KubernetesService migration'
expect(c).to be_active end
expect(c.platform_kubernetes.api_url).to eq(new_kubernetes_service.api_url)
expect(c.platform_kubernetes.ca_pem).to eq(new_kubernetes_service.ca_pem)
expect(c.platform_kubernetes.token).to eq(new_kubernetes_service.token)
end
expect(new_kubernetes_service).not_to be_active
end
end
context 'when user stopped using the kubernetes service' do
before do
new_kubernetes_service.update(active: false)
end
it 'migrates' do context 'when KubernetesService is not active' do
expect{ migrate! }.to change { Clusters::Cluster.count }.by(1) let(:active) { false }
Clusters::Cluster.last.tap do |c| # Platforms::Kubernetes validates `token` reagdless of the activeness
expect(c).not_to be_active # KubernetesService validates `token` if only it's activated
expect(c.platform_kubernetes.api_url).to eq(new_kubernetes_service.api_url) # However, in this migration file, there are no validations because of the migration specific model class
expect(c.platform_kubernetes.ca_pem).to eq(new_kubernetes_service.ca_pem) # therefore, Validation Error will not happen in this case and just migrate data
expect(c.platform_kubernetes.token).to eq(new_kubernetes_service.token) let(:token) { '' }
end
expect(new_kubernetes_service).not_to be_active it_behaves_like 'KubernetesService migration'
end
end
end
end end
end end
context 'when user configured kubernetes from Integration > Kubernetes' do context 'when unique KubernetesService spawned from Service Template' do
let(:project) { create(:project) } it 'migrates the KubernetesService to Platform::Kubernetes' do
let!(:kubernetes_service) { create(:kubernetes_service, project: project) }
context 'when user is using the kubernetes service' do
it 'migrates' do
expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
Clusters::Cluster.last.tap do |c|
expect(c).to be_active
expect(c.platform_kubernetes.api_url).to eq(kubernetes_service.api_url)
expect(c.platform_kubernetes.ca_pem).to eq(kubernetes_service.ca_pem)
expect(c.platform_kubernetes.token).to eq(kubernetes_service.token)
end
expect(kubernetes_service).not_to be_active
end
end end
end
context 'when user stopped using the kubernetes service' do context 'when synced KubernetesService exists' do
before do it 'does not migrate the KubernetesService' do # Because the corresponding Platform::Kubernetes already exists
kubernetes_service.update(active: false)
end
it 'migrates' do
expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
Clusters::Cluster.last.tap do |c|
expect(c).not_to be_active
expect(c.platform_kubernetes.api_url).to eq(kubernetes_service.api_url)
expect(c.platform_kubernetes.ca_pem).to eq(kubernetes_service.ca_pem)
expect(c.platform_kubernetes.token).to eq(kubernetes_service.token)
end
expect(kubernetes_service).not_to be_active
end
end end
end end
context 'when nothing is configured' do context 'when KubernetesService does not exist' do
it 'migrates' do it 'does not migrate the KubernetesService' do
expect{ migrate! }.not_to change { Clusters::Cluster.count }
end
end
def disable_cluster! end
cluster.update!(enabled: false)
kubernetes_service.update!(active: false)
end end
def destory_cluster! # context 'when user configured kubernetes from CI/CD > Clusters' do
cluster.destroy! # let(:project) { create(:project) }
kubernetes_service.destroy! # let(:user) { create(:user) }
end
# # Platforms::Kubernetes (New archtecture)
# let!(:cluster) do
# create(:cluster,
# projects: [project],
# user: user,
# provider_type: :gcp,
# platform_type: :kubernetes,
# provider_gcp: provider_gcp,
# platform_kubernetes: platform_kubernetes)
# end
# let(:provider_gcp) { create(:cluster_provider_gcp, :created) }
# let(:platform_kubernetes) { create(:cluster_platform_kubernetes, :configured) }
# # KubernetesService (Automatically synchronized when Platforms::Kubernetes created)
# let!(:kubernetes_service) { create(:kubernetes_service, project: project) }
# context 'when user is using the cluster' do
# it 'migrates' do
# expect{ migrate! }.not_to change { Clusters::Cluster.count }
# expect(cluster).to be_active
# expect(kubernetes_service).not_to be_active
# end
# end
# context 'when user disabled cluster' do
# before do
# disable_cluster!
# end
# context 'when user configured kubernetes from Integration > Kubernetes' do
# before do
# kubernetes_service.update(
# active: true,
# api_url: 'http://new.kube.com',
# ca_pem: nil,
# token: 'z' * 40).reload
# end
# context 'when user is using the kubernetes service' do
# it 'migrates' do
# expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
# Clusters::Cluster.last.tap do |c|
# expect(c).to be_active
# expect(c.platform_kubernetes.api_url).to eq(kubernetes_service.api_url)
# expect(c.platform_kubernetes.ca_pem).to eq(kubernetes_service.ca_pem)
# expect(c.platform_kubernetes.token).to eq(kubernetes_service.token)
# end
# expect(kubernetes_service).not_to be_active
# end
# end
# context 'when user stopped using the kubernetes service' do
# before do
# kubernetes_service.update(active: false)
# end
# it 'migrates' do
# expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
# Clusters::Cluster.last.tap do |c|
# expect(c).not_to be_active
# expect(c.platform_kubernetes.api_url).to eq(kubernetes_service.api_url)
# expect(c.platform_kubernetes.ca_pem).to eq(kubernetes_service.ca_pem)
# expect(c.platform_kubernetes.token).to eq(kubernetes_service.token)
# end
# expect(kubernetes_service).not_to be_active
# end
# end
# end
# end
# context 'when user deleted cluster' do
# before do
# destory_cluster!
# end
# context 'when user configured kubernetes from Integration > Kubernetes' do
# let!(:new_kubernetes_service) do
# project.create_kubernetes_service(
# active: true,
# api_url: 'http://123.123.123.123',
# ca_pem: nil,
# token: 'a' * 40)
# end
# context 'when user is using the kubernetes service' do
# it 'migrates' do
# expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
# Clusters::Cluster.last.tap do |c|
# expect(c).to be_active
# expect(c.platform_kubernetes.api_url).to eq(new_kubernetes_service.api_url)
# expect(c.platform_kubernetes.ca_pem).to eq(new_kubernetes_service.ca_pem)
# expect(c.platform_kubernetes.token).to eq(new_kubernetes_service.token)
# end
# expect(new_kubernetes_service).not_to be_active
# end
# end
# context 'when user stopped using the kubernetes service' do
# before do
# new_kubernetes_service.update(active: false)
# end
# it 'migrates' do
# expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
# Clusters::Cluster.last.tap do |c|
# expect(c).not_to be_active
# expect(c.platform_kubernetes.api_url).to eq(new_kubernetes_service.api_url)
# expect(c.platform_kubernetes.ca_pem).to eq(new_kubernetes_service.ca_pem)
# expect(c.platform_kubernetes.token).to eq(new_kubernetes_service.token)
# end
# expect(new_kubernetes_service).not_to be_active
# end
# end
# end
# end
# end
# context 'when user configured kubernetes from Integration > Kubernetes' do
# let(:project) { create(:project) }
# let!(:kubernetes_service) { create(:kubernetes_service, project: project) }
# context 'when user is using the kubernetes service' do
# it 'migrates' do
# expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
# Clusters::Cluster.last.tap do |c|
# expect(c).to be_active
# expect(c.platform_kubernetes.api_url).to eq(kubernetes_service.api_url)
# expect(c.platform_kubernetes.ca_pem).to eq(kubernetes_service.ca_pem)
# expect(c.platform_kubernetes.token).to eq(kubernetes_service.token)
# end
# expect(kubernetes_service).not_to be_active
# end
# end
# context 'when user stopped using the kubernetes service' do
# before do
# kubernetes_service.update(active: false)
# end
# it 'migrates' do
# expect{ migrate! }.to change { Clusters::Cluster.count }.by(1)
# Clusters::Cluster.last.tap do |c|
# expect(c).not_to be_active
# expect(c.platform_kubernetes.api_url).to eq(kubernetes_service.api_url)
# expect(c.platform_kubernetes.ca_pem).to eq(kubernetes_service.ca_pem)
# expect(c.platform_kubernetes.token).to eq(kubernetes_service.token)
# end
# expect(kubernetes_service).not_to be_active
# end
# end
# end
# context 'when nothing is configured' do
# it 'migrates' do
# expect{ migrate! }.not_to change { Clusters::Cluster.count }
# end
# end
# def disable_cluster!
# cluster.update!(enabled: false)
# kubernetes_service.update!(active: false)
# end
# def destory_cluster!
# cluster.destroy!
# kubernetes_service.destroy!
# end
end end
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7