Skip to content

Commit c2f29a8

Browse files
authored
fix: upgrade http-facade and fix incompatible issues (#158)
Signed-off-by: moxiaoying <1159230165@qq.com>
1 parent 158977f commit c2f29a8

File tree

4 files changed

+25
-20
lines changed

4 files changed

+25
-20
lines changed

opengemini-client/src/test/java/io/opengemini/client/impl/OpenGeminiClientTest.java

Lines changed: 11 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -57,9 +57,9 @@ class OpenGeminiClientTest extends TestBase {
5757

5858
protected List<OpenGeminiClient> clientList() throws OpenGeminiException {
5959
List<HttpClientEngine> engines = new ArrayList<>();
60-
engines.add(HttpClientEngine.AsyncHttpClient);
61-
engines.add(HttpClientEngine.JAVA);
62-
engines.add(HttpClientEngine.JAVA8);
60+
engines.add(HttpClientEngine.Async);
61+
engines.add(HttpClientEngine.Java);
62+
engines.add(HttpClientEngine.Java8);
6363
engines.add(HttpClientEngine.OkHttp);
6464
List<OpenGeminiClient> clients = new ArrayList<>();
6565
for (HttpClientEngine engine : engines) {
@@ -68,10 +68,12 @@ protected List<OpenGeminiClient> clientList() throws OpenGeminiException {
6868
.connectTimeout(Duration.ofSeconds(3))
6969
.timeout(Duration.ofSeconds(3))
7070
.build();
71-
Configuration configuration = Configuration.builder()
72-
.addresses(Collections.singletonList(new Address("127.0.0.1", 8086)))
73-
.httpConfig(httpConfig)
74-
.build();
71+
Configuration configuration =
72+
Configuration.builder()
73+
.addresses(Collections.singletonList(new Address("127.0.0.1", 8086)))
74+
.httpConfig(httpConfig)
75+
.gzipEnabled(false)
76+
.build();
7577
clients.add(OpenGeminiClientFactory.create(configuration));
7678
}
7779
return clients;
@@ -89,6 +91,7 @@ void setUp() {
8991
.addresses(Collections.singletonList(new Address("127.0.0.1", 8086)))
9092
.httpConfig(httpConfig)
9193
.authConfig(new AuthConfig(AuthType.PASSWORD, "test", "testPwd123@".toCharArray(), null))
94+
.gzipEnabled(false)
9295
.build();
9396
this.openGeminiClient = new OpenGeminiClient(configuration);
9497
}
@@ -261,6 +264,7 @@ void query_should_throws_exception_when_address_is_wrong() throws IOException {
261264
Configuration configuration = Configuration.builder()
262265
.addresses(Collections.singletonList(new Address("127.0.0.1", 28086)))
263266
.httpConfig(new HttpClientConfig.Builder().build())
267+
.gzipEnabled(false)
264268
.build();
265269

266270
try (OpenGeminiClient wrongClient = new OpenGeminiClient(configuration)) {

opengemini-client/src/test/java/io/opengemini/client/impl/OpenGeminiClientWriteTest.java

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -47,9 +47,9 @@ class OpenGeminiClientWriteTest extends TestBase {
4747

4848
protected List<OpenGeminiClient> clientList() throws OpenGeminiException {
4949
List<HttpClientEngine> engines = new ArrayList<>();
50-
engines.add(HttpClientEngine.AsyncHttpClient);
51-
engines.add(HttpClientEngine.JAVA);
52-
engines.add(HttpClientEngine.JAVA8);
50+
engines.add(HttpClientEngine.Async);
51+
engines.add(HttpClientEngine.Java);
52+
engines.add(HttpClientEngine.Java8);
5353
engines.add(HttpClientEngine.OkHttp);
5454
List<OpenGeminiClient> clients = new ArrayList<>();
5555
for (HttpClientEngine engine : engines) {
@@ -58,10 +58,12 @@ protected List<OpenGeminiClient> clientList() throws OpenGeminiException {
5858
.connectTimeout(Duration.ofSeconds(3))
5959
.timeout(Duration.ofSeconds(3))
6060
.build();
61-
Configuration configuration = Configuration.builder()
62-
.addresses(Collections.singletonList(new Address("127.0.0.1", 8086)))
63-
.httpConfig(httpConfig)
64-
.build();
61+
Configuration configuration =
62+
Configuration.builder()
63+
.addresses(Collections.singletonList(new Address("127.0.0.1", 8086)))
64+
.httpConfig(httpConfig)
65+
.gzipEnabled(false)
66+
.build();
6567
clients.add(OpenGeminiClientFactory.create(configuration));
6668
}
6769
return clients;

opengemini-client/src/test/java/io/opengemini/client/impl/OpenGeminiWrongAddressTest.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,9 @@ class OpenGeminiWrongAddressTest {
4343

4444
protected List<OpenGeminiClient> clientList() throws OpenGeminiException {
4545
List<HttpClientEngine> engines = new ArrayList<>();
46-
engines.add(HttpClientEngine.AsyncHttpClient);
47-
engines.add(HttpClientEngine.JAVA);
48-
engines.add(HttpClientEngine.JAVA8);
46+
engines.add(HttpClientEngine.Async);
47+
engines.add(HttpClientEngine.Java);
48+
engines.add(HttpClientEngine.Java8);
4949
engines.add(HttpClientEngine.OkHttp);
5050
List<OpenGeminiClient> clients = new ArrayList<>();
5151
for (HttpClientEngine engine : engines) {
@@ -56,8 +56,7 @@ protected List<OpenGeminiClient> clientList() throws OpenGeminiException {
5656
.build();
5757
Configuration configuration = Configuration.builder()
5858
.addresses(Collections.singletonList(new Address("127.0.0.1", 28086)))
59-
.httpConfig(httpConfig)
60-
.build();
59+
.httpConfig(httpConfig).gzipEnabled(false).build();
6160
clients.add(OpenGeminiClientFactory.create(configuration));
6261
}
6362
return clients;

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@
4343
<async-http-client.version>3.0.0.Beta3</async-http-client.version>
4444
<commons-lang3.version>3.17.0</commons-lang3.version>
4545
<grpc.version>1.61.1</grpc.version>
46-
<http-facade.version>0.2.1</http-facade.version>
46+
<http-facade.version>0.4.0</http-facade.version>
4747
<jackson.version>2.17.2</jackson.version>
4848
<junit.version>5.11.1</junit.version>
4949
<kotlin.version>1.9.22</kotlin.version>

0 commit comments

Comments
 (0)