split into gcp and user controllers again

2 files changed, 83 insertions, 0 deletions

diff --git a/app/controllers/projects/clusters/gcp_controller.rb b/app/controllers/projects/clusters/gcp_controller.rb
new file mode 100644
index 00000000000..ac9a906fe47
--- /dev/null
+++ b/app/controllers/projects/clusters/gcp_controller.rb
@@ -0,0 +1,41 @@
+class Projects::Clusters::GcpController < Projects::ApplicationController
+  include ClustersHelper
+  before_action :authorize_read_cluster!
+  before_action :authorize_create_cluster!, only: [:create]
+  helper_method :gcp_authorize_url
+  helper_method :token_in_session
+  helper_method :valid_gcp_token
+
+  def create
+    @cluster = ::Clusters::CreateService
+      .new(project, current_user, create_params)
+      .execute(token_in_session)
+
+    if @cluster.persisted?
+      redirect_to project_cluster_path(project, @cluster)
+    else
+      @gcp_cluster = @cluster
+      user_cluster
+
+      render 'projects/clusters/new', locals: { active_tab: 'gcp' }
+    end
+  end
+
+  private
+
+  def create_params
+    params.require(:cluster).permit(
+      :enabled,
+      :name,
+      :environment_scope,
+      provider_gcp_attributes: [
+        :gcp_project_id,
+        :zone,
+        :num_nodes,
+        :machine_type
+      ]).merge(
+        provider_type: :gcp,
+        platform_type: :kubernetes
+      )
+  end
+end
diff --git a/app/controllers/projects/clusters/user_controller.rb b/app/controllers/projects/clusters/user_controller.rb
new file mode 100644
index 00000000000..9da6a60e6b3
--- /dev/null
+++ b/app/controllers/projects/clusters/user_controller.rb
@@ -0,0 +1,42 @@
+class Projects::Clusters::UserController < Projects::ApplicationController
+  include ClustersHelper
+  before_action :authorize_read_cluster!
+  before_action :authorize_create_cluster!, only: [:create]
+  helper_method :gcp_authorize_url
+  helper_method :token_in_session
+  helper_method :valid_gcp_token
+
+  def create
+    @cluster = ::Clusters::CreateService
+      .new(project, current_user, create_params)
+      .execute
+
+    if @cluster.persisted?
+      redirect_to project_cluster_path(project, @cluster)
+    else
+      @user_cluster = @cluster
+      gcp_cluster
+
+      render 'projects/clusters/new', locals: { active_tab: 'user' }
+    end
+  end
+
+  private
+
+  def create_params
+    params.require(:cluster).permit(
+      :enabled,
+      :name,
+      :environment_scope,
+      platform_kubernetes_attributes: [
+        :namespace,
+        :api_url,
+        :token,
+        :ca_cert
+      ]).merge(
+        provider_type: :user,
+        platform_type: :kubernetes
+      )
+  end
+end
+