package config_test

import (
	"os"
	"testing"

	"github.com/stretchr/testify/require"

	"edge-infra.dev/pkg/edge/datasync/shoot/config"
)

func TestGetTargetTopic(t *testing.T) {
	os.Setenv("TOPICS_MAPPING", `[{"source": "public", "target": "public_target"}, {"source": "tlogs", "target": "tlogs_target"}]`)

	res := config.GetTargetTopic("public")
	require.Equal(t, "public_target", res)

	res = config.GetTargetTopic("tlogs")
	require.Equal(t, "tlogs_target", res)
}