Skip to content

Commit fce60be

Browse files
committed
DEVX-658: updating okhttp to v5
1 parent 2dacf2d commit fce60be

File tree

9 files changed

+25
-25
lines changed

9 files changed

+25
-25
lines changed

commercetools/commercetools-okhttp-client5/src/main/java/com/commercetools/http/okhttp4/BuilderOptions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11

2-
package com.commercetools.http.okhttp4;
2+
package com.commercetools.http.okhttp5;
33

44
import okhttp3.OkHttpClient;
55

commercetools/commercetools-okhttp-client5/src/main/java/com/commercetools/http/okhttp4/CtOkHttp5Client.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11

2-
package com.commercetools.http.okhttp4;
2+
package com.commercetools.http.okhttp5;
33

44
import java.io.IOException;
55
import java.util.*;
@@ -29,52 +29,52 @@ public class CtOkHttp5Client extends HttpClientBase {
2929

3030
private final OkHttpClient okHttpClient;
3131

32-
public CtOkHttp4Client() {
32+
public CtOkHttp5Client() {
3333
super();
3434
okHttpClient = clientBuilder.get().dispatcher(createDispatcher(MAX_REQUESTS, MAX_REQUESTS)).build();
3535
}
3636

37-
public CtOkHttp4Client(final BuilderOptions options) {
37+
public CtOkHttp5Client(final BuilderOptions options) {
3838
super();
3939
okHttpClient = options.plus(clientBuilder.get().dispatcher(createDispatcher(MAX_REQUESTS, MAX_REQUESTS)))
4040
.build();
4141
}
4242

43-
public CtOkHttp4Client(final Supplier<OkHttpClient.Builder> builderSupplier) {
43+
public CtOkHttp5Client(final Supplier<OkHttpClient.Builder> builderSupplier) {
4444
super();
4545
okHttpClient = builderSupplier.get().build();
4646
}
4747

48-
public CtOkHttp4Client(final int maxRequests, final int maxRequestsPerHost) {
48+
public CtOkHttp5Client(final int maxRequests, final int maxRequestsPerHost) {
4949
super();
5050
okHttpClient = clientBuilder.get().dispatcher(createDispatcher(maxRequests, maxRequestsPerHost)).build();
5151
}
5252

53-
public CtOkHttp4Client(final int maxRequests, final int maxRequestsPerHost, final BuilderOptions options) {
53+
public CtOkHttp5Client(final int maxRequests, final int maxRequestsPerHost, final BuilderOptions options) {
5454
super();
5555
okHttpClient = options.plus(clientBuilder.get().dispatcher(createDispatcher(maxRequests, maxRequestsPerHost)))
5656
.build();
5757
}
5858

59-
public CtOkHttp4Client(final ExecutorService executor) {
59+
public CtOkHttp5Client(final ExecutorService executor) {
6060
super(executor);
6161
okHttpClient = clientBuilder.get().dispatcher(createDispatcher(executor, MAX_REQUESTS, MAX_REQUESTS)).build();
6262
}
6363

64-
public CtOkHttp4Client(final ExecutorService executor, final BuilderOptions options) {
64+
public CtOkHttp5Client(final ExecutorService executor, final BuilderOptions options) {
6565
super(executor);
6666
okHttpClient = options.plus(clientBuilder.get().dispatcher(createDispatcher(MAX_REQUESTS, MAX_REQUESTS)))
6767
.build();
6868
}
6969

70-
public CtOkHttp4Client(final ExecutorService executor, final int maxRequests, final int maxRequestsPerHost) {
70+
public CtOkHtt54Client(final ExecutorService executor, final int maxRequests, final int maxRequestsPerHost) {
7171
super(executor);
7272
okHttpClient = clientBuilder.get()
7373
.dispatcher(createDispatcher(executor, maxRequests, maxRequestsPerHost))
7474
.build();
7575
}
7676

77-
public CtOkHttp4Client(final ExecutorService executor, final int maxRequests, final int maxRequestsPerHost,
77+
public CtOkHttp5Client(final ExecutorService executor, final int maxRequests, final int maxRequestsPerHost,
7878
final BuilderOptions options) {
7979
super(executor);
8080
okHttpClient = options
@@ -103,7 +103,7 @@ public okhttp3.Dispatcher createDispatcher(final ExecutorService executor, final
103103

104104
@Override
105105
public CompletableFuture<ApiHttpResponse<byte[]>> execute(final ApiHttpRequest request) {
106-
return makeRequest(okHttpClient, toRequest(request)).thenApplyAsync(CtOkHttp4Client::toResponse, executor());
106+
return makeRequest(okHttpClient, toRequest(request)).thenApplyAsync(CtOkHttp5Client::toResponse, executor());
107107

108108
}
109109

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,21 +1,21 @@
11

2-
package com.commercetools.http.okhttp4;
2+
package com.commercetools.http.okhttp5;
33

44
import java.util.concurrent.ExecutorService;
55
import java.util.function.Supplier;
66

77
import io.vrap.rmf.base.client.BaseHttpClientSupplier;
88
import io.vrap.rmf.base.client.VrapHttpClient;
99

10-
public class OkHttp4ClientSupplier extends BaseHttpClientSupplier {
10+
public class OkHttp5ClientSupplier extends BaseHttpClientSupplier {
1111

1212
@Override
1313
public VrapHttpClient get() {
14-
return new CtOkHttp4Client();
14+
return new CtOkHttp5Client();
1515
}
1616

1717
@Override
1818
public Supplier<VrapHttpClient> get(ExecutorService executorService) {
19-
return () -> new CtOkHttp4Client(executorService);
19+
return () -> new CtOkHttp5Client(executorService);
2020
}
2121
}

commercetools/commercetools-okhttp-client5/src/main/java/com/commercetools/http/okhttp4/OkHttpClientSolutionInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11

2-
package com.commercetools.http.okhttp4;
2+
package com.commercetools.http.okhttp5;
33

44
import io.vrap.rmf.base.client.SolutionInfo;
55

Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
com.commercetools.http.okhttp4.OkHttp4ClientSupplier
1+
com.commercetools.http.okhttp5.OkHttp4ClientSupplier
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
com.commercetools.http.okhttp4.OkHttp4ClientSupplier
1+
com.commercetools.http.okhttp5.OkHttp4ClientSupplier
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
com.commercetools.http.okhttp4.OkHttpClientSolutionInfo
1+
com.commercetools.http.okhttp5.OkHttpClientSolutionInfo

commercetools/commercetools-okhttp-client5/src/test/java/com/commercetools/http/okhttp4/SolutionInfoTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11

2-
package com.commercetools.http.okhttp4;
2+
package com.commercetools.http.okhttp5;
33

44
import com.vdurmont.semver4j.Semver;
55

commercetools/commercetools-okhttp-client5/src/test/java/com/commercetools/http/okhttp4/SupplierTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11

2-
package com.commercetools.http.okhttp4;
2+
package com.commercetools.http.okhttp5;
33

44
import java.io.ByteArrayInputStream;
55
import java.io.ByteArrayOutputStream;
@@ -19,7 +19,7 @@
1919
public class SupplierTest {
2020
@Test
2121
public void testCreate() {
22-
Assertions.assertThat(HttpClientSupplier.of().get()).isInstanceOf(CtOkHttp4Client.class);
22+
Assertions.assertThat(HttpClientSupplier.of().get()).isInstanceOf(CtOkHttp5Client.class);
2323
}
2424

2525
@Test
@@ -32,7 +32,7 @@ public void testUnzip() throws IOException {
3232
gzipOs.close();
3333
ByteArrayInputStream inputStream = new ByteArrayInputStream(os.toByteArray());
3434

35-
CtOkHttp4Client.UnzippingInterceptor interceptor = new CtOkHttp4Client.UnzippingInterceptor();
35+
CtOkHttp5Client.UnzippingInterceptor interceptor = new CtOkHttp5Client.UnzippingInterceptor();
3636

3737
Response gzipped = new Response.Builder().request(new Request.Builder().url("http://localhost").build())
3838
.protocol(Protocol.HTTP_1_1)
@@ -51,7 +51,7 @@ public void testUnzip() throws IOException {
5151
Assertions.assertThat(unzipped.body().source().isOpen()).isTrue();
5252
Assertions.assertThat(inputStream.available()).isEqualTo(31);
5353

54-
ApiHttpResponse<byte[]> response = CtOkHttp4Client.toResponse(unzipped);
54+
ApiHttpResponse<byte[]> response = CtOkHttp5Client.toResponse(unzipped);
5555

5656
Assertions.assertThat(gzipped.body().source().isOpen()).isFalse();
5757
Assertions.assertThat(unzipped.body().source().isOpen()).isFalse();

0 commit comments

Comments
 (0)