1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
package testhelper
import (
"context"
"testing"
"github.com/golang/protobuf/proto"
"github.com/stretchr/testify/require"
"google.golang.org/grpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/metadata"
"google.golang.org/grpc/status"
)
// SetCtxGrpcMethod will set the gRPC context value for the proper key
// responsible for an RPC full method name. This directly corresponds to the
// gRPC function responsible for extracting the method:
// https://godoc.org/google.golang.org/grpc#Method
func SetCtxGrpcMethod(ctx context.Context, method string) context.Context {
return grpc.NewContextWithServerTransportStream(ctx, mockServerTransportStream{method})
}
type mockServerTransportStream struct {
method string
}
func (msts mockServerTransportStream) Method() string { return msts.method }
func (mockServerTransportStream) SetHeader(md metadata.MD) error { return nil }
func (mockServerTransportStream) SendHeader(md metadata.MD) error { return nil }
func (mockServerTransportStream) SetTrailer(md metadata.MD) error { return nil }
// RequireGrpcError asserts the passed err is of the same code as expectedCode.
func RequireGrpcError(t testing.TB, err error, expectedCode codes.Code) {
t.Helper()
if err == nil {
t.Fatal("Expected an error, got nil")
}
// Check that the code matches
status, _ := status.FromError(err)
if code := status.Code(); code != expectedCode {
t.Fatalf("Expected an error with code %v, got %v. The error was %q", expectedCode, code, err.Error())
}
}
func GrpcErrorHasMessage(grpcError error, msg string) bool {
status, ok := status.FromError(grpcError)
if !ok {
return false
}
return status.Message() == msg
}
// MergeOutgoingMetadata merges provided metadata-s and returns context with resulting value.
func MergeOutgoingMetadata(ctx context.Context, md ...metadata.MD) context.Context {
ctxmd, ok := metadata.FromOutgoingContext(ctx)
if !ok {
return metadata.NewOutgoingContext(ctx, metadata.Join(md...))
}
return metadata.NewOutgoingContext(ctx, metadata.Join(append(md, ctxmd)...))
}
// MergeIncomingMetadata merges provided metadata-s and returns context with resulting value.
func MergeIncomingMetadata(ctx context.Context, md ...metadata.MD) context.Context {
ctxmd, ok := metadata.FromIncomingContext(ctx)
if !ok {
return metadata.NewIncomingContext(ctx, metadata.Join(md...))
}
return metadata.NewIncomingContext(ctx, metadata.Join(append(md, ctxmd)...))
}
func ProtoEqual(t testing.TB, expected proto.Message, actual proto.Message) {
require.True(t, proto.Equal(expected, actual), "proto messages not equal\nexpected: %v\ngot: %v", expected, actual)
}
|
