package serializer_test

import (
	"encoding/json"
	"testing"

	"github.com/google/uuid"
	"github.com/stretchr/testify/require"

	protos "edge-infra.dev/pkg/edge/datasync/internal/protos/upload"
	"edge-infra.dev/pkg/edge/datasync/internal/serializer"
)

func TestProtoToJson(t *testing.T) {
	messageID := uuid.New().String()
	message := &protos.Message{ID: messageID, Type: "tlog", Payload: []byte("this is some payload")}

	jsonMessage, _ := serializer.ProtobufToJSON(message)

	var result protos.Message
	err := json.Unmarshal([]byte(jsonMessage), &result)
	require.Nil(t, err)
	require.Equal(t, messageID, result.ID)
	require.Equal(t, "tlog", result.Type)
	require.Equal(t, "this is some payload", string(result.Payload))
}