package task

import (
	"context"

	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"sigs.k8s.io/controller-runtime/pkg/client"
)

const (
	RDSSecretName   string = "tiflow-rds-secret"
	RDSSecretKey    string = "credentials_json"
	RDSSecretEnvKey string = "TIFLOW_RDS_SECRET"
)

func IsRDSSecretExists(ctx context.Context, tiflowNs string, remote client.Client) bool {
	secret := &corev1.Secret{
		ObjectMeta: metav1.ObjectMeta{
			Namespace: tiflowNs,
			Name:      RDSSecretName,
		},
	}
	if err := remote.Get(ctx, client.ObjectKeyFromObject(secret), secret); err != nil {
		return false
	}

	return true
}