2017-09-25 07:10:25 +00:00
|
|
|
class Projects::ClustersController < Projects::ApplicationController
|
2017-11-01 11:11:47 +00:00
|
|
|
before_action :cluster, except: [:login, :index, :new, :new_gcp, :create]
|
2017-10-03 14:44:06 +00:00
|
|
|
before_action :authorize_read_cluster!
|
2017-11-01 11:11:47 +00:00
|
|
|
before_action :authorize_create_cluster!, only: [:new, :new_gcp, :create]
|
|
|
|
before_action :authorize_google_api, only: [:new_gcp, :create]
|
2017-10-03 14:44:06 +00:00
|
|
|
before_action :authorize_update_cluster!, only: [:update]
|
|
|
|
before_action :authorize_admin_cluster!, only: [:destroy]
|
2017-09-25 07:10:25 +00:00
|
|
|
|
2017-10-05 15:04:35 +00:00
|
|
|
def index
|
|
|
|
if project.cluster
|
|
|
|
redirect_to project_cluster_path(project, project.cluster)
|
|
|
|
else
|
|
|
|
redirect_to new_project_cluster_path(project)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2017-09-27 12:01:08 +00:00
|
|
|
def login
|
|
|
|
begin
|
2017-11-01 11:11:47 +00:00
|
|
|
state = generate_session_key_redirect(providers_gcp_new_namespace_project_clusters_url.to_s)
|
2017-10-06 12:28:40 +00:00
|
|
|
|
2017-10-06 14:14:14 +00:00
|
|
|
@authorize_url = GoogleApi::CloudPlatform::Client.new(
|
|
|
|
nil, callback_google_api_auth_url,
|
|
|
|
state: state).authorize_url
|
2017-09-30 15:54:22 +00:00
|
|
|
rescue GoogleApi::Auth::ConfigMissingError
|
2017-10-02 08:13:46 +00:00
|
|
|
# no-op
|
2017-09-27 12:01:08 +00:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2017-09-25 07:10:25 +00:00
|
|
|
def new
|
|
|
|
end
|
|
|
|
|
2017-11-01 11:11:47 +00:00
|
|
|
def new_gcp
|
2017-10-31 18:59:40 +00:00
|
|
|
@cluster = Clusters::Cluster.new.tap do |cluster|
|
|
|
|
cluster.build_provider_gcp
|
|
|
|
end
|
2017-09-25 07:10:25 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
def create
|
2017-10-23 08:36:35 +00:00
|
|
|
@cluster = Clusters::CreateService
|
2017-10-05 15:04:35 +00:00
|
|
|
.new(project, current_user, create_params)
|
2017-09-30 15:54:22 +00:00
|
|
|
.execute(token_in_session)
|
2017-09-26 14:05:12 +00:00
|
|
|
|
2017-09-30 15:54:22 +00:00
|
|
|
if @cluster.persisted?
|
2017-10-05 15:04:35 +00:00
|
|
|
redirect_to project_cluster_path(project, @cluster)
|
2017-09-30 15:54:22 +00:00
|
|
|
else
|
2017-11-01 14:13:22 +00:00
|
|
|
render :new_gcp
|
2017-09-30 15:54:22 +00:00
|
|
|
end
|
2017-09-28 09:11:17 +00:00
|
|
|
end
|
2017-09-27 12:01:08 +00:00
|
|
|
|
2017-09-30 15:54:22 +00:00
|
|
|
def status
|
2017-09-28 09:11:17 +00:00
|
|
|
respond_to do |format|
|
|
|
|
format.json do
|
2017-10-02 12:58:50 +00:00
|
|
|
Gitlab::PollingInterval.set_header(response, interval: 10_000)
|
|
|
|
|
2017-10-03 21:21:54 +00:00
|
|
|
render json: ClusterSerializer
|
|
|
|
.new(project: @project, current_user: @current_user)
|
|
|
|
.represent_status(@cluster)
|
2017-09-27 12:53:50 +00:00
|
|
|
end
|
|
|
|
end
|
2017-09-25 07:10:25 +00:00
|
|
|
end
|
|
|
|
|
2017-10-03 14:44:06 +00:00
|
|
|
def show
|
2017-09-25 07:10:25 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
def update
|
2017-10-23 08:36:35 +00:00
|
|
|
Clusters::UpdateService
|
2017-10-05 15:04:35 +00:00
|
|
|
.new(project, current_user, update_params)
|
2017-09-30 15:54:22 +00:00
|
|
|
.execute(cluster)
|
2017-09-28 15:08:11 +00:00
|
|
|
|
2017-10-04 19:13:01 +00:00
|
|
|
if cluster.valid?
|
|
|
|
flash[:notice] = "Cluster was successfully updated."
|
|
|
|
redirect_to project_cluster_path(project, project.cluster)
|
|
|
|
else
|
|
|
|
render :show
|
|
|
|
end
|
2017-09-25 07:10:25 +00:00
|
|
|
end
|
|
|
|
|
2017-09-27 13:17:41 +00:00
|
|
|
def destroy
|
2017-09-28 15:08:11 +00:00
|
|
|
if cluster.destroy
|
2017-10-05 19:33:29 +00:00
|
|
|
flash[:notice] = "Cluster integration was successfully removed."
|
2017-09-28 15:08:11 +00:00
|
|
|
redirect_to project_clusters_path(project), status: 302
|
|
|
|
else
|
2017-10-05 19:33:29 +00:00
|
|
|
flash[:notice] = "Cluster integration was not removed."
|
2017-10-03 14:44:06 +00:00
|
|
|
render :show
|
2017-09-28 15:08:11 +00:00
|
|
|
end
|
2017-09-27 13:17:41 +00:00
|
|
|
end
|
|
|
|
|
2017-09-25 07:10:25 +00:00
|
|
|
private
|
|
|
|
|
|
|
|
def cluster
|
2017-11-15 19:15:48 +00:00
|
|
|
@cluster ||= project.clusters.find_by(id: params[:id])&.present(current_user: current_user) || render_404
|
2017-09-25 07:10:25 +00:00
|
|
|
end
|
|
|
|
|
2017-10-05 15:04:35 +00:00
|
|
|
def create_params
|
|
|
|
params.require(:cluster).permit(
|
2017-10-13 17:21:23 +00:00
|
|
|
:enabled,
|
2017-10-23 08:36:35 +00:00
|
|
|
:name,
|
2017-10-13 17:21:23 +00:00
|
|
|
:provider_type,
|
2017-10-23 08:36:35 +00:00
|
|
|
provider_gcp_attributes: [
|
|
|
|
:gcp_project_id,
|
|
|
|
:zone,
|
|
|
|
:num_nodes,
|
2017-10-13 17:21:23 +00:00
|
|
|
:machine_type
|
|
|
|
])
|
2017-09-25 07:10:25 +00:00
|
|
|
end
|
2017-09-26 08:46:09 +00:00
|
|
|
|
2017-10-05 15:04:35 +00:00
|
|
|
def update_params
|
2017-11-02 14:19:11 +00:00
|
|
|
params.require(:cluster).permit(:enabled)
|
2017-10-05 15:04:35 +00:00
|
|
|
end
|
|
|
|
|
2017-09-27 12:01:08 +00:00
|
|
|
def authorize_google_api
|
2017-10-02 08:13:46 +00:00
|
|
|
unless GoogleApi::CloudPlatform::Client.new(token_in_session, nil)
|
|
|
|
.validate_token(expires_at_in_session)
|
2017-09-27 12:01:08 +00:00
|
|
|
redirect_to action: 'login'
|
|
|
|
end
|
|
|
|
end
|
2017-09-30 15:54:22 +00:00
|
|
|
|
|
|
|
def token_in_session
|
2017-10-02 08:13:46 +00:00
|
|
|
@token_in_session ||=
|
|
|
|
session[GoogleApi::CloudPlatform::Client.session_key_for_token]
|
|
|
|
end
|
|
|
|
|
|
|
|
def expires_at_in_session
|
|
|
|
@expires_at_in_session ||=
|
|
|
|
session[GoogleApi::CloudPlatform::Client.session_key_for_expires_at]
|
2017-09-30 15:54:22 +00:00
|
|
|
end
|
2017-10-03 14:44:06 +00:00
|
|
|
|
2017-10-06 14:14:14 +00:00
|
|
|
def generate_session_key_redirect(uri)
|
|
|
|
GoogleApi::CloudPlatform::Client.new_session_key_for_redirect_uri do |key|
|
|
|
|
session[key] = uri
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2017-10-03 14:44:06 +00:00
|
|
|
def authorize_update_cluster!
|
2017-10-03 21:21:54 +00:00
|
|
|
access_denied! unless can?(current_user, :update_cluster, cluster)
|
2017-10-03 14:44:06 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
def authorize_admin_cluster!
|
2017-10-03 21:21:54 +00:00
|
|
|
access_denied! unless can?(current_user, :admin_cluster, cluster)
|
2017-10-03 14:44:06 +00:00
|
|
|
end
|
2017-09-25 07:10:25 +00:00
|
|
|
end
|