1 package serializer_test
2
3 import (
4 "encoding/json"
5 "testing"
6
7 "github.com/google/uuid"
8 "github.com/stretchr/testify/require"
9
10 protos "edge-infra.dev/pkg/edge/datasync/internal/protos/upload"
11 "edge-infra.dev/pkg/edge/datasync/internal/serializer"
12 )
13
14 func TestProtoToJson(t *testing.T) {
15 messageID := uuid.New().String()
16 message := &protos.Message{ID: messageID, Type: "tlog", Payload: []byte("this is some payload")}
17
18 jsonMessage, _ := serializer.ProtobufToJSON(message)
19
20 var result protos.Message
21 err := json.Unmarshal([]byte(jsonMessage), &result)
22 require.Nil(t, err)
23 require.Equal(t, messageID, result.ID)
24 require.Equal(t, "tlog", result.Type)
25 require.Equal(t, "this is some payload", string(result.Payload))
26 }
27
View as plain text