bbc3b7040b
* util/wrapper: Add Static Client wrapper
* util/wrapper/static: pass address to stream too
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
* add static client wrapper tests
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
* server: fix error message spaces between words
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
* server/{rpc,grpc}: replace log.Error with log.Errorf
* server/grpc: fix log typo
* server/rpc: fix log typo
Co-authored-by: Vasiliy Tolstov <v.tolstov@unistack.org>
73 lines
1.7 KiB
Go
73 lines
1.7 KiB
Go
package wrapper_test
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/micro/go-micro/v2/broker"
|
|
bmemory "github.com/micro/go-micro/v2/broker/memory"
|
|
"github.com/micro/go-micro/v2/client"
|
|
rmemory "github.com/micro/go-micro/v2/registry/memory"
|
|
"github.com/micro/go-micro/v2/server"
|
|
tmemory "github.com/micro/go-micro/v2/transport/memory"
|
|
wrapper "github.com/micro/go-micro/v2/util/wrapper"
|
|
)
|
|
|
|
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 TestStaticClientWrapper(t *testing.T) {
|
|
var err error
|
|
|
|
req := client.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()
|
|
|
|
srv := server.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 := client.NewClient(
|
|
client.Registry(reg),
|
|
client.Broker(brk),
|
|
client.Transport(tr),
|
|
)
|
|
|
|
w1 := wrapper.StaticClient("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 := wrapper.StaticClient(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)
|
|
}
|
|
}
|