2020-09-29 11:15:29 +03:00
|
|
|
package grpc_test
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"fmt"
|
|
|
|
"io"
|
|
|
|
"net"
|
|
|
|
"testing"
|
|
|
|
"time"
|
|
|
|
|
2021-01-16 02:49:58 +03:00
|
|
|
grpc "github.com/unistack-org/micro-client-grpc/v3"
|
|
|
|
protocodec "github.com/unistack-org/micro-codec-proto/v3"
|
2021-01-29 16:47:26 +03:00
|
|
|
regRouter "github.com/unistack-org/micro-router-register/v3"
|
2020-09-29 11:15:29 +03:00
|
|
|
pb "github.com/unistack-org/micro-tests/client/grpc/proto"
|
|
|
|
"github.com/unistack-org/micro/v3/client"
|
|
|
|
"github.com/unistack-org/micro/v3/errors"
|
2021-01-29 16:47:26 +03:00
|
|
|
"github.com/unistack-org/micro/v3/register"
|
2020-09-29 11:15:29 +03:00
|
|
|
"github.com/unistack-org/micro/v3/router"
|
|
|
|
pgrpc "google.golang.org/grpc"
|
|
|
|
"google.golang.org/grpc/codes"
|
|
|
|
"google.golang.org/grpc/status"
|
|
|
|
)
|
|
|
|
|
|
|
|
type testServer struct {
|
|
|
|
pb.UnimplementedTestServer
|
|
|
|
}
|
|
|
|
|
|
|
|
func (g *testServer) Call(ctx context.Context, in *pb.Request) (*pb.Response, error) {
|
|
|
|
if in.Name == "Error" {
|
|
|
|
return nil, &errors.Error{Id: "id", Code: 99, Detail: "detail"}
|
|
|
|
}
|
|
|
|
return &pb.Response{Msg: "Hello " + in.Name}, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (g *testServer) Stream(stream pb.Test_StreamServer) error {
|
|
|
|
rsp := &pb.Response{}
|
|
|
|
for {
|
|
|
|
req, err := stream.Recv()
|
|
|
|
if err != nil && err == io.EOF {
|
|
|
|
break
|
|
|
|
} else if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
rsp.Msg = req.Name
|
|
|
|
if err = stream.Send(rsp); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
time.Sleep(200 * time.Millisecond)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestGRPCClient(t *testing.T) {
|
2020-11-03 02:24:07 +03:00
|
|
|
ctx := context.Background()
|
2020-09-29 11:15:29 +03:00
|
|
|
l, err := net.Listen("tcp", "127.0.0.1:0")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("failed to listen: %v", err)
|
|
|
|
}
|
|
|
|
defer l.Close()
|
|
|
|
|
|
|
|
s := pgrpc.NewServer()
|
|
|
|
pb.RegisterTestServer(s, &testServer{})
|
|
|
|
|
|
|
|
go func() {
|
|
|
|
if err := s.Serve(l); err != nil {
|
|
|
|
t.Log(err)
|
|
|
|
}
|
|
|
|
}()
|
|
|
|
defer s.Stop()
|
|
|
|
|
2021-01-29 16:47:26 +03:00
|
|
|
// create mock register
|
2021-02-12 20:50:02 +03:00
|
|
|
r := register.NewRegister()
|
2020-09-29 11:15:29 +03:00
|
|
|
|
|
|
|
// register service
|
2021-01-29 16:47:26 +03:00
|
|
|
if err := r.Register(ctx, ®ister.Service{
|
2020-09-29 11:15:29 +03:00
|
|
|
Name: "helloworld",
|
|
|
|
Version: "test",
|
2021-01-29 16:47:26 +03:00
|
|
|
Nodes: []*register.Node{
|
2020-09-29 11:15:29 +03:00
|
|
|
{
|
|
|
|
Id: "test-1",
|
|
|
|
Address: l.Addr().String(),
|
|
|
|
Metadata: map[string]string{
|
|
|
|
"protocol": "grpc",
|
|
|
|
},
|
|
|
|
},
|
|
|
|
},
|
|
|
|
}); err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
// create router
|
2021-01-29 16:47:26 +03:00
|
|
|
rtr := regRouter.NewRouter(router.Register(r))
|
2020-09-29 11:15:29 +03:00
|
|
|
|
|
|
|
// create client
|
2020-11-26 08:57:54 +03:00
|
|
|
c := grpc.NewClient(client.Codec("application/grpc+proto", protocodec.NewCodec()), client.Router(rtr))
|
2020-09-29 11:15:29 +03:00
|
|
|
|
|
|
|
testMethods := []string{
|
|
|
|
"/helloworld.Test/Call",
|
|
|
|
"Test.Call",
|
|
|
|
}
|
|
|
|
|
|
|
|
for _, method := range testMethods {
|
|
|
|
req := c.NewRequest("helloworld", method, &pb.Request{
|
|
|
|
Name: "John",
|
|
|
|
})
|
|
|
|
|
|
|
|
rsp := pb.Response{}
|
|
|
|
|
|
|
|
err = c.Call(context.TODO(), req, &rsp)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
if rsp.Msg != "Hello John" {
|
|
|
|
t.Fatalf("Got unexpected response %v", rsp.Msg)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
for _, method := range testMethods {
|
|
|
|
req := c.NewRequest("helloworld", method, &pb.Request{
|
|
|
|
Name: "Error",
|
|
|
|
})
|
|
|
|
|
|
|
|
rsp := pb.Response{}
|
|
|
|
|
|
|
|
err = c.Call(context.TODO(), req, &rsp)
|
|
|
|
if err == nil {
|
|
|
|
t.Fatal("nil error received")
|
|
|
|
}
|
|
|
|
|
|
|
|
verr, ok := err.(*errors.Error)
|
|
|
|
if !ok {
|
|
|
|
t.Fatalf("invalid error received %#+v\n", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
if verr.Code != 99 && verr.Id != "id" && verr.Detail != "detail" {
|
|
|
|
t.Fatalf("invalid error received %#+v\n", verr)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)
|
|
|
|
defer cancel()
|
|
|
|
|
2021-04-10 01:32:25 +03:00
|
|
|
req := c.NewRequest("helloworld", "Test.Stream", &pb.Request{}, client.StreamingRequest(true))
|
2020-09-29 11:15:29 +03:00
|
|
|
stream, err := c.Stream(ctx, req)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
defer stream.Close()
|
|
|
|
|
|
|
|
go func() {
|
|
|
|
for i := 0; i < 5; i++ {
|
|
|
|
fmt.Printf("send to stream\n")
|
|
|
|
if err = stream.Send(&pb.Request{Name: "test name"}); err != nil {
|
|
|
|
t.Fatal(err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}()
|
|
|
|
|
|
|
|
rsp := &pb.Response{}
|
|
|
|
|
|
|
|
for i := 0; i < 5; i++ {
|
|
|
|
fmt.Printf("recv from stream\n")
|
|
|
|
if err = stream.Recv(rsp); err != nil {
|
|
|
|
st, ok := status.FromError(err)
|
|
|
|
if !ok {
|
|
|
|
t.Fatalf("%v", err)
|
|
|
|
}
|
|
|
|
if st.Code() != codes.DeadlineExceeded {
|
|
|
|
t.Fatalf("%v", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if rsp.Msg != "test name" {
|
|
|
|
t.Fatalf("invalid msg: %v", rsp)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|