summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk/modules
diff options
context:
space:
mode:
Diffstat (limited to 'sca-java-2.x/trunk/modules')
-rw-r--r--sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/META-INF/MANIFEST.MF1
-rw-r--r--sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/pom.xml45
-rw-r--r--sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCServiceServlet.java79
3 files changed, 58 insertions, 67 deletions
diff --git a/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/META-INF/MANIFEST.MF b/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/META-INF/MANIFEST.MF
index cb951b84a2..8f550a8fc6 100644
--- a/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/META-INF/MANIFEST.MF
+++ b/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/META-INF/MANIFEST.MF
@@ -17,6 +17,7 @@ Import-Package: javax.security.auth.login,
org.apache.http.util,
org.apache.tuscany.sca.assembly;version="2.0.0",
org.apache.tuscany.sca.binding.jsonrpc;version="2.0.0",
+ org.apache.tuscany.sca.common.http;version="2.0.0",
org.apache.tuscany.sca.core;version="2.0.0",
org.apache.tuscany.sca.databinding.javabeans;version="2.0.0",
org.apache.tuscany.sca.databinding.json;version="2.0.0",
diff --git a/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/pom.xml b/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/pom.xml
index b585c3b0b8..ba7b49e7b7 100644
--- a/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/pom.xml
+++ b/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/pom.xml
@@ -7,15 +7,15 @@
* 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.
+ * under the License.
-->
<project>
<modelVersion>4.0.0</modelVersion>
@@ -41,7 +41,7 @@
<artifactId>tuscany-core-spi</artifactId>
<version>2.0-SNAPSHOT</version>
</dependency>
-
+
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-core</artifactId>
@@ -53,38 +53,44 @@
<artifactId>tuscany-databinding</artifactId>
<version>2.0-SNAPSHOT</version>
</dependency>
-
+
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-databinding-json</artifactId>
<version>2.0-SNAPSHOT</version>
</dependency>
-
+
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-host-http</artifactId>
<version>2.0-SNAPSHOT</version>
</dependency>
-
+
+ <dependency>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-common-http</artifactId>
+ <version>2.0-SNAPSHOT</version>
+ </dependency>
+
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.0.3</version>
- </dependency>
+ </dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore</artifactId>
<version>4.0.1</version>
- </dependency>
-
+ </dependency>
+
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-host-jetty</artifactId>
<version>2.0-SNAPSHOT</version>
<scope>test</scope>
- </dependency>
-
+ </dependency>
+
<dependency>
<groupId>org.jabsorb</groupId>
<artifactId>jabsorb</artifactId>
@@ -98,20 +104,21 @@
<version>1.6.1</version>
<scope>runtime</scope>
</dependency>
+
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-jdk14</artifactId>
<version>1.6.1</version>
<scope>runtime</scope>
</dependency>
-
+
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
- <version>2.5</version>
+ <version>2.5</version>
<scope>provided</scope>
</dependency>
-
+
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
@@ -126,7 +133,7 @@
<artifactId>servlet-api</artifactId>
</exclusion>
</exclusions>
- </dependency>
+ </dependency>
<!-- Test Dependencies -->
@@ -136,14 +143,14 @@
<version>2.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
-
+
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-implementation-java-runtime</artifactId>
<version>2.0-SNAPSHOT</version>
<scope>test</scope>
- </dependency>
-
+ </dependency>
+
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
diff --git a/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCServiceServlet.java b/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCServiceServlet.java
index 7ecfa83893..b4f7d7040b 100644
--- a/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCServiceServlet.java
+++ b/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCServiceServlet.java
@@ -6,15 +6,15 @@
* 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.
+ * under the License.
*/
package org.apache.tuscany.sca.binding.jsonrpc.provider;
@@ -24,9 +24,7 @@ import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
-import java.math.BigInteger;
import java.net.URLDecoder;
-import java.security.MessageDigest;
import java.util.Date;
import java.util.List;
@@ -37,6 +35,7 @@ import javax.servlet.http.HttpSession;
import org.apache.commons.codec.binary.Base64;
import org.apache.tuscany.sca.assembly.Binding;
+import org.apache.tuscany.sca.common.http.HTTPUtil;
import org.apache.tuscany.sca.databinding.json.JSONDataBinding;
import org.apache.tuscany.sca.interfacedef.Operation;
import org.apache.tuscany.sca.invocation.Message;
@@ -52,7 +51,7 @@ import org.oasisopen.sca.ServiceRuntimeException;
/**
* Servlet that handles JSON-RPC requests invoking SCA services.
- *
+ *
* There is an instance of this Servlet for each <binding.jsonrpc>
*
* @version $Rev$ $Date$
@@ -61,14 +60,14 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
private static final long serialVersionUID = 1L;
transient MessageFactory messageFactory;
-
+
transient Binding binding;
transient String serviceName;
transient Object serviceInstance;
transient RuntimeEndpoint endpoint;
transient Class<?> serviceInterface;
- public JSONRPCServiceServlet(MessageFactory messageFactory,
+ public JSONRPCServiceServlet(MessageFactory messageFactory,
RuntimeEndpoint endpoint,
Class<?> serviceInterface,
Object serviceInstance) {
@@ -95,7 +94,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
} else {
try {
handleServiceRequest(request, response);
-
+
} catch(RuntimeException re) {
if (re.getCause() instanceof javax.security.auth.login.LoginException) {
response.setHeader("WWW-Authenticate", "BASIC realm=\"" + "ldap-realm" + "\"");
@@ -122,7 +121,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
if (charset == null) {
charset = "UTF-8";
}
-
+
CharArrayWriter data = new CharArrayWriter();
if (request.getMethod().equals("GET")) {
// if using GET Support (see http://groups.google.com/group/json-rpc/web/json-rpc-over-http)
@@ -144,9 +143,9 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
// JavaScript exceptions.
throw new RuntimeException("Unable to parse request", e);
}
-
+
} else {
- // default POST style
+ // default POST style
BufferedReader in = new BufferedReader(new InputStreamReader(request.getInputStream(), charset));
// Read the request into charArray
@@ -156,7 +155,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
data.write(buf, 0, ret);
}
}
-
+
JSONObject jsonReq = null;
String method = null;
//parse the JSON payload
@@ -170,7 +169,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
throw new RuntimeException("Unable to parse request", e);
}
- // check if it's a system request
+ // check if it's a system request
// or a method invocation
byte[] bout;
try {
@@ -190,17 +189,17 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
// needed to support naughty browsers such as Konqueror and Safari
// which do not honour the charset set in the response
response.setContentType("text/plain;charset=utf-8");
-
+
//set Cache-Control to no-cache to avoid intermediary
//proxy/reverse-proxy caches and always hit the server
//that would identify if the value was current or not
response.setHeader("Cache-Control", "no-cache");
response.setHeader("Expires", new Date(0).toGMTString());
-
+
//handle etag if using GET
if( request.getMethod().equals("GET")) {
- String eTag = calculateETag(bout);
-
+ String eTag = HTTPUtil.calculateHashETag(bout);
+
// Test request for predicates.
String predicate = request.getHeader( "If-Match" );
if (( predicate != null ) && ( !predicate.equals(eTag) )) {
@@ -214,10 +213,10 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
response.sendError(HttpServletResponse.SC_NOT_MODIFIED);
return;
}
-
+
response.addHeader("ETag", eTag);
}
-
+
OutputStream out = response.getOutputStream();
out.write(bout);
out.flush();
@@ -238,11 +237,11 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
out.flush();
out.close();
}
-
+
protected byte[] handleJSONRPCSystemInvocation(HttpServletRequest request, HttpServletResponse response, String requestData) throws IOException,
UnsupportedEncodingException, JSONException {
/*
- * Create a new bridge for every request to avoid all the problems with
+ * Create a new bridge for every request to avoid all the problems with
* JSON-RPC-Java storing the bridge in the session
*/
HttpSession session = request.getSession();
@@ -250,7 +249,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
JSONRPCBridge jsonrpcBridge = new JSONRPCBridge();
jsonrpcBridge.registerObject("Service", serviceInstance, serviceInterface);
session.setAttribute("JSONRPCBridge", jsonrpcBridge);
-
+
org.json.JSONObject jsonReq = null;
JSONRPCResult jsonResp = null;
jsonReq = new org.json.JSONObject(requestData);
@@ -265,7 +264,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
return jsonResp.toString().getBytes("UTF-8");
}
-
+
protected byte[] handleJSONRPCMethodInvocation(HttpServletRequest request, HttpServletResponse response, JSONObject jsonReq) throws IOException,
UnsupportedEncodingException {
@@ -278,7 +277,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
if ((method != null) && (method.indexOf('.') < 0)) {
jsonReq.putOpt("method", "Service" + "." + method);
}
-
+
// Extract the arguments
JSONArray array = jsonReq.getJSONArray("params");
args = new Object[array.length()];
@@ -294,7 +293,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
// invoke the request
Operation jsonOperation = findOperation(method);
Object result = null;
-
+
// Invoke the get operation on the service implementation
Message requestMessage = messageFactory.createMessage();
@@ -337,7 +336,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
return jsonResponse.toString().getBytes("UTF-8");
} catch (Exception e) {
throw new ServiceRuntimeException("Unable to create JSON response", e);
- }
+ }
} else {
// regular operation returning some value
@@ -356,7 +355,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
return jsonResponse.toString().getBytes("UTF-8");
} catch (Exception e) {
throw new ServiceRuntimeException("Unable to create JSON response", e);
- }
+ }
}
}
} else {
@@ -365,7 +364,7 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
JSONRPCResult errorResult = new JSONRPCResult(JSONRPCResult.CODE_REMOTE_EXCEPTION, id, exception );
return errorResult.toString().getBytes("UTF-8");
}
-
+
}
/**
@@ -378,12 +377,12 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
if (method.contains(".")) {
method = method.substring(method.lastIndexOf(".") + 1);
}
-
- List<Operation> operations = endpoint.getComponentServiceInterfaceContract().getInterface().getOperations();
+
+ List<Operation> operations = endpoint.getComponentServiceInterfaceContract().getInterface().getOperations();
//endpoint.getComponentTypeServiceInterfaceContract().getInterface().getOperations();
//componentService.getBindingProvider(binding).getBindingInterfaceContract().getInterface().getOperations();
-
+
Operation result = null;
for (Operation o : operations) {
if (o.isDynamic())
@@ -395,21 +394,5 @@ public class JSONRPCServiceServlet extends JSONRPCServlet {
}
return result;
- }
-
- private String calculateETag(byte[] content) {
- String eTag = "invalid";
- try {
- MessageDigest messageDigest = MessageDigest.getInstance("MD5");
- byte[] digest = messageDigest.digest(content);
- BigInteger number = new BigInteger(1, digest);
- StringBuffer sb = new StringBuffer('0');
- sb.append(number.toString(16));
- eTag = sb.toString();
- } catch(Exception e) {
- //ignore, we will return random etag
- eTag = Integer.toString((new java.util.Random()).nextInt(Integer.MAX_VALUE));
- }
- return eTag;
}
}
generated by cgit v1.2.3 (git 2.25.1) at 2024-07-14 17:46:03 +0000