Reducing scope of PR

config/confighttp/compression.go

@@ -32,7 +32,11 @@ var availableDecoders = map[string]func(body io.ReadCloser) (io.ReadCloser, erro
 		return nil, nil
 	},
 	"gzip": func(body io.ReadCloser) (io.ReadCloser, error) {
-		return gzip.NewReader(body)
+		gr, err := gzip.NewReader(body)
+		if err != nil {
+			return nil, err
+		}
+		return gr, nil
 	},
 	"zstd": func(body io.ReadCloser) (io.ReadCloser, error) {
 		zr, err := zstd.NewReader(
@@ -49,11 +53,23 @@ var availableDecoders = map[string]func(body io.ReadCloser) (io.ReadCloser, erro
 		return zr.IOReadCloser(), nil
 	},
 	"zlib": func(body io.ReadCloser) (io.ReadCloser, error) {
-		return zlib.NewReader(body)
+		zr, err := zlib.NewReader(body)
+		if err != nil {
+			return nil, err
+		}
+		return zr, nil
 	},
-	//nolint:unparam // Require to have error return so it can be part of map
 	"snappy": func(body io.ReadCloser) (io.ReadCloser, error) {
-		return io.NopCloser(snappy.NewReader(body)), nil
+		sr := snappy.NewReader(body)
+		sb := new(bytes.Buffer)
+		_, err := io.Copy(sb, sr)
+		if err != nil {
+			return nil, err
+		}
+		if err = body.Close(); err != nil {
+			return nil, err
+		}
+		return io.NopCloser(sb), nil
 	},
 	//nolint:unparam // Require to have error return so it can be part of map
 	"lz4": func(body io.ReadCloser) (io.ReadCloser, error) {

config/confighttp/compression_test.go

@@ -244,7 +244,7 @@ func TestHTTPContentDecompressionHandler(t *testing.T) {
 			encoding: "snappy",
 			reqBody:  bytes.NewBuffer(testBody),
 			respCode: http.StatusBadRequest,
-			respBody: "snappy: corrupt input",
+			respBody: "snappy: corrupt input\n",
 		},
 		{
 			name:     "InvalidLz4",

config/confighttp/compressor.go

@@ -7,7 +7,7 @@ import (
 	"bytes"
 	"compress/gzip"
 	"compress/zlib"
-	"fmt"
+	"errors"
 	"io"
 	"sync"
 
@@ -61,7 +61,7 @@ func newCompressor(compressionType configcompression.Type) (*compressor, error)
 	case configcompression.TypeLz4:
 		return lz4Pool, nil
 	}
-	return nil, fmt.Errorf("unsupported compression type %q", compressionType)
+	return nil, errors.New("unsupported compression type, ")
 }
 
 func (p *compressor) compress(buf *bytes.Buffer, body io.ReadCloser) error {