From 758606f62728211166e80f6e73784366ad85dffc Mon Sep 17 00:00:00 2001
From: Gordon <46924906+FGadvancer@users.noreply.github.com>
Date: Tue, 3 Sep 2024 18:20:52 +0800
Subject: [PATCH] fix: encoder replace to json encoder.

---
 internal/msggateway/encoder.go | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

diff --git a/internal/msggateway/encoder.go b/internal/msggateway/encoder.go
index 66d74ccb2..056f46236 100644
--- a/internal/msggateway/encoder.go
+++ b/internal/msggateway/encoder.go
@@ -15,6 +15,8 @@
 package msggateway
 
 import (
+	"encoding/json"
+
 	"github.com/openimsdk/tools/errs"
 )
 
@@ -30,17 +32,17 @@ func NewGobEncoder() *GobEncoder {
 }
 
 func (g *GobEncoder) Encode(data any) ([]byte, error) {
-	if b, ok := data.([]byte); ok {
-		return b, nil
+	b, err := json.Marshal(data)
+	if err != nil {
+		return nil, errs.New("Encoder.Encode failed", "action", "encode")
 	}
-	return nil, errs.New("Encoder.Encode failed", "action", "encode")
+	return b, nil
 }
 
 func (g *GobEncoder) Decode(encodeData []byte, decodeData any) error {
-	if b, ok := decodeData.(*[]byte); ok {
-		*b = encodeData
-		return nil
+	err := json.Unmarshal(encodeData, decodeData)
+	if err != nil {
+		return errs.New("Encoder.Decode failed", "action", "decode")
 	}
-
-	return errs.New("Encoder.Decode failed", "action", "decode")
+	return nil
 }