293 lines
8.7 KiB
Java
293 lines
8.7 KiB
Java
/**
|
|
*
|
|
*/
|
|
package org.gcube.common.workspacetaskexecutor;
|
|
|
|
import java.io.IOException;
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
import java.util.Random;
|
|
import java.util.UUID;
|
|
|
|
import org.gcube.common.homelibrary.home.exceptions.HomeNotFoundException;
|
|
import org.gcube.common.homelibrary.home.exceptions.InternalErrorException;
|
|
import org.gcube.common.homelibrary.home.workspace.WorkspaceItem;
|
|
import org.gcube.common.homelibrary.home.workspace.exceptions.ItemNotFoundException;
|
|
import org.gcube.common.homelibrary.home.workspace.exceptions.WorkspaceFolderNotFoundException;
|
|
import org.gcube.common.workspacetaskexecutor.dataminer.WorkspaceDataMinerTaskExecutor;
|
|
import org.gcube.common.workspacetaskexecutor.shared.TaskParameter;
|
|
import org.gcube.common.workspacetaskexecutor.shared.TaskParameterType;
|
|
import org.gcube.common.workspacetaskexecutor.shared.dataminer.TaskConfiguration;
|
|
import org.gcube.common.workspacetaskexecutor.util.Converter;
|
|
import org.gcube.common.workspacetaskexecutor.util.JsonUtil;
|
|
import org.gcube.common.workspacetaskexecutor.util.WsUtil;
|
|
import org.gcube.data.analysis.dataminermanagercl.shared.parameters.ParameterType;
|
|
import org.json.JSONArray;
|
|
import org.json.JSONException;
|
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import com.fasterxml.jackson.core.type.TypeReference;
|
|
|
|
|
|
/**
|
|
*
|
|
* @author Francesco Mangiacrapa francesco.mangiacrapa@isti.cnr.it
|
|
* Apr 26, 2018
|
|
*/
|
|
public class TestDataMinerTaskExecutor {
|
|
|
|
|
|
public static String USERNAME = "francesco.mangiacrapa";
|
|
public static String SCOPE = "/gcube/devsec";
|
|
|
|
public static String WORKSPACE_FOLDER_ID = "f5c2f5ab-5c35-4418-8e60-d48d173538ed";
|
|
|
|
private static JsonUtil jUtil = new JsonUtil();
|
|
|
|
//CREATE DUMMY CONFIGURATIONS
|
|
private static List<TaskConfiguration> listDummyConf;
|
|
|
|
|
|
/**
|
|
*
|
|
*/
|
|
private static void eraseAllTaskConfigurations(WorkspaceDataMinerTaskExecutor exec) {
|
|
|
|
try {
|
|
Boolean done = exec.eraseAllTaskConfigurations(WORKSPACE_FOLDER_ID);
|
|
System.out.println("\n\nErase configurations done: "+done);
|
|
}
|
|
catch (Exception e1) {
|
|
// TODO Auto-generated catch block
|
|
e1.printStackTrace();
|
|
}
|
|
}
|
|
|
|
private static void setDummyTaskConfigurations(WorkspaceDataMinerTaskExecutor exec){
|
|
|
|
|
|
//SET TASK CONFIGURATION
|
|
try {
|
|
for (TaskConfiguration taskConfiguration : listDummyConf) {
|
|
exec.setTaskConfiguration(taskConfiguration);
|
|
}
|
|
System.out.println("\n\nSet Task configurations done!");
|
|
}
|
|
catch (Exception e) {
|
|
// TODO Auto-generated catch block
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
private static void deleteConfiguration(WorkspaceDataMinerTaskExecutor exec, TaskConfiguration conf){
|
|
try {
|
|
Boolean done = exec.removeTaskConfiguration(conf);
|
|
System.out.println("\n\nErase configuration done: "+done);
|
|
}
|
|
catch (Exception e) {
|
|
// TODO Auto-generated catch block
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
|
|
public static void main(String[] args) {
|
|
|
|
// ScopeProvider.instance.set(SCOPE);
|
|
// listDummyConf = gelDummyListOfConfigurations(3);
|
|
// WorkspaceDataMinerTaskExecutor exec = WorkspaceDataMinerTaskExecutor.getInstance();
|
|
// exec.withOwner(USERNAME);
|
|
// //jsonCheck();
|
|
//
|
|
// //ERASE ALL CONFIGURATIONS
|
|
// eraseAllTaskConfigurations(exec);
|
|
|
|
|
|
//GET LIST CONFIGURATIONS
|
|
//getConfigurations(exec);
|
|
|
|
//ERASE ALL CONFIGURATIONS
|
|
//eraseAllTaskConfigurations(exec);
|
|
|
|
//SET TASK CONFIGURATION
|
|
//setDummyTaskConfigurations(exec);
|
|
//
|
|
//// deleteConfiguration(exec, listDummyConf.get(1));
|
|
////
|
|
//getConfigurations(exec);
|
|
|
|
|
|
// listDummyConf.get(2).setTaskId("Updated task id");
|
|
// HashMap<String, String> map = new HashMap<String, String>();
|
|
// map.put("Pippo", "Value Pippo");
|
|
// map.put("Paperino", "Value Paperino");
|
|
// listDummyConf.get(2).setMapParameters(map);
|
|
//
|
|
// try {
|
|
// exec.setTaskConfiguration(listDummyConf.get(2));
|
|
// }
|
|
// catch (Exception e) {
|
|
// // TODO Auto-generated catch block
|
|
// e.printStackTrace();
|
|
// };
|
|
//
|
|
// getConfigurations(exec);
|
|
|
|
//
|
|
// //UPDATE TASK CONFIGURATION
|
|
// HashMap<String, String> map = new HashMap<String, String>();
|
|
// map.put("Pippo", "Value Pippo");
|
|
// map.put("Paperino", "Value Paperino");
|
|
// c2.setMapParameters(map);
|
|
//
|
|
// try {
|
|
// exec.setTaskConfiguration(c2);
|
|
// }
|
|
// catch (Exception e) {
|
|
// // TODO Auto-generated catch block
|
|
// e.printStackTrace();
|
|
// }
|
|
|
|
//checkGubeProperties(gelDummyListOfConfigurations());
|
|
|
|
|
|
// try {
|
|
// //exec.removeTaskConfiguration(taskConfiguration)
|
|
// //exec.checkItemExecutable(WORKSPACE_FOLDER_ID);
|
|
// }
|
|
// catch (ItemNotExecutableException e) {
|
|
// // TODO Auto-generated catch block
|
|
// e.printStackTrace();
|
|
//
|
|
// System.out.println("The item is not executable...");
|
|
// }
|
|
// catch (Exception e) {
|
|
// // TODO Auto-generated catch block
|
|
// e.printStackTrace();
|
|
// }
|
|
|
|
}
|
|
|
|
public static List<TaskConfiguration> getConfigurations(WorkspaceDataMinerTaskExecutor exec){
|
|
|
|
try {
|
|
List<TaskConfiguration> conf = exec.getListOfTaskConfigurations(WORKSPACE_FOLDER_ID);
|
|
if(conf!=null){
|
|
System.out.println("\n\nSaved configuration/s is/are: ");
|
|
for (TaskConfiguration taskConfiguration : conf) {
|
|
System.out.println(taskConfiguration);
|
|
}
|
|
}
|
|
|
|
return conf;
|
|
}
|
|
catch (Exception e) {
|
|
// TODO Auto-generated catch block
|
|
e.printStackTrace();
|
|
}
|
|
return null;
|
|
}
|
|
|
|
|
|
public static void checkGubeProperties(List<TaskConfiguration> listConfigurations){
|
|
|
|
//SET
|
|
try {
|
|
WorkspaceItem workspaceItem = WsUtil.getItem(USERNAME, WORKSPACE_FOLDER_ID);
|
|
|
|
JSONArray jsonArray = jUtil.toJSONArray(listConfigurations);
|
|
System.out.println("Json array to save: "+jsonArray);
|
|
WsUtil.setPropertyValue(workspaceItem, WorkspaceDataMinerTaskExecutor.WS_DM_TASK_TASK_CONF, jsonArray.toString());
|
|
|
|
//GET
|
|
String jsonArrayConf = WsUtil.getPropertyValue(workspaceItem, WorkspaceDataMinerTaskExecutor.WS_DM_TASK_TASK_CONF);
|
|
System.out.println("Json array read from "+WorkspaceDataMinerTaskExecutor.WS_DM_TASK_TASK_CONF+": "+jsonArray);
|
|
|
|
|
|
TypeReference<List<TaskConfiguration>> mapType = new TypeReference<List<TaskConfiguration>>() {};
|
|
List<TaskConfiguration> listUnM = jUtil.readList(jsonArrayConf, mapType);
|
|
System.out.println("Json array to listUnM...");
|
|
for (TaskConfiguration taskConfiguration : listUnM) {
|
|
System.out.println(taskConfiguration);
|
|
}
|
|
}
|
|
catch (WorkspaceFolderNotFoundException | ItemNotFoundException
|
|
| InternalErrorException | HomeNotFoundException | JsonProcessingException | JSONException e) {
|
|
// TODO Auto-generated catch block
|
|
e.printStackTrace();
|
|
}
|
|
catch (IOException e) {
|
|
// TODO Auto-generated catch block
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
public static TaskConfiguration createDummyConfiguration(int index){
|
|
List<ParameterType> availableTypes = Converter.getEnumList(ParameterType.class);
|
|
List<TaskParameterType> types = new ArrayList<TaskParameterType>();
|
|
for (ParameterType parameter : availableTypes) {
|
|
types.add(new TaskParameterType(parameter.name()));
|
|
}
|
|
|
|
System.out.println(types.toString());
|
|
|
|
// for (String availableType : tpt.getParametersTypes()) {
|
|
// System.out.println(availableType);
|
|
// }
|
|
|
|
List<TaskParameter> listParameters = new ArrayList<TaskParameter>();
|
|
|
|
TaskParameter tp = new TaskParameter();
|
|
tp.setKey("publiclink");
|
|
tp.setValue("this is the public link "+index);
|
|
tp.setType(new TaskParameterType(ParameterType.FILE.toString()));
|
|
|
|
listParameters.add(tp);
|
|
|
|
TaskParameter tp2 = new TaskParameter();
|
|
tp2.setKey("key"+index);
|
|
tp2.setValue("value "+index);
|
|
tp2.setType(types.get(new Random().nextInt(types.size())));
|
|
listParameters.add(tp2);
|
|
|
|
return new TaskConfiguration(index+"", UUID.randomUUID().toString(), index+"name", null, USERNAME, SCOPE, "my token", WORKSPACE_FOLDER_ID, listParameters);
|
|
}
|
|
|
|
|
|
public static List<TaskConfiguration> gelDummyListOfConfigurations(int total){
|
|
List<TaskConfiguration> listConfigurations = new ArrayList<>(total);
|
|
for (int i=0; i<total; i++) {
|
|
TaskConfiguration c = createDummyConfiguration(i);
|
|
listConfigurations.add(c);
|
|
}
|
|
return listConfigurations;
|
|
}
|
|
|
|
public static void jsonCheck(){
|
|
|
|
|
|
List<TaskConfiguration> listConfigurations = gelDummyListOfConfigurations(3);
|
|
try {
|
|
JSONArray jsonArray = jUtil.toJSONArray(listConfigurations);
|
|
System.out.println("Json array: "+jsonArray);
|
|
TypeReference<List<TaskConfiguration>> mapType = new TypeReference<List<TaskConfiguration>>() {};
|
|
List<TaskConfiguration> listUnM = jUtil.readList(jsonArray.toString(), mapType);
|
|
System.out.println("Json array to listUnM...");
|
|
for (TaskConfiguration taskConfiguration : listUnM) {
|
|
System.out.println(taskConfiguration);
|
|
}
|
|
|
|
}
|
|
catch (JsonProcessingException | JSONException e) {
|
|
// TODO Auto-generated catch block
|
|
e.printStackTrace();
|
|
}
|
|
catch (IOException e) {
|
|
// TODO Auto-generated catch block
|
|
e.printStackTrace();
|
|
}
|
|
|
|
}
|
|
}
|
|
|