feat: add DisableDecompress field.

Author: ghosind

README.md

@@ -171,6 +171,7 @@ There are the available config options for performing a request, and all fields
 | `Body` | `any` | The request body. |
 | `ContentType` | `string` | The content type of this request. Available options are: `"json"`, and default `"json"`. |
 | `Context` | `context.Context` | Self-control context. |
+| `DisableDecompress` | `bool` | Indicates whether or not disable decompression of the response body automatically. |
 | `Headers` | `map[string][]string` | Custom headers to be sent. |
 | `MaxRedirects` | `int` | The maximum number of redirects for the request, default 5. |
 | `Method` | `string` | HTTP request method, default `GET`. |

README_CN.md

@@ -170,6 +170,7 @@ resp, err := cli.GET("/products/1")
 | `Body` | `any` | 请求内容 |
 | `ContentType` | `string` | 请求内容类型，当前可用值包括：`"json"`，默认为`"json"` |
 | `Context` | `context.Context` | 用于请求的上下文 |
+| `DisableDecompress` | `bool` | 是否禁用自动解压 |
 | `Headers` | `map[string][]string` | 自定义请求头部 |
 | `MaxRedirects` | `int` | 最大跳转次数 |
 | `Method` | `string` | 请求方式，默认为`GET` |

builtin_test.go

@@ -107,7 +107,7 @@ func TestRequestWithBody(t *testing.T) {
 func TestRequestWithGZipEncodedBody(t *testing.T) {
 	a := assert.New(t)
 
-	data, _, err := ToObject[testResponse](Request("", RequestOptions{
+	data, resp, err := ToObject[testResponse](Request("", RequestOptions{
 		BaseURL: "http://localhost:8080",
 		Headers: map[string][]string{
 			"Accept-Encoding": {"gzip", "deflate"},
@@ -117,12 +117,13 @@ func TestRequestWithGZipEncodedBody(t *testing.T) {
 
 	a.NotNilNow(data.Method)
 	a.EqualNow(*data.Method, "GET")
+	a.NotTrueNow(resp.Header.Get("Content-Encoding"))
 }
 
 func TestRequestWithDeflateEncodedBody(t *testing.T) {
 	a := assert.New(t)
 
-	data, _, err := ToObject[testResponse](Request("", RequestOptions{
+	data, resp, err := ToObject[testResponse](Request("", RequestOptions{
 		BaseURL: "http://localhost:8080",
 		Headers: map[string][]string{
 			"Accept-Encoding": {"deflate"},
@@ -132,6 +133,7 @@ func TestRequestWithDeflateEncodedBody(t *testing.T) {
 
 	a.NotNilNow(data.Method)
 	a.EqualNow(*data.Method, "GET")
+	a.NotTrueNow(resp.Header.Get("Content-Encoding"))
 }
 
 func TestRequestWithInvalidContentEncoding(t *testing.T) {
@@ -160,6 +162,21 @@ func TestRequestWithInvalidContentEncoding(t *testing.T) {
 	a.NotNilNow(err)
 }
 
+func TestRequestWithContentEncodingAndDisableDecompress(t *testing.T) {
+	a := assert.New(t)
+
+	resp, err := Request("", RequestOptions{
+		BaseURL: "http://localhost:8080",
+		Headers: map[string][]string{
+			"Accept-Encoding": {"gzip", "deflate"},
+		},
+		DisableDecompress: true,
+	})
+	a.NilNow(err)
+
+	a.EqualNow(resp.Header.Get("Content-Encoding"), "gzip")
+}
+
 func TestRequestWithParameters(t *testing.T) {
 	a := assert.New(t)
 

request.go

@@ -70,6 +70,9 @@ type RequestOptions struct {
 	//	  Context: ctx,
 	//	})
 	Context context.Context
+	// DisableDecompress indicates whether or not disable decompression of the response body
+	// automatically. If it is set to `true`, it will not decompress the response body.
+	DisableDecompress bool
 	// Headers are custom headers to be sent.
 	//
 	//	resp, err := request.Request("http://example.com", request.RequestOptions{
@@ -169,7 +172,9 @@ func (cli *Client) handleResponse(
 	resp *http.Response,
 	opt RequestOptions,
 ) (*http.Response, error) {
-	resp = cli.decodeResponseBody(resp)
+	if !opt.DisableDecompress {
+		resp = cli.decodeResponseBody(resp)
+	}
 
 	return cli.validateResponse(resp, opt)
 }
@@ -187,13 +192,15 @@ func (cli *Client) decodeResponseBody(resp *http.Response) *http.Response {
 		reader := flate.NewReader(bytes.NewReader(data))
 		resp.Body.Close()
 		resp.Body = reader
+		resp.Header.Del("Content-Encoding")
 	case "gzip", "x-gzip":
 		reader, err := gzip.NewReader(resp.Body)
 		if err != nil {
 			return nil
 		}
 		resp.Body.Close()
 		resp.Body = reader
+		resp.Header.Del("Content-Encoding")
 	}
 
 	return resp