93 lines
3.4 KiB
Java
93 lines
3.4 KiB
Java
package org.gcube.portlets.user.statisticalalgorithmsimporter.server.storage;
|
|
|
|
import java.beans.XMLDecoder;
|
|
import java.beans.XMLEncoder;
|
|
import java.io.ByteArrayInputStream;
|
|
import java.io.ByteArrayOutputStream;
|
|
import java.io.InputStream;
|
|
|
|
import org.gcube.application.framework.core.session.ASLSession;
|
|
import org.gcube.common.homelibrary.home.exceptions.InternalErrorException;
|
|
import org.gcube.common.homelibrary.home.workspace.WorkspaceItem;
|
|
import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.exception.StatAlgoImporterServiceException;
|
|
import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.project.Project;
|
|
import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.project.ProjectFolder;
|
|
import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.workspace.ItemDescription;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
|
/**
|
|
*
|
|
* @author Giancarlo Panichi email: <a
|
|
* href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
|
*
|
|
*/
|
|
public class ProjectArchiver {
|
|
|
|
public static final Logger logger = LoggerFactory
|
|
.getLogger(ProjectArchiver.class);
|
|
|
|
public static void archive(Project project, ASLSession aslSession)
|
|
throws StatAlgoImporterServiceException {
|
|
|
|
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
|
|
XMLEncoder xmlEncoder = new XMLEncoder(byteArrayOutputStream);
|
|
xmlEncoder.writeObject(project);
|
|
xmlEncoder.close();
|
|
logger.debug("Archived:" + byteArrayOutputStream);
|
|
|
|
ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(
|
|
byteArrayOutputStream.toByteArray());
|
|
FilesStorage filesStorage = new FilesStorage();
|
|
filesStorage.saveStatisticalAlgorithmProject(aslSession.getUsername(),
|
|
byteArrayInputStream, project.getProjectFolder()
|
|
.getItemDescription().getId());
|
|
|
|
}
|
|
|
|
public static boolean existProjectInFolder(ItemDescription newProjectFolder,
|
|
ASLSession aslSession) throws StatAlgoImporterServiceException {
|
|
FilesStorage filesStorage = new FilesStorage();
|
|
return filesStorage.existProjectItemOnWorkspace(aslSession.getUsername(), newProjectFolder.getId());
|
|
|
|
}
|
|
|
|
|
|
public static Project readProject(ItemDescription newProjectFolder,
|
|
ASLSession aslSession) throws StatAlgoImporterServiceException {
|
|
FilesStorage filesStorage = new FilesStorage();
|
|
InputStream inputStream = filesStorage.retrieveProjectItemOnWorkspace(
|
|
aslSession.getUsername(), newProjectFolder.getId());
|
|
|
|
XMLDecoder xmlDecoder = new XMLDecoder(inputStream);
|
|
Project project = (Project) xmlDecoder.readObject();
|
|
xmlDecoder.close();
|
|
|
|
WorkspaceItem projectFolderItem=filesStorage.retrieveItemInfoOnWorkspace(aslSession.getUsername(), newProjectFolder.getId());
|
|
try {
|
|
newProjectFolder.setId(projectFolderItem.getId());
|
|
newProjectFolder.setName(projectFolderItem.getName());
|
|
newProjectFolder.setOwner(projectFolderItem.getOwner().getPortalLogin());
|
|
newProjectFolder.setPath(projectFolderItem.getPath());
|
|
newProjectFolder.setType(projectFolderItem.getType().name());
|
|
} catch (InternalErrorException e) {
|
|
logger.error(e.getLocalizedMessage());
|
|
e.printStackTrace();
|
|
throw new StatAlgoImporterServiceException(e.getLocalizedMessage());
|
|
|
|
}
|
|
|
|
if(project!=null && project.getProjectFolder()!=null &&
|
|
newProjectFolder.compareInfo(project.getProjectFolder().getItemDescription())){
|
|
|
|
} else {
|
|
project.setProjectFolder(new ProjectFolder(newProjectFolder));
|
|
archive(project, aslSession);
|
|
}
|
|
return project;
|
|
}
|
|
|
|
|
|
}
|