in pkg/controller/direct/datastream/connectionprofile_controller.go [269:310]
func (a *ConnectionProfileAdapter) normalizeReferenceFields(ctx context.Context) error {
obj := a.desired
if obj.Spec.OracleProfile != nil && obj.Spec.OracleProfile.OracleASMConfig != nil && obj.Spec.OracleProfile.OracleASMConfig.SecretRef != nil {
if err := refsv1beta1secret.NormalizedSecret(ctx, obj.Spec.OracleProfile.OracleASMConfig.SecretRef, a.reader, obj.GetNamespace()); err != nil {
return err
}
}
if obj.Spec.ForwardSSHConnectivity != nil && obj.Spec.ForwardSSHConnectivity.SecretRef != nil {
if err := refsv1beta1secret.NormalizedSecret(ctx, obj.Spec.ForwardSSHConnectivity.SecretRef, a.reader, obj.GetNamespace()); err != nil {
return err
}
}
if obj.Spec.MySQLProfile != nil && obj.Spec.MySQLProfile.SecretRef != nil {
if err := refsv1beta1secret.NormalizedSecret(ctx, obj.Spec.MySQLProfile.SecretRef, a.reader, obj.GetNamespace()); err != nil {
return err
}
}
if obj.Spec.OracleProfile != nil && obj.Spec.OracleProfile.SecretRef != nil {
if err := refsv1beta1secret.NormalizedSecret(ctx, obj.Spec.OracleProfile.SecretRef, a.reader, obj.GetNamespace()); err != nil {
return err
}
}
if obj.Spec.OracleProfile != nil && obj.Spec.OracleProfile.SecreteManagerSecretRef != nil {
if _, err := refs.ResolveSecretManagerSecretRef(ctx, a.reader, obj, obj.Spec.OracleProfile.SecreteManagerSecretRef); err != nil {
return err
}
}
// TODO: PostgresqlProfile is not implemented yet
if obj.Spec.SQLServerProfile != nil && obj.Spec.SQLServerProfile.SecretRef != nil {
if err := refsv1beta1secret.NormalizedSecret(ctx, obj.Spec.SQLServerProfile.SecretRef, a.reader, obj.GetNamespace()); err != nil {
return err
}
}
if obj.Spec.PrivateConnectivity != nil && obj.Spec.PrivateConnectivity.PrivateConnectionRef != nil {
if _, err := obj.Spec.PrivateConnectivity.PrivateConnectionRef.NormalizedExternal(ctx, a.reader, obj.GetNamespace()); err != nil {
return err
}
}
return nil
}