opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

interop: implement special_status_message interop test (#2241)

Browse Source 
fixes #2240
This commit is contained in:
Menghan Li
2018-07-30 13:33:50 -07:00
committed by GitHub
parent efcc5364b8
commit 8fbeaf87a6
2 changed files with 25 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
interop/client/client.go
View File

@ -64,6 +64,7 @@ var (
cancel_after_begin: cancellation after metadata has been sent but before payloads are sent; cancel_after_begin: cancellation after metadata has been sent but before payloads are sent;
cancel_after_first_response: cancellation after receiving 1st message from the server; cancel_after_first_response: cancellation after receiving 1st message from the server;
status_code_and_message: status code propagated back to client; status_code_and_message: status code propagated back to client;
special_status_message: Unicode and whitespace is correctly processed in status message;
custom_metadata: server will echo custom metadata; custom_metadata: server will echo custom metadata;
unimplemented_method: client attempts to call unimplemented method; unimplemented_method: client attempts to call unimplemented method;
unimplemented_service: client attempts to call unimplemented service.`) unimplemented_service: client attempts to call unimplemented service.`)
@ -193,6 +194,9 @@ func main() {
case "status_code_and_message": case "status_code_and_message":
interop.DoStatusCodeAndMessage(tc) interop.DoStatusCodeAndMessage(tc)
grpclog.Infoln("StatusCodeAndMessage done") grpclog.Infoln("StatusCodeAndMessage done")
case "special_status_message":
interop.DoSpecialStatusMessage(tc)
grpclog.Infoln("SpecialStatusMessage done")
case "custom_metadata": case "custom_metadata":
interop.DoCustomMetadata(tc) interop.DoCustomMetadata(tc)
grpclog.Infoln("CustomMetadata done") grpclog.Infoln("CustomMetadata done")

21
interop/test_utils.go
View File

@ -563,6 +563,27 @@ func DoStatusCodeAndMessage(tc testpb.TestServiceClient, args ...grpc.CallOption
} }
} }
// DoSpecialStatusMessage verifies Unicode and whitespace is correctly processed
// in status message.
func DoSpecialStatusMessage(tc testpb.TestServiceClient, args ...grpc.CallOption) {
const (
code int32 = 2
msg string = "\t\ntest with whitespace\r\nand Unicode BMP ☺ and non-BMP 😈\t\n"
)
expectedErr := status.Error(codes.Code(code), msg)
req := &testpb.SimpleRequest{
ResponseStatus: &testpb.EchoStatus{
Code: code,
Message: msg,
},
}
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
if _, err := tc.UnaryCall(ctx, req, args...); err == nil || err.Error() != expectedErr.Error() {
grpclog.Fatalf("%v.UnaryCall(_, %v) = _, %v, want _, %v", tc, req, err, expectedErr)
}
}
// DoUnimplementedService attempts to call a method from an unimplemented service. // DoUnimplementedService attempts to call a method from an unimplemented service.
func DoUnimplementedService(tc testpb.UnimplementedServiceClient) { func DoUnimplementedService(tc testpb.UnimplementedServiceClient) {
_, err := tc.UnimplementedCall(context.Background(), &testpb.Empty{}) _, err := tc.UnimplementedCall(context.Background(), &testpb.Empty{})