package common

import (
	"testing"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
	. "github.com/tidbcloud/dataflow-service-e2e/internal/model"
)

func TestKafkaAuthenticationPreservesCredentials(t *testing.T) {
	auth := kafkaAuthentication(&KafkaEntity{
		KafkaDimensions: KafkaDimensions{AuthType: DataflowKafkaAuthTypeSASLPLAIN},
		User:            "kafka-user",
		Password:        "kafka-password",
	})

	require.NotNil(t, auth.AuthType)
	assert.Equal(t, "SASL_PLAIN", string(*auth.AuthType))
	assert.Equal(t, "kafka-user", auth.UserName)
	assert.Equal(t, "kafka-password", auth.Password)
}