Feat add zip #315 (#329)

* add zipcompress

pkg/compressor/zip_compress.go

@@ -16,3 +16,44 @@
  */
 
 package compressor
+
+import (
+	"bytes"
+	"io"
+
+	"github.com/klauspost/compress/zlib"
+)
+
+type Zip struct{}
+
+func (z Zip) Compress(data []byte) ([]byte, error) {
+	var buf bytes.Buffer
+	var zp = zlib.NewWriter(&buf)
+	if _, err := zp.Write(data); err != nil {
+		return nil, err
+	}
+	if err := zp.Close(); err != nil {
+		return nil, err
+	}
+	return buf.Bytes(), nil
+}
+
+func (z Zip) Decompress(data []byte) ([]byte, error) {
+	var buf bytes.Buffer
+	buf.Write(data)
+	r, err := zlib.NewReader(&buf)
+	if err != nil {
+		return nil, err
+	}
+	if err := r.Close(); err != nil {
+		return nil, err
+	}
+	if _, err := io.Copy(&buf, r); err != nil {
+		return nil, err
+	}
+	return buf.Bytes(), nil
+}
+
+func (z Zip) GetCompressorType() CompressorType {
+	return CompressorZstd
+}

pkg/compressor/zip_compress_test.go

@@ -0,0 +1,23 @@
+package compressor
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestZipCompress(t *testing.T) {
+	str := "test"
+
+	g := &Zip{}
+
+	compressRes, err := g.Compress([]byte(str))
+	assert.NoError(t, err)
+	t.Logf("compress res: %v", string(compressRes))
+
+	decompressRes, err := g.Decompress(compressRes)
+	assert.NoError(t, err)
+	t.Logf("decompress res: %v", string(decompressRes))
+
+	assert.Equal(t, str, string(decompressRes))
+}