readwriter_test ci failed fix

remoting/getty/readwriter_test.go

@@ -41,11 +41,11 @@ func TestTCPPackageHandle(t *testing.T) {
 
 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 @@ func getServer(t *testing.T) (*Server, *common.URL) {
 	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 @@ func getServer(t *testing.T) (*Server, *common.URL) {
 		}})
 	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 @@ func getServer(t *testing.T) (*Server, *common.URL) {
 
 	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"
+}