clients/service-center-client/src/test/java/org/apache/servicecomb/service/center/client/ServiceCenterClientTest.java - servicecomb-java-chassis - Git at Google

 /*
  * 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 org.apache.servicecomb.service.center.client;

 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;

 import org.apache.servicecomb.http.client.common.HttpResponse;
 import org.apache.servicecomb.service.center.client.model.HeartbeatsRequest;
 import org.apache.servicecomb.service.center.client.model.InstancesRequest;
 import org.apache.servicecomb.service.center.client.model.Microservice;
 import org.apache.servicecomb.service.center.client.model.MicroserviceInstance;
 import org.apache.servicecomb.service.center.client.model.MicroserviceInstanceStatus;
 import org.apache.servicecomb.service.center.client.model.MicroserviceInstancesResponse;
 import org.apache.servicecomb.service.center.client.model.MicroservicesResponse;
 import org.apache.servicecomb.service.center.client.model.RegisteredMicroserviceInstanceResponse;
 import org.apache.servicecomb.service.center.client.model.RegisteredMicroserviceResponse;
 import org.apache.servicecomb.service.center.client.model.SchemaInfo;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 import org.mockito.Mockito;

 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.SerializationFeature;

 /**
  * Created by   on 2019/10/17.
  */
 public class ServiceCenterClientTest {

   @Test
   public void TestGetServiceCenterInstances() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     String responseString = "{\n"
         + "  \"instances\": [\n"
         + "    {\n"
         + "      \"instanceId\": \"111111\",\n"
         + "      \"serviceId\": \"222222\",\n"
         + "      \"version\": \"1.0\",\n"
         + "      \"hostName\": \"Test\",\n"
         + "      \"endpoints\": [\n"
         + "        \"string\"\n"
         + "      ],\n"
         + "      \"status\": \"UP\",\n"
         + "      \"properties\": {\n"
         + "        \"additionalProp1\": \"string\",\n"
         + "        \"additionalProp2\": \"string\",\n"
         + "        \"additionalProp3\": \"string\"\n"
         + "      },\n"
         + "      \"healthCheck\": {\n"
         + "        \"mode\": \"push\",\n"
         + "        \"port\": \"0\",\n"
         + "        \"interval\": \"0\",\n"
         + "        \"times\": \"0\"\n"
         + "      },\n"
         + "      \"dataCenterInfo\": {\n"
         + "        \"name\": \"string\",\n"
         + "        \"region\": \"string\",\n"
         + "        \"availableZone\": \"string\"\n"
         + "      },\n"
         + "      \"timestamp\": \"333333\",\n"
         + "      \"modTimestamp\": \"4444444\"\n"
         + "    }\n"
         + "  ]\n"
         + "}";

     httpResponse.setContent(responseString);

     Mockito.when(serviceCenterRawClient.getHttpRequest("/registry/health", null, null)).thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     MicroserviceInstancesResponse serviceCenterInstances = serviceCenterClient.getServiceCenterInstances();

     Assertions.assertNotNull(serviceCenterInstances);
     Assertions.assertEquals(1, serviceCenterInstances.getInstances().size());
     Assertions.assertEquals("111111", serviceCenterInstances.getInstances().get(0).getInstanceId());
     Assertions.assertEquals("222222", serviceCenterInstances.getInstances().get(0).getServiceId());
   }

   @Test
   public void TestRegistryService() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     httpResponse.setContent("{\"serviceId\": \"111111\"}");

     Microservice microservice = new Microservice();
     microservice.setServiceName("Test");
     ObjectMapper objectMapper = new ObjectMapper();
     objectMapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);

     Mockito.when(serviceCenterRawClient
         .postHttpRequest("/registry/microservices", null, objectMapper.writeValueAsString(microservice)))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     RegisteredMicroserviceResponse actualResponse = serviceCenterClient.registerMicroservice(microservice);

     Assertions.assertNotNull(actualResponse);
     Assertions.assertEquals("111111", actualResponse.getServiceId());
   }

   @Test
   public void TestGetServiceMessage() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     String responseString = "{\n"
         + "  \"service\": {\n"
         + "      \"serviceId\": \"111111\",\n"
         + "      \"environment\": \"string\",\n"
         + "      \"appId\": \"string\",\n"
         + "      \"serviceName\": \"string\",\n"
         + "      \"version\": \"string\",\n"
         + "      \"description\": \"string\",\n"
         + "      \"level\": \"string\",\n"
         + "      \"registerBy\": \"string\",\n"
         + "      \"schemas\": [\n"
         + "        \"string\"\n"
         + "      ],\n"
         + "      \"status\": \"UP\",\n"
         + "      \"timestamp\": \"string\",\n"
         + "      \"modTimestamp\": \"string\",\n"
         + "      \"framework\": {\n"
         + "        \"name\": \"string\",\n"
         + "        \"version\": \"string\"\n"
         + "      },\n"
         + "      \"paths\": [\n"
         + "        {\n"
         + "          \"Path\": \"string\",\n"
         + "          \"Property\": {\n"
         + "            \"additionalProp1\": \"string\",\n"
         + "            \"additionalProp2\": \"string\",\n"
         + "            \"additionalProp3\": \"string\"\n"
         + "          }\n"
         + "        }\n"
         + "      ],\n"
         + "      \"properties\": {\n"
         + "        \"additionalProp1\": \"string\",\n"
         + "        \"additionalProp2\": \"string\",\n"
         + "        \"additionalProp3\": \"string\"\n"
         + "      }\n"
         + "    }\n"
         + "}";

     httpResponse.setContent(responseString);

     Mockito.when(serviceCenterRawClient.getHttpRequest("/registry/microservices/111111", null, null))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     Microservice microservices = serviceCenterClient.getMicroserviceByServiceId("111111");

     Assertions.assertNotNull(microservices);
     Assertions.assertEquals("111111", microservices.getServiceId());
   }

   @Test
   public void TestGetServiceList() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");

     MicroservicesResponse microservicesResponse = new MicroservicesResponse();
     List<Microservice> microserviceList = new ArrayList<>();
     microserviceList.add(new Microservice("Test1"));
     microserviceList.add(new Microservice("Test2"));
     microserviceList.add(new Microservice("Test3"));
     microservicesResponse.setServices(microserviceList);
     ObjectMapper mapper = new ObjectMapper();
     httpResponse.setContent(mapper.writeValueAsString(microservicesResponse));

     Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     MicroservicesResponse actualMicroservicesResponse = serviceCenterClient.getMicroserviceList();

     Assertions.assertNotNull(actualMicroservicesResponse);
     Assertions.assertEquals(3, actualMicroservicesResponse.getServices().size());
     Assertions.assertEquals("Test1", actualMicroservicesResponse.getServices().get(0).getServiceName());
   }

   @Test
   public void TestQueryServiceId() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     httpResponse.setContent("{\"serviceId\": \"111111\"}");

     Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     Microservice microservice = new Microservice("Test111");
     RegisteredMicroserviceResponse actualServiceId = serviceCenterClient.queryServiceId(microservice);

     Assertions.assertNotNull(actualServiceId);
     Assertions.assertEquals("111111", actualServiceId.getServiceId());
   }

   @Test
   public void TestRegisterServiceInstance() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     httpResponse.setContent("{\"instanceId\": \"111111\"}");

     MicroserviceInstance instance = new MicroserviceInstance();
     instance.setInstanceId("111111");
     instance.setServiceId("222222");
     ObjectMapper mapper = new ObjectMapper();
     mapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);

     Mockito.when(serviceCenterRawClient.postHttpRequest("/registry/microservices/222222/instances", null,
         mapper.writeValueAsString(instance)))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     RegisteredMicroserviceInstanceResponse actualResponse = serviceCenterClient.registerMicroserviceInstance(instance);

     Assertions.assertNotNull(actualResponse);
     Assertions.assertEquals("111111", actualResponse.getInstanceId());
   }

   @Test
   public void TestDeleteServiceInstance() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");

     Mockito.when(serviceCenterRawClient.deleteHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     serviceCenterClient.deleteMicroserviceInstance("111", "222");
   }

   @Test
   public void TestGetServiceInstanceList() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     String responseString = "{\n"
         + "  \"instances\": [\n"
         + "    {\n"
         + "      \"instanceId\": \"111111\",\n"
         + "      \"serviceId\": \"222222\",\n"
         + "      \"version\": \"1.0\",\n"
         + "      \"hostName\": \"Test\",\n"
         + "      \"endpoints\": [\n"
         + "        \"string\"\n"
         + "      ],\n"
         + "      \"status\": \"UP\",\n"
         + "      \"timestamp\": \"333333\",\n"
         + "      \"modTimestamp\": \"4444444\"\n"
         + "    }\n"
         + "  ]\n"
         + "}";

     httpResponse.setContent(responseString);

     Mockito.when(serviceCenterRawClient.getHttpRequest("/registry/microservices/222222/instances", null, null))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     MicroserviceInstancesResponse serviceCenterInstances = serviceCenterClient
         .getMicroserviceInstanceList("222222");

     Assertions.assertNotNull(serviceCenterInstances);
     Assertions.assertEquals(1, serviceCenterInstances.getInstances().size());
     Assertions.assertEquals("111111", serviceCenterInstances.getInstances().get(0).getInstanceId());
     Assertions.assertEquals("222222", serviceCenterInstances.getInstances().get(0).getServiceId());
   }

   @Test
   public void TestGetServiceInstanceMessage() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     String responseString = "{\n"
         + "  \"instance\": {\n"
         + "      \"instanceId\": \"111\",\n"
         + "      \"serviceId\": \"222\",\n"
         + "      \"version\": \"1.0\",\n"
         + "      \"hostName\": \"Test\",\n"
         + "      \"endpoints\": [\n"
         + "        \"string\"\n"
         + "      ],\n"
         + "      \"status\": \"UP\",\n"
         + "      \"properties\": {\n"
         + "        \"additionalProp1\": \"string\",\n"
         + "        \"additionalProp2\": \"string\",\n"
         + "        \"additionalProp3\": \"string\"\n"
         + "      },\n"
         + "      \"healthCheck\": {\n"
         + "        \"mode\": \"push\",\n"
         + "        \"port\": \"0\",\n"
         + "        \"interval\": \"0\",\n"
         + "        \"times\": \"0\"\n"
         + "      },\n"
         + "      \"dataCenterInfo\": {\n"
         + "        \"name\": \"string\",\n"
         + "        \"region\": \"string\",\n"
         + "        \"availableZone\": \"string\"\n"
         + "      },\n"
         + "      \"timestamp\": \"333333\",\n"
         + "      \"modTimestamp\": \"4444444\"\n"
         + "    }\n"
         + "}";

     httpResponse.setContent(responseString);

     Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     MicroserviceInstance responseInstance = serviceCenterClient
         .getMicroserviceInstance("111", "222");

     Assertions.assertNotNull(responseInstance);
     Assertions.assertEquals("111", responseInstance.getInstanceId());
     Assertions.assertEquals("Test", responseInstance.getHostName());
   }

   @Test
   public void TestSendHeartBeats() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");

     HeartbeatsRequest heartbeatsRequest = new HeartbeatsRequest("001", "1001");
     heartbeatsRequest.addInstances(new InstancesRequest("002", "1002"));
     ObjectMapper mapper = new ObjectMapper();

     Mockito
         .when(serviceCenterRawClient.putHttpRequest("/registry/microservices/111/instances/222/heartbeat", null, null))
         .thenReturn(httpResponse);
     Mockito.when(serviceCenterRawClient
         .putHttpRequest("/registry/heartbeats", null, mapper.writeValueAsString(heartbeatsRequest)))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     serviceCenterClient.sendHeartBeats(heartbeatsRequest);
   }

   @Test
   public void TestUpdateServicesInstanceStatus() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");

     Mockito.when(serviceCenterRawClient.putHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     Boolean result = serviceCenterClient
         .updateMicroserviceInstanceStatus("111", "222", MicroserviceInstanceStatus.UP);

     Assertions.assertNotNull(result);
     Assertions.assertEquals(true, result);
   }

   @Test
   public void TestGetServiceSchemas() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     String responseString = "{\n"
         + "  \"schemas\": [\n"
         + "    {\n"
         + "      \"schemaId\": \"111111\",\n"
         + "      \"schema\": \"test\",\n"
         + "      \"summary\": \"test\"\n"
         + "    }\n"
         + "  ]\n"
         + "}";
     httpResponse.setContent(responseString);

     Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     List<SchemaInfo> schemaResponse = serviceCenterClient
         .getServiceSchemasList("111", false);

     ObjectMapper mapper = new ObjectMapper();
     JsonNode jsonNode = mapper.readTree(mapper.writeValueAsString(schemaResponse));

     Assertions.assertNotNull(jsonNode);
     Assertions.assertEquals("111111", jsonNode.get(0).get("schemaId").textValue());
     Assertions.assertEquals("test", jsonNode.get(0).get("schema").textValue());
   }

   @Test
   public void TestGetServiceSchemasContext() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");
     String responseString = "{\n"
         + "  \"schema\": \"test context\"\n"
         + "}";
     httpResponse.setContent(responseString);

     Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     String schemaContext = serviceCenterClient
         .getServiceSchemaContext("111", "222");

     Assertions.assertNotNull(schemaContext);
     Assertions.assertEquals("test context", schemaContext);
   }

   @Test
   public void TestUpdateServiceSchema() throws IOException {

     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");

     Mockito.when(serviceCenterRawClient.putHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
         .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     boolean result = serviceCenterClient
         .updateServiceSchemaContext("111", new SchemaInfo());

     Assertions.assertTrue(result);
   }

   @Test
   public void testUpdateMicroserviceProperties() throws IOException {
     ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

     HttpResponse httpResponse = new HttpResponse();
     httpResponse.setStatusCode(200);
     httpResponse.setMessage("ok");

     Mockito.when(serviceCenterRawClient.putHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
             .thenReturn(httpResponse);

     ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
     boolean result = serviceCenterClient
             .updateMicroserviceProperties("111", new HashMap<String, String>());

     Assertions.assertTrue(result);
   }
 }
	/*
	* 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 org.apache.servicecomb.service.center.client;

	import java.io.IOException;
	import java.util.ArrayList;
	import java.util.HashMap;
	import java.util.List;

	import org.apache.servicecomb.http.client.common.HttpResponse;
	import org.apache.servicecomb.service.center.client.model.HeartbeatsRequest;
	import org.apache.servicecomb.service.center.client.model.InstancesRequest;
	import org.apache.servicecomb.service.center.client.model.Microservice;
	import org.apache.servicecomb.service.center.client.model.MicroserviceInstance;
	import org.apache.servicecomb.service.center.client.model.MicroserviceInstanceStatus;
	import org.apache.servicecomb.service.center.client.model.MicroserviceInstancesResponse;
	import org.apache.servicecomb.service.center.client.model.MicroservicesResponse;
	import org.apache.servicecomb.service.center.client.model.RegisteredMicroserviceInstanceResponse;
	import org.apache.servicecomb.service.center.client.model.RegisteredMicroserviceResponse;
	import org.apache.servicecomb.service.center.client.model.SchemaInfo;
	import org.junit.jupiter.api.Assertions;
	import org.junit.jupiter.api.Test;
	import org.mockito.Mockito;

	import com.fasterxml.jackson.databind.JsonNode;
	import com.fasterxml.jackson.databind.ObjectMapper;
	import com.fasterxml.jackson.databind.SerializationFeature;

	/**
	* Created by on 2019/10/17.
	*/
	public class ServiceCenterClientTest {

	@Test
	public void TestGetServiceCenterInstances() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	String responseString = "{\n"
	+ " \"instances\": [\n"
	+ " {\n"
	+ " \"instanceId\": \"111111\",\n"
	+ " \"serviceId\": \"222222\",\n"
	+ " \"version\": \"1.0\",\n"
	+ " \"hostName\": \"Test\",\n"
	+ " \"endpoints\": [\n"
	+ " \"string\"\n"
	+ " ],\n"
	+ " \"status\": \"UP\",\n"
	+ " \"properties\": {\n"
	+ " \"additionalProp1\": \"string\",\n"
	+ " \"additionalProp2\": \"string\",\n"
	+ " \"additionalProp3\": \"string\"\n"
	+ " },\n"
	+ " \"healthCheck\": {\n"
	+ " \"mode\": \"push\",\n"
	+ " \"port\": \"0\",\n"
	+ " \"interval\": \"0\",\n"
	+ " \"times\": \"0\"\n"
	+ " },\n"
	+ " \"dataCenterInfo\": {\n"
	+ " \"name\": \"string\",\n"
	+ " \"region\": \"string\",\n"
	+ " \"availableZone\": \"string\"\n"
	+ " },\n"
	+ " \"timestamp\": \"333333\",\n"
	+ " \"modTimestamp\": \"4444444\"\n"
	+ " }\n"
	+ " ]\n"
	+ "}";

	httpResponse.setContent(responseString);

	Mockito.when(serviceCenterRawClient.getHttpRequest("/registry/health", null, null)).thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	MicroserviceInstancesResponse serviceCenterInstances = serviceCenterClient.getServiceCenterInstances();

	Assertions.assertNotNull(serviceCenterInstances);
	Assertions.assertEquals(1, serviceCenterInstances.getInstances().size());
	Assertions.assertEquals("111111", serviceCenterInstances.getInstances().get(0).getInstanceId());
	Assertions.assertEquals("222222", serviceCenterInstances.getInstances().get(0).getServiceId());
	}

	@Test
	public void TestRegistryService() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	httpResponse.setContent("{\"serviceId\": \"111111\"}");

	Microservice microservice = new Microservice();
	microservice.setServiceName("Test");
	ObjectMapper objectMapper = new ObjectMapper();
	objectMapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);

	Mockito.when(serviceCenterRawClient
	.postHttpRequest("/registry/microservices", null, objectMapper.writeValueAsString(microservice)))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	RegisteredMicroserviceResponse actualResponse = serviceCenterClient.registerMicroservice(microservice);

	Assertions.assertNotNull(actualResponse);
	Assertions.assertEquals("111111", actualResponse.getServiceId());
	}

	@Test
	public void TestGetServiceMessage() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	String responseString = "{\n"
	+ " \"service\": {\n"
	+ " \"serviceId\": \"111111\",\n"
	+ " \"environment\": \"string\",\n"
	+ " \"appId\": \"string\",\n"
	+ " \"serviceName\": \"string\",\n"
	+ " \"version\": \"string\",\n"
	+ " \"description\": \"string\",\n"
	+ " \"level\": \"string\",\n"
	+ " \"registerBy\": \"string\",\n"
	+ " \"schemas\": [\n"
	+ " \"string\"\n"
	+ " ],\n"
	+ " \"status\": \"UP\",\n"
	+ " \"timestamp\": \"string\",\n"
	+ " \"modTimestamp\": \"string\",\n"
	+ " \"framework\": {\n"
	+ " \"name\": \"string\",\n"
	+ " \"version\": \"string\"\n"
	+ " },\n"
	+ " \"paths\": [\n"
	+ " {\n"
	+ " \"Path\": \"string\",\n"
	+ " \"Property\": {\n"
	+ " \"additionalProp1\": \"string\",\n"
	+ " \"additionalProp2\": \"string\",\n"
	+ " \"additionalProp3\": \"string\"\n"
	+ " }\n"
	+ " }\n"
	+ " ],\n"
	+ " \"properties\": {\n"
	+ " \"additionalProp1\": \"string\",\n"
	+ " \"additionalProp2\": \"string\",\n"
	+ " \"additionalProp3\": \"string\"\n"
	+ " }\n"
	+ " }\n"
	+ "}";

	httpResponse.setContent(responseString);

	Mockito.when(serviceCenterRawClient.getHttpRequest("/registry/microservices/111111", null, null))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	Microservice microservices = serviceCenterClient.getMicroserviceByServiceId("111111");

	Assertions.assertNotNull(microservices);
	Assertions.assertEquals("111111", microservices.getServiceId());
	}

	@Test
	public void TestGetServiceList() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");

	MicroservicesResponse microservicesResponse = new MicroservicesResponse();
	List<Microservice> microserviceList = new ArrayList<>();
	microserviceList.add(new Microservice("Test1"));
	microserviceList.add(new Microservice("Test2"));
	microserviceList.add(new Microservice("Test3"));
	microservicesResponse.setServices(microserviceList);
	ObjectMapper mapper = new ObjectMapper();
	httpResponse.setContent(mapper.writeValueAsString(microservicesResponse));

	Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	MicroservicesResponse actualMicroservicesResponse = serviceCenterClient.getMicroserviceList();

	Assertions.assertNotNull(actualMicroservicesResponse);
	Assertions.assertEquals(3, actualMicroservicesResponse.getServices().size());
	Assertions.assertEquals("Test1", actualMicroservicesResponse.getServices().get(0).getServiceName());
	}

	@Test
	public void TestQueryServiceId() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	httpResponse.setContent("{\"serviceId\": \"111111\"}");

	Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	Microservice microservice = new Microservice("Test111");
	RegisteredMicroserviceResponse actualServiceId = serviceCenterClient.queryServiceId(microservice);

	Assertions.assertNotNull(actualServiceId);
	Assertions.assertEquals("111111", actualServiceId.getServiceId());
	}

	@Test
	public void TestRegisterServiceInstance() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	httpResponse.setContent("{\"instanceId\": \"111111\"}");

	MicroserviceInstance instance = new MicroserviceInstance();
	instance.setInstanceId("111111");
	instance.setServiceId("222222");
	ObjectMapper mapper = new ObjectMapper();
	mapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);

	Mockito.when(serviceCenterRawClient.postHttpRequest("/registry/microservices/222222/instances", null,
	mapper.writeValueAsString(instance)))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	RegisteredMicroserviceInstanceResponse actualResponse = serviceCenterClient.registerMicroserviceInstance(instance);

	Assertions.assertNotNull(actualResponse);
	Assertions.assertEquals("111111", actualResponse.getInstanceId());
	}

	@Test
	public void TestDeleteServiceInstance() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");

	Mockito.when(serviceCenterRawClient.deleteHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	serviceCenterClient.deleteMicroserviceInstance("111", "222");
	}

	@Test
	public void TestGetServiceInstanceList() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	String responseString = "{\n"
	+ " \"instances\": [\n"
	+ " {\n"
	+ " \"instanceId\": \"111111\",\n"
	+ " \"serviceId\": \"222222\",\n"
	+ " \"version\": \"1.0\",\n"
	+ " \"hostName\": \"Test\",\n"
	+ " \"endpoints\": [\n"
	+ " \"string\"\n"
	+ " ],\n"
	+ " \"status\": \"UP\",\n"
	+ " \"timestamp\": \"333333\",\n"
	+ " \"modTimestamp\": \"4444444\"\n"
	+ " }\n"
	+ " ]\n"
	+ "}";

	httpResponse.setContent(responseString);

	Mockito.when(serviceCenterRawClient.getHttpRequest("/registry/microservices/222222/instances", null, null))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	MicroserviceInstancesResponse serviceCenterInstances = serviceCenterClient
	.getMicroserviceInstanceList("222222");

	Assertions.assertNotNull(serviceCenterInstances);
	Assertions.assertEquals(1, serviceCenterInstances.getInstances().size());
	Assertions.assertEquals("111111", serviceCenterInstances.getInstances().get(0).getInstanceId());
	Assertions.assertEquals("222222", serviceCenterInstances.getInstances().get(0).getServiceId());
	}

	@Test
	public void TestGetServiceInstanceMessage() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	String responseString = "{\n"
	+ " \"instance\": {\n"
	+ " \"instanceId\": \"111\",\n"
	+ " \"serviceId\": \"222\",\n"
	+ " \"version\": \"1.0\",\n"
	+ " \"hostName\": \"Test\",\n"
	+ " \"endpoints\": [\n"
	+ " \"string\"\n"
	+ " ],\n"
	+ " \"status\": \"UP\",\n"
	+ " \"properties\": {\n"
	+ " \"additionalProp1\": \"string\",\n"
	+ " \"additionalProp2\": \"string\",\n"
	+ " \"additionalProp3\": \"string\"\n"
	+ " },\n"
	+ " \"healthCheck\": {\n"
	+ " \"mode\": \"push\",\n"
	+ " \"port\": \"0\",\n"
	+ " \"interval\": \"0\",\n"
	+ " \"times\": \"0\"\n"
	+ " },\n"
	+ " \"dataCenterInfo\": {\n"
	+ " \"name\": \"string\",\n"
	+ " \"region\": \"string\",\n"
	+ " \"availableZone\": \"string\"\n"
	+ " },\n"
	+ " \"timestamp\": \"333333\",\n"
	+ " \"modTimestamp\": \"4444444\"\n"
	+ " }\n"
	+ "}";

	httpResponse.setContent(responseString);

	Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	MicroserviceInstance responseInstance = serviceCenterClient
	.getMicroserviceInstance("111", "222");

	Assertions.assertNotNull(responseInstance);
	Assertions.assertEquals("111", responseInstance.getInstanceId());
	Assertions.assertEquals("Test", responseInstance.getHostName());
	}

	@Test
	public void TestSendHeartBeats() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");

	HeartbeatsRequest heartbeatsRequest = new HeartbeatsRequest("001", "1001");
	heartbeatsRequest.addInstances(new InstancesRequest("002", "1002"));
	ObjectMapper mapper = new ObjectMapper();

	Mockito
	.when(serviceCenterRawClient.putHttpRequest("/registry/microservices/111/instances/222/heartbeat", null, null))
	.thenReturn(httpResponse);
	Mockito.when(serviceCenterRawClient
	.putHttpRequest("/registry/heartbeats", null, mapper.writeValueAsString(heartbeatsRequest)))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	serviceCenterClient.sendHeartBeats(heartbeatsRequest);
	}

	@Test
	public void TestUpdateServicesInstanceStatus() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");

	Mockito.when(serviceCenterRawClient.putHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	Boolean result = serviceCenterClient
	.updateMicroserviceInstanceStatus("111", "222", MicroserviceInstanceStatus.UP);

	Assertions.assertNotNull(result);
	Assertions.assertEquals(true, result);
	}

	@Test
	public void TestGetServiceSchemas() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	String responseString = "{\n"
	+ " \"schemas\": [\n"
	+ " {\n"
	+ " \"schemaId\": \"111111\",\n"
	+ " \"schema\": \"test\",\n"
	+ " \"summary\": \"test\"\n"
	+ " }\n"
	+ " ]\n"
	+ "}";
	httpResponse.setContent(responseString);

	Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	List<SchemaInfo> schemaResponse = serviceCenterClient
	.getServiceSchemasList("111", false);

	ObjectMapper mapper = new ObjectMapper();
	JsonNode jsonNode = mapper.readTree(mapper.writeValueAsString(schemaResponse));

	Assertions.assertNotNull(jsonNode);
	Assertions.assertEquals("111111", jsonNode.get(0).get("schemaId").textValue());
	Assertions.assertEquals("test", jsonNode.get(0).get("schema").textValue());
	}

	@Test
	public void TestGetServiceSchemasContext() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");
	String responseString = "{\n"
	+ " \"schema\": \"test context\"\n"
	+ "}";
	httpResponse.setContent(responseString);

	Mockito.when(serviceCenterRawClient.getHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	String schemaContext = serviceCenterClient
	.getServiceSchemaContext("111", "222");

	Assertions.assertNotNull(schemaContext);
	Assertions.assertEquals("test context", schemaContext);
	}

	@Test
	public void TestUpdateServiceSchema() throws IOException {

	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");

	Mockito.when(serviceCenterRawClient.putHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	boolean result = serviceCenterClient
	.updateServiceSchemaContext("111", new SchemaInfo());

	Assertions.assertTrue(result);
	}

	@Test
	public void testUpdateMicroserviceProperties() throws IOException {
	ServiceCenterRawClient serviceCenterRawClient = Mockito.mock(ServiceCenterRawClient.class);

	HttpResponse httpResponse = new HttpResponse();
	httpResponse.setStatusCode(200);
	httpResponse.setMessage("ok");

	Mockito.when(serviceCenterRawClient.putHttpRequest(Mockito.any(), Mockito.any(), Mockito.any()))
	.thenReturn(httpResponse);

	ServiceCenterClient serviceCenterClient = new ServiceCenterClient(serviceCenterRawClient);
	boolean result = serviceCenterClient
	.updateMicroserviceProperties("111", new HashMap<String, String>());

	Assertions.assertTrue(result);
	}
	}