package v1

import (
	"context"

	. "github.com/onsi/ginkgo/v2"
	. "github.com/onsi/gomega"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

var _ = Describe("Cdc", func() {

	Context("Create cdc used for mysql/kafka", func() {

		It("should contains provider type and region label", func() {
			pt, _, nt, _ := prepareCluster()
			cdc := &TiCDC{
				ObjectMeta: metav1.ObjectMeta{
					Name:      "networkpeer-" + RandomString(5),
					Namespace: nt.Namespace,
				},
				Spec: TiCDCSpec{
					NetworkName: nt.Name,
				},
			}

			err := k8sClient.Create(context.TODO(), cdc)
			Expect(err).To(BeNil())
			Expect(cdc.Labels[ProviderTypeLabel]).To(Equal(pt.Name))
			Expect(cdc.Labels[RegionLabel]).To(Equal(nt.Spec.Region))
		})
	})
})