From fe6c2a06098d7d559e64632c4c83a834a2b1a3eb Mon Sep 17 00:00:00 2001
From: Luca Frosini <luca.frosini@isti.cnr.it>
Date: Fri, 23 Sep 2016 12:24:23 +0000
Subject: [PATCH] Fixing tests

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/private/luca.frosini/infrastructure-tests@131745 82a268e6-3cf1-43bd-a215-b396298e98cf
---
 pom.xml                                       |  34 +++++-
 ...eeperPluginSmartExecutorSchedulerTest.java |   5 +-
 src/test/java/org/gcube/test/TempTest.java    |  54 +++++++++
 .../org/gcube/testutility/ScopedTest.java     |   7 +-
 .../org/gcube/testutility/TestUtility.java    |  14 +--
 .../executor/client/DefaultExecutorTest.java  | 107 ++++++++++++------
 .../executor/client/QueriedClientTest.java    |   2 +-
 7 files changed, 166 insertions(+), 57 deletions(-)

diff --git a/pom.xml b/pom.xml
index 373d0e4..1672578 100644
--- a/pom.xml
+++ b/pom.xml
@@ -22,12 +22,35 @@
 		<url>https://svn.d4science.research-infrastructures.eu/gcube//private/luca.frosini/${project.artifactId}</url>
 	</scm>
 
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<groupId>org.gcube.distribution</groupId>
+				<artifactId>gcube-bom</artifactId>
+				<version>LATEST</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+
+
   <dependencies>
 
+		<dependency>
+			<groupId>org.gcube.common</groupId>
+			<artifactId>authorization-client</artifactId>
+			<scope>provided</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.gcube.common</groupId>
+			<artifactId>common-authorization</artifactId>
+			<scope>provided</scope>
+		</dependency>
+
 		<dependency>
 			<groupId>org.gcube.data.publishing</groupId>
 			<artifactId>document-store-lib</artifactId>
-			<version>[1.1.0-SNAPSHOT, 2.0.0-SNAPSHOT)</version>
 			<scope>test</scope>
 		</dependency>
 		<dependency>
@@ -65,7 +88,6 @@
 		<dependency>
 			<groupId>org.gcube.accounting</groupId>
 			<artifactId>accounting-lib</artifactId>
-			<version>[2.2.0-SNAPSHOT, 3.0.0-SNAPSHOT)</version>
 			<scope>test</scope>
 		</dependency>
 		
@@ -89,6 +111,9 @@
 			<scope>test</scope>
 		</dependency>
 
+
+
+
 		 
 		<dependency>
 			<groupId>org.gcube.vremanagement</groupId>
@@ -118,7 +143,7 @@
 		<dependency>
 			<groupId>org.acme</groupId>
 			<artifactId>HelloWorldPlugin</artifactId>
-			<version>[1.1.0-SNAPSHOT, 2.0.0-SNAPSHOT)</version>
+			<version>[1.2.0-SNAPSHOT, 2.0.0-SNAPSHOT)</version>
 			<scope>test</scope>
 		</dependency>
 		<!--
@@ -140,20 +165,17 @@
 		<dependency>
 			<groupId>org.gcube.resources</groupId>
 			<artifactId>registry-publisher</artifactId>
-			<version>[1.0.0-SNAPSHOT, 2.0.0-SNAPSHOT)</version>
 			<scope>test</scope>
 		</dependency>
 		<dependency>
 			<groupId>org.gcube.core</groupId>
 			<artifactId>common-encryption</artifactId>
-			<version>[1.0.0-SNAPSHOT, 2.0.0-SNAPSHOT)</version>
 			<scope>test</scope>
 		</dependency>
 		
 		<dependency>
 			<groupId>org.slf4j</groupId>
 			<artifactId>slf4j-api</artifactId>
-			<version>1.7.5</version>
 			<scope>test</scope>
 		</dependency>
 		<dependency>
diff --git a/src/test/java/org/gcube/informationsystem/sweeper/ISSweeperPluginSmartExecutorSchedulerTest.java b/src/test/java/org/gcube/informationsystem/sweeper/ISSweeperPluginSmartExecutorSchedulerTest.java
index e238c8f..59687c4 100644
--- a/src/test/java/org/gcube/informationsystem/sweeper/ISSweeperPluginSmartExecutorSchedulerTest.java
+++ b/src/test/java/org/gcube/informationsystem/sweeper/ISSweeperPluginSmartExecutorSchedulerTest.java
@@ -7,7 +7,6 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.UUID;
 
