Testing gRPC Services

func TestGetUser(t *testing.T) {
    s := &userServer{repo: newFakeRepo()}
    res, err := s.GetUser(context.Background(), &userv1.GetUserRequest{Id: "u1"})
    require.NoError(t, err)
    require.Equal(t, "Ada", res.Name)
}

import "google.golang.org/grpc/test/bufconn"
lis := bufconn.Listen(1024 * 1024)
srv := grpc.NewServer()
userv1.RegisterUserServiceServer(srv, &userServer{})
go srv.Serve(lis)
conn, _ := grpc.NewClient("passthrough:///bufnet",
    grpc.WithContextDialer(func(_ context.Context, _ string) (net.Conn, error) { return lis.Dial() }),
    grpc.WithTransportCredentials(insecure.NewCredentials()),
)

mockgen -source=gen/user/v1/user_grpc.pb.go -destination=mocks/user_mock.go

stream, _ := client.ListUsers(ctx, &userv1.ListUsersRequest{})
var got []*userv1.User
for {
    u, err := stream.Recv()
    if errors.Is(err, io.EOF) { break }
    require.NoError(t, err)
    got = append(got, u)
}
require.Len(t, got, 3)