Function TestEncodeDecodeStatus

extgrpc/ext_grpc_test.go:90–219

(t *testing.T)

}

func TestEncodeDecodeStatus(t *testing.T) {
	testcases := []struct {
		desc          string
		makeStatus    func(*testing.T, codes.Code, string, []proto.Message) statusIface
		fromError     func(err error) statusIface
		expectDetails []interface{} // nil elements signify errors
	}{
		{
			desc: "gogo status",
			makeStatus: func(t *testing.T, code codes.Code, msg string, details []proto.Message) statusIface {
				s, err := gogostatus.New(code, msg).WithDetails(details...)
				require.NoError(t, err)
				return s
			},
			fromError: func(err error) statusIface {
				return gogostatus.Convert(err)
			},
			expectDetails: []interface{}{
				nil, // Protobuf decode fails
				&errorspb.StringsPayload{Details: []string{"foo", "bar"}}, // gogoproto succeeds
				nil, // dummy decode fails
			},
		},
		{
			desc: "grpc status",
			makeStatus: func(t *testing.T, code codes.Code, msg string, details []proto.Message) statusIface {
				s := grpcstatus.New(code, msg)
				for _, detail := range details {
					var err error
					s, err = s.WithDetails(protoiface.MessageV1(detail))
					require.NoError(t, err)
				}
				return s
			},
			fromError: func(err error) statusIface {
				return grpcstatus.Convert(err)
			},
			expectDetails: []interface{}{
				// Protobuf succeeds
				func() interface{} {
					var st interface{} = grpcstatus.New(codes.Internal, "status").Proto()
					res := reflect.New(reflect.TypeOf(st).Elem()).Interface()
					copyPublicFields(res, st)
					return res
				}(),
				nil, // gogoproto decode fails
				nil, // dummy decode fails
			},
		},
	}
	for _, tc := range testcases {
		tc := tc
		t.Run(tc.desc, func(t *testing.T) {
			ctx := context.Background()

			// Create a Status, using statusIface to support gRPC and gogo variants.
			status := tc.makeStatus(t, codes.NotFound, "message", []proto.Message{
				grpcstatus.New(codes.Internal, "status").Proto(),          // standard Protobuf