-import org.gcube.common.scope.api.ScopeProvider;
 import org.gcube.testutility.ScopedTest;
 import org.gcube.vremanagement.executor.api.types.LaunchParameter;
 import org.gcube.vremanagement.executor.api.types.Scheduling;
@@ -33,7 +32,7 @@ public class ISSweeperPluginSmartExecutorSchedulerTest extends ScopedTest {
 	public void before() throws Exception{
 		super.before();
 		//ScopeProvider.instance.reset(); // Comment this to run the test. this line has been added to avoid unwanted launch
-		ScopeProvider.instance.set("/gcube");
+		//ScopeProvider.instance.set("/gcube/devsec");
 		proxy = ExecutorPlugin.getExecutorProxy(ISSweeperPluginDeclaration.NAME).build();
 		Assert.assertNotNull(proxy);
 	}
@@ -41,7 +40,7 @@ public class ISSweeperPluginSmartExecutorSchedulerTest extends ScopedTest {
 	public UUID scheduleTest(Scheduling scheduling) throws Exception {
 		Map<String, Object> inputs = new HashMap<String, Object>();
 		logger.debug("Inputs : {}", inputs);
-		inputs.put(ISSweeperPlugin.EXPIRING_MINUTES_TIMEOUT, 15);
+		inputs.put(ISSweeperPlugin.EXPIRING_MINUTES_TIMEOUT, 30);
 		inputs.put(ISSweeperPlugin.DEAD_DAYS_TIMEOUT, 3);
 		
 		LaunchParameter parameter = new LaunchParameter(ISSweeperPluginDeclaration.NAME, inputs);
diff --git a/src/test/java/org/gcube/test/TempTest.java b/src/test/java/org/gcube/test/TempTest.java
index b4dba2b..d096f6f 100644
--- a/src/test/java/org/gcube/test/TempTest.java
+++ b/src/test/java/org/gcube/test/TempTest.java
@@ -3,6 +3,18 @@
  */
 package org.gcube.test;
 
+import java.io.StringWriter;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.UUID;
+
+import org.gcube.common.resources.gcore.GenericResource;
+import org.gcube.common.resources.gcore.Resource;
+import org.gcube.common.resources.gcore.Resources;
+import org.gcube.common.scope.api.ScopeProvider;
+import org.gcube.informationsystem.publisher.RegistryPublisherFactory;
+import org.gcube.informationsystem.publisher.ScopedPublisher;
+import org.gcube.informationsystem.publisher.exception.RegistryNotFoundException;
 import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -24,4 +36,46 @@ public class TempTest {
 			logger.error("Not found", e);
 		}
 	}
+	
+	private static void publishScopedResource(Resource resource, List<String> scopes) throws RegistryNotFoundException, Exception {
+		StringWriter stringWriter = new StringWriter();
+		Resources.marshal(resource, stringWriter);
+		
+		ScopedPublisher scopedPublisher = RegistryPublisherFactory.scopedPublisher();
+	    try {
+			logger.debug("Trying to publish to {}:\n{}", scopes, stringWriter);
+	    	scopedPublisher.create(resource, scopes);
+		} catch (RegistryNotFoundException e) {
+			logger.error("The resource was not published", e);
+			throw e;
+		}
+	}
+	
+	@Test
+	public void anotherTest(){
+		ScopeProvider.instance.set("/gcube");
+		try {
+			
+			GenericResource a = new GenericResource();
+			 
+			List<String> b = new LinkedList<>();
+			String scope = ScopeProvider.instance.get();
+			b.add(scope);
+	 
+			a.newProfile().name(UUID.randomUUID().toString()).type("FHN-nodes").description("FHN node");
+			a.profile().newBody("<name>Nunzio</name>");
+	 		
+			try {
+				publishScopedResource(a,b);
+			} catch (Exception e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			
+			
+			logger.debug("OK");
+		} catch (Exception e) {
+			logger.error("Not found", e);
+		}
+	}
 }
diff --git a/src/test/java/org/gcube/testutility/ScopedTest.java b/src/test/java/org/gcube/testutility/ScopedTest.java
index f329fd9..b44090f 100644
--- a/src/test/java/org/gcube/testutility/ScopedTest.java
+++ b/src/test/java/org/gcube/testutility/ScopedTest.java
@@ -4,6 +4,7 @@
 package org.gcube.testutility;
 
 //import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
+import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
 import org.gcube.common.scope.api.ScopeProvider;
 import org.junit.After;
 import org.junit.Before;
@@ -16,13 +17,13 @@ public class ScopedTest {
 
 	@Before
 	public void before() throws Exception{
-		//SecurityTokenProvider.instance.set(TestUtility.TOKEN);
-		ScopeProvider.instance.set("/gcube/devNext");
+		SecurityTokenProvider.instance.set(TestUtility.TOKEN);
+		ScopeProvider.instance.set("/gcube/devNext/NextNext");
 	}
 	
 	@After
 	public void after() throws Exception{
-		//SecurityTokenProvider.instance.reset();
+		SecurityTokenProvider.instance.reset();
 		ScopeProvider.instance.reset();
 	}
 	
diff --git a/src/test/java/org/gcube/testutility/TestUtility.java b/src/test/java/org/gcube/testutility/TestUtility.java
index cb20c48..4ac81bd 100644
--- a/src/test/java/org/gcube/testutility/TestUtility.java
+++ b/src/test/java/org/gcube/testutility/TestUtility.java
@@ -5,10 +5,9 @@ package org.gcube.testutility;
 
 import java.io.StringWriter;
 
-/*import org.gcube.common.authorization.client.Constants;
 import org.gcube.common.authorization.library.AuthorizationEntry;
 import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
-*/
+import org.gcube.common.authorization.client.Constants;
 import org.gcube.common.resources.gcore.Resource;
 import org.gcube.common.resources.gcore.Resources;
 import org.gcube.common.scope.api.ScopeProvider;
@@ -24,7 +23,7 @@ import org.slf4j.LoggerFactory;
  */
 public class TestUtility {
 
-	public static final String TOKEN = "";
+	public static final String TOKEN = "7c66c94c-7f6e-49cd-9a34-909cd3832f3e-98187548";
 	public static final String PARENT_TOKEN = "";
 	
 	/**
@@ -33,23 +32,16 @@ public class TestUtility {
 	private static Logger logger = LoggerFactory.getLogger(TestUtility.class);
 	
 	public static String getScope(){
-		return ScopeProvider.instance.get();
-		//return getScopeFromToken();
-	}
-	
-	/*
-	public static String getScopeFromToken(){
 		String token = SecurityTokenProvider.instance.get();
 		AuthorizationEntry authorizationEntry;
 		try {
 			authorizationEntry = Constants.authorizationService().get(token);
 		} catch (Exception e) {
-			throw new RuntimeException(e);
+			return ScopeProvider.instance.get();
 		}
 		String scope = authorizationEntry.getContext();
 		return scope;
 	}
-	*/
 	
 	/**
 	 * Publish the provided resource on current scope
diff --git a/src/test/java/org/gcube/vremanagement/executor/client/DefaultExecutorTest.java b/src/test/java/org/gcube/vremanagement/executor/client/DefaultExecutorTest.java
index 7227d76..a5177cb 100644
--- a/src/test/java/org/gcube/vremanagement/executor/client/DefaultExecutorTest.java
+++ b/src/test/java/org/gcube/vremanagement/executor/client/DefaultExecutorTest.java
@@ -7,10 +7,10 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.UUID;
 
+import org.acme.HWPluginStateNotification;
 import org.acme.HelloWorldPlugin;
 import org.acme.HelloWorldPluginDeclaration;
-import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
-import org.gcube.testutility.TestUtility;
+import org.gcube.testutility.ScopedTest;
 import org.gcube.vremanagement.executor.api.types.LaunchParameter;
 import org.gcube.vremanagement.executor.api.types.Scheduling;
 import org.gcube.vremanagement.executor.client.plugins.ExecutorPlugin;
@@ -29,22 +29,22 @@ import org.slf4j.LoggerFactory;
  * @author Luca Frosini (ISTI - CNR) http://www.lucafrosini.com/
  *
  */
-public class DefaultExecutorTest {
+public class DefaultExecutorTest extends ScopedTest {
 	
 	private static Logger logger = LoggerFactory.getLogger(DefaultExecutorTest.class);
 	
 	private SmartExecutorProxy proxy;
 	
 	@Before
-	public void before(){
-		SecurityTokenProvider.instance.set(TestUtility.TOKEN);
+	public void before() throws Exception{
+		super.before();
 		proxy = ExecutorPlugin.getExecutorProxy().build();
 		Assert.assertNotNull(proxy);
 	}
 	
 	@After
-	public void after(){
-		SecurityTokenProvider.instance.reset();
+	public void after() throws Exception{
+		super.after();
 	}
 	
 	@Test
@@ -63,7 +63,7 @@ public class DefaultExecutorTest {
 	public void getState() {
 		String executionIdentifier = UUID.randomUUID().toString();
 		try {
-			proxy.getState(executionIdentifier);
+			proxy.getStateEvolution(executionIdentifier);
 		} catch (Exception e) {
 			Assert.assertEquals(PluginInstanceNotFoundException.class, e.getCause().getClass());
 		}
@@ -77,17 +77,21 @@ public class DefaultExecutorTest {
 		long sleepTime = 10000; // 1000 millisec * 10 = 10 sec
 		inputs.put(HelloWorldPlugin.SLEEP_TIME, sleepTime);
 		LaunchParameter launchParameter = new LaunchParameter(HelloWorldPluginDeclaration.NAME, inputs);
+		
+		Map<String, String> notificationInputs = new HashMap<String, String>();
+		notificationInputs.put("Hello", "Hello World Notification:) :)");
+		launchParameter.addPluginStateNotifications(HWPluginStateNotification.class, notificationInputs);
 		try {
 			String executionIdentifier = proxy.launch(launchParameter);
 
-			Thread.sleep(1000);
-			Assert.assertEquals(PluginState.RUNNING, proxy.getState(executionIdentifier));
+			Thread.sleep(1000); // 1 sec
+			Assert.assertEquals(PluginState.RUNNING, proxy.getStateEvolution(executionIdentifier).getPluginState());
 			
-			Thread.sleep(4000);
-			Assert.assertEquals(PluginState.RUNNING, proxy.getState(executionIdentifier));
+			Thread.sleep(4000); // 4 sec (total : 5 sec) 
+			Assert.assertEquals(PluginState.RUNNING, proxy.getStateEvolution(executionIdentifier).getPluginState());
 			
-			Thread.sleep(6000);
-			Assert.assertEquals(PluginState.DONE, proxy.getState(executionIdentifier));
+			Thread.sleep(6000); // 6 sec (total : 11 sec)
+			Assert.assertEquals(PluginState.DONE, proxy.getStateEvolution(executionIdentifier).getPluginState());
 			
 		} catch (Exception e) {
 			logger.error("testOk Exception", e);
@@ -104,23 +108,34 @@ public class DefaultExecutorTest {
 		
 		Map<String, Object> inputs = new HashMap<String, Object>();
 		inputs.put("Hello", "World");
-		long sleepTime = 10000; // 1000 millisec * 10 = 10 sec
+		long sleepTime = 20000; // 1000 millisec * 20 = 20 sec
 		inputs.put(HelloWorldPlugin.SLEEP_TIME, sleepTime);
 		// Every 5 minutes, for 12 times (one hour totally).
-		Scheduling scheduling = new Scheduling(60*5,12,false);
-		LaunchParameter launchParameter = new LaunchParameter(HelloWorldPluginDeclaration.NAME, inputs, scheduling);
+		Scheduling scheduling = new Scheduling(60*5,12,true);
+		scheduling.setGlobal(false);
 		
+		LaunchParameter launchParameter = new LaunchParameter(HelloWorldPluginDeclaration.NAME, inputs, scheduling);
+		Map<String, String> notificationInputs = new HashMap<String, String>();
+		notificationInputs.put("Hello", "Hello World Notification:) :)");
+		launchParameter.addPluginStateNotifications(HWPluginStateNotification.class, notificationInputs);
 		try {
 			String executionIdentifier = proxy.launch(launchParameter);
 
-			Thread.sleep(1000);
-			Assert.assertEquals(PluginState.RUNNING, proxy.getState(executionIdentifier));
+			Thread.sleep(1000); // 2 sec
+			Assert.assertEquals(PluginState.RUNNING, proxy.getStateEvolution(executionIdentifier).getPluginState());
 			
-			Thread.sleep(4000);
-			Assert.assertEquals(PluginState.RUNNING, proxy.getState(executionIdentifier));
+			Thread.sleep(4000); // 8 sec (total : 10 sec) 
+			Assert.assertEquals(PluginState.RUNNING, proxy.getStateEvolution(executionIdentifier).getPluginState());
 			
-			Thread.sleep(6000);
-			Assert.assertEquals(PluginState.DONE, proxy.getState(executionIdentifier));
+			Thread.sleep(6000); // 12 sec (total : 22 sec)
+			Assert.assertEquals(PluginState.DONE, proxy.getStateEvolution(executionIdentifier).getPluginState());
+			
+			Thread.sleep(1000*60*5); // After 5 minutes the thread should be active again
+			Assert.assertEquals(PluginState.RUNNING, proxy.getStateEvolution(executionIdentifier).getPluginState());
+			Assert.assertEquals(PluginState.RUNNING, proxy.getIterationStateEvolution(executionIdentifier, 1).getPluginState());
+			
+			logger.debug("Trying to stop scheduled task");
+			proxy.unSchedule(executionIdentifier, true);
 			
 		} catch (Exception e) {
 			logger.error("testOk Exception", e);
@@ -136,29 +151,55 @@ public class DefaultExecutorTest {
 		
 		Map<String, Object> inputs = new HashMap<String, Object>();
 		inputs.put("Hello", "World");
-		long sleepTime = 10000; // 1000 millisec * 10 = 10 sec
+		long sleepTime = 20000; // 1000 millisec * 20 = 20 sec
 		inputs.put(HelloWorldPlugin.SLEEP_TIME, sleepTime);
 		// Every 5 minutes, for 12 times (one hour totally).
 		Scheduling scheduling = new Scheduling(60*5,12,true);
-		LaunchParameter launchParameter = new LaunchParameter(HelloWorldPluginDeclaration.NAME, inputs, scheduling);
+		scheduling.setGlobal(true);
 		
+		LaunchParameter launchParameter = new LaunchParameter(HelloWorldPluginDeclaration.NAME, inputs, scheduling);
+		Map<String, String> notificationInputs = new HashMap<String, String>();
+		notificationInputs.put("Hello", "Hello World Notification:) :)");
+		launchParameter.addPluginStateNotifications(HWPluginStateNotification.class, notificationInputs);
 		try {
 			String executionIdentifier = proxy.launch(launchParameter);
-
-			Thread.sleep(1000);
-			Assert.assertEquals(PluginState.RUNNING, proxy.getState(executionIdentifier));
+			logger.debug("Task Lauched with ID : {}", executionIdentifier);
 			
-			Thread.sleep(4000);
-			Assert.assertEquals(PluginState.RUNNING, proxy.getState(executionIdentifier));
+			Thread.sleep(1000); // 2 sec
+			Assert.assertEquals(PluginState.RUNNING, proxy.getStateEvolution(executionIdentifier).getPluginState());
 			
-			Thread.sleep(6000);
-			Assert.assertEquals(PluginState.DONE, proxy.getState(executionIdentifier));
+			Thread.sleep(4000); // 8 sec (total : 10 sec) 
+			Assert.assertEquals(PluginState.RUNNING, proxy.getStateEvolution(executionIdentifier).getPluginState());
+			
+			Thread.sleep(6000); // 12 sec (total : 22 sec)
+			Assert.assertEquals(PluginState.DONE, proxy.getStateEvolution(executionIdentifier).getPluginState());
+			
+			Thread.sleep(1000*60*5); // After 5 minutes the thread should be active again
+			Assert.assertEquals(PluginState.RUNNING, proxy.getStateEvolution(executionIdentifier).getPluginState());
+			Assert.assertEquals(PluginState.RUNNING, proxy.getIterationStateEvolution(executionIdentifier, 1).getPluginState());
+			
+			proxy.stop(executionIdentifier);
+			
+			
+			Thread.sleep(1000*60*5); // After 5 minutes the thread should be active again. Goign to unschedule globally
+			logger.debug("Trying to stop scheduled task");
+			Assert.assertTrue(proxy.unSchedule(executionIdentifier, false));
+			
+			
+			Thread.sleep(1000*60); 
+			Assert.assertTrue(proxy.unSchedule(executionIdentifier, true));
 			
 		} catch (Exception e) {
 			logger.error("testOk Exception", e);
 			throw e;
 		}
-				
+		
+	}
+	
+	@Test
+	public void testUnschedule() throws Exception {
+		//proxy.unSchedule("542ddb03-d8d7-4913-8700-2acfa74c7485", true);
+		//proxy.unSchedule("37d8f020-cdeb-4b2c-b245-4deabc1fe149", false);
 	}
 
 }
diff --git a/src/test/java/org/gcube/vremanagement/executor/client/QueriedClientTest.java b/src/test/java/org/gcube/vremanagement/executor/client/QueriedClientTest.java
index 4103538..421a03e 100644
--- a/src/test/java/org/gcube/vremanagement/executor/client/QueriedClientTest.java
+++ b/src/test/java/org/gcube/vremanagement/executor/client/QueriedClientTest.java
@@ -55,7 +55,7 @@ public class QueriedClientTest {
 		LaunchParameter launchParameter = new LaunchParameter(HelloWorldPluginDeclaration.NAME, inputs);
 		try {
 			String executionIdentifier = proxy.launch(launchParameter);
-			proxy.getState(executionIdentifier);
+			proxy.getStateEvolution(executionIdentifier);
 		} catch (Exception e) {
 			throw e;
 		}