add string to bytes util

Author: ogbanugot

brokers/redis/list.go

@@ -253,7 +253,8 @@ func (b *List) Status() bool {
 }
 
 func ListUnmarshalMessage(msg *disq.Message, body string) error {
-	if err := msgpack.Unmarshal([]byte(body), (*disq.MessageRaw)(msg)); err != nil {
+	err := msg.UnmarshalBinary(disq.StringToBytes(body))
+	if err != nil {
 		return err
 	}
 	return nil

brokers/redis/stream.go

@@ -13,7 +13,6 @@ import (
 	"github.com/go-redis/redis/v8"
 	"github.com/google/uuid"
 	log "github.com/sirupsen/logrus"
-	"github.com/vmihailenco/msgpack"
 )
 
 // Broker based on redis STREAM and ZSET.
@@ -316,7 +315,8 @@ func unixMs(tm time.Time) int64 {
 
 func StreamUnmarshalMessage(msg *disq.Message, xmsg *redis.XMessage) error {
 	body := xmsg.Values["body"].(string)
-	if err := msgpack.Unmarshal([]byte(body), (*disq.MessageRaw)(msg)); err != nil {
+	err := msg.UnmarshalBinary(disq.StringToBytes(body))
+	if err != nil {
 		return err
 	}
 	msg.ID = xmsg.ID

util.go

@@ -5,6 +5,7 @@ import (
 	"os"
 	"strconv"
 	"time"
+	"unsafe"
 )
 
 func UnixMs(tm time.Time) int64 {
@@ -21,3 +22,18 @@ func ConsumerName() string {
 func DurEqual(d1, d2 time.Duration, threshold int) bool {
 	return (d2 >= d1 && (d2-d1) < time.Duration(threshold)*time.Second)
 }
+
+// BytesToString converts byte slice to string.
+func BytesToString(b []byte) string {
+	return *(*string)(unsafe.Pointer(&b))
+}
+
+// StringToBytes converts string to byte slice.
+func StringToBytes(s string) []byte {
+	return *(*[]byte)(unsafe.Pointer(
+		&struct {
+			string
+			Cap int
+		}{s, len(s)},
+	))
+}