85 lines
2.0 KiB
Go
85 lines
2.0 KiB
Go
|
// +build ignore
|
||
|
|
|
||
|
|
package client_test
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"testing"
|
||
|
|
|
||
|
|
"github.com/unistack-org/micro/v3/broker"
|
||
|
|
bmemory "github.com/unistack-org/micro/v3/broker/memory"
|
||
|
|
"github.com/unistack-org/micro/v3/client"
|
||
|
|
"github.com/unistack-org/micro/v3/client/grpc"
|
||
|
|
tmemory "github.com/unistack-org/micro/v3/network/transport/memory"
|
||
|
|
rmemory "github.com/unistack-org/micro/v3/registry/memory"
|
||
|
|
"github.com/unistack-org/micro/v3/router"
|
||
|
|
rtreg "github.com/unistack-org/micro/v3/router/registry"
|
||
|
|
"github.com/unistack-org/micro/v3/server"
|
||
|
|
grpcsrv "github.com/unistack-org/micro/v3/server/grpc"
|
||
|
|
cw "github.com/unistack-org/micro/v3/util/client"
|
||
|
|
)
|
||
|
|
|
||
|
|
type TestFoo struct {
|
||
|
|
}
|
||
|
|
|
||
|
|
type TestReq struct{}
|
||
|
|
|
||
|
|
type TestRsp struct {
|
||
|
|
Data string
|
||
|
|
}
|
||
|
|
|
||
|
|
func (h *TestFoo) Bar(ctx context.Context, req *TestReq, rsp *TestRsp) error {
|
||
|
|
rsp.Data = "pass"
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestStaticClient(t *testing.T) {
|
||
|
|
var err error
|
||
|
|
|
||
|
|
req := grpc.NewClient().NewRequest(
|
||
|
|
"go.micro.service.foo",
|
||
|
|
"TestFoo.Bar",
|
||
|
|
&TestReq{},
|
||
|
|
client.WithContentType("application/json"),
|
||
|
|
)
|
||
|
|
rsp := &TestRsp{}
|
||
|
|
|
||
|
|
reg := rmemory.NewRegistry()
|
||
|
|
brk := bmemory.NewBroker(broker.Registry(reg))
|
||
|
|
tr := tmemory.NewTransport()
|
||
|
|
rtr := rtreg.NewRouter(router.Registry(reg))
|
||
|
|
|
||
|
|
srv := grpcsrv.NewServer(
|
||
|
|
server.Broker(brk),
|
||
|
|
server.Registry(reg),
|
||
|
|
server.Name("go.micro.service.foo"),
|
||
|
|
server.Address("127.0.0.1:0"),
|
||
|
|
server.Transport(tr),
|
||
|
|
)
|
||
|
|
if err = srv.Handle(srv.NewHandler(&TestFoo{})); err != nil {
|
||
|
|
t.Fatal(err)
|
||
|
|
}
|
||
|
|
|
||
|
|
if err = srv.Start(); err != nil {
|
||
|
|
t.Fatal(err)
|
||
|
|
}
|
||
|
|
|
||
|
|
cli := grpc.NewClient(
|
||
|
|
client.Router(rtr),
|
||
|
|
client.Broker(brk),
|
||
|
|
client.Transport(tr),
|
||
|
|
)
|
||
|
|
|
||
|
|
w1 := cw.Static("xxx_localhost:12345", cli)
|
||
|
|
if err = w1.Call(context.TODO(), req, nil); err == nil {
|
||
|
|
t.Fatal("address xxx_#localhost:12345 must not exists and call must be failed")
|
||
|
|
}
|
||
|
|
|
||
|
|
w2 := cw.Static(srv.Options().Address, cli)
|
||
|
|
if err = w2.Call(context.TODO(), req, rsp); err != nil {
|
||
|
|
t.Fatal(err)
|
||
|
|
} else if rsp.Data != "pass" {
|
||
|
|
t.Fatalf("something wrong with response: %#+v", rsp)
|
||
|
|
}
|
||
|
|
}
|