104 lines
2.6 KiB
Go
104 lines
2.6 KiB
Go
/*
|
|
Copyright The containerd Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package errdefs
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"testing"
|
|
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
)
|
|
|
|
func TestGRPCRoundTrip(t *testing.T) {
|
|
errShouldLeaveAlone := errors.New("unknown to package")
|
|
|
|
for _, testcase := range []struct {
|
|
input error
|
|
cause error
|
|
str string
|
|
}{
|
|
{
|
|
input: ErrAlreadyExists,
|
|
cause: ErrAlreadyExists,
|
|
},
|
|
{
|
|
input: ErrNotFound,
|
|
cause: ErrNotFound,
|
|
},
|
|
//nolint:dupword
|
|
{
|
|
input: fmt.Errorf("test test test: %w", ErrFailedPrecondition),
|
|
cause: ErrFailedPrecondition,
|
|
str: "test test test: failed precondition",
|
|
},
|
|
{
|
|
input: status.Errorf(codes.Unavailable, "should be not available"),
|
|
cause: ErrUnavailable,
|
|
str: "should be not available: unavailable",
|
|
},
|
|
{
|
|
input: errShouldLeaveAlone,
|
|
cause: ErrUnknown,
|
|
str: errShouldLeaveAlone.Error() + ": " + ErrUnknown.Error(),
|
|
},
|
|
{
|
|
input: context.Canceled,
|
|
cause: context.Canceled,
|
|
str: "context canceled",
|
|
},
|
|
{
|
|
input: fmt.Errorf("this is a test cancel: %w", context.Canceled),
|
|
cause: context.Canceled,
|
|
str: "this is a test cancel: context canceled",
|
|
},
|
|
{
|
|
input: context.DeadlineExceeded,
|
|
cause: context.DeadlineExceeded,
|
|
str: "context deadline exceeded",
|
|
},
|
|
{
|
|
input: fmt.Errorf("this is a test deadline exceeded: %w", context.DeadlineExceeded),
|
|
cause: context.DeadlineExceeded,
|
|
str: "this is a test deadline exceeded: context deadline exceeded",
|
|
},
|
|
} {
|
|
t.Run(testcase.input.Error(), func(t *testing.T) {
|
|
t.Logf("input: %v", testcase.input)
|
|
gerr := ToGRPC(testcase.input)
|
|
t.Logf("grpc: %v", gerr)
|
|
ferr := FromGRPC(gerr)
|
|
t.Logf("recovered: %v", ferr)
|
|
|
|
if !errors.Is(ferr, testcase.cause) {
|
|
t.Fatalf("unexpected cause: !errors.Is(%v, %v)", ferr, testcase.cause)
|
|
}
|
|
|
|
expected := testcase.str
|
|
if expected == "" {
|
|
expected = testcase.cause.Error()
|
|
}
|
|
if ferr.Error() != expected {
|
|
t.Fatalf("unexpected string: %q != %q", ferr.Error(), expected)
|
|
}
|
|
})
|
|
}
|
|
|
|
}
|