| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package nacos |
| |
| //import ( |
| // "math/rand" |
| // "strconv" |
| // "testing" |
| // "time" |
| //) |
| // |
| //import ( |
| // gxset "github.com/dubbogo/gost/container/set" |
| // "github.com/stretchr/testify/assert" |
| //) |
| // |
| //import ( |
| // "dubbo.apache.org/dubbo-go/v3/common/constant" |
| // "dubbo.apache.org/dubbo-go/v3/common/extension" |
| // "dubbo.apache.org/dubbo-go/v3/config" |
| // "dubbo.apache.org/dubbo-go/v3/metadata/mapping" |
| // "dubbo.apache.org/dubbo-go/v3/registry" |
| // "dubbo.apache.org/dubbo-go/v3/registry/event" |
| //) |
| // |
| //var testName = "test" |
| // |
| //func Test_newNacosServiceDiscovery(t *testing.T) { |
| // name := "nacos1" |
| // _, err := newNacosServiceDiscovery(name) |
| // |
| // // the ServiceDiscoveryConfig not found |
| // assert.NotNil(t, err) |
| // |
| // sdc := &config.ServiceDiscoveryConfig{ |
| // Protocol: "nacos", |
| // RemoteRef: "mock", |
| // } |
| // config.GetBaseConfig().ServiceDiscoveries[name] = sdc |
| // |
| // _, err = newNacosServiceDiscovery(name) |
| // |
| // // RemoteConfig not found |
| // assert.NotNil(t, err) |
| // |
| // config.GetBaseConfig().Remotes["mock"] = &config.RemoteConfig{ |
| // Address: "console.nacos.io:80", |
| // TimeoutStr: "10s", |
| // } |
| // |
| // res, err := newNacosServiceDiscovery(name) |
| // assert.Nil(t, err) |
| // assert.NotNil(t, res) |
| //} |
| // |
| //func TestNacosServiceDiscovery_CRUD(t *testing.T) { |
| // if !checkNacosServerAlive() { |
| // return |
| // } |
| // prepareData() |
| // |
| // extension.SetGlobalServiceNameMapping(func() mapping.ServiceNameMapping { |
| // return mapping.NewMockServiceNameMapping() |
| // }) |
| // |
| // rand.Seed(time.Now().Unix()) |
| // serviceName := "service-name" + strconv.Itoa(rand.Intn(10000)) |
| // id := "id" |
| // host := "host" |
| // port := 123 |
| // instance := ®istry.DefaultServiceInstance{ |
| // ID: id, |
| // ServiceName: serviceName, |
| // Host: host, |
| // Port: port, |
| // Enable: true, |
| // Healthy: true, |
| // Metadata: nil, |
| // } |
| // |
| // // clean data |
| // serviceDiscovery, err := extension.GetServiceDiscovery(constant.NACOS_KEY, testName) |
| // assert.Nil(t, err) |
| // |
| // // clean data for local test |
| // err = serviceDiscovery.Unregister(®istry.DefaultServiceInstance{ |
| // ID: id, |
| // ServiceName: serviceName, |
| // Host: host, |
| // Port: port, |
| // }) |
| // assert.Nil(t, err) |
| // |
| // err = serviceDiscovery.Register(instance) |
| // |
| // assert.Nil(t, err) |
| // |
| // // sometimes nacos may be failed to push update of instance, |
| // // so it need 10s to pull, we sleep 10 second to make sure instance has been update |
| // time.Sleep(5 * time.Second) |
| // page := serviceDiscovery.GetHealthyInstancesByPage(serviceName, 0, 10, true) |
| // assert.NotNil(t, page) |
| // assert.Equal(t, 0, page.GetOffset()) |
| // assert.Equal(t, 10, page.GetPageSize()) |
| // assert.Equal(t, 1, page.GetDataSize()) |
| // |
| // instance = page.GetData()[0].(*registry.DefaultServiceInstance) |
| // instance.ServiceName = serviceName |
| // assert.NotNil(t, instance) |
| // assert.Equal(t, id, instance.GetID()) |
| // assert.Equal(t, host, instance.GetHost()) |
| // assert.Equal(t, port, instance.GetPort()) |
| // // TODO: console.nacos.io has updated to nacos 2.0 and serviceName has changed in 2.0, so ignore temporarily. |
| // // assert.Equal(t, serviceName, instance.GetServiceName()) |
| // assert.Equal(t, 0, len(instance.GetMetadata())) |
| // |
| // instance.Metadata["a"] = "b" |
| // err = serviceDiscovery.Update(instance) |
| // assert.Nil(t, err) |
| // |
| // time.Sleep(5 * time.Second) |
| // pageMap := serviceDiscovery.GetRequestInstances([]string{serviceName}, 0, 1) |
| // assert.Equal(t, 1, len(pageMap)) |
| // |
| // page = pageMap[serviceName] |
| // assert.NotNil(t, page) |
| // assert.Equal(t, 1, len(page.GetData())) |
| // |
| // instance = page.GetData()[0].(*registry.DefaultServiceInstance) |
| // v, ok := instance.Metadata["a"] |
| // assert.True(t, ok) |
| // assert.Equal(t, "b", v) |
| // |
| // // test dispatcher event |
| // hs := gxset.NewSet() |
| // hs.Add(serviceName) |
| // // test AddListener |
| // err = serviceDiscovery.AddListener(event.NewServiceInstancesChangedListener(hs)) |
| // assert.Nil(t, err) |
| //} |
| // |
| //func TestNacosServiceDiscovery_GetDefaultPageSize(t *testing.T) { |
| // prepareData() |
| // serviceDiscovery, _ := extension.GetServiceDiscovery(constant.NACOS_KEY, testName) |
| // assert.Equal(t, registry.DefaultPageSize, serviceDiscovery.GetDefaultPageSize()) |
| //} |
| // |
| //func TestNacosServiceDiscovery_Destroy(t *testing.T) { |
| // prepareData() |
| // serviceDiscovery, err := extension.GetServiceDiscovery(constant.NACOS_KEY, testName) |
| // assert.Nil(t, err) |
| // assert.NotNil(t, serviceDiscovery) |
| // err = serviceDiscovery.Destroy() |
| // assert.Nil(t, err) |
| //} |
| // |
| //func prepareData() { |
| // config.GetBaseConfig().ServiceDiscoveries[testName] = &config.ServiceDiscoveryConfig{ |
| // Protocol: "nacos", |
| // RemoteRef: testName, |
| // } |
| // |
| // config.GetBaseConfig().Remotes[testName] = &config.RemoteConfig{ |
| // Address: "console.nacos.io:80", |
| // TimeoutStr: "10s", |
| // } |
| //} |
