TUSCANY-2487 - Adding jsonRPC data type test cases + small refactoring to the jsonRPC test cases
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@678792 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
c0c0198c21
commit
7f38364933
7 changed files with 377 additions and 41 deletions
|
@ -1,7 +1,27 @@
|
|||
/*
|
||||
* 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.tuscany.sca.binding.jsonrpc;
|
||||
|
||||
public class BusinessException extends Exception {
|
||||
public BusinessException(String message)
|
||||
private static final long serialVersionUID = 7234119326657905710L;
|
||||
|
||||
public BusinessException(String message)
|
||||
{
|
||||
super(message);
|
||||
}
|
||||
|
|
|
@ -18,6 +18,13 @@
|
|||
*/
|
||||
package org.apache.tuscany.sca.binding.jsonrpc;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
|
||||
/**
|
||||
* Interface of our sample JSONRPC service.
|
||||
*
|
||||
|
@ -30,4 +37,17 @@ public interface Echo {
|
|||
void echoRuntimeException() throws RuntimeException;
|
||||
|
||||
void echoBusinessException() throws BusinessException;
|
||||
|
||||
int echoInt(int param);
|
||||
|
||||
boolean echoBoolean(boolean param);
|
||||
|
||||
Map echoMap(HashMap map);
|
||||
|
||||
TestBean echoBean(TestBean testBean);
|
||||
|
||||
List echoList(ArrayList list);
|
||||
|
||||
Set echoSet(HashSet set);
|
||||
|
||||
}
|
||||
|
|
|
@ -18,6 +18,14 @@
|
|||
*/
|
||||
package org.apache.tuscany.sca.binding.jsonrpc;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
|
||||
|
||||
|
||||
/**
|
||||
|
@ -39,6 +47,44 @@ public class EchoComponentImpl implements Echo {
|
|||
|
||||
public void echoRuntimeException() throws RuntimeException {
|
||||
throw new RuntimeException("Runtime Exception");
|
||||
}
|
||||
|
||||
public int echoInt(int param) {
|
||||
int value = param;
|
||||
return value;
|
||||
}
|
||||
|
||||
public boolean echoBoolean(boolean param) {
|
||||
boolean value = param;
|
||||
return value;
|
||||
}
|
||||
|
||||
public Map echoMap(HashMap param) {
|
||||
Map map = new HashMap();
|
||||
map = param;
|
||||
return map;
|
||||
}
|
||||
|
||||
public TestBean echoBean(TestBean testBean1) {
|
||||
TestBean testBean = new TestBean();
|
||||
testBean.setTestString(testBean1.getTestString());
|
||||
testBean.setTestInt(testBean1.getTestInt());
|
||||
return testBean;
|
||||
}
|
||||
|
||||
public List echoList(ArrayList param){
|
||||
List list = new ArrayList();
|
||||
for(Iterator itr = param.iterator();itr.hasNext();)
|
||||
{
|
||||
list.add(itr.next());
|
||||
}
|
||||
return list;
|
||||
}
|
||||
|
||||
public Set echoSet(HashSet param){
|
||||
Set set = new HashSet();
|
||||
set = param;
|
||||
return set;
|
||||
|
||||
}
|
||||
}
|
||||
|
|
|
@ -0,0 +1,149 @@
|
|||
/*
|
||||
* 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.tuscany.sca.binding.jsonrpc;
|
||||
|
||||
import java.io.ByteArrayInputStream;
|
||||
|
||||
import junit.framework.Assert;
|
||||
|
||||
import org.apache.tuscany.sca.host.embedded.SCADomain;
|
||||
import org.json.JSONObject;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import com.meterware.httpunit.PostMethodWebRequest;
|
||||
import com.meterware.httpunit.WebConversation;
|
||||
import com.meterware.httpunit.WebRequest;
|
||||
import com.meterware.httpunit.WebResponse;
|
||||
|
||||
/**
|
||||
* @version $Rev$ $Date$
|
||||
*/
|
||||
public class JSONRPCDataTypeTestCase{
|
||||
|
||||
private static final String SERVICE_PATH = "/EchoService";
|
||||
|
||||
private static final String SERVICE_URL = "http://localhost:8085/SCADomain" + SERVICE_PATH;
|
||||
|
||||
private SCADomain domain;
|
||||
|
||||
@Before
|
||||
public void setUp() throws Exception {
|
||||
domain = SCADomain.newInstance("JSONRPCBinding.composite");
|
||||
}
|
||||
|
||||
@After
|
||||
public void tearDown() throws Exception {
|
||||
domain.close();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testInt() throws Exception {
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoInt\", \"params\": [12345], \"id\": 4}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonResp = new JSONObject(response.getText());
|
||||
|
||||
Assert.assertEquals(12345, jsonResp.getInt("result"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testBoolean() throws Exception {
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoBoolean\", \"params\": [true], \"id\": 5}");
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonResp = new JSONObject(response.getText());
|
||||
|
||||
Assert.assertEquals(true, jsonResp.getBoolean("result"));
|
||||
}
|
||||
|
||||
@Ignore("TUSCANY-2488")
|
||||
public void testMap() throws Exception {
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoMap\", \"params\": [ {\"javaClass\": \"java.util.HashMap\", \"map\": { \"Binding\": \"JSON-RPC\"}}], \"id\": 6}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonResp = new JSONObject(response.getText());
|
||||
|
||||
Assert.assertEquals("JSON-RPC", jsonResp.getJSONObject("result").getJSONObject("map").getString("name"));
|
||||
}
|
||||
|
||||
@Ignore("TUSCANY-2488")
|
||||
public void testList() throws Exception {
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoList\", \"params\": [ {\"javaClass\": \"java.util.ArrayList\", \"list\": [0,1,2,3,4]}], \"id\": 8}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonResp = new JSONObject(response.getText());
|
||||
|
||||
Assert.assertEquals(0, jsonResp.getJSONObject("result").getJSONArray("list").get(0));
|
||||
}
|
||||
|
||||
@Ignore("TUSCANY-2488")
|
||||
public void testSet() throws Exception {
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoSet\", \"params\": [ {\"javaClass\": \"java.util.HashSet\", \"set\": {\"1\": \"red\", \"2\": \"blue\"}}],\"id\": 9}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonResp = new JSONObject(response.getText());
|
||||
|
||||
Assert.assertEquals(0, jsonResp.getJSONObject("result").getJSONObject("set").getString("red"));
|
||||
}
|
||||
|
||||
@Ignore("TUSCANY-2488")
|
||||
public void testBean() throws Exception {
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoBean\", \"params\": [ {\"javaClass\": \"org.apache.tuscany.sca.binding.jsonrpc.TestBean\", \"testString\": \"JSON-RPC\", \"testInt\":1234}], \"id\": 7}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonResp = new JSONObject(response.getText());
|
||||
|
||||
Assert.assertEquals("JSON-RPC", jsonResp.getJSONObject("result").getString("testString"));
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
|
@ -0,0 +1,86 @@
|
|||
/*
|
||||
* 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.tuscany.sca.binding.jsonrpc;
|
||||
|
||||
import java.io.ByteArrayInputStream;
|
||||
|
||||
import junit.framework.Assert;
|
||||
|
||||
import org.apache.tuscany.sca.host.embedded.SCADomain;
|
||||
import org.json.JSONObject;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Test;
|
||||
|
||||
import com.meterware.httpunit.PostMethodWebRequest;
|
||||
import com.meterware.httpunit.WebConversation;
|
||||
import com.meterware.httpunit.WebRequest;
|
||||
import com.meterware.httpunit.WebResponse;
|
||||
|
||||
/**
|
||||
* @version $Rev$ $Date$
|
||||
*/
|
||||
public class JSONRPCExceptionTestCase{
|
||||
|
||||
private static final String SERVICE_PATH = "/EchoService";
|
||||
|
||||
private static final String SERVICE_URL = "http://localhost:8085/SCADomain" + SERVICE_PATH;
|
||||
|
||||
private SCADomain domain;
|
||||
|
||||
@Before
|
||||
public void setUp() throws Exception {
|
||||
domain = SCADomain.newInstance("JSONRPCBinding.composite");
|
||||
}
|
||||
|
||||
@After
|
||||
public void tearDown() throws Exception {
|
||||
domain.close();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testRuntimeException() throws Exception{
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoRuntimeException\", \"params\": [], \"id\": 2}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonErr = new JSONObject(response.getText()).getJSONObject("error");
|
||||
|
||||
Assert.assertEquals("Runtime Exception", jsonErr.getString("msg"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testBusinessException() throws Exception{
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoBusinessException\", \"params\": [], \"id\": 3}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonErr = new JSONObject(response.getText()).getJSONObject("error");
|
||||
|
||||
Assert.assertEquals("Business Exception", jsonErr.getString("msg"));
|
||||
}
|
||||
}
|
|
@ -20,10 +20,13 @@ package org.apache.tuscany.sca.binding.jsonrpc;
|
|||
|
||||
import java.io.ByteArrayInputStream;
|
||||
|
||||
import junit.framework.TestCase;
|
||||
import junit.framework.Assert;
|
||||
|
||||
import org.apache.tuscany.sca.host.embedded.SCADomain;
|
||||
import org.json.JSONObject;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Test;
|
||||
|
||||
import com.meterware.httpunit.PostMethodWebRequest;
|
||||
import com.meterware.httpunit.WebConversation;
|
||||
|
@ -33,7 +36,7 @@ import com.meterware.httpunit.WebResponse;
|
|||
/**
|
||||
* @version $Rev$ $Date$
|
||||
*/
|
||||
public class JSONRPCServiceTestCase extends TestCase {
|
||||
public class JSONRPCServiceTestCase{
|
||||
|
||||
private static final String SERVICE_PATH = "/EchoService";
|
||||
|
||||
|
@ -41,16 +44,17 @@ public class JSONRPCServiceTestCase extends TestCase {
|
|||
|
||||
private SCADomain domain;
|
||||
|
||||
@Override
|
||||
protected void setUp() throws Exception {
|
||||
@Before
|
||||
public void setUp() throws Exception {
|
||||
domain = SCADomain.newInstance("JSONRPCBinding.composite");
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void tearDown() throws Exception {
|
||||
@After
|
||||
public void tearDown() throws Exception {
|
||||
domain.close();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testJSONRPCBinding() throws Exception {
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echo\", \"params\": [\"Hello JSON-RPC\"], \"id\": 1}");
|
||||
|
||||
|
@ -58,39 +62,9 @@ public class JSONRPCServiceTestCase extends TestCase {
|
|||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
assertEquals(200, response.getResponseCode());
|
||||
Assert.assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonResp = new JSONObject(response.getText());
|
||||
assertEquals("echo: Hello JSON-RPC", jsonResp.getString("result"));
|
||||
Assert.assertEquals("echo: Hello JSON-RPC", jsonResp.getString("result"));
|
||||
}
|
||||
|
||||
public void testRuntimeException() throws Exception{
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoRuntimeException\", \"params\": [], \"id\": 2}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonErr = new JSONObject(response.getText()).getJSONObject("error");
|
||||
|
||||
assertEquals("Runtime Exception", jsonErr.getString("msg"));
|
||||
}
|
||||
|
||||
public void testBusinessException() throws Exception{
|
||||
JSONObject jsonRequest = new JSONObject("{ \"method\": \"echoBusinessException\", \"params\": [], \"id\": 3}");
|
||||
|
||||
WebConversation wc = new WebConversation();
|
||||
WebRequest request = new PostMethodWebRequest( SERVICE_URL, new ByteArrayInputStream(jsonRequest.toString().getBytes("UTF-8")),"application/json");
|
||||
WebResponse response = wc.getResource(request);
|
||||
|
||||
assertEquals(200, response.getResponseCode());
|
||||
|
||||
JSONObject jsonErr = new JSONObject(response.getText()).getJSONObject("error");
|
||||
|
||||
assertEquals("Business Exception", jsonErr.getString("msg"));
|
||||
}
|
||||
|
||||
|
||||
}
|
|
@ -0,0 +1,41 @@
|
|||
/*
|
||||
* 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.tuscany.sca.binding.jsonrpc;
|
||||
|
||||
public class TestBean {
|
||||
private String testString;
|
||||
private int testInt;
|
||||
|
||||
public String getTestString() {
|
||||
return testString;
|
||||
}
|
||||
|
||||
public void setTestString(String testString) {
|
||||
this.testString = testString;
|
||||
}
|
||||
|
||||
public int getTestInt() {
|
||||
return testInt;
|
||||
}
|
||||
|
||||
public void setTestInt(int testInt) {
|
||||
this.testInt = testInt;
|
||||
}
|
||||
|
||||
}
|
Loading…
Add table
Reference in a new issue