263 lines
7.5 KiB
Java
263 lines
7.5 KiB
Java
/**
|
|
*
|
|
*/
|
|
package org.gcube.common.workspacetaskexecutor;
|
|
|
|
import java.io.IOException;
|
|
import java.util.ArrayList;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
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.scope.api.ScopeProvider;
|
|
import org.gcube.common.workspacetaskexecutor.dataminer.WorkspaceDataMinerTaskExecutor;
|
|
import org.gcube.common.workspacetaskexecutor.shared.dataminer.TaskConfiguration;
|
|
import org.gcube.common.workspacetaskexecutor.util.JsonUtil;
|
|
import org.gcube.common.workspacetaskexecutor.util.WsUtil;
|
|
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 = gelDummyListOfConfigurations(3);
|
|
|
|
/**
|
|
*
|
|
*/
|
|
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);
|
|
WorkspaceDataMinerTaskExecutor exec = WorkspaceDataMinerTaskExecutor.getInstance();
|
|
exec.withOwner(USERNAME);
|
|
//jsonCheck();
|
|
|
|
//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){
|
|
Map<String, String> mapParameters = new HashMap<String, String>();
|
|
mapParameters.put("publiclink", "this is the public link "+index);
|
|
return new TaskConfiguration(index+"", UUID.randomUUID().toString(), null, SCOPE, "my token", WORKSPACE_FOLDER_ID, mapParameters);
|
|
}
|
|
|
|
|
|
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();
|
|
}
|
|
|
|
}
|
|
}
|
|
|