Function TestClusterErrorToHTTP

gateway/rest/cluster_errors_test.go:16–38

(t *testing.T)

)

func TestClusterErrorToHTTP(t *testing.T) {
	tests := []struct {
		name           string
		err            error
		expectedStatus int
	}{
		{"nil", nil, http.StatusOK},
		{"apiserver_not_ready", stderrors.New("apiserver not ready"), http.StatusServiceUnavailable},
		{"connection_refused", stderrors.New("connection refused"), http.StatusServiceUnavailable},
		{"lease_not_found", kubeclienterrors.ErrLeaseNotFound, http.StatusNotFound},
		{"no_deployment_for_lease", kubeclienterrors.ErrNoDeploymentForLease, http.StatusNotFound},
		{"no_manifest_for_lease", kubeclienterrors.ErrNoManifestForLease, http.StatusNotFound},
		{"no_service_for_lease", kubeclienterrors.ErrNoServiceForLease, http.StatusNotFound},
		{"k8s_not_found", kubeErrors.NewNotFound(schema.GroupResource{}, "lease"), http.StatusNotFound},
		{"unknown", stderrors.New("other"), http.StatusInternalServerError},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			wrapped := clusterErrorToHTTP(tt.err)
			require.Equal(t, tt.expectedStatus, httperror.StatusCodeFrom(wrapped))
		})
	}
}