1 files changed, 90 insertions, 0 deletions
diff --git a/spec/services/google_cloud/create_cloudsql_instance_service_spec.rb b/spec/services/google_cloud/create_cloudsql_instance_service_spec.rb
new file mode 100644
index 00000000000..cd0dd75e576
--- /dev/null
+++ b/spec/services/google_cloud/create_cloudsql_instance_service_spec.rb
@@ -0,0 +1,90 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+
+RSpec.describe GoogleCloud::CreateCloudsqlInstanceService do
+  let(:project) { create(:project) }
+  let(:user) { create(:user) }
+  let(:gcp_project_id) { 'gcp_project_120' }
+  let(:environment_name) { 'test_env_42' }
+  let(:database_version) { 'POSTGRES_8000' }
+  let(:tier) { 'REIT_TIER' }
+  let(:service) do
+    described_class.new(project, user, {
+      gcp_project_id: gcp_project_id,
+      environment_name: environment_name,
+      database_version: database_version,
+      tier: tier
+    })
+  end
+
+  describe '#execute' do
+    before do
+      allow_next_instance_of(::Ci::VariablesFinder) do |variable_finder|
+        allow(variable_finder).to receive(:execute).and_return([])
+      end
+    end
+
+    it 'triggers creation of a cloudsql instance' do
+      expect_next_instance_of(GoogleApi::CloudPlatform::Client) do |client|
+        expected_instance_name = "gitlab-#{project.id}-postgres-8000-test-env-42"
+        expect(client).to receive(:create_cloudsql_instance)
+                            .with(gcp_project_id,
+                                  expected_instance_name,
+                                  String,
+                                  database_version,
+                                  'us-east1',
+                                  tier)
+      end
+
+      result = service.execute
+      expect(result[:status]).to be(:success)
+    end
+
+    it 'triggers worker to manage cloudsql instance creation operation results' do
+      expect_next_instance_of(GoogleApi::CloudPlatform::Client) do |client|
+        expect(client).to receive(:create_cloudsql_instance)
+      end
+
+      expect(GoogleCloud::CreateCloudsqlInstanceWorker).to receive(:perform_in)
+
+      result = service.execute
+      expect(result[:status]).to be(:success)
+    end
+
+    context 'when google APIs fail' do
+      it 'returns error' do
+        expect_next_instance_of(GoogleApi::CloudPlatform::Client) do |client|
+          expect(client).to receive(:create_cloudsql_instance).and_raise(Google::Apis::Error.new('mock-error'))
+        end
+
+        result = service.execute
+        expect(result[:status]).to eq(:error)
+      end
+    end
+
+    context 'when project has GCP_REGION defined' do
+      let(:gcp_region) { instance_double(::Ci::Variable, key: 'GCP_REGION', value: 'user-defined-region') }
+
+      before do
+        allow_next_instance_of(::Ci::VariablesFinder) do |variable_finder|
+          allow(variable_finder).to receive(:execute).and_return([gcp_region])
+        end
+      end
+
+      it 'uses defined region' do
+        expect_next_instance_of(GoogleApi::CloudPlatform::Client) do |client|
+          expect(client).to receive(:create_cloudsql_instance)
+                              .with(gcp_project_id,
+                                    String,
+                                    String,
+                                    database_version,
+                                    'user-defined-region',
+                                    tier)
+        end
+
+        service.execute
+      end
+    end
+  end
+end