summaryrefslogtreecommitdiffstats
path: root/rest-client/src/test/java/org
diff options
context:
space:
mode:
authorZhaoxing <meng.zhaoxing1@zte.com.cn>2017-08-08 14:02:53 +0800
committerZhaoxing <meng.zhaoxing1@zte.com.cn>2017-08-08 14:02:53 +0800
commitc0604184b2aa8cff924ca783ec6b36f1f5988775 (patch)
tree1c70ffe1ad90c915b3382a37eb2fa80901519c7b /rest-client/src/test/java/org
parent706fc9fed496972968fde136c3e4e10f9578a5b3 (diff)
init code
Change-Id: Icd0948118397b256da70dfbcbbec5520dc5eafd4 Signed-off-by: Zhaoxing <meng.zhaoxing1@zte.com.cn>
Diffstat (limited to 'rest-client/src/test/java/org')
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/ReaderHelperTest.java116
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/TestServiceUtil.java92
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestHttpRest.java1179
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestHttpContentExchange.java592
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulConfigure.java238
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulFactory.java109
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulOptions.java288
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulParametes.java229
-rw-r--r--rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulResponse.java273
9 files changed, 0 insertions, 3116 deletions
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/ReaderHelperTest.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/ReaderHelperTest.java
deleted file mode 100644
index 9922476..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/ReaderHelperTest.java
+++ /dev/null
@@ -1,116 +0,0 @@
-/*
- * Copyright 2016 Huawei Technologies Co., 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 org.openo.baseservice.roa.util;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import java.io.Reader;
-import java.io.StringReader;
-
-import junit.framework.Assert;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 12-Jun-2016
- */
-public class ReaderHelperTest {
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- }
-
- /**
- * Test method for {@link org.openo.baseservice.util.inf.ReaderHelper#getLine()}.
- */
- @Test
- public void testGetLine() {
- final String message = "hello.. how are you?";
- final Reader reader = new StringReader(message);
- final ReaderHelper helper = new ReaderHelper(reader);
- final String actual = helper.getLine();
- Assert.assertEquals(message, actual);
- }
-
- /**
- * Test method for {@link org.openo.baseservice.util.inf.ReaderHelper#getLine()}.
- */
- @Test
- public void testGetLineMultiLine() {
- final String line1 = "hello.. how are you?";
- final String line2 = "I am fine.";
- final Reader reader = new StringReader(line1 + System.lineSeparator() + line2);
- final ReaderHelper helper = new ReaderHelper(reader);
- String actual = helper.getLine();
- Assert.assertEquals(line1, actual);
- actual = helper.getLine();
- Assert.assertEquals(line2, actual);
- actual = helper.getLine();
- Assert.assertEquals(null, actual);
- }
-
- @Test
- public void testGetLineNull() {
- final ReaderHelper helper = new ReaderHelper(null);
- final String actual = helper.getLine();
- Assert.assertEquals(null, actual);
-
- }
-
-}
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/TestServiceUtil.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/TestServiceUtil.java
deleted file mode 100644
index d99d562..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/TestServiceUtil.java
+++ /dev/null
@@ -1,92 +0,0 @@
-/*
- * Copyright 2016 Huawei Technologies Co., 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 org.openo.baseservice.roa.util;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 13-Jun-2016
- */
-public class TestServiceUtil {
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetServiceHost() {
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetServicePort() {
- }
-}
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestHttpRest.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestHttpRest.java
deleted file mode 100644
index 47d4ac8..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestHttpRest.java
+++ /dev/null
@@ -1,1179 +0,0 @@
-/*
- * Copyright 2016 Huawei Technologies Co., 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 org.openo.baseservice.roa.util.restclient;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-
-import java.io.IOException;
-import java.io.UnsupportedEncodingException;
-import java.lang.reflect.Field;
-import java.net.URLEncoder;
-
-import org.eclipse.jetty.client.HttpClient;
-import org.eclipse.jetty.client.HttpExchange;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.rules.ExpectedException;
-import org.junit.runner.RunWith;
-import org.openo.baseservice.remoteservice.exception.ServiceException;
-
-import mockit.Mock;
-import mockit.MockUp;
-import mockit.Mocked;
-import mockit.NonStrictExpectations;
-import mockit.integration.junit4.JMockit;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 13-Jun-2016
- */
-@RunWith(JMockit.class)
-public class TestHttpRest {
-
- @Rule
- public ExpectedException thrown = ExpectedException.none();
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testInitHttpRest() throws Exception {
- final RestfulOptions options = new RestfulOptions();
- new MockUp<HttpClient>() {
-
- @Mock
- public void doStart() {
- System.out.println("started");
- }
- };
- final HttpRest httpRest = new HttpRest();
- httpRest.initHttpRest(options);
- final Field httpClient = HttpBaseRest.class.getDeclaredField("client");
- httpClient.setAccessible(true);
- Assert.assertNotNull(httpClient.get(httpRest));
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testInitHttpRestExcpetion() throws Exception {
- final RestfulOptions options = new RestfulOptions();
- new MockUp<HttpClient>() {
-
- @Mock
- public void doStart() throws Exception {
- throw new Exception();
- }
- };
- final HttpRest httpRest = new HttpRest();
- thrown.expect(ServiceException.class);
- thrown.expectMessage("http client init failed.");
- httpRest.initHttpRest(options);
- final Field httpClient = HttpRest.class.getDeclaredField("client");
- httpClient.setAccessible(true);
- Assert.assertNull(httpClient.get(httpRest));
- System.out.println("finished");
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testInitHttpRestNull() throws Exception {
- final HttpRest httpRest = new HttpRest();
- thrown.expect(ServiceException.class);
- thrown.expectMessage("option is null.");
- httpRest.initHttpRest(null);
- }
-
- /**
- * <br/>
- *
- * @throws NoSuchFieldException
- * @throws Exception
- * @since
- */
- @Test
- public void testCreateRestHttpContentExchange() throws NoSuchFieldException, Exception {
- final HttpBaseRest httpRest = new HttpRest();
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- }
-
- };
- final RestHttpContentExchange exchange = httpRest.createRestHttpContentExchange(callback);
- assertNotNull(exchange);
- final Field callbackField = RestHttpContentExchange.class.getDeclaredField("callback");
- assertNotNull(callbackField);
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testGetStringRestfulParametes() throws Exception {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parametes = new RestfulParametes();
- parametes.put("id", "1234");
- parametes.put("name", "some-name");
- parametes.put("address", null);
- parametes.putHttpContextHeader("Content-Type", "application/json");
- parametes.putHttpContextHeader("Accept-Encoding", "*/*");
- final RestfulResponse response = httpRest.get("path/to/service", parametes);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
-
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testGetStringRestfulParametesRestfulOptions() throws Exception {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulResponse response = httpRest.get("path/to/service", new RestfulParametes(), options);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testGetStringRestfulParametesEncodeError() throws Exception {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- new NonStrictExpectations() {
-
- @Mocked
- URLEncoder encoder;
-
- {
- URLEncoder.encode(anyString, RestfulClientConst.ENCODING);
- result = new UnsupportedEncodingException();
- }
-
- };
-
- thrown.expect(ServiceException.class);
- thrown.expectMessage("Broken VM does not support");
-
- final RestfulParametes parametes = new RestfulParametes();
- parametes.put("id", "1234");
- parametes.put("name", "some-name");
- parametes.put("address", null);
- parametes.putHttpContextHeader("Content-Type", "application/json");
- parametes.putHttpContextHeader("Accept-Encoding", "*/*");
- final RestfulResponse response = httpRest.get("path/to/service", parametes);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
-
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testHeadStringRestfulParametes() throws Exception {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parametes = new RestfulParametes();
- parametes.put("id", "1234");
- parametes.put("name", "some-name");
- parametes.put("address", null);
- parametes.putHttpContextHeader("Content-Type", "");
- parametes.putHttpContextHeader("Accept-Encoding", "");
- final RestfulResponse response = httpRest.head("path/to/service", parametes);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testHeadStringRestfulParametesRestfulOptions() throws Exception {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parametes = new RestfulParametes();
- parametes.put("id", "1234");
- parametes.put("name", "some-name");
- parametes.put("address", null);
- parametes.putHttpContextHeader("Content-Type", "");
- parametes.putHttpContextHeader("Accept-Encoding", "");
- final RestfulResponse response = httpRest.head("path/to/service", parametes, options);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @param options
- * @return
- * @throws ServiceException
- * @since
- */
- private HttpRest getHttpRest(final RestfulOptions options) throws ServiceException {
- final HttpRest httpRest = new HttpRest();
- {
- new MockUp<HttpClient>() {
-
- @Mock
- public void doStart() {
- System.out.println("started");
- }
-
- @Mock
- public void send(final HttpExchange exchange) throws IOException {
- System.out.println("send");
- }
- };
- httpRest.initHttpRest(options);
-
- }
- return httpRest;
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testAsyncGetStringRestfulParametesRestfulAsyncCallback() throws Exception {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncGet("path/to/service", new RestfulParametes(), callback);
- httpRest.asyncGet("path/to/service", new RestfulParametes(), null);
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testAsyncGetStringRestfulParametesRestfulOptionsRestfulAsyncCallback() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncGet("path/to/service", new RestfulParametes(), new RestfulOptions(), callback);
- httpRest.asyncGet("path/to/service", new RestfulParametes(), new RestfulOptions(), null);
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testPutStringRestfulParametes() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parametes = new RestfulParametes();
- parametes.put("id", "1234");
- parametes.put("name", "some-name");
- parametes.put("address", null);
- parametes.putHttpContextHeader("Content-Type", "");
- parametes.putHttpContextHeader("Accept-Encoding", "");
- final RestfulResponse response = httpRest.put("path/to/service", parametes);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testPutStringRestfulParametesRestfulOptions() throws ServiceException {
-
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parametes = new RestfulParametes();
- parametes.put("id", "1234");
- parametes.put("name", "some-name");
- parametes.put("address", null);
- parametes.putHttpContextHeader("Content-Type", "");
- parametes.putHttpContextHeader("Accept-Encoding", "");
- final RestfulResponse response = httpRest.put("path/to/service", parametes, null);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testAsyncPutStringRestfulParametesRestfulAsyncCallback() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncPut("path/to/service", new RestfulParametes(), callback);
- httpRest.asyncPut("path/to/service", new RestfulParametes(), null);
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testAsyncPutStringRestfulParametesRestfulOptionsRestfulAsyncCallback() throws Exception {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncPut("path/to/service", new RestfulParametes(), new RestfulOptions(), callback);
- httpRest.asyncPut("path/to/service", new RestfulParametes(), new RestfulOptions(), null);
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testPostStringRestfulParametes() throws Exception {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone");
- return HttpExchange.STATUS_EXPIRED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_EXPIRED);
- return response;
- }
-
- };
- final RestfulParametes parameters = new RestfulParametes();
- parameters.put("id", "1234");
- parameters.put("name", "some-name");
- parameters.put("address", null);
- parameters.putHttpContextHeader("Content-Type", "");
- parameters.putHttpContextHeader("Accept-Encoding", "");
-
- thrown.expect(ServiceException.class);
- thrown.expectMessage("request is expierd");
- final RestfulResponse response = httpRest.post("http://localhost:80/path/to/service", parameters);
- assertEquals(HttpExchange.STATUS_EXPIRED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testPostStringRestfulParametesRestfulOptions() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone" + HttpExchange.STATUS_EXCEPTED);
- return HttpExchange.STATUS_EXCEPTED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parameters = new RestfulParametes();
- parameters.put("id", "1234");
- parameters.put("name", "some-name");
- parameters.put("address", null);
- parameters.setRawData("{ \"data\"=\"sample JSON data\"");
- parameters.putHttpContextHeader("Content-Type", "");
- parameters.putHttpContextHeader("Accept-Encoding", "");
- thrown.expect(ServiceException.class);
- thrown.expectMessage("request is exception");
- final RestfulResponse response = httpRest.post("path/to/service", parameters, null);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testAsyncPostStringRestfulParametesRestfulAsyncCallback() throws Exception {
- final RestfulOptions options = new RestfulOptions();
- options.setRestTimeout(10);
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone:" + HttpExchange.STATUS_EXCEPTED);
- return 99;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_EXCEPTED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncPost("path/to/service", new RestfulParametes(), options, callback);
- httpRest.asyncPost("path/to/service", new RestfulParametes(), options, null);
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testAsyncPostStringRestfulParametesRestfulOptionsRestfulAsyncCallback() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
- options.setRestTimeout(10);
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone:" + HttpExchange.STATUS_COMPLETED);
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncPost("path/to/service", new RestfulParametes(), options, callback);
- httpRest.asyncPost("path/to/service", new RestfulParametes(), options, null);
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testDeleteStringRestfulParametes() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpBaseRest httpRest = getHttpRest(options);
-
- final RestfulResponse response = httpRest.delete("path/to/service", null);
- assertEquals(-1, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testDeleteStringRestfulParametesRestfulOptions() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone" + HttpExchange.STATUS_COMPLETED);
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parameters = new RestfulParametes();
- parameters.put("id", "1234");
- parameters.put("name", "some-name");
- parameters.put("address", null);
- parameters.setRawData("{ \"data\"=\"sample JSON data\"");
- parameters.putHttpContextHeader("Content-Type", "");
- parameters.putHttpContextHeader("Accept-Encoding", "");
- final RestfulResponse response = httpRest.delete("path/to/service", parameters, options);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testAsyncDeleteStringRestfulParametesRestfulAsyncCallback() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
- options.setRestTimeout(10);
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone:" + HttpExchange.STATUS_COMPLETED);
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncDelete("path/to/service", new RestfulParametes(), callback);
- httpRest.asyncDelete("path/to/service", new RestfulParametes(), null);
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testAsyncDeleteStringRestfulParametesRestfulOptionsRestfulAsyncCallback() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
- options.setRestTimeout(10);
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone:" + HttpExchange.STATUS_COMPLETED);
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncDelete("path/to/service", new RestfulParametes(), options, callback);
- httpRest.asyncDelete("path/to/service", new RestfulParametes(), options, null);
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testPatchStringRestfulParametes() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone" + HttpExchange.STATUS_COMPLETED);
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parameters = new RestfulParametes();
- parameters.put("id", "1234");
- parameters.put("name", "some-name");
- parameters.put("address", null);
- parameters.setRawData("{ \"data\"=\"sample JSON data\"");
- parameters.putHttpContextHeader("Content-Type", "");
- parameters.putHttpContextHeader("Accept-Encoding", "");
- final RestfulResponse response = httpRest.patch("path/to/service", parameters);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testPatchStringRestfulParametesRestfulOptions() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone" + HttpExchange.STATUS_COMPLETED);
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
- final RestfulParametes parameters = new RestfulParametes();
- parameters.put("id", "1234");
- parameters.put("name", "some-name");
- parameters.put("address", null);
- parameters.setRawData("{ \"data\"=\"sample JSON data\"");
- parameters.putHttpContextHeader("Content-Type", "");
- parameters.putHttpContextHeader("Accept-Encoding", "");
- final RestfulResponse response = httpRest.patch("path/to/service", parameters, options);
- assertEquals(HttpExchange.STATUS_COMPLETED, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testAsyncPatchStringRestfulParametesRestfulAsyncCallback() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
- options.setRestTimeout(10);
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone:" + HttpExchange.STATUS_COMPLETED);
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncPatch("path/to/service", new RestfulParametes(), callback);
- httpRest.asyncPatch("path/to/service", new RestfulParametes(), null);
- }
-
- /**
- * <br/>
- *
- * @throws ServiceException
- * @since
- */
- @Test
- public void testAsyncPatchStringRestfulParametesRestfulOptionsRestfulAsyncCallback() throws ServiceException {
- final RestfulOptions options = new RestfulOptions();
- options.setRestTimeout(10);
-
- final HttpBaseRest httpRest = getHttpRest(options);
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public int waitForDone() {
- System.out.println("waitForDone:" + HttpExchange.STATUS_COMPLETED);
- return HttpExchange.STATUS_COMPLETED;
- }
-
- @Mock
- public RestfulResponse getResponse() throws IOException {
- final RestfulResponse response = new RestfulResponse();
- response.setStatus(HttpExchange.STATUS_COMPLETED);
- return response;
- }
-
- };
-
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- System.out.println("callback called.");
-
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
-
- System.out.println("handleExcepion called.");
- }
-
- };
- httpRest.asyncPatch("path/to/service", new RestfulParametes(), options, callback);
- httpRest.asyncPatch("path/to/service", new RestfulParametes(), options, null);
- }
-
-}
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestHttpContentExchange.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestHttpContentExchange.java
deleted file mode 100644
index dbd1b1e..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestHttpContentExchange.java
+++ /dev/null
@@ -1,592 +0,0 @@
-/*
- * Copyright 2016-2017 Huawei Technologies Co., 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 org.openo.baseservice.roa.util.restclient;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.lang.reflect.Field;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.atomic.AtomicInteger;
-import java.util.zip.GZIPInputStream;
-
-import org.apache.log4j.Level;
-import org.apache.log4j.LogManager;
-import org.eclipse.jetty.client.Address;
-import org.eclipse.jetty.client.CachedExchange;
-import org.eclipse.jetty.client.HttpDestination;
-import org.eclipse.jetty.client.HttpExchange;
-import org.eclipse.jetty.http.HttpFields;
-import org.eclipse.jetty.http.HttpHeaders;
-import org.eclipse.jetty.io.Buffer;
-import org.eclipse.jetty.io.ByteArrayBuffer;
-import org.eclipse.jetty.util.StringUtil;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Ignore;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.rules.ExpectedException;
-import org.junit.runner.RunWith;
-import org.openo.baseservice.remoteservice.exception.ServiceException;
-
-import mockit.Mock;
-import mockit.MockUp;
-import mockit.Mocked;
-import mockit.integration.junit4.JMockit;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 20-Jun-2016
- */
-@RunWith(JMockit.class)
-public class TestRestHttpContentExchange {
-
- @Mocked
- HttpDestination mockedDest;
-
- @Rule
- public ExpectedException thrown = ExpectedException.none();
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- LogManager.getLogger(RestHttpContentExchange.class).setLevel(Level.ERROR);
- }
-
- /**
- * <br/>
- *
- * @throws IOException
- * @since
- */
- @Test
- public void testOnRequestCommitted() throws IOException {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.onRequestCommitted();
-
- LogManager.getLogger(RestHttpContentExchange.class).setLevel(Level.DEBUG);
- exchange.onRequestCommitted();
- }
-
- /**
- * <br/>
- *
- * @throws IOException
- * @since
- */
- @Test
- public void testOnRequestComplete() throws IOException {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.onRequestComplete();
-
- LogManager.getLogger(RestHttpContentExchange.class).setLevel(Level.DEBUG);
- exchange.onRequestComplete();
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testOnResponseComplete() throws Exception {
- RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.onResponseComplete();
-
- LogManager.getLogger(RestHttpContentExchange.class).setLevel(Level.DEBUG);
- exchange.onResponseComplete();
-
- final AtomicInteger isCallback = new AtomicInteger(0);
- final AtomicInteger isException = new AtomicInteger(0);
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- isCallback.set(1);
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
- isException.set(1);
- }
-
- };
-
- final Field statusField = HttpExchange.class.getDeclaredField("_status");
- statusField.setAccessible(true);
- exchange = new RestHttpContentExchange(false, callback);
- statusField.set(exchange, new AtomicInteger(200));
- exchange.setAddress(new Address("localhost", 9999));
- exchange.setRequestURI("/the/request/uri");
- exchange.onResponseComplete();
- assertEquals(1, isCallback.get());
- assertEquals(0, isException.get());
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- @Ignore
- public void testDecompressGzipToStr() throws Exception {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
-
- final InputStream stream = ClassLoader.getSystemResourceAsStream("sample.txt.gz");
- final byte[] binaryData = new byte[1024];
- stream.read(binaryData);
- final String expected = "sample data.";
-
- final String actual = exchange.decompressGzipToStr(binaryData);
-
- System.out.println("actual: '" + actual + "'");
- System.out.println("expected: '" + expected + "'");
- assertEquals(actual, expected);
-
- new MockUp<ByteArrayInputStream>() {
-
- @Mock
- public int read() throws Exception {
- throw new IOException();
- }
-
- @Mock
- public int read(final byte abyte0[], final int i, final int j) {
-
- return -1;
- }
-
- };
-
- thrown.expect(IOException.class);
- exchange.decompressGzipToStr(binaryData);
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- @Ignore
- public void testDecompressGzipToStrException() throws Exception {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
-
- final InputStream stream = ClassLoader.getSystemResourceAsStream("sample.txt.gz");
- final byte[] binaryData = new byte[1024];
- stream.read(binaryData);
- final String expected = "sample data.";
-
- new MockUp<GZIPInputStream>() {
-
- @Mock
- public void close() throws IOException {
- throw new IOException();
- }
-
- };
-
- new MockUp<InputStreamReader>() {
-
- @Mock
- public void close() throws IOException {
- throw new IOException();
- }
-
- };
-
- new MockUp<ByteArrayInputStream>() {
-
- @Mock
- public void close() throws IOException {
- throw new IOException();
- }
-
- };
-
- final String actual = exchange.decompressGzipToStr(binaryData);
-
- System.out.println("actual: '" + actual + "'");
- System.out.println("expected: '" + expected + "'");
- assertEquals(actual, expected);
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testDecompressGzipToStrNull() throws Exception {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- final String expected = "";
- final String actual = exchange.decompressGzipToStr(null);
-
- System.out.println("actual: '" + actual + "'");
- System.out.println("expected: '" + expected + "'");
- assertEquals(actual, expected);
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testOnResponseHeaderBufferBuffer() throws Exception {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
-
- final Buffer name = new ByteArrayBuffer("key");
- final Buffer value = new ByteArrayBuffer("value");
- exchange.onResponseHeader(name, value);
-
- new MockUp<HttpHeaders>() {
-
- @Mock
- public int getOrdinal(final Buffer buffer) {
- return HttpHeaders.CONTENT_ENCODING_ORDINAL;
- }
-
- };
- exchange.onResponseHeader(name, value);
-
- new MockUp<StringUtil>() {
-
- @Mock
- public String asciiToLowerCase(final String s) {
- return "gzip";
- }
-
- };
- exchange.onResponseHeader(name, value);
-
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testOnExceptionThrowable() {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.onException(new Exception());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testOnExceptionThrowableWithCallback() {
- final AtomicInteger isCallback = new AtomicInteger(0);
- final AtomicInteger isException = new AtomicInteger(0);
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- isCallback.set(1);
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
- isException.set(1);
- }
-
- };
- final RestHttpContentExchange exchange = new RestHttpContentExchange(true, callback);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.onException(new Exception());
- assertEquals(0, isCallback.get());
- assertEquals(1, isException.get());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testOnConnectionFailedThrowable() {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.onConnectionFailed(new Exception());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testOnConnectionFailedThrowableException() {
- final AtomicInteger isCallback = new AtomicInteger(0);
- final AtomicInteger isException = new AtomicInteger(0);
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- isCallback.set(1);
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
- isException.set(1);
- }
-
- };
- final RestHttpContentExchange exchange = new RestHttpContentExchange(true, callback);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.onConnectionFailed(new Exception());
- assertEquals(0, isCallback.get());
- assertEquals(1, isException.get());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testExpireHttpDestination() {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(true, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.expire(mockedDest);
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testExpireHttpDestinationException() throws Exception {
- final AtomicInteger isCallback = new AtomicInteger(0);
- final AtomicInteger isException = new AtomicInteger(0);
- final List<Throwable> thrSet = new ArrayList<Throwable>();
- final RestfulAsyncCallback callback = new RestfulAsyncCallback() {
-
- @Override
- public void callback(final RestfulResponse response) {
- isCallback.set(1);
- }
-
- @Override
- public void handleExcepion(final Throwable e) {
- isException.set(1);
- thrSet.add(e);
- }
-
- };
- final RestHttpContentExchange exchange = new RestHttpContentExchange(true, callback);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- exchange.expire(mockedDest);
- assertEquals(0, isCallback.get());
- assertEquals(1, isException.get());
- assertEquals(1, thrSet.size());
- final Throwable t = thrSet.get(0);
- assertEquals(ServiceException.class, t.getClass());
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testIsGzip() throws Exception {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
-
- final Buffer name = new ByteArrayBuffer("key");
- final Buffer value = new ByteArrayBuffer("value");
-
- new MockUp<HttpHeaders>() {
-
- @Mock
- public int getOrdinal(final Buffer buffer) {
- return HttpHeaders.CONTENT_ENCODING_ORDINAL;
- }
-
- };
- exchange.onResponseHeader(name, value);
- assertFalse(exchange.isGzip());
-
- new MockUp<StringUtil>() {
-
- @Mock
- public String asciiToLowerCase(final String s) {
- return "gzip";
- }
-
- };
- exchange.onResponseHeader(name, value);
- assertTrue(exchange.isGzip());
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testGetResponse() throws Exception {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
-
- final Field statusField = HttpExchange.class.getDeclaredField("_status");
- statusField.setAccessible(true);
- statusField.set(exchange, new AtomicInteger(200));
-
- RestfulResponse response = exchange.getResponse();
- assertEquals(0, response.getStatus());
-
- final HttpFields fields = new HttpFields();
- final Field headerFields = CachedExchange.class.getDeclaredField("_responseFields");
- headerFields.setAccessible(true);
- headerFields.set(exchange, fields);
- response = exchange.getResponse();
- assertEquals(0, response.getStatus());
- fields.add("Content-Type", "application/json");
- fields.add("Content-Encode", "UTF-8");
- response = exchange.getResponse();
- assertEquals(0, response.getStatus());
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public void testGetResponseGzip() throws Exception {
- final RestHttpContentExchange exchange = new RestHttpContentExchange(false, null);
- final Address address = new Address("localhost", 9999);
- exchange.setAddress(address);
- exchange.setRequestURI("/the/request/uri");
- new MockUp<RestHttpContentExchange>() {
-
- @Mock
- public boolean isGzip() {
- return true;
- }
- };
- final Field statusField = HttpExchange.class.getDeclaredField("_status");
- statusField.setAccessible(true);
- statusField.set(exchange, new AtomicInteger(200));
-
- final RestfulResponse response = exchange.getResponse();
- assertEquals(0, response.getStatus());
- }
-}
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulConfigure.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulConfigure.java
deleted file mode 100644
index 7cc7b1e..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulConfigure.java
+++ /dev/null
@@ -1,238 +0,0 @@
-/*
- * Copyright 2016 Huawei Technologies Co., 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 org.openo.baseservice.roa.util.restclient;
-
-import static org.junit.Assert.assertEquals;
-
-import org.openo.baseservice.util.impl.SystemEnvVariablesDefImpl;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-
-import net.sf.json.JSONObject;
-
-import java.io.File;
-import java.io.IOException;
-import java.net.URL;
-
-import mockit.Mock;
-import mockit.MockUp;
-import mockit.integration.junit4.JMockit;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 20-Jun-2016
- */
-@RunWith(JMockit.class)
-public class TestRestfulConfigure {
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- setAppRoot();
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- }
-
- private static void setAppRoot() {
- final URL resource = ClassLoader.getSystemResource("etc/conf/restclient.json");
- final String urlPath = resource.getPath().replace("etc/conf/restclient.json", "");
-
- try {
- final String path = new File(urlPath).getCanonicalPath();
- System.out.println("path: " + path);
-
- System.setProperty("catalina.base", path);
- System.out.println("approot:" + System.getProperty("catalina.base"));
- } catch(final IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- }
-
- /**
- * <br/>
- * @throws Exception
- * @since
- */
- @Test
- public final void testRestfulConfigure() throws Exception {
- final RestfulConfigure configure = new RestfulConfigure();
- final RestfulOptions options = configure.getOptions();
- assertEquals("127.0.0.1", options.getHost());
- assertEquals(8080, options.getPort());
- assertEquals(1000, options.getIntOption("ConnectTimeout"));
- assertEquals(10, options.getIntOption("thread"));
- assertEquals(500000, options.getIntOption("idletimeout"));
- assertEquals(10000, options.getIntOption("timeout"));
-
- }
-
- /**
- * <br/>
- * @throws Exception
- * @since
- */
- @Test
- public final void testRestfulConfigureAppRootNull() throws Exception {
- new MockUp<SystemEnvVariablesDefImpl>() {
-
- @Mock
- public String getAppRoot() {
- return null;
- }
-
- };
- final RestfulConfigure configure = new RestfulConfigure();
- final RestfulOptions options = configure.getOptions();
-
- assertEquals("", options.getHost());
- assertEquals(0, options.getPort());
- assertEquals(3000, options.getIntOption("ConnectTimeout"));
- assertEquals(200, options.getIntOption("thread"));
- assertEquals(30000, options.getIntOption("idletimeout"));
- assertEquals(30000, options.getIntOption("timeout"));
-
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public final void testRestfulConfigureDefault() throws Exception {
-
- {
-
- new MockUp<File>() {
-
- @Mock
- public boolean isFile() {
- return false;
- }
- };
- final RestfulConfigure configure = new RestfulConfigure();
- final RestfulOptions options = configure.getOptions();
- assertEquals("", options.getHost());
- assertEquals(0, options.getPort());
- assertEquals(3000, options.getIntOption("ConnectTimeout"));
- assertEquals(200, options.getIntOption("thread"));
- assertEquals(30000, options.getIntOption("idletimeout"));
- assertEquals(30000, options.getIntOption("timeout"));
- }
-
- }
-
- /**
- * <br/>
- *
- * @throws Exception
- * @since
- */
- @Test
- public final void testRestfulConfigureException() throws Exception {
-
- new MockUp<JSONObject>() {
-
- @Mock
- JSONObject fromObject(final Object object) throws IOException {
- throw new IOException();
- }
- };
-
- final RestfulConfigure configure = new RestfulConfigure();
- final RestfulOptions options = configure.getOptions();
- assertEquals("", options.getHost());
- assertEquals(0, options.getPort());
- assertEquals(3000, options.getIntOption("ConnectTimeout"));
- assertEquals(200, options.getIntOption("thread"));
- assertEquals(30000, options.getIntOption("idletimeout"));
- assertEquals(30000, options.getIntOption("timeout"));
-
- }
-
- /**
- *
- * @since
- */
- @Test
- public final void testRestfulConfigureString() {
- final String configFile = "rest-client-test.json";
- final String appRoot = System.getProperty("catalina.base");
- final RestfulConfigure configure = new RestfulConfigure(appRoot + File.separator + configFile);
- final RestfulOptions options = configure.getOptions();
- assertEquals("10.10.10.10", options.getHost());
- assertEquals(443, options.getPort());
- assertEquals(10, options.getIntOption("ConnectTimeout"));
- assertEquals(100, options.getIntOption("thread"));
- assertEquals(30, options.getIntOption("idletimeout"));
- assertEquals(60, options.getIntOption("timeout"));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public final void testGetOptions() {
- }
-} \ No newline at end of file
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulFactory.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulFactory.java
deleted file mode 100644
index 5678732..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulFactory.java
+++ /dev/null
@@ -1,109 +0,0 @@
-/*
- * Copyright 2016 Huawei Technologies Co., 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 org.openo.baseservice.roa.util.restclient;
-
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-
-import org.openo.baseservice.remoteservice.exception.ServiceException;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-
-import mockit.Mock;
-import mockit.MockUp;
-import mockit.integration.junit4.JMockit;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 21-Jun-2016
- */
-@RunWith(JMockit.class)
-public class TestRestfulFactory {
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetRestInstance() {
- Restful instance = RestfulFactory.getRestInstance("https");
- assertNull(instance);
- new MockUp<HttpRest>() {
-
- @Mock
- public void initHttpRest(final RestfulOptions option) throws ServiceException {
- throw new ServiceException();
- }
-
- };
- instance = RestfulFactory.getRestInstance("http");
- assertNotNull(instance);
-
- instance = RestfulFactory.getRestInstance("http");
- assertNotNull(instance);
- }
-}
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulOptions.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulOptions.java
deleted file mode 100644
index b91bbef..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulOptions.java
+++ /dev/null
@@ -1,288 +0,0 @@
-/*
- * Copyright 2016 Huawei Technologies Co., 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 org.openo.baseservice.roa.util.restclient;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertSame;
-import static org.junit.Assert.assertTrue;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.rules.ExpectedException;
-import org.junit.runner.RunWith;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import mockit.integration.junit4.JMockit;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 20-Jun-2016
- */
-@RunWith(JMockit.class)
-public class TestRestfulOptions {
-
- @Rule
- final public ExpectedException thrown = ExpectedException.none();
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetPort() {
- final RestfulOptions options = new RestfulOptions();
- final int port = 9091;
- assertEquals(0, options.getPort());
- options.setPort(port);
- assertEquals(port, options.getPort());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetPort() {
- final RestfulOptions options = new RestfulOptions();
- final int port = 9091;
- assertTrue(options.setPort(port));
- assertEquals(port, options.getPort());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetHost() {
- final RestfulOptions options = new RestfulOptions();
- final String host = "localhost";
- assertEquals("", options.getHost());
- options.setHost(host);
- assertEquals(host, options.getHost());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetHost() {
- final RestfulOptions options = new RestfulOptions();
- final String host = "localhost";
- assertTrue(options.setHost(host));
- assertEquals(host, options.getHost());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetRestTimeout() {
- final RestfulOptions options = new RestfulOptions();
- int timeout = 0;
- assertFalse(options.setRestTimeout(timeout));
- assertEquals(0, options.getRestTimeout());
-
- timeout = 1;
- assertTrue(options.setRestTimeout(timeout));
- assertEquals(timeout, options.getRestTimeout());
-
- timeout = 10;
- assertTrue(options.setRestTimeout(timeout));
- assertEquals(timeout, options.getRestTimeout());
-
- timeout = RestfulOptions.REST_OPTIONS_TIMEOUT_MAXTIMEOUT - 1;
- assertTrue(options.setRestTimeout(timeout));
- assertEquals(timeout, options.getRestTimeout());
-
- timeout = RestfulOptions.REST_OPTIONS_TIMEOUT_MAXTIMEOUT;
- assertTrue(options.setRestTimeout(timeout));
- assertEquals(timeout, options.getRestTimeout());
-
- timeout = RestfulOptions.REST_OPTIONS_TIMEOUT_MAXTIMEOUT + 1;
- assertFalse(options.setRestTimeout(timeout));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetRestTimeout() {
- final RestfulOptions options = new RestfulOptions();
- int timeout = 0;
- assertEquals(0, options.getRestTimeout());
-
- timeout = 1;
- assertTrue(options.setRestTimeout(timeout));
- assertEquals(timeout, options.getRestTimeout());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetOption() {
- final RestfulOptions options = new RestfulOptions();
- assertNull(options.getOption("invalid"));
-
- options.setHost("localhost");
- Object obj = options.getOption(RestfulClientConst.HOST_KEY_NAME);
- assertNotNull(obj);
- assertTrue(obj instanceof String);
- assertEquals("localhost", obj);
-
- final List<String> list = new ArrayList<String>();
- list.add("data");
- options.setOption("list", list);
- obj = options.getOption("list");
- assertNotNull(obj);
- assertTrue(obj instanceof List);
- assertSame(list, obj);
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetIntOption() {
- final RestfulOptions options = new RestfulOptions();
-
- assertEquals(0, options.getIntOption("count"));
-
- options.setOption("count", 1);
- assertEquals(1, options.getIntOption("count"));
-
- thrown.expect(RuntimeException.class);
-
- options.setOption("string-count", "two");
- final int value = options.getIntOption("string-count");
- assertEquals(2, value);
-
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetStringOption() {
- final RestfulOptions options = new RestfulOptions();
-
- assertEquals("", options.getStringOption("count"));
-
- options.setOption("string-count", "one");
- assertEquals("one", options.getStringOption("string-count"));
-
- thrown.expect(RuntimeException.class);
-
- options.setOption("count", 2);
- final String value = options.getStringOption("count");
- assertEquals(2, value);
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetOption() {
- final RestfulOptions options = new RestfulOptions();
- assertNull(options.getOption("invalid"));
-
- options.setHost("localhost");
- Object obj = options.getOption(RestfulClientConst.HOST_KEY_NAME);
- assertNotNull(obj);
- assertTrue(obj instanceof String);
- assertEquals("localhost", obj);
-
- final List<String> list = new ArrayList<String>();
- list.add("data");
- options.setOption("list", list);
- obj = options.getOption("list");
- assertNotNull(obj);
- assertTrue(obj instanceof List);
- assertSame(list, obj);
- }
-}
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulParametes.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulParametes.java
deleted file mode 100644
index fbe9430..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulParametes.java
+++ /dev/null
@@ -1,229 +0,0 @@
-/*
- * Copyright 2016 Huawei Technologies Co., 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 org.openo.baseservice.roa.util.restclient;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNull;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 21-Jun-2016
- */
-public class TestRestfulParametes {
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGet() {
- final RestfulParametes params = new RestfulParametes();
- assertNull(params.get("param"));
- final Map<String, String> paramMap = new HashMap<String, String>();
- params.setParamMap(paramMap);
- paramMap.put("param", "value");
- assertEquals("value", params.get("param"));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetRawData() {
- final RestfulParametes params = new RestfulParametes();
- final String data = "Sample data.";
- params.setRawData(data);
- assertEquals(data, params.getRawData());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetRawData() {
- final RestfulParametes params = new RestfulParametes();
- assertNull(params.getRawData());
- final String data = "Sample data.";
- params.setRawData(data);
- assertEquals(data, params.getRawData());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testPut() {
- final RestfulParametes params = new RestfulParametes();
- params.put("somekey", "somevalue");
- params.put("otherkey", "othervalue");
- assertEquals("somevalue", params.get("somekey"));
- assertEquals("othervalue", params.get("otherkey"));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testPutHttpContextHeaderStringString() {
- final RestfulParametes params = new RestfulParametes();
- params.putHttpContextHeader("Context-Encoding", "UTF-8");
- assertEquals("UTF-8", params.getHttpContextHeader("Context-Encoding"));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testPutHttpContextHeaderStringInt() {
- final RestfulParametes params = new RestfulParametes();
- params.putHttpContextHeader("Expire-At", 1000);
- assertEquals("1000", params.getHttpContextHeader("Expire-At"));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetHttpContextHeader() {
- final RestfulParametes params = new RestfulParametes();
- params.putHttpContextHeader("Expire-At", 1000);
- params.putHttpContextHeader("Context-Encoding", "UTF-8");
- assertEquals("1000", params.getHttpContextHeader("Expire-At"));
- assertEquals("UTF-8", params.getHttpContextHeader("Context-Encoding"));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetParamMap() {
- final RestfulParametes params = new RestfulParametes();
- params.put("key", "value");
- final Map<String, String> map = params.getParamMap();
- assertEquals("value", map.get("key"));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetParamMap() {
- final RestfulParametes params = new RestfulParametes();
- final Map<String, String> map = new HashMap<String, String>();
- map.put("key", "value");
- params.setParamMap(map);
- assertEquals("value", params.get("key"));
-
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetHeaderMap() {
- final RestfulParametes params = new RestfulParametes();
- params.putHttpContextHeader("key", "value");
- final Map<String, String> map = params.getHeaderMap();
- assertEquals("value", map.get("key"));
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetHeaderMap() {
- final RestfulParametes params = new RestfulParametes();
- final Map<String, String> map = new HashMap<String, String>();
- map.put("key", "value");
- params.setHeaderMap(map);
- assertEquals("value", params.getHttpContextHeader("key"));
- }
-}
diff --git a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulResponse.java b/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulResponse.java
deleted file mode 100644
index 19fc7d5..0000000
--- a/rest-client/src/test/java/org/openo/baseservice/roa/util/restclient/TestRestfulResponse.java
+++ /dev/null
@@ -1,273 +0,0 @@
-/*
- * Copyright 2016 Huawei Technologies Co., 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 org.openo.baseservice.roa.util.restclient;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertSame;
-import static org.junit.Assert.assertTrue;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.rules.ExpectedException;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * <br/>
- * <p>
- * </p>
- *
- * @author
- * @version 20-Jun-2016
- */
-public class TestRestfulResponse {
-
- @Rule
- public ExpectedException thrown = ExpectedException.none();
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @Before
- public void setUp() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @throws java.lang.Exception
- * @since
- */
- @After
- public void tearDown() throws Exception {
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetStatus() {
- final RestfulResponse response = new RestfulResponse();
- int actual = response.getStatus();
- int expected = -1;
-
- assertEquals(expected, actual);
- expected = 202;
- response.setStatus(expected);
- actual = response.getStatus();
- assertEquals(expected, actual);
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetStatus() {
- final RestfulResponse response = new RestfulResponse();
- final int expected = 10;
- response.setStatus(expected);
- final int actual = response.getStatus();
- assertEquals(expected, actual);
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetRespHeaderMap() {
- final RestfulResponse response = new RestfulResponse();
- Map<String, String> expected = response.getRespHeaderMap();
- assertNull(expected);
- expected = new HashMap<String, String>();
- expected.put("key", "value");
- response.setRespHeaderMap(expected);
- final Map<String, String> actual = response.getRespHeaderMap();
- assertNotNull(actual);
- assertSame(actual, expected);
-
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetRespHeaderMap() {
- final RestfulResponse response = new RestfulResponse();
- response.setRespHeaderMap(null);
- Map<String, String> expected = response.getRespHeaderMap();
- assertNull(expected);
- expected = new HashMap<String, String>();
- expected.put("key", "value");
- response.setRespHeaderMap(expected);
- final Map<String, String> actual = response.getRespHeaderMap();
- assertNotNull(actual);
- assertSame(actual, expected);
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetRespHeaderInt() {
- final RestfulResponse response = new RestfulResponse();
- response.setRespHeaderMap(null);
- int actual = response.getRespHeaderInt("somekey");
- assertEquals(-1, actual);
- final Map<String, String> headers = new HashMap<String, String>();
- headers.put("key", "value");
- headers.put("count", "1");
- response.setRespHeaderMap(headers);
- actual = response.getRespHeaderInt("somekey");
- assertEquals(-1, actual);
-
- actual = response.getRespHeaderInt("count");
- assertEquals(1, actual);
-
- thrown.expect(RuntimeException.class);
- actual = response.getRespHeaderInt("key");
- assertEquals(1, actual);
-
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetRespHeaderLong() {
- final RestfulResponse response = new RestfulResponse();
- response.setRespHeaderMap(null);
- long actual = response.getRespHeaderLong("somekey");
- assertEquals(-1, actual);
- final Map<String, String> headers = new HashMap<String, String>();
- headers.put("key", "value");
- headers.put("count", "1");
- headers.put("max", "" + Long.MAX_VALUE);
- headers.put("max++", Long.MAX_VALUE + 1 + "");
- response.setRespHeaderMap(headers);
- actual = response.getRespHeaderLong("somekey");
- assertEquals(-1, actual);
-
- actual = response.getRespHeaderLong("count");
- assertEquals(1, actual);
-
- actual = response.getRespHeaderLong("max");
- assertEquals(Long.MAX_VALUE, actual);
-
- actual = response.getRespHeaderLong("max++");
- assertTrue(actual < 0);
-
- thrown.expect(RuntimeException.class);
- actual = response.getRespHeaderLong("key");
- assertEquals(1, actual);
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetRespHeaderStr() {
- final RestfulResponse response = new RestfulResponse();
- response.setRespHeaderMap(null);
- String actual = response.getRespHeaderStr("somekey");
- assertEquals(null, actual);
- final Map<String, String> headers = new HashMap<String, String>();
- headers.put("key", "value");
- headers.put("count", "1");
- headers.put("max", "" + Long.MAX_VALUE);
- response.setRespHeaderMap(headers);
- actual = response.getRespHeaderStr("somekey");
- assertEquals(null, actual);
-
- actual = response.getRespHeaderStr("key");
- assertEquals("value", actual);
-
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testGetResponseContent() {
- final RestfulResponse response = new RestfulResponse();
- assertEquals(null, response.getResponseContent());
-
- final String content = "{ \"content\" = \"The response content\" }";
- response.setResponseJson(content);
- assertEquals(content, response.getResponseContent());
- }
-
- /**
- * <br/>
- *
- * @since
- */
- @Test
- public void testSetResponseJson() {
- final RestfulResponse response = new RestfulResponse();
- assertEquals(null, response.getResponseContent());
-
- final String content = "{ \"content\" = \"The response content\" }";
- response.setResponseJson(content);
- assertEquals(content, response.getResponseContent());
- }
-}