package app

import (
	"testing"

	"github.com/stretchr/testify/require"

	"github.com/tidbcloud/tidb-management-service/tidb-mgmt-service/pkg/config"
)

func TestSupportedChangefeedSinkTypes(t *testing.T) {
	require.ElementsMatch(t, []string{"S3", "KAFKA", "MYSQL"}, supportedChangefeedSinkTypes(nil))
	require.ElementsMatch(
		t,
		[]string{"PULSAR"},
		supportedChangefeedSinkTypes(&config.DedicatedToPremiumPrecheckConfig{SupportedChangefeedSinkTypes: []string{"PULSAR"}}),
	)
}