From 48a83770d5fadbcd75c0913632b34f909cf233fb Mon Sep 17 00:00:00 2001
From: kaixuan xu <triumph_9431@qq.com>
Date: Sat, 18 Jan 2025 03:33:13 +0000
Subject: [PATCH] feat: add test compress

Signed-off-by: kaixuan xu <triumph_9431@qq.com>
---
 .../opengemini/client/common/BaseClient.java  | 48 ++++++++++---------
 .../client/impl/OpenGeminiClient.java         |  1 -
 2 files changed, 25 insertions(+), 24 deletions(-)

diff --git a/opengemini-client-common/src/main/java/io/opengemini/client/common/BaseClient.java b/opengemini-client-common/src/main/java/io/opengemini/client/common/BaseClient.java
index 035cca2..f7d1bdc 100644
--- a/opengemini-client-common/src/main/java/io/opengemini/client/common/BaseClient.java
+++ b/opengemini-client-common/src/main/java/io/opengemini/client/common/BaseClient.java
@@ -81,31 +81,33 @@ public BaseClient(Configuration conf) {
     }
 
     private void applyCodec(Configuration config, Map<String, List<String>> headers) {
-
-        List<String> acceptHeader = new ArrayList<>();
-        switch (config.getContentType()) {
-            case MSGPACK:
-                acceptHeader.add("application/msgpack");
-                break;
-            case JSON:
-                acceptHeader.add("application/json");
-                break;
-        }
+        if (config.getContentType() != null) {
+            List<String> acceptHeader = new ArrayList<>();
+            switch (config.getContentType()) {
+                case MSGPACK:
+                    acceptHeader.add("application/msgpack");
+                    break;
+                case JSON:
+                    acceptHeader.add("application/json");
+                    break;
+            }
         headers.put("Accept", acceptHeader);
-
-        List<String> acceptEncodingHeader = new ArrayList<>();
-        switch (config.getCompressMethod()) {
-            case GZIP:
-                acceptEncodingHeader.add("gzip");
-                break;
-            case ZSTD:
-                acceptEncodingHeader.add("zstd");
-                break;
-            case SNAPPY:
-                acceptEncodingHeader.add("snappy");
-                break;
         }
-        headers.put("Accept-Encoding", acceptEncodingHeader);
+        if(config.getCompressMethod() != null) {
+            List<String> acceptEncodingHeader = new ArrayList<>();
+            switch (config.getCompressMethod()) {
+                case GZIP:
+                    acceptEncodingHeader.add("gzip");
+                    break;
+                case ZSTD:
+                    acceptEncodingHeader.add("zstd");
+                    break;
+                case SNAPPY:
+                    acceptEncodingHeader.add("snappy");
+                    break;
+            }
+            headers.put("Accept-Encoding", acceptEncodingHeader);
+        }
     }
 
     /**
diff --git a/opengemini-client/src/main/java/io/opengemini/client/impl/OpenGeminiClient.java b/opengemini-client/src/main/java/io/opengemini/client/impl/OpenGeminiClient.java
index c8bba28..4cbcbe7 100644
--- a/opengemini-client/src/main/java/io/opengemini/client/impl/OpenGeminiClient.java
+++ b/opengemini-client/src/main/java/io/opengemini/client/impl/OpenGeminiClient.java
@@ -16,7 +16,6 @@
 
 package io.opengemini.client.impl;
 
-import com.sun.org.apache.bcel.internal.generic.RETURN;
 import io.github.openfacade.http.BasicAuthRequestFilter;
 import io.github.openfacade.http.HttpClient;
 import io.github.openfacade.http.HttpClientConfig;