add batch config testcase
This commit is contained in:
xiaochun.xxc
parent
402b31adb6
commit
4f613691ae
@ -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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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<String> 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"));
|
||||
}
|
||||
|
||||
<T> ResponseEntity<T> request(String path, MultiValueMap<String, String> params, Class<T> clazz, HttpMethod httpMethod) {
|
||||
|
||||
HttpHeaders headers = new HttpHeaders();
|
||||
|
||||
HttpEntity<?> entity = new HttpEntity<T>(headers);
|
||||
|
||||
UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(this.url.toString() + path)
|
||||
.queryParams(params);
|
||||
|
||||
return this.restTemplate.exchange(
|
||||
builder.toUriString(), httpMethod, entity, clazz);
|
||||
}
|
||||
|
||||
<T> ResponseEntity<T> request(String path, HttpHeaders headers, MultiValueMap<String, String> params, Class<T> clazz, HttpMethod httpMethod) {
|
||||
|
||||
HttpEntity<?> entity = new HttpEntity<T>(headers);
|
||||
|
||||
UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(this.url.toString() + path)
|
||||
.queryParams(params);
|
||||
|
||||
return this.restTemplate.exchange(
|
||||
builder.toUriString(), httpMethod, entity, clazz);
|
||||
}
|
||||
|
||||
}
|
||||
@ -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<Instance> 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);
|
||||
|
||||
Loading…
Reference in New Issue
Block a user