fix(cluster): import cluster verification failure

TomatoAres · May 13, 2020 · e701629 · e701629
1 parent 86219f4
commit e701629
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/api/platform/validation/clustercredential.go b/api/platform/validation/clustercredential.go
@@ -20,6 +20,7 @@ package validation
 
 import (
  "context"
+ "errors"
  "time"
 
  apierrors "k8s.io/apimachinery/pkg/api/errors"
@@ -69,7 +70,7 @@ func ValidateClusterCredential(ctx context.Context, credential *platform.Cluster
  if credential.CACert != nil {
  restConfig.CAData = credential.CACert
  if err = utilvalidation.ValidateRESTConfig(ctx, restConfig); err != nil {
- if !apierrors.IsUnauthorized(err) {
+ if status := apierrors.APIStatus(nil); !errors.As(err, &status) {
  allErrs = append(allErrs, field.Invalid(field.NewPath("caCert"), "", err.Error()))
  }
  }

diff --git a/pkg/platform/provider/imported/validation/cluster.go b/pkg/platform/provider/imported/validation/cluster.go
@@ -20,6 +20,7 @@ package validation
 
 import (
  "context"
+ "errors"
  "fmt"
  "time"
 
@@ -113,7 +114,7 @@ func ValidatClusterCredentialRef(ctx context.Context, cluster *types.Cluster, fl
  if credential.CACert != nil {
  restConfig.CAData = credential.CACert
  if err = utilvalidation.ValidateRESTConfig(ctx, restConfig); err != nil {
- if !apierrors.IsUnauthorized(err) {
+ if status := apierrors.APIStatus(nil); !errors.As(err, &status) {
  allErrs = append(allErrs, field.Invalid(field.NewPath("caCert"), "", err.Error()))
  }
  }