Skip to content

Commit 54f9c8b

Browse files
ukclivecoxbrendanburns
authored andcommitted
Fixes to cover review comments
1 parent 207c660 commit 54f9c8b

File tree

1 file changed

+29
-26
lines changed

1 file changed

+29
-26
lines changed

util/src/main/java/io/kubernetes/client/ProtoClient.java

Lines changed: 29 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ public <T extends Message> ObjectOrStatus<T> update(T obj, String path, String a
134134
* @param path The path to call in the API server
135135
* @return The response status
136136
*/
137-
public <T extends Message> ObjectOrStatus<T> delete(T.Builder builder, String path) throws ApiException, IOException {
137+
public <T extends Message> ObjectOrStatus<T> delete(T.Builder builder,String path) throws ApiException, IOException {
138138
return request(builder, path, "DELETE", null, null, null);
139139
}
140140

@@ -149,27 +149,25 @@ public <T extends Message> ObjectOrStatus<T> delete(T.Builder builder, String pa
149149
if (deleteOptions == null) {
150150
return delete(builder,path);
151151
}
152-
else {
153-
HashMap<String, String> headers = new HashMap<String, String>();
154-
headers.put("Content-Type", MEDIA_TYPE);
155-
headers.put("Accept", MEDIA_TYPE);
156-
Request request = apiClient.buildRequest(path, "DELETE", new ArrayList<Pair>(), new ArrayList<Pair>(), null,
157-
headers, new HashMap<String, Object>(), new String[0], null);
158-
byte[] bytes = encode(deleteOptions, "v1", "DeleteOptions");
159-
request = request.newBuilder().delete(RequestBody.create(MediaType.parse(MEDIA_TYPE), bytes)).build();
160-
Response resp = apiClient.getHttpClient().newCall(request).execute();
161-
Unknown u = parse(resp.body().byteStream());
162-
resp.body().close();
163-
164-
if (u.getTypeMeta().getApiVersion().equals("v1") &&
165-
u.getTypeMeta().getKind().equals("Status")) {
152+
153+
HashMap<String, String> headers = new HashMap<String, String>();
154+
headers.put("Content-Type", MEDIA_TYPE);
155+
headers.put("Accept", MEDIA_TYPE);
156+
Request request = apiClient.buildRequest(path, "DELETE", new ArrayList<Pair>(), new ArrayList<Pair>(), null,
157+
headers, new HashMap<String, Object>(), new String[0], null);
158+
byte[] bytes = encode(deleteOptions, "v1", "DeleteOptions");
159+
request = request.newBuilder().delete(RequestBody.create(MediaType.parse(MEDIA_TYPE), bytes)).build();
160+
Response resp = apiClient.getHttpClient().newCall(request).execute();
161+
Unknown u = parse(resp.body().byteStream());
162+
resp.body().close();
163+
164+
if (u.getTypeMeta().getApiVersion().equals("v1") &&
165+
u.getTypeMeta().getKind().equals("Status")) {
166166
Status status = Status.newBuilder().mergeFrom(u.getRaw()).build();
167167
return new ObjectOrStatus(null, status);
168-
}
169-
170-
return new ObjectOrStatus((T) builder.mergeFrom(u.getRaw()).build(), null);
171168
}
172169

170+
return new ObjectOrStatus((T) builder.mergeFrom(u.getRaw()).build(), null);
173171
}
174172

175173
/**
@@ -192,14 +190,19 @@ public <T extends Message> ObjectOrStatus<T> request(T.Builder builder, String p
192190
headers, new HashMap<String, Object>(), new String[0], null);
193191
if (body != null) {
194192
byte[] bytes = encode(body, apiVersion, kind);
195-
if ("POST".equals(method))
196-
request = request.newBuilder().post(RequestBody.create(MediaType.parse(MEDIA_TYPE), bytes)).build();
197-
else if ("PUT".equals(method))
198-
request = request.newBuilder().put(RequestBody.create(MediaType.parse(MEDIA_TYPE), bytes)).build();
199-
else if ("PATCH".equals(method))
200-
request = request.newBuilder().patch(RequestBody.create(MediaType.parse(MEDIA_TYPE), bytes)).build();
201-
else
202-
throw new ApiException("Unknown proto client API method: "+method);
193+
switch (method) {
194+
case "POST":
195+
request = request.newBuilder().post(RequestBody.create(MediaType.parse(MEDIA_TYPE), bytes)).build();
196+
break;
197+
case "PUT":
198+
request = request.newBuilder().put(RequestBody.create(MediaType.parse(MEDIA_TYPE), bytes)).build();
199+
break;
200+
case "PATCH":
201+
request = request.newBuilder().patch(RequestBody.create(MediaType.parse(MEDIA_TYPE), bytes)).build();
202+
break;
203+
default:
204+
throw new ApiException("Unknown proto client API method: " + method);
205+
}
203206
}
204207
Response resp = apiClient.getHttpClient().newCall(request).execute();
205208
Unknown u = parse(resp.body().byteStream());

0 commit comments

Comments
 (0)