2017-10-13 13:21:23 -04:00
|
|
|
module Clusters
|
|
|
|
class CreateService < BaseService
|
2017-10-23 04:36:35 -04:00
|
|
|
attr_reader :access_token
|
2017-10-01 04:48:21 -04:00
|
|
|
|
2017-12-04 08:18:58 -05:00
|
|
|
def execute(access_token = nil)
|
2017-10-23 04:36:35 -04:00
|
|
|
@access_token = access_token
|
2017-10-05 15:33:29 -04:00
|
|
|
|
2018-01-29 14:49:00 -05:00
|
|
|
raise ArgumentError.new(_('Instance does not support multiple Kubernetes clusters')) unless can_create_cluster?
|
2017-11-18 14:18:42 -05:00
|
|
|
|
2017-10-23 04:36:35 -04:00
|
|
|
create_cluster.tap do |cluster|
|
2017-10-03 17:24:32 -04:00
|
|
|
ClusterProvisionWorker.perform_async(cluster.id) if cluster.persisted?
|
2017-10-03 10:44:06 -04:00
|
|
|
end
|
2017-09-28 05:11:17 -04:00
|
|
|
end
|
2017-10-23 04:36:35 -04:00
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def create_cluster
|
2017-11-02 10:19:11 -04:00
|
|
|
Clusters::Cluster.create(cluster_params)
|
2017-10-23 04:36:35 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def cluster_params
|
|
|
|
return @cluster_params if defined?(@cluster_params)
|
|
|
|
|
2017-11-01 03:12:44 -04:00
|
|
|
params[:provider_gcp_attributes].try do |provider|
|
|
|
|
provider[:access_token] = access_token
|
2017-10-31 04:47:48 -04:00
|
|
|
end
|
2017-10-23 04:36:35 -04:00
|
|
|
|
2017-11-02 10:19:11 -04:00
|
|
|
@cluster_params = params.merge(user: current_user, projects: [project])
|
2017-10-23 04:36:35 -04:00
|
|
|
end
|
2017-11-18 14:18:42 -05:00
|
|
|
|
|
|
|
def can_create_cluster?
|
2017-12-05 07:48:55 -05:00
|
|
|
project.clusters.empty?
|
2017-11-18 14:18:42 -05:00
|
|
|
end
|
2017-09-28 05:11:17 -04:00
|
|
|
end
|
|
|
|
end
|