249 lines
8.4 KiB
Java
249 lines
8.4 KiB
Java
/**
|
|
*
|
|
*/
|
|
package org.gcube.portlets.user.td.gwtservice.server;
|
|
|
|
import java.io.IOException;
|
|
import java.util.Iterator;
|
|
import java.util.List;
|
|
import java.util.UUID;
|
|
|
|
import javax.servlet.ServletException;
|
|
import javax.servlet.http.HttpServlet;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import javax.servlet.http.HttpServletResponse;
|
|
import javax.servlet.http.HttpSession;
|
|
|
|
import org.apache.commons.fileupload.FileItem;
|
|
import org.apache.commons.fileupload.FileItemFactory;
|
|
import org.apache.commons.fileupload.FileUploadException;
|
|
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
|
|
import org.apache.commons.fileupload.servlet.ServletFileUpload;
|
|
import org.gcube.common.scope.api.ScopeProvider;
|
|
import org.gcube.portlets.user.td.gwtservice.server.file.CodelistMappingFileUploadSession;
|
|
import org.gcube.portlets.user.td.gwtservice.server.file.FileUploadListener;
|
|
import org.gcube.portlets.user.td.gwtservice.server.file.FileUtil;
|
|
import org.gcube.portlets.user.td.gwtservice.server.util.ServiceCredentials;
|
|
import org.gcube.portlets.user.td.gwtservice.shared.Constants;
|
|
import org.gcube.portlets.user.td.gwtservice.shared.exception.TDGWTServiceException;
|
|
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadMonitor;
|
|
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadState;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import com.allen_sauer.gwt.log.client.Log;
|
|
|
|
/**
|
|
*
|
|
* @author "Giancarlo Panichi" <a
|
|
* href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
|
*
|
|
*/
|
|
public class CodelistMappingUploadServlet extends HttpServlet {
|
|
|
|
protected static Logger logger = LoggerFactory
|
|
.getLogger(CodelistMappingUploadServlet.class);
|
|
|
|
/**
|
|
*
|
|
*/
|
|
private static final long serialVersionUID = -4197748678713054285L;
|
|
|
|
@SuppressWarnings("rawtypes")
|
|
protected void doPost(HttpServletRequest request,
|
|
HttpServletResponse response) throws ServletException, IOException {
|
|
|
|
logger.trace("Post");
|
|
|
|
HttpSession session = request.getSession();
|
|
|
|
if (session == null) {
|
|
logger.error("Error getting the upload session, no session valid found: "
|
|
+ session);
|
|
response.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR,
|
|
"ERROR-Error getting the user session, no session found"
|
|
+ session);
|
|
return;
|
|
}
|
|
logger.info("Codelist Mapping session id: " + session.getId());
|
|
|
|
ServiceCredentials serviceCredentials;
|
|
|
|
try {
|
|
String scopeGroupId = request.getParameter(Constants.CURR_GROUP_ID);
|
|
|
|
// String currUserId = request
|
|
// .getParameter(Constants.CURR_USER_ID);
|
|
// serviceCredentials = SessionUtil.getServiceCredentials(request,
|
|
// scopeGroupId, currUserId);
|
|
serviceCredentials = SessionUtil.getServiceCredentials(request,
|
|
scopeGroupId);
|
|
|
|
ScopeProvider.instance.set(serviceCredentials.getScope());
|
|
|
|
} catch (TDGWTServiceException e) {
|
|
logger.error(
|
|
"Error retrieving credentials:" + e.getLocalizedMessage(),
|
|
e);
|
|
throw new ServletException(e.getLocalizedMessage());
|
|
}
|
|
|
|
CodelistMappingFileUploadSession codelistMappingFileUploadSession = new CodelistMappingFileUploadSession();
|
|
// CodelistMappingMonitor codelistMappingMonitor=new
|
|
// CodelistMappingMonitor();
|
|
FileUploadMonitor fileUploadMonitor = new FileUploadMonitor();
|
|
|
|
String id = UUID.randomUUID().toString();
|
|
logger.info("Upload Id: " + id);
|
|
codelistMappingFileUploadSession.setId(id);
|
|
codelistMappingFileUploadSession
|
|
.setFileUploadState(FileUploadState.STARTED);
|
|
// codelistMappingFileUploadSession.setCodelistMappingMonitor(codelistMappingMonitor);
|
|
SessionUtil.setFileUploadMonitor(request, serviceCredentials,
|
|
fileUploadMonitor);
|
|
|
|
try {
|
|
SessionUtil.setCodelistMappingFileUploadSession(request,
|
|
serviceCredentials, codelistMappingFileUploadSession);
|
|
} catch (Exception e) {
|
|
logger.error(e.getLocalizedMessage(), e);
|
|
throw new ServletException(e.getLocalizedMessage());
|
|
}
|
|
|
|
FileItemFactory factory = new DiskFileItemFactory();
|
|
ServletFileUpload upload = new ServletFileUpload(factory);
|
|
|
|
FileUploadListener uploadListener = new FileUploadListener(
|
|
fileUploadMonitor);
|
|
upload.setProgressListener(uploadListener);
|
|
|
|
FileItem uploadItem = null;
|
|
Log.info("Start upload file ");
|
|
try {
|
|
List items = upload.parseRequest(request);
|
|
Iterator it = items.iterator();
|
|
while (it.hasNext()) {
|
|
FileItem item = (FileItem) it.next();
|
|
if (!item.isFormField()
|
|
&& "uploadFormElement".equals(item.getFieldName())) {
|
|
uploadItem = item;
|
|
}
|
|
}
|
|
} catch (FileUploadException e) {
|
|
FileUploadMonitor fum = null;
|
|
try {
|
|
fum = SessionUtil.getFileUploadMonitor(request,
|
|
serviceCredentials);
|
|
} catch (TDGWTServiceException e1) {
|
|
logger.error(e1.getLocalizedMessage(), e1);
|
|
throw new ServletException(e1.getLocalizedMessage());
|
|
}
|
|
fum.setFailed("An error occured elaborating the HTTP request",
|
|
FileUtil.exceptionDetailMessage(e));
|
|
SessionUtil.setFileUploadMonitor(request, serviceCredentials, fum);
|
|
codelistMappingFileUploadSession
|
|
.setFileUploadState(FileUploadState.FAILED);
|
|
try {
|
|
SessionUtil.setCodelistMappingFileUploadSession(request,
|
|
serviceCredentials, codelistMappingFileUploadSession);
|
|
} catch (Exception e1) {
|
|
logger.error(e1.getLocalizedMessage(), e1);
|
|
throw new ServletException(e1.getLocalizedMessage());
|
|
}
|
|
logger.error("Error processing request in upload servlet", e);
|
|
response.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR,
|
|
"ERROR-Error during request processing: " + e.getMessage());
|
|
return;
|
|
}
|
|
|
|
if (uploadItem == null) {
|
|
FileUploadMonitor fum = null;
|
|
try {
|
|
fum = SessionUtil.getFileUploadMonitor(request,
|
|
serviceCredentials);
|
|
} catch (TDGWTServiceException e1) {
|
|
logger.error(e1.getLocalizedMessage(), e1);
|
|
throw new ServletException(e1.getLocalizedMessage());
|
|
}
|
|
fum.setFailed(
|
|
"An error occured elaborating the HTTP request: No file found",
|
|
"Upload request without file");
|
|
SessionUtil.setFileUploadMonitor(request, serviceCredentials, fum);
|
|
|
|
codelistMappingFileUploadSession
|
|
.setFileUploadState(FileUploadState.FAILED);
|
|
try {
|
|
SessionUtil.setCodelistMappingFileUploadSession(request,
|
|
serviceCredentials, codelistMappingFileUploadSession);
|
|
} catch (Exception e) {
|
|
logger.error(e.getLocalizedMessage(), e);
|
|
throw new ServletException(e.getLocalizedMessage());
|
|
}
|
|
logger.error("Error processing request in upload servlet: No file to upload");
|
|
response.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR,
|
|
"No file to upload");
|
|
return;
|
|
}
|
|
|
|
String contentType = uploadItem.getContentType();
|
|
|
|
logger.trace("ContentType: " + contentType);
|
|
|
|
try {
|
|
FileUtil.setImportFileCodelistMapping(
|
|
codelistMappingFileUploadSession,
|
|
uploadItem.getInputStream(), uploadItem.getName(),
|
|
contentType);
|
|
} catch (Exception e) {
|
|
FileUploadMonitor fum = null;
|
|
try {
|
|
fum = SessionUtil.getFileUploadMonitor(request,
|
|
serviceCredentials);
|
|
} catch (TDGWTServiceException e1) {
|
|
logger.error(e1.getLocalizedMessage(), e1);
|
|
throw new ServletException(e1.getLocalizedMessage());
|
|
}
|
|
fum.setFailed("An error occured elaborating the file",
|
|
FileUtil.exceptionDetailMessage(e));
|
|
SessionUtil.setFileUploadMonitor(request, serviceCredentials, fum);
|
|
|
|
codelistMappingFileUploadSession
|
|
.setFileUploadState(FileUploadState.FAILED);
|
|
try {
|
|
SessionUtil.setCodelistMappingFileUploadSession(request,
|
|
serviceCredentials, codelistMappingFileUploadSession);
|
|
} catch (Exception e1) {
|
|
logger.error(e1.getLocalizedMessage(), e1);
|
|
throw new ServletException(e1.getLocalizedMessage());
|
|
}
|
|
logger.error("Error elaborating the stream", e);
|
|
uploadItem.delete();
|
|
response.getWriter().write("ERROR-" + e.getMessage());
|
|
return;
|
|
}
|
|
|
|
uploadItem.delete();
|
|
|
|
logger.trace("changing state");
|
|
FileUploadMonitor fum = null;
|
|
try {
|
|
fum = SessionUtil.getFileUploadMonitor(request, serviceCredentials);
|
|
} catch (TDGWTServiceException e) {
|
|
logger.error(e.getLocalizedMessage(), e);
|
|
throw new ServletException(e.getLocalizedMessage());
|
|
}
|
|
fum.setState(FileUploadState.COMPLETED);
|
|
SessionUtil.setFileUploadMonitor(request, serviceCredentials, fum);
|
|
|
|
try {
|
|
SessionUtil.setCodelistMappingFileUploadSession(request,
|
|
serviceCredentials, codelistMappingFileUploadSession);
|
|
} catch (Exception e) {
|
|
logger.error(e.getLocalizedMessage(), e);
|
|
throw new ServletException(e.getLocalizedMessage());
|
|
}
|
|
response.getWriter().write("OK");
|
|
}
|
|
|
|
}
|