commit 0583f469c89191307da0058b73af6bea7fb93690
author xiejiajun <xiejiajun02@163.con> Fri Mar 19 01:27:46 2021 +0800
committer xiejiajun <xiejiajun02@163.con> Fri Mar 19 01:27:46 2021 +0800
tree db1445754bc5eb6f320a8dd4c9009098dd62191b
parent 3afacb4746b5098302c6a4bb87f3c33329f4b9bb

readwriter_test ci failed fix

remoting/getty/readwriter_test.go

diff --git a/remoting/getty/readwriter_test.go b/remoting/getty/readwriter_test.go
index 8223196..0bdaf68 100644
--- a/remoting/getty/readwriter_test.go
+++ b/remoting/getty/readwriter_test.go
@@ -41,11 +41,11 @@
 
 func testDecodeTCPPackage(t *testing.T, svr *Server, client *Client) {
 	request := remoting.NewRequest("2.0.2")
-	up := &UserProvider{}
-	invocation := createInvocation("GetUser", nil, nil, []interface{}{[]interface{}{"1", "username"}},
+	up := &AdminProvider{}
+	invocation := createInvocation("GetAdmin", nil, nil, []interface{}{[]interface{}{"1", "username"}},
 		[]reflect.Value{reflect.ValueOf([]interface{}{"1", "username"}), reflect.ValueOf(up)})
-	attachment := map[string]string{INTERFACE_KEY: "com.dubbogo.user.UserProvider",
-		PATH_KEY:    "UserProvider",
+	attachment := map[string]string{INTERFACE_KEY: "com.ikurento.user.AdminProvider",
+		PATH_KEY:    "AdminProvider",
 		VERSION_KEY: "1.0.0",
 	}
 	setAttachment(invocation, attachment)
@@ -76,9 +76,9 @@
 	hessian.RegisterPOJO(&User{})
 	remoting.RegistryCodec("dubbo", &DubboTestCodec{})
 
-	methods, err := common.ServiceMap.Register("com.dubbogo.user.UserProvider", "dubbo", "", "", &UserProvider{})
+	methods, err := common.ServiceMap.Register("com.ikurento.user.AdminProvider", "dubbo", "", "", &AdminProvider{})
 	assert.NoError(t, err)
-	assert.Equal(t, "GetBigPkg,GetUser,GetUser0,GetUser1,GetUser2,GetUser3,GetUser4,GetUser5,GetUser6", methods)
+	assert.Equal(t, "GetAdmin", methods)
 
 	// config
 	SetClientConf(ClientConfig{
@@ -122,15 +122,15 @@
 		}})
 	assert.NoError(t, srvConf.CheckValidity())
 
-	url, err := common.NewURL("dubbo://127.0.0.1:20061/com.dubbogo.user.UserProvider?anyhost=true&" +
+	url, err := common.NewURL("dubbo://127.0.0.1:20061/com.ikurento.user.AdminProvider?anyhost=true&" +
 		"application=BDTService&category=providers&default.timeout=10000&dubbo=dubbo-provider-golang-1.0.0&" +
-		"environment=dev&interface=com.ikurento.user.UserProvider&ip=127.0.0.1&methods=GetUser%2C&" +
+		"environment=dev&interface=com.ikurento.user.AdminProvider&ip=127.0.0.1&methods=GetAdmin%2C&" +
 		"module=dubbogo+user-info+server&org=ikurento.com&owner=ZX&pid=1447&revision=0.0.1&" +
-		"side=provider&timeout=3000&timestamp=1556509797245&bean.name=UserProvider")
+		"side=provider&timeout=3000&timestamp=1556509797245&bean.name=AdminProvider")
 	assert.NoError(t, err)
 	// init server
-	userProvider := &UserProvider{}
-	_, err = common.ServiceMap.Register("", url.Protocol, "", "0.0.1", userProvider)
+	adminProvider := &AdminProvider{}
+	_, err = common.ServiceMap.Register("com.ikurento.user.AdminProvider", url.Protocol, "", "0.0.1", adminProvider)
 	assert.NoError(t, err)
 	invoker := &proxy_factory.ProxyInvoker{
 		BaseInvoker: *protocol.NewBaseInvoker(url),
@@ -152,3 +152,18 @@
 
 	return server, url
 }
+
+type (
+	AdminProvider struct {
+	}
+)
+
+func (u *AdminProvider) GetAdmin(ctx context.Context, req []interface{}, rsp *User) error {
+	rsp.Id = req[0].(string)
+	rsp.Name = req[1].(string)
+	return nil
+}
+
+func (u *AdminProvider) Reference() string {
+	return "AdminProvider"
+}