1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
|
# frozen_string_literal: true
module GoogleApi
module CloudPlatformHelpers
def stub_google_api_validate_token
request.session[GoogleApi::CloudPlatform::Client.session_key_for_token] = 'token'
request.session[GoogleApi::CloudPlatform::Client.session_key_for_expires_at] = 1.hour.since.to_i.to_s
end
def stub_google_api_expired_token
request.session[GoogleApi::CloudPlatform::Client.session_key_for_token] = 'token'
request.session[GoogleApi::CloudPlatform::Client.session_key_for_expires_at] = 1.hour.ago.to_i.to_s
end
def stub_cloud_platform_projects_list(options)
WebMock.stub_request(:get, cloud_platform_projects_list_url)
.to_return(cloud_platform_response(cloud_platform_projects_body(options)))
end
def stub_cloud_platform_projects_get_billing_info(project_id, billing_enabled)
WebMock.stub_request(:get, cloud_platform_projects_get_billing_info_url(project_id))
.to_return(cloud_platform_response(cloud_platform_projects_billing_info_body(project_id, billing_enabled)))
end
def stub_cloud_platform_get_zone_cluster(project_id, zone, cluster_id, options = {})
WebMock.stub_request(:get, cloud_platform_get_zone_cluster_url(project_id, zone, cluster_id))
.to_return(cloud_platform_response(cloud_platform_cluster_body(options)))
end
def stub_cloud_platform_get_zone_cluster_error(project_id, zone, cluster_id)
WebMock.stub_request(:get, cloud_platform_get_zone_cluster_url(project_id, zone, cluster_id))
.to_return(status: [500, "Internal Server Error"])
end
def stub_cloud_platform_create_cluster(project_id, zone, options = {})
WebMock.stub_request(:post, cloud_platform_create_cluster_url(project_id, zone))
.to_return(cloud_platform_response(cloud_platform_operation_body(options)))
end
def stub_cloud_platform_create_cluster_error(project_id, zone)
WebMock.stub_request(:post, cloud_platform_create_cluster_url(project_id, zone))
.to_return(status: [500, "Internal Server Error"])
end
def stub_cloud_platform_get_zone_operation(project_id, zone, operation_id, options = {})
WebMock.stub_request(:get, cloud_platform_get_zone_operation_url(project_id, zone, operation_id))
.to_return(cloud_platform_response(cloud_platform_operation_body(options)))
end
def stub_cloud_platform_get_zone_operation_error(project_id, zone, operation_id)
WebMock.stub_request(:get, cloud_platform_get_zone_operation_url(project_id, zone, operation_id))
.to_return(status: [500, "Internal Server Error"])
end
def cloud_platform_projects_list_url
"https://cloudresourcemanager.googleapis.com/v1/projects"
end
def cloud_platform_projects_get_billing_info_url(project_id)
"https://cloudbilling.googleapis.com/v1/projects/#{project_id}/billingInfo"
end
def cloud_platform_get_zone_cluster_url(project_id, zone, cluster_id)
"https://container.googleapis.com/v1/projects/#{project_id}/zones/#{zone}/clusters/#{cluster_id}"
end
def cloud_platform_create_cluster_url(project_id, zone)
"https://container.googleapis.com/v1beta1/projects/#{project_id}/zones/#{zone}/clusters"
end
def cloud_platform_get_zone_operation_url(project_id, zone, operation_id)
"https://container.googleapis.com/v1/projects/#{project_id}/zones/#{zone}/operations/#{operation_id}"
end
def cloud_platform_response(body)
{ status: 200, headers: { 'Content-Type' => 'application/json' }, body: body.to_json }
end
def load_sample_cert
pem_file = File.expand_path(Rails.root.join('spec/fixtures/clusters/sample_cert.pem'))
Base64.encode64(File.read(pem_file))
end
##
# gcloud container clusters create
# https://cloud.google.com/kubernetes-engine/docs/reference/rest/v1/projects.zones.clusters/create
# rubocop:disable Metrics/CyclomaticComplexity
# rubocop:disable Metrics/PerceivedComplexity
def cloud_platform_cluster_body(options)
{
name: options[:name] || 'string',
description: options[:description] || 'string',
initialNodeCount: options[:initialNodeCount] || 'number',
masterAuth: {
username: options[:username] || 'string',
password: options[:password] || 'string',
clusterCaCertificate: options[:clusterCaCertificate] || load_sample_cert,
clientCertificate: options[:clientCertificate] || 'string',
clientKey: options[:clientKey] || 'string'
},
loggingService: options[:loggingService] || 'string',
monitoringService: options[:monitoringService] || 'string',
network: options[:network] || 'string',
clusterIpv4Cidr: options[:clusterIpv4Cidr] || 'string',
subnetwork: options[:subnetwork] || 'string',
enableKubernetesAlpha: options[:enableKubernetesAlpha] || 'boolean',
labelFingerprint: options[:labelFingerprint] || 'string',
selfLink: options[:selfLink] || 'string',
zone: options[:zone] || 'string',
endpoint: options[:endpoint] || 'string',
initialClusterVersion: options[:initialClusterVersion] || 'string',
currentMasterVersion: options[:currentMasterVersion] || 'string',
currentNodeVersion: options[:currentNodeVersion] || 'string',
createTime: options[:createTime] || 'string',
status: options[:status] || 'RUNNING',
statusMessage: options[:statusMessage] || 'string',
nodeIpv4CidrSize: options[:nodeIpv4CidrSize] || 'number',
servicesIpv4Cidr: options[:servicesIpv4Cidr] || 'string',
currentNodeCount: options[:currentNodeCount] || 'number',
expireTime: options[:expireTime] || 'string'
}
end
# rubocop:enable Metrics/CyclomaticComplexity
# rubocop:enable Metrics/PerceivedComplexity
def cloud_platform_operation_body(options)
{
name: options[:name] || 'operation-1234567891234-1234567',
zone: options[:zone] || 'us-central1-a',
operationType: options[:operationType] || 'CREATE_CLUSTER',
status: options[:status] || 'PENDING',
detail: options[:detail] || 'detail',
statusMessage: options[:statusMessage] || '',
selfLink: options[:selfLink] || 'https://container.googleapis.com/v1/projects/123456789101/zones/us-central1-a/operations/operation-1234567891234-1234567',
targetLink: options[:targetLink] || 'https://container.googleapis.com/v1/projects/123456789101/zones/us-central1-a/clusters/test-cluster',
startTime: options[:startTime] || '2017-09-13T16:49:13.055601589Z',
endTime: options[:endTime] || ''
}
end
def cloud_platform_projects_body(options)
{
projects: [
{
projectNumber: options[:project_number] || "1234",
projectId: options[:project_id] || "test-project-1234",
lifecycleState: "ACTIVE",
name: options[:name] || "test-project",
createTime: "2017-12-16T01:48:29.129Z",
parent: {
type: "organization",
id: "12345"
}
}
]
}
end
def cloud_platform_projects_billing_info_body(project_id, billing_enabled)
{
name: "projects/#{project_id}/billingInfo",
projectId: project_id.to_s,
billingAccountName: "account-name",
billingEnabled: billing_enabled
}
end
end
end
|
