master
parent 057fe1080d
commit 23cadb7e58
  1. 6
      pom.xml
  2. 63
      src/main/java/org/gcube/portal/ddas/BrokerResponse.java
  3. 7
      src/main/java/org/gcube/portal/ddas/DdasVREService.java

@ -9,11 +9,11 @@
</parent>
<modelVersion>4.0.0</modelVersion>
<groupId>org.gcube.portal.bc.ddas</groupId>
<artifactId>DDAS-VRE-Servlet</artifactId>
<packaging>war</packaging>
<version>1.0.0-SNAPSHOT</version>
<packaging>war</packaging>
<scm>
<connection>scm:git:https://code-repo.d4science.org/gCubeSystem/${project.artifactId}.git</connection>
<developerConnection>scm:git:https://code-repo.d4science.org/gCubeSystem/${project.artifactId}.git</developerConnection>
@ -21,7 +21,7 @@
</scm>
<name>DDAS-VRE-Servlet Webapp</name>
<description>....</description>
<description>This component is a servlet responding to the push performed by Blue-Cloud Data Discovery and Access Service to move data downlaods onto the VRE</description>
<properties>
<java-version>1.8</java-version>
<liferay-version>6.2.5</liferay-version>

@ -0,0 +1,63 @@
package org.gcube.portal.ddas;
import java.net.URL;
import java.time.Instant;
public class BrokerResponse {
private int status;
private String message;
private long timeStamp;
private URL vreConfirmUrl;
public BrokerResponse() {
}
public BrokerResponse(int status, String message, URL vreConfirmUrl) {
super();
this.status = status;
this.message = message;
this.vreConfirmUrl = vreConfirmUrl;
Instant instant = Instant.now();
this.timeStamp = instant.toEpochMilli();
}
public int getStatus() {
return status;
}
public void setStatus(int status) {
this.status = status;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public long getTimeStamp() {
return timeStamp;
}
public void setTimeStamp(long timeStamp) {
this.timeStamp = timeStamp;
}
public URL getVreConfirmUrl() {
return vreConfirmUrl;
}
public void setVreConfirmUrl(URL vreConfirmUrl) {
this.vreConfirmUrl = vreConfirmUrl;
}
@Override
public String toString() {
return "BrokerResponse [status=" + status + ", message=" + message + ", timeStamp=" + timeStamp
+ ", vreConfirmUrl=" + vreConfirmUrl + "]";
}
}

@ -84,7 +84,12 @@ public class DdasVREService extends HttpServlet {
response.getWriter().write(toReturn);
}
/**
* the method writes the request JSON in the memcached for @see CACHE_SECONDS_EXPIRATION seconds
* @param requestId
* @param jsonObject
* @return true if the operations is successful
*/
private boolean authorizeRequest(String requestId,JsonObject jsonObject) {
OperationFuture<Boolean> writeOp = null;
try {

Loading…
Cancel
Save