Update pom.xml

Updated for gCubeRelease 6.0.0

CHANGELOG.md

@@ -1,5 +1,18 @@
+This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
+
 # Changelog for "dataminer"
 
+
+## [v1.9.1]
+
+- Updated gcube-bom to 2.4.1
+
+
+## [v1.9.0] - 2022-04-05
+
+-  Added support to  new JWT token via URI Resolver [#23107]
+
+
 ## [v1.8.1] - 2022-03-21
 
 - Update wps service to support not writing of the computation status to the user's workspace [#23054]
@@ -62,6 +75,3 @@
 
 - First Release
 
-
-This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
-

pom.xml

@@ -1,15 +1,16 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 	<parent>
 		<artifactId>maven-parent</artifactId>
 		<groupId>org.gcube.tools</groupId>
-		<version>1.1.0</version>
+		<version>1.2.0</version>
 		<relativePath />
 	</parent>
 	<groupId>org.gcube.dataanalysis</groupId>
 	<artifactId>dataminer</artifactId>
-	<version>1.8.1</version>
+	<version>1.9.1</version>
 	<name>dataminer</name>
 	<description>An e-Infrastructure service providing state-of-the art DataMining algorithms and ecological modelling approaches under the Web Processing Service (WPS) standard.</description>
 
@@ -21,7 +22,7 @@
 
 	<developers>
 		<developer>
-			<name>Gianpaolo Coro</name>
+			<name>Gianpaolo 52n-wps-io-implCoro</name>
 			<email>gianpaolo.coro@isti.cnr.it</email>
 			<organization>CNR Pisa, Istituto di Scienza e Tecnologie dell'Informazione "A. Faedo"</organization>
 			<roles>
@@ -55,7 +56,7 @@
 			<dependency>
 				<groupId>org.gcube.distribution</groupId>
 				<artifactId>gcube-bom</artifactId>
-				<version>2.0.2</version>
+				<version>2.4.1</version>
 				<type>pom</type>
 				<scope>import</scope>
 			</dependency>
@@ -91,12 +92,12 @@
 		<dependency>
 			<groupId>org.gcube.dataanalysis</groupId>
 			<artifactId>52n-wps-algorithm-gcube</artifactId>
-			<version>[3.6.1,3.7.0)</version>
+			<version>[3.6.1,3.7.0-SNAPSHOT)</version>
 		</dependency>
 		<dependency>
 			<groupId>org.gcube.dataanalysis</groupId>
 			<artifactId>52n-wps-server-gcube</artifactId>
-			<version>[3.6.1, 3.7.0)</version>
+			<version>[3.6.1, 3.7.0-SNAPSHOT)</version>
 		</dependency>
 		<dependency>
 			<groupId>org.gcube.dataanalysis</groupId>
@@ -106,7 +107,7 @@
 		<dependency>
 			<groupId>org.gcube.dataanalysis</groupId>
 			<artifactId>ecological-engine-geospatial-extensions</artifactId>
-			<version>[1.5.2-SNAPSHOT,2.0.0-SNAPSHOT)</version>
+			<version>[1.5.2,2.0.0-SNAPSHOT)</version>
 			<exclusions>
 				<exclusion>
 					<artifactId>log4j</artifactId>
@@ -117,12 +118,12 @@
 		<dependency>
 			<groupId>org.gcube.dataanalysis</groupId>
 			<artifactId>ecological-engine-external-algorithms</artifactId>
-			<version>[1.2.2-SNAPSHOT,2.0.0-SNAPSHOT)</version>
+			<version>[1.2.2,2.0.0-SNAPSHOT)</version>
 		</dependency>
 		<dependency>
 			<groupId>org.gcube.dataanalysis</groupId>
 			<artifactId>ecological-engine-smart-executor</artifactId>
-			<version>[1.6.5-SNAPSHOT,2.0.0-SNAPSHOT)</version>
+			<version>[1.6.5,2.0.0-SNAPSHOT)</version>
 			<exclusions>
 				<exclusion>
 					<groupId>org.glassfish.jersey.core</groupId>
@@ -145,6 +146,7 @@
 				</exclusion>
 			</exclusions>
 		</dependency>
+
 		<dependency>
 			<groupId>junit</groupId>
 			<artifactId>junit</artifactId>
@@ -199,7 +201,7 @@
 		<repository>
 			<id>n52-releases</id>
 			<name>52n Releases</name>
-			<url>http://52north.org/maven/repo/releases</url>
+			<url>https://52north.org/maven/repo/releases</url>
 			<releases>
 				<enabled>true</enabled>
 			</releases>

src/main/java/org/gcube/dataanalysis/wps/statisticalmanager/synchserver/is/InformationSystemUtils.java

@@ -0,0 +1,67 @@
+package org.gcube.dataanalysis.wps.statisticalmanager.synchserver.is;
+
+import java.util.List;
+
+import org.gcube.common.resources.gcore.ServiceEndpoint;
+import org.gcube.common.resources.gcore.ServiceEndpoint.Runtime;
+import org.gcube.common.scope.api.ScopeProvider;
+import org.gcube.resources.discovery.client.api.DiscoveryClient;
+import org.gcube.resources.discovery.client.queries.api.SimpleQuery;
+import org.gcube.resources.discovery.icclient.ICFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class InformationSystemUtils {
+
+	private static final Logger LOGGER = LoggerFactory.getLogger(InformationSystemUtils.class);
+	private static final String URI_RESOLVER_SERVICE_CATEGORY = "Service";
+	private static final String URI_RESOLVER_SERVICE_NAME = "HTTP-URI-Resolver";
+
+	public static String retrieveUriResolverOat(String scope) throws Exception {
+		try {
+			LOGGER.info("Retrieve URI Resolver Oat Service Info");
+
+			if (scope == null || scope.length() == 0) {
+				String error="Invalid request scope: " + scope;
+				LOGGER.error(error);
+				throw new Exception(error);
+			}
+
+			ScopeProvider.instance.set(scope);
+
+			SimpleQuery query = ICFactory.queryFor(ServiceEndpoint.class);
+			query.addCondition("$resource/Profile/Category/text() eq '" + URI_RESOLVER_SERVICE_CATEGORY + "'")
+					.addCondition("$resource/Profile/Name/text() eq '" + URI_RESOLVER_SERVICE_NAME + "'")
+					.setResult("$resource/Profile/RunTime");
+			DiscoveryClient<Runtime> client = ICFactory.clientFor(Runtime.class);
+		
+			List<Runtime> runtimeList = client.submit(query);
+			String serviceAddress = null;
+			if (runtimeList != null && !runtimeList.isEmpty()) {
+				for (int i = 0; i < runtimeList.size(); i++) {
+					Runtime accessPoint = runtimeList.get(i);
+					if (accessPoint != null) {
+						StringBuilder sb=new StringBuilder();
+						sb.append("https://");
+						sb.append(accessPoint.hostedOn());
+						sb.append("/oat/get");
+						serviceAddress=sb.toString();
+						break;
+					}
+				}
+			} else {
+				String error="RuntimeList error: "+runtimeList;
+				LOGGER.error(error);
+				throw new Exception(error);
+			}
+
+			LOGGER.info("Uri Resolver Oat Service Info: " + serviceAddress);
+			return serviceAddress;
+
+		} catch (Throwable e) {
+			LOGGER.error("Error in discovery Uri Resolver Oat Service Endpoint in scope: " + scope);
+			LOGGER.error(e.getLocalizedMessage(),e);
+			throw e;
+		}
+	}
+}

src/main/java/org/gcube/dataanalysis/wps/statisticalmanager/synchserver/mapping/TokenManager.java

@@ -2,9 +2,21 @@ package org.gcube.dataanalysis.wps.statisticalmanager.synchserver.mapping;
 
 import static org.gcube.common.authorization.client.Constants.authorizationService;
 
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+
+import javax.ws.rs.core.Response;
+
 import org.gcube.common.authorization.library.AuthorizationEntry;
+import org.gcube.common.authorization.library.provider.AccessTokenProvider;
 import org.gcube.common.authorization.library.provider.AuthorizationProvider;
 import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
+import org.gcube.common.scope.api.ScopeProvider;
+import org.gcube.dataanalysis.wps.statisticalmanager.synchserver.is.InformationSystemUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -35,16 +47,20 @@ public class TokenManager {
 
 	public void getCredentials() {
 		try {
-			LOGGER.debug("Retrieving token credentials");
+			LOGGER.info("Retrieving token credentials");
 			// get username from SmartGears
 			username = AuthorizationProvider.instance.get().getClient().getId();
 			token = SecurityTokenProvider.instance.get();
+			if (token == null || token.isEmpty()) {
+				String jwtToken = AccessTokenProvider.instance.get();
+				scope = ScopeProvider.instance.get();
+				token = getGcubeTokenFromUriResolver(jwtToken, scope);
+			}
 			AuthorizationEntry entry = authorizationService().get(token);
 			scope = entry.getContext();
 			tokenQualifier = entry.getQualifier();
-
 		} catch (Exception e) {
-			LOGGER.error("Error Retrieving token credentials ",e);
+			LOGGER.error("Error Retrieving token credentials: "+e.getLocalizedMessage(),e);
 			scope = null;
 			username = null;
 
@@ -53,8 +69,55 @@ public class TokenManager {
 			scope = ConfigurationManager.defaultScope;
 			username = ConfigurationManager.defaultUsername;
 		}
-		LOGGER.debug("Retrieved scope: {} Username: {} Token {} SIMULATION MODE: {} ",scope, username, token, ConfigurationManager.isSimulationMode());
+		LOGGER.info("Retrieved scope: {} Username: {} Token {} SIMULATION MODE: {} ", scope, username, token,
+				ConfigurationManager.isSimulationMode());
 
 	}
 
+	public String getGcubeTokenFromUriResolver(String jwtToken, String scope) throws Exception {
+		String gcubeToken = null;
+		String uriResolverOatURL = InformationSystemUtils.retrieveUriResolverOat(scope);
+		try {
+			LOGGER.info("Create Request: "+ uriResolverOatURL);
+			URL urlObj = new URL(uriResolverOatURL);
+			HttpURLConnection connection = (HttpURLConnection) urlObj.openConnection();
+			connection.setRequestMethod("GET");
+			connection.setRequestProperty("Authorization", "Bearer " + jwtToken);
+			connection.setDoOutput(true);
+			try (AutoCloseable conc = () -> connection.disconnect()) {
+				int responseCode = connection.getResponseCode();
+				LOGGER.info("Response Code: " + responseCode);
+				
+				if (Response.Status.fromStatusCode(responseCode).compareTo(Response.Status.OK) == 0) {
+					try (InputStream ins = connection.getInputStream();
+							BufferedReader in = new BufferedReader(new InputStreamReader(ins))) {
+						String inputLine = null;
+						while ((inputLine = in.readLine()) != null) {
+							break;
+						}
+						gcubeToken = inputLine;
+					}
+				} else {
+					String error = "Invalid Response Code retrieving GCube Token from Uri Resolver: " + responseCode;
+					LOGGER.error(error);
+					try (InputStream ins = connection.getErrorStream();
+							BufferedReader in = new BufferedReader(new InputStreamReader(ins))) {
+						String inputLine = null;
+						while ((inputLine = in.readLine()) != null) {
+							LOGGER.error(inputLine);
+						}
+					}
+					throw new Exception(error);
+				}
+			}
+
+		} catch (IOException e) {
+			LOGGER.error("Error retrieving GcubeToken from Uri Resolver: "+e.getLocalizedMessage());
+			e.printStackTrace();
+			throw e;
+		}
+		LOGGER.info("Retrieved GcubeToken: "+gcubeToken);
+		return gcubeToken;
+	}
+
 }

src/test/java/org/gcube/dataanalysis/wps/statisticalmanager/synchserver/mapping/TokenManagerTest.java

@@ -0,0 +1,26 @@
+package org.gcube.dataanalysis.wps.statisticalmanager.synchserver.mapping;
+
+import org.apache.log4j.BasicConfigurator;
+import org.junit.Test;
+
+public class TokenManagerTest {
+
+	private static final String JWT_TOKEN = "";
+	private static final String SCOPE = "/gcube/devsec/devVRE";
+
+	
+	@Test
+	public void retrieveTokenFromUriResolver() throws Exception {
+		try {
+			BasicConfigurator.configure();
+			System.out.println("Test Retrieve Token From Uri Resolver");
+			TokenManager tm = new TokenManager();
+			String token = tm.getGcubeTokenFromUriResolver(JWT_TOKEN, SCOPE);
+			System.out.println("GcubeToken retrieved: "+token);
+		} catch (Exception e) {
+			System.out.println(e.getLocalizedMessage());
+			e.getStackTrace();
+		}
+	}
+
+}

src/test/java/org/gcube/dataanalysis/wps/statisticalmanager/synchserver/test/AlgorithmTest.java

@@ -30,7 +30,7 @@ public class AlgorithmTest {
 		
 		String protocol = "http";
 		String hostname = "dataminer-genericworkers.d4science.org";
-		String token = "257800d8-24bf-4bae-83cd-ea99369e7dd6-843339462";
+		String token = "xxx-xxx-xxx-xxx";
 		String layerID = "08ee0d70-4d8b-4f42-8b06-d709482bca95";
 						 
 		Iterator<String> uris =  getUrisIterator();