161 lines
5.2 KiB
Java
161 lines
5.2 KiB
Java
/**
|
|
*
|
|
*/
|
|
package org.gcube.portlets.user.workspace.server.util;
|
|
|
|
import javax.servlet.http.HttpSession;
|
|
|
|
import org.gcube.application.framework.core.session.ASLSession;
|
|
import org.gcube.application.framework.core.session.SessionManager;
|
|
import org.gcube.common.core.utils.logging.GCUBEClientLog;
|
|
import org.gcube.common.core.utils.logging.GCUBELog;
|
|
import org.gcube.portlets.user.homelibrary.home.HomeLibrary;
|
|
import org.gcube.portlets.user.homelibrary.home.exceptions.HomeNotFoundException;
|
|
import org.gcube.portlets.user.homelibrary.home.exceptions.InternalErrorException;
|
|
import org.gcube.portlets.user.homelibrary.home.workspace.Workspace;
|
|
import org.gcube.portlets.user.homelibrary.home.workspace.exceptions.WorkspaceFolderNotFoundException;
|
|
import org.gcube.portlets.user.workspace.server.GWTWorkspaceBuilder;
|
|
|
|
|
|
/**
|
|
* @author Federico De Faveri defaveri@isti.cnr.it
|
|
*
|
|
*/
|
|
public class Util {
|
|
|
|
public static final String USERNAME_ATTRIBUTE = "username";
|
|
public static final String FOLDERIMPORTER_ATTRIBUTE = "FOLDER_IMPORTER";
|
|
public static final String METADATACONVERTER_ATTRIBUTE = "METADATA_CONVERTER";
|
|
public static final String WORKSPACE_EVENT_COLLECTOR_ATTRIBUTE = "EVENT_COLLECTOR";
|
|
public static final String WORKSPACEBUILDER_ATTRIBUTE = "WORKSPACEBUILDER";
|
|
|
|
// public static final String TEST_SCOPE = "/gcube/devsec";
|
|
// public static final String TEST_USER = "pasquale.pagano";
|
|
|
|
public static final String TEST_SCOPE = "/gcube/devsec/devVRE";
|
|
// public static final String TEST_USER = "federico.defaveri";
|
|
// public static final String TEST_USER = "massimiliano.assante";
|
|
public static final String TEST_USER = "francesco.mangiacrapa";
|
|
|
|
// public static final String TEST_USER = "pasquale.pagano";
|
|
|
|
public static GCUBEClientLog defaultLogger = new GCUBEClientLog("WorkspacePortlet");
|
|
|
|
public static ASLSession getAslSession(HttpSession httpSession)
|
|
{
|
|
String sessionID = httpSession.getId();
|
|
String user = (String) httpSession.getAttribute(USERNAME_ATTRIBUTE);
|
|
|
|
if (user == null) {
|
|
|
|
defaultLogger.error("WORKSPACE PORTLET STARTING IN TEST MODE - NO USER FOUND");
|
|
|
|
//for test only
|
|
httpSession.setAttribute(USERNAME_ATTRIBUTE, TEST_USER);
|
|
ASLSession session = SessionManager.getInstance().getASLSession(sessionID, TEST_USER);
|
|
session.setScope(TEST_SCOPE);
|
|
//session.setScope("/d4science.research-infrastructures.eu/Ecosystem/TryIt");
|
|
|
|
return session;
|
|
}
|
|
|
|
return SessionManager.getInstance().getASLSession(sessionID, user);
|
|
}
|
|
|
|
public static Workspace getWorkspace(final HttpSession httpSession) throws InternalErrorException, HomeNotFoundException, WorkspaceFolderNotFoundException
|
|
{
|
|
final ASLSession session = getAslSession(httpSession);
|
|
|
|
Workspace workspace = HomeLibrary.getUserWorkspace(session);
|
|
|
|
final GCUBELog logger = getLogger(workspace);
|
|
|
|
if (session.getAttribute(METADATACONVERTER_ATTRIBUTE) == null){
|
|
|
|
logger.trace("Initializing the Metadata converter");
|
|
|
|
Thread mcLoader = new Thread(new Runnable(){
|
|
|
|
public void run() {
|
|
try {
|
|
MetadataConverter mc = new MetadataConverter(logger);
|
|
mc.setup(session);
|
|
session.setAttribute(METADATACONVERTER_ATTRIBUTE, mc);
|
|
}catch (Exception e) {
|
|
logger.error("Error initializing the Metadata Converter: "+e.getMessage());
|
|
}
|
|
}
|
|
|
|
});
|
|
|
|
mcLoader.start();
|
|
}
|
|
if (session.getAttribute(WORKSPACE_EVENT_COLLECTOR_ATTRIBUTE) == null){
|
|
|
|
|
|
logger.trace("Initializing the event collector");
|
|
|
|
//we prepare the event collector
|
|
WorkspaceEventCollector eventCollector = new WorkspaceEventCollector(logger);
|
|
workspace.addWorkspaceListener(eventCollector);
|
|
session.setAttribute(WORKSPACE_EVENT_COLLECTOR_ATTRIBUTE, eventCollector);
|
|
}
|
|
|
|
if (session.getAttribute(WORKSPACEBUILDER_ATTRIBUTE) == null)
|
|
{
|
|
logger.trace("Initializing the workspace area builder");
|
|
|
|
GWTWorkspaceBuilder builder = new GWTWorkspaceBuilder(logger);
|
|
session.setAttribute(WORKSPACEBUILDER_ATTRIBUTE, builder);
|
|
}
|
|
|
|
return workspace;
|
|
|
|
}
|
|
|
|
public static GCUBELog getLogger(Workspace workspace)
|
|
{
|
|
/* TODO if (workspace instanceof PersistentFSWorkspace){
|
|
PersistentFSWorkspace persistentFSWorkspace = (PersistentFSWorkspace) workspace;
|
|
try {
|
|
return persistentFSWorkspace.getWorkspacePortletLogger();
|
|
} catch (InternalErrorException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}*/
|
|
|
|
return defaultLogger;
|
|
}
|
|
|
|
public static MetadataConverter getMetadataConverter(GCUBELog logger, HttpSession httpSession)
|
|
{
|
|
MetadataConverter mc = (MetadataConverter) httpSession.getAttribute(METADATACONVERTER_ATTRIBUTE);
|
|
|
|
if (mc==null)
|
|
{
|
|
|
|
mc = new MetadataConverter(logger);
|
|
ASLSession session = getAslSession(httpSession);
|
|
mc.setup(session);
|
|
session.setAttribute(METADATACONVERTER_ATTRIBUTE, mc);
|
|
}
|
|
|
|
mc.isReady();
|
|
|
|
return mc;
|
|
}
|
|
|
|
public static WorkspaceEventCollector getEventCollector(HttpSession httpSession)
|
|
{
|
|
ASLSession session = getAslSession(httpSession);
|
|
return (WorkspaceEventCollector) session.getAttribute(Util.WORKSPACE_EVENT_COLLECTOR_ATTRIBUTE);
|
|
}
|
|
|
|
public static GWTWorkspaceBuilder getGWTWorkspaceBuilder(HttpSession httpSession)
|
|
{
|
|
ASLSession session = getAslSession(httpSession);
|
|
return (GWTWorkspaceBuilder) session.getAttribute(Util.WORKSPACEBUILDER_ATTRIBUTE);
|
|
}
|
|
|
|
}
|