fix(#267): Maybe fixed empty message bug

lxgr-linux · Nov 21, 2024 · e6a0df7 · e6a0df7
1 parent 7e42717
commit e6a0df7
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/pkg/bs_rpc/client.go b/pkg/bs_rpc/client.go
@@ -110,7 +110,7 @@ func (c Client) Listen(ctx context.Context) error {
 			msgBuf = append(msgBuf, buf...)
 		}
 
-		if bytes.Contains(msgBuf, ENDSECTION) {
+		if bytes.Contains(msgBuf, ENDSECTION) && !bytes.Equal(msgBuf, ENDSECTION) {
 			msgParts := bytes.Split(msgBuf, ENDSECTION)
 
 			m, err := Unmarshall(

diff --git a/pkg/bs_rpc/encoding.go b/pkg/bs_rpc/encoding.go
@@ -8,7 +8,10 @@ import (
 
 func Unmarshall(reg *msg.Registry, b []byte) (msg.Msg[msg.Body], error) {
 	genericMsg := msg.Msg[msg.Body]{}
-	_ = json.Unmarshal(b, &genericMsg)
+	err := json.Unmarshal(b, &genericMsg)
+	if err != nil {
+		return genericMsg, err
+	}
 
 	unMarshaller, err := reg.GetUnMarshaller(genericMsg.Type)
 	if err != nil {

diff --git a/pkg/server/pokete/msg/position/subscription.go b/pkg/server/pokete/msg/position/subscription.go
@@ -52,6 +52,8 @@ func ReveiveUpdates(ctx context.Context) error {
 			return fmt.Errorf("message not positon update but: `%s`", u.GetType())
 		}
 
+		slog.InfoContext(ctx, fmt.Sprintf("%v", u.Position))
+
 		err = us.SetNewPositionToUser(conId, u.Position)
 		if err != nil {
 			return err