package work

import (
	"basic.com/valib/deliver.git"

	"basic.com/pubsub/protomsg.git"
)

const mode = deliver.PushPull

// MsgRS msg recv and snd
type MsgRS struct {
	Msg protomsg.SdkMessage
}

func snappyCompress(in []byte) ([]byte, error) {
	return in, nil
	// out := snappy.Encode(nil, in)
	// return out, nil
}

// Compress compress
func Compress(in []byte) ([]byte, error) {
	return in, nil
	// return lz4Compress(in)
	// return snappyCompress(in)
}

func lz4Compress(in []byte) ([]byte, error) {
	return in, nil

	// out := make([]byte, len(in))
	// ht := make([]int, 64<<10) // buffer for the compression table
	// n, err := lz4.CompressBlock(in, out, ht)
	// if err != nil {
	// 	logo.Errorln(err)
	// 	return nil, err
	// }
	// if n >= len(in) {
	// 	logo.Infoln("image is not compressible")
	// }
	// out = out[:n] // compressed data
	// return out, nil
}

////////////////////////////////////////////////////////////////
func snappyUncompress(in []byte) ([]byte, error) {
	return in, nil
	// out, err := snappy.Decode(nil, in)
	// return out, err
}

// UnCompress uncompress
func UnCompress(in []byte) ([]byte, error) {
	return in, nil
	// return lz4Uncompress(in)
	// return snappyUncompress(in)
}

func lz4Uncompress(in []byte) ([]byte, error) {
	return in, nil

	// out := make([]byte, 10*len(in))
	// n, err := lz4.UncompressBlock(in, out)
	// if err != nil {
	// 	logo.Errorln(err)
	// 	return nil, err
	// }
	// out = out[:n] // uncompressed data
	// return out, nil
}