errors.go

package errors

import (
	"encoding/json"
	"fmt"
	"net/http"

	grpcstatus "google.golang.org/grpc/status"

	apierros "k8s.io/apimachinery/pkg/api/errors"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime/schema"
)

const StatusReasonPublishError metav1.StatusReason = "PublishError"

// ToStatusError converts the err to a kube status error
func ToStatusError(qualifiedResource schema.GroupResource, name string, err error) *apierros.StatusError {
	grpcErr, ok := grpcstatus.FromError(err)
	if !ok {
		return NewPublishError(qualifiedResource, name, err)
	}

	var statusErr apierros.StatusError
	if unmarshalErr := json.Unmarshal([]byte(grpcErr.Message()), &statusErr); unmarshalErr != nil {
		return NewPublishError(qualifiedResource, name, err)
	}

	return &statusErr
}

// NewPublishError returns an error indicating a resource could not be published, and the client can try again.
func NewPublishError(qualifiedResource schema.GroupResource, name string, err error) *apierros.StatusError {
	return &apierros.StatusError{
		ErrStatus: metav1.Status{
			Status: metav1.StatusFailure,
			Code:   http.StatusInternalServerError,
			Reason: StatusReasonPublishError,
			Details: &metav1.StatusDetails{
				Group:  qualifiedResource.Group,
				Kind:   qualifiedResource.Resource,
				Name:   name,
				Causes: []metav1.StatusCause{{Message: err.Error()}},
			},
			Message: fmt.Sprintf("Failed to publish resource %s: %v", name, err),
		},
	}
}

// IsPublishError determines if err is a publish error which indicates that the request can be retried
// by the client.
func IsPublishError(err error) bool {
	return apierros.ReasonForError(err) == StatusReasonPublishError
}