diff --git a/test/src/test/java/com/alibaba/nacos/test/config/ConfigBeta_ITCase.java b/test/src/test/java/com/alibaba/nacos/test/config/ConfigBeta_ITCase.java new file mode 100644 index 000000000..18278f9a5 --- /dev/null +++ b/test/src/test/java/com/alibaba/nacos/test/config/ConfigBeta_ITCase.java @@ -0,0 +1,384 @@ +/* + * Copyright 1999-2018 Alibaba Group Holding Ltd. + * + * Licensed 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 com.alibaba.nacos.test.config; + +import java.net.URL; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import com.alibaba.fastjson.JSONObject; +import com.alibaba.nacos.api.NacosFactory; +import com.alibaba.nacos.api.PropertyKeyConst; +import com.alibaba.nacos.api.config.ConfigService; +import com.alibaba.nacos.api.config.listener.Listener; +import com.alibaba.nacos.api.exception.NacosException; +import com.alibaba.nacos.config.server.Config; +import com.alibaba.nacos.naming.misc.HttpClient.HttpResult; +import com.alibaba.nacos.test.naming.NamingBase; +import com.alibaba.nacos.test.naming.Params; + +import org.junit.Assert; +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.boot.test.web.client.TestRestTemplate; +import org.springframework.boot.web.server.LocalServerPort; +import org.springframework.http.HttpEntity; +import org.springframework.http.HttpHeaders; +import org.springframework.http.ResponseEntity; +import org.springframework.http.HttpMethod; +import org.springframework.http.ResponseEntity.HeadersBuilder; +import org.springframework.test.context.junit4.SpringRunner; +import org.springframework.util.MultiValueMap; +import org.springframework.web.util.UriComponentsBuilder; + +/** + * @author xiaochun.xxc + * @date 2019-07-03 + **/ +@RunWith(SpringRunner.class) +@SpringBootTest(classes = Config.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT) +public class ConfigBeta_ITCase { + + @LocalServerPort + private int port; + + private String url; + + private ConfigService configService; + + @Autowired + private TestRestTemplate restTemplate; + + static final String CONFIG_CONTROLLER_PATH = "/nacos/v1/cs"; + + String dataId = "com.dungu.test"; + String group = "default"; + String tenant = "dungu"; + String content = "test"; + String appName = "nacos"; + + @Before + public void init() throws NacosException { + url = String.format("http://localhost:%d", port); + } + + /** + * @TCDescription : 正常发布Beta配置 + * @TestStep : + * @ExpectResult : + */ + @Test + public void publishBetaConfig() throws Exception { + HttpHeaders headers = new HttpHeaders(); + headers.add("betaIps", "127.0.0.1,127.0.0.2"); + + ResponseEntity response = request(CONFIG_CONTROLLER_PATH + "/configs", headers, + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .appendParam("content", content) + .appendParam("config_tags", "") + .appendParam("appName", appName) + .done(), + String.class, + HttpMethod.POST); + Assert.assertTrue(response.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("true", response.getBody()); + } + + /** + * @TCDescription : 必选content未设置的发布Beta配置 + * @TestStep : + * @ExpectResult : + */ + @Test + public void publishBetaConfig_no_content() throws Exception { + HttpHeaders headers = new HttpHeaders(); + headers.add("betaIps", "127.0.0.1,127.0.0.2"); + + ResponseEntity response = request(CONFIG_CONTROLLER_PATH + "/configs", headers, + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .appendParam("config_tags", "") + .appendParam("appName", appName) + .done(), + String.class, + HttpMethod.POST); + Assert.assertFalse(response.getStatusCode().is2xxSuccessful()); + } + + /** + * @TCDescription : 可选参数betaIps不存在时，发布Beta配置应该不成功。 + * @TestStep : + * @ExpectResult : + */ + @Test + public void publishBetaConfig_noBetaIps_beta() throws Exception { + HttpHeaders headers = new HttpHeaders(); //不存在betaIps + + ResponseEntity response = request(CONFIG_CONTROLLER_PATH + "/configs", headers, + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .appendParam("content", content) + .appendParam("config_tags", "") + .appendParam("appName", appName) + .done(), + String.class, + HttpMethod.POST); + Assert.assertTrue(response.getStatusCode().is2xxSuccessful()); + System.out.println(response.getBody()); + Assert.assertEquals("true", response.getBody()); + + ResponseEntity response1 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=true", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.GET); + Assert.assertTrue(response1.getStatusCode().is2xxSuccessful()); + Assert.assertEquals(null, JSONObject.parseObject(response1.getBody()).getString("data")); + } + + /** + * @TCDescription : 可选参数betaIps不存在时，发布Beta配置应该不成功。 + * @TestStep : + * @ExpectResult : + */ + @Test + public void publishBetaConfig_noBetaIps() throws Exception { + HttpHeaders headers = new HttpHeaders(); //不存在betaIps + + ResponseEntity response = request(CONFIG_CONTROLLER_PATH + "/configs", headers, + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .appendParam("content", content) + .appendParam("config_tags", "") + .appendParam("appName", appName) + .done(), + String.class, + HttpMethod.POST); + Assert.assertTrue(response.getStatusCode().is2xxSuccessful()); + System.out.println(response.getBody()); + Assert.assertEquals("true", response.getBody()); + + ResponseEntity response1 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=false", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.GET); + Assert.assertTrue(response1.getStatusCode().is2xxSuccessful()); + System.out.println(response1.getBody()); + Assert.assertEquals(content, response1.getBody()); + } + + /** + * @TCDescription : 正常获取Beta配置 + * @TestStep : + * @ExpectResult : + */ + @Test + public void getBetaConfig() throws Exception { + HttpHeaders headers = new HttpHeaders(); + headers.add("betaIps", "127.0.0.1,127.0.0.2"); + + ResponseEntity response = request(CONFIG_CONTROLLER_PATH + "/configs", headers, + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .appendParam("content", content) + .appendParam("config_tags", "") + .appendParam("appName", appName) + .done(), + String.class, + HttpMethod.POST); + Assert.assertTrue(response.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("true", response.getBody()); + + ResponseEntity response1 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=true", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.GET); + Assert.assertTrue(response1.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("com.dungu.test", JSONObject.parseObject(response1.getBody()).getJSONObject("data").getString("dataId")); + } + + /** + * @TCDescription : 正常删除Beta配置 + * @TestStep : + * @ExpectResult : + */ + @Test + public void deleteBetaConfig() throws Exception { + + HttpHeaders headers = new HttpHeaders(); + headers.add("betaIps", "127.0.0.1,127.0.0.2"); + + ResponseEntity response = request(CONFIG_CONTROLLER_PATH + "/configs", headers, + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .appendParam("content", content) + .appendParam("config_tags", "") + .appendParam("appName", appName) + .done(), + String.class, + HttpMethod.POST); + Assert.assertTrue(response.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("true", response.getBody()); + + ResponseEntity response1 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=true", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.GET); + Assert.assertTrue(response1.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("com.dungu.test", JSONObject.parseObject(response1.getBody()).getJSONObject("data").getString("dataId")); + + ResponseEntity response2 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=true", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.DELETE); + Assert.assertTrue(response2.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("true", JSONObject.parseObject(response2.getBody()).getString("data")); + + ResponseEntity response3 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=true", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.GET); + Assert.assertTrue(response3.getStatusCode().is2xxSuccessful()); + Assert.assertEquals(null, JSONObject.parseObject(response3.getBody()).getString("data")); + } + + + /** + * @TCDescription : beta=false时，删除Beta配置 + * @TestStep : + * @ExpectResult : + */ + @Test + public void deleteBetaConfig_delete_beta_false() throws Exception { + + HttpHeaders headers = new HttpHeaders(); + headers.add("betaIps", "127.0.0.1,127.0.0.2"); + + ResponseEntity response = request(CONFIG_CONTROLLER_PATH + "/configs", headers, + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .appendParam("content", content) + .appendParam("config_tags", "") + .appendParam("appName", appName) + .done(), + String.class, + HttpMethod.POST); + Assert.assertTrue(response.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("true", response.getBody()); + + ResponseEntity response1 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=true", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.GET); + Assert.assertTrue(response1.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("com.dungu.test", JSONObject.parseObject(response1.getBody()).getJSONObject("data").getString("dataId")); + + ResponseEntity response2 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=false", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.DELETE); + Assert.assertTrue(response2.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("true", response2.getBody()); + + ResponseEntity response3 = request(CONFIG_CONTROLLER_PATH + "/configs?beta=true", + Params.newParams() + .appendParam("dataId", dataId) + .appendParam("group", group) + .appendParam("tenant", tenant) + .done(), + String.class, + HttpMethod.GET); + Assert.assertTrue(response3.getStatusCode().is2xxSuccessful()); + Assert.assertEquals("com.dungu.test", JSONObject.parseObject(response3.getBody()).getJSONObject("data").getString("dataId")); + } + + ResponseEntity request(String path, MultiValueMap params, Class clazz, HttpMethod httpMethod) { + + HttpHeaders headers = new HttpHeaders(); + + HttpEntity entity = new HttpEntity(headers); + + UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(this.url.toString() + path) + .queryParams(params); + + return this.restTemplate.exchange( + builder.toUriString(), httpMethod, entity, clazz); + } + + ResponseEntity request(String path, HttpHeaders headers, MultiValueMap params, Class clazz, HttpMethod httpMethod) { + + HttpEntity entity = new HttpEntity(headers); + + UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(this.url.toString() + path) + .queryParams(params); + + return this.restTemplate.exchange( + builder.toUriString(), httpMethod, entity, clazz); + } + +} diff --git a/test/src/test/java/com/alibaba/nacos/test/naming/RegisterInstance_ITCase.java b/test/src/test/java/com/alibaba/nacos/test/naming/RegisterInstance_ITCase.java index e453e9d8b..e46618fcc 100644 --- a/test/src/test/java/com/alibaba/nacos/test/naming/RegisterInstance_ITCase.java +++ b/test/src/test/java/com/alibaba/nacos/test/naming/RegisterInstance_ITCase.java @@ -120,7 +120,7 @@ public class RegisterInstance_ITCase { String serviceName = randomDomainName(); - System.err.println(serviceName); + System.out.println(serviceName); naming.registerInstance(serviceName, TEST_IP_4_DOM_1, TEST_PORT, TEST_NEW_CLUSTER_4_DOM_1); @@ -128,7 +128,7 @@ public class RegisterInstance_ITCase { List instances = naming.getAllInstances(serviceName); - Assert.assertEquals(instances.size(), 1); + Assert.assertEquals(1, instances.size()); Assert.assertTrue(instances.get(0).getInstanceId().contains(serviceName)); //Assert.assertEquals(instances2.get(0).getService().getName(), serviceName); Assert.assertEquals(instances.get(0).getIp(), TEST_IP_4_DOM_1);