func NewReader()

in pkg/sdk/value/compression/reader.go [38:88]
45 lines of code
14 McCabe index (conditional complexity)

func NewReader(r io.Reader, algorithm string) (io.ReadCloser, error) {
	// Normalize input
	algorithm = strings.TrimSpace(strings.ToLower(algorithm))

	var (
		compressedReader io.ReadCloser
		readerErr        error
	)

	// Apply transformation
	switch algorithm {
	case "identity":
		compressedReader = io.NopCloser(r)
	case "gzip":
		compressedReader, readerErr = gzip.NewReader(r)
	case "lzw", "lzw-lsb":
		compressedReader = lzw.NewReader(r, lzw.LSB, 8)
	case "lzw-msb":
		compressedReader = lzw.NewReader(r, lzw.MSB, 8)
	case "lz4":
		compressedReader = io.NopCloser(lz4.NewReader(r))
	case "s2", "snappy":
		compressedReader = io.NopCloser(s2.NewReader(r))
	case "zlib":
		compressedReader, readerErr = zlib.NewReader(r)
	case "flate", "deflate":
		compressedReader = flate.NewReader(r)
	case "lzma":
		reader, err := xz.NewReader(r)
		if err != nil {
			readerErr = err
		} else {
			compressedReader = io.NopCloser(reader)
		}
	case "zstd":
		reader, err := zstd.NewReader(r)
		if err != nil {
			readerErr = err
		} else {
			compressedReader = reader.IOReadCloser()
		}
	default:
		return nil, fmt.Errorf("unhandled compression algorithm '%s'", algorithm)
	}
	if readerErr != nil {
		return nil, fmt.Errorf("unable to initialize '%s' compressor: %w", algorithm, readerErr)
	}

	// No error
	return compressedReader, nil
}