Update to new PortalContext

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/portlets/user/statistical-algorithms-importer@142244 82a268e6-3cf1-43bd-a215-b396298e98cf

pom.xml

@@ -216,13 +216,6 @@
 			<scope>provided</scope>
 		</dependency>
 
-		<!-- GCube Widgets -->
-		<dependency>
-			<groupId>org.gcube.portlets.user</groupId>
-			<artifactId>gcube-widgets</artifactId>
-			<scope>compile</scope>
-		</dependency>
-
 		<!-- Storage -->
 		<dependency>
 			<groupId>org.gcube.contentmanagement</groupId>
@@ -258,8 +251,11 @@
 
 
 		<!-- Social -->
-		<!-- <dependency> <groupId>org.gcube.portal</groupId> <artifactId>social-networking-library</artifactId> 
-			<scope>provided</scope> </dependency> -->
+		<!-- <dependency>
+			<groupId>org.gcube.portal</groupId>
+			<artifactId>social-networking-library</artifactId>
+			<scope>provided</scope>
+		</dependency> -->
 		<dependency>
 			<groupId>org.gcube.applicationsupportlayer</groupId>
 			<artifactId>aslsocial</artifactId>

src/main/java/org/gcube/portlets/user/statisticalalgorithmsimporter/client/upload/CodeUploadPanel.java

@@ -37,7 +37,7 @@ import com.sencha.gxt.widget.core.client.form.FormPanel;
  */
 public class CodeUploadPanel extends FormPanel {
 
-	private static final String UPLOAD_SERVLET = "LocalUploadServlet";
+	
 
 	private static final int STATUS_POLLING_DELAY = 1000;
 
@@ -73,7 +73,11 @@ public class CodeUploadPanel extends FormPanel {
 
 	private void create() {
 		setId("CodeUploadPanel");
-		setAction(GWT.getModuleBaseURL() + UPLOAD_SERVLET);
+		String path = GWT.getModuleBaseURL()
+				+ Constants.LOCAL_UPLOAD_SERVLET + "?"
+				+ Constants.CURR_GROUP_ID + "="
+				+ GCubeClientContext.getCurrentContextId();
+		setAction(path);
 		setWidth("100%");
 
 		setEncoding(Encoding.MULTIPART);
@@ -186,11 +190,9 @@ public class CodeUploadPanel extends FormPanel {
 		parent.setButtonAlign(BoxLayoutPack.CENTER);
 		
 		Hidden currGroupId=new Hidden(Constants.CURR_GROUP_ID, GCubeClientContext.getCurrentContextId());
-		Hidden currUserId=new Hidden(Constants.CURR_USER_ID, GCubeClientContext.getCurrentUserId());
 		
 		VerticalLayoutContainer vlc = new VerticalLayoutContainer();
 		vlc.add(currGroupId);
-		vlc.add(currUserId);
 		vlc.add(fileUploadFieldLabel, new VerticalLayoutData(1, -1, new Margins(0)));
 		vlc.add(uploadProgressBar, new VerticalLayoutData(1, -1, new Margins(5,0,0,0)));
 		uploadProgressBar.setVisible(false);
@@ -208,12 +210,6 @@ public class CodeUploadPanel extends FormPanel {
 
 	protected void startUpload() {
 		disableUpload();
-
-		StringBuilder actionUrl = new StringBuilder();
-		actionUrl.append(GWT.getModuleBaseURL());
-		actionUrl.append(UPLOAD_SERVLET);
-		setAction(actionUrl.toString());
-		Log.info("Start Upload action Url " + actionUrl.toString());
 		submit();
 
 		progressUpdater.scheduleRepeating(STATUS_POLLING_DELAY);

src/main/java/org/gcube/portlets/user/statisticalalgorithmsimporter/server/LocalUploadServlet.java

@@ -18,7 +18,6 @@ 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.statisticalalgorithmsimporter.server.file.CodeFileUploadSession;
 import org.gcube.portlets.user.statisticalalgorithmsimporter.server.file.FileUploadListener;
 import org.gcube.portlets.user.statisticalalgorithmsimporter.server.file.FileUtil;
@@ -66,17 +65,28 @@ public class LocalUploadServlet extends HttpServlet {
 		}
 		logger.info("Code Import session id: " + session.getId());
 
+		ServiceCredentials serviceCredentials;
+
+		String scopeGroupId = request.getHeader(Constants.CURR_GROUP_ID);
+		if (scopeGroupId == null || scopeGroupId.isEmpty()) {
+			scopeGroupId = request.getParameter(Constants.CURR_GROUP_ID);
+			if (scopeGroupId == null || scopeGroupId.isEmpty()) {
+				logger.error("CURR_GROUP_ID is null, it is a mandatory parameter in custom servlet: "
+						+ scopeGroupId);
+				throw new ServletException(
+						"CURR_GROUP_ID is null, it is a mandatory parameter in custom servlet: "
+								+ scopeGroupId);
+			}
+		}
+
 		try {
-			String scopeGroupId = request.getParameter(Constants.CURR_GROUP_ID);
-			String currUserId = request.getParameter(Constants.CURR_USER_ID);
-			ServiceCredentials serviceCredentials = SessionUtil
-					.getServiceCredentials(request, scopeGroupId, currUserId);
+			serviceCredentials = SessionUtil.getServiceCredentials(request,
+					scopeGroupId);
 
-			ScopeProvider.instance.set(serviceCredentials.getScope());
-
-		} catch (StatAlgoImporterServiceException e) {
-			logger.error(e.getLocalizedMessage());
-			e.printStackTrace();
+		} catch (Exception e) {
+			logger.error(
+					"Error retrieving credentials:" + e.getLocalizedMessage(),
+					e);
 			throw new ServletException(e.getLocalizedMessage());
 		}
 		

src/main/java/org/gcube/portlets/user/statisticalalgorithmsimporter/server/SessionOp.java

@@ -0,0 +1,119 @@
+package org.gcube.portlets.user.statisticalalgorithmsimporter.server;
+
+import java.util.HashMap;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+import org.gcube.portlets.user.statisticalalgorithmsimporter.server.util.ServiceCredentials;
+
+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>
+ *
+ * @param <T>
+ */
+public class SessionOp<T> {
+
+	private static Logger logger = LoggerFactory.getLogger(SessionOp.class);
+
+	public T get(HttpServletRequest httpRequest,
+			ServiceCredentials serviceCredentials, String attribute,
+			Class<T> cls) throws Exception {
+		HttpSession httpSession = httpRequest.getSession();
+		T value = null;
+
+		@SuppressWarnings("unchecked")
+		HashMap<String, T> map = (HashMap<String, T>) httpSession
+				.getAttribute(attribute);
+
+		if (map != null) {
+			if (map.containsKey(serviceCredentials.getScope())) {
+				value = map.get(serviceCredentials.getScope());
+			} else {
+				logger.error("" + attribute + " was not acquired");
+				try {
+					value = cls.newInstance();
+					map.put(serviceCredentials.getScope(), value);
+				} catch (InstantiationException | IllegalAccessException e) {
+					String error = "Error reading session attribute: "
+							+ e.getLocalizedMessage();
+					logger.error(error, e);
+					throw new Exception(error, e);
+				}
+
+			}
+		} else {
+			logger.error("" + attribute + " was not acquired");
+			map = new HashMap<>();
+			try {
+				value = cls.newInstance();
+				map.put(serviceCredentials.getScope(), value);
+				httpSession.setAttribute(attribute, map);
+			} catch (InstantiationException | IllegalAccessException e) {
+				String error = "Error reading session attribute: "
+						+ e.getLocalizedMessage();
+				logger.error(error, e);
+				throw new Exception(error, e);
+			}
+
+		}
+		return value;
+	}
+
+	public T get(HttpServletRequest httpRequest,
+			ServiceCredentials serviceCredentials, String attribute) {
+		HttpSession httpSession = httpRequest.getSession();
+		T value = null;
+
+		@SuppressWarnings("unchecked")
+		HashMap<String, T> map = (HashMap<String, T>) httpSession
+				.getAttribute(attribute);
+
+		if (map != null) {
+			if (map.containsKey(serviceCredentials.getScope())) {
+				value = map.get(serviceCredentials.getScope());
+			} else {
+				logger.error("" + attribute + " was not acquired");
+			}
+		} else {
+			logger.error("" + attribute + " was not acquired");
+		}
+		return value;
+	}
+
+	public void set(HttpServletRequest httpRequest,
+			ServiceCredentials serviceCredentials, String attribute, T value) {
+		HttpSession httpSession = httpRequest.getSession();
+
+		@SuppressWarnings("unchecked")
+		HashMap<String, T> map = (HashMap<String, T>) httpSession
+				.getAttribute(attribute);
+
+		if (map != null) {
+			map.put(serviceCredentials.getScope(), value);
+		} else {
+			map = new HashMap<>();
+			map.put(serviceCredentials.getScope(), value);
+			httpSession.setAttribute(attribute, map);
+		}
+	}
+	
+	public void remove(HttpServletRequest httpRequest,
+			ServiceCredentials serviceCredentials, String attribute) {
+		HttpSession httpSession = httpRequest.getSession();
+
+		@SuppressWarnings("unchecked")
+		HashMap<String, T> map = (HashMap<String, T>) httpSession
+				.getAttribute(attribute);
+
+		if (map != null) {
+			map.remove(serviceCredentials.getScope());
+		} 
+	}
+	
+
+}

src/main/java/org/gcube/portlets/user/statisticalalgorithmsimporter/server/SessionUtil.java

@@ -9,7 +9,9 @@ import javax.servlet.ServletContext;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpSession;
 
+import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
 import org.gcube.common.portal.PortalContext;
+import org.gcube.common.scope.api.ScopeProvider;
 import org.gcube.portlets.user.statisticalalgorithmsimporter.server.file.CodeFileUploadSession;
 import org.gcube.portlets.user.statisticalalgorithmsimporter.server.social.Recipient;
 import org.gcube.portlets.user.statisticalalgorithmsimporter.server.util.ServiceCredentials;
@@ -20,7 +22,6 @@ import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.file.FileUpl
 import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.project.Project;
 import org.gcube.portlets.user.statisticalalgorithmsimporter.shared.session.SessionConstants;
 import org.gcube.vomanagement.usermanagement.impl.LiferayGroupManager;
-import org.gcube.vomanagement.usermanagement.impl.LiferayUserManager;
 import org.gcube.vomanagement.usermanagement.model.GCubeGroup;
 import org.gcube.vomanagement.usermanagement.model.GCubeUser;
 import org.slf4j.Logger;
@@ -36,14 +37,27 @@ public class SessionUtil {
 
 	private static Logger logger = LoggerFactory.getLogger(SessionUtil.class);
 
+	/**
+	 * 
+	 * @param httpServletRequest
+	 * @return
+	 * @throws TDGWTServiceException
+	 */
 	public static ServiceCredentials getServiceCredentials(
 			HttpServletRequest httpServletRequest)
 			throws StatAlgoImporterServiceException {
-		return getServiceCredentials(httpServletRequest, null, null);
+		return getServiceCredentials(httpServletRequest, null);
 	}
 
+	/**
+	 * 
+	 * @param httpServletRequest
+	 * @param scopeGroupId
+	 * @return
+	 * @throws TDGWTServiceException
+	 */
 	public static ServiceCredentials getServiceCredentials(
-			HttpServletRequest httpServletRequest, String scopeGroupId, String currUserId)
+			HttpServletRequest httpServletRequest, String scopeGroupId)
 			throws StatAlgoImporterServiceException {
 
 		ServiceCredentials sCredentials = null;
@@ -55,17 +69,29 @@ public class SessionUtil {
 
 		if (Constants.DEBUG_MODE) {
 			logger.info("No credential found in session, use test user!");
+			/*
+			 * InfoLocale infoLocale = getInfoLocale(httpServletRequest, null);
+			 * Locale locale = new Locale(infoLocale.getLanguage());
+			 * 
+			 * ResourceBundle messages = ResourceBundle.getBundle(
+			 * StatAlgoImporterServiceMessagesConstants.TDGWTServiceMessages,
+			 * locale);
+			 */
 			userName = Constants.DEFAULT_USER;
 			scope = Constants.DEFAULT_SCOPE;
 			token = Constants.DEFAULT_TOKEN;
 
+			logger.info("Set SecurityToken: " + token);
+			SecurityTokenProvider.instance.set(token);
+			logger.info("Set ScopeProvider: " + scope);
+			ScopeProvider.instance.set(scope);
+
 			sCredentials = new ServiceCredentials(userName, scope, token);
 
 		} else {
 			logger.info("Retrieving credential in session!");
 			PortalContext pContext = PortalContext.getConfiguration();
 			boolean hasScopeGroupId = false;
-			boolean hasCurrUserId = false;
 
 			if (scopeGroupId != null && !scopeGroupId.isEmpty()) {
 				hasScopeGroupId = true;
@@ -74,42 +100,19 @@ public class SessionUtil {
 				hasScopeGroupId = false;
 			}
 
-			if (currUserId != null && !currUserId.isEmpty()) {
-				hasCurrUserId = true;
-
-			} else {
-				hasCurrUserId = false;
-			}
-
 			if (hasScopeGroupId) {
 				scope = pContext.getCurrentScope(scopeGroupId);
 			} else {
 				scope = pContext.getCurrentScope(httpServletRequest);
-
 			}
 
-			logger.debug("Scope: " + scope);
 			if (scope == null || scope.isEmpty()) {
 				String error = "Error retrieving scope: " + scope;
 				logger.error(error);
 				throw new StatAlgoImporterServiceException(error);
 			}
 
-			GCubeUser gCubeUser = null;
-
-			if (hasCurrUserId) {
-				try {
-					gCubeUser = new LiferayUserManager().getUserById(Long
-							.valueOf(currUserId));
-				} catch (Exception e) {
-					String error = "Error retrieving gCubeUser for: [userId= "
-							+ currUserId + ", scope: " + scope + "]";
-					logger.error(error, e);
-					throw new StatAlgoImporterServiceException(error);
-				}
-			} else {
-				gCubeUser = pContext.getCurrentUser(httpServletRequest);
-			}
+			GCubeUser gCubeUser = pContext.getCurrentUser(httpServletRequest);
 
 			if (gCubeUser == null) {
 				String error = "Error retrieving gCubeUser in scope " + scope
@@ -119,7 +122,6 @@ public class SessionUtil {
 			}
 
 			userName = gCubeUser.getUsername();
-			logger.debug("UserName: " + userName);
 
 			if (userName == null || userName.isEmpty()) {
 				String error = "Error retrieving username in scope " + scope
@@ -128,22 +130,8 @@ public class SessionUtil {
 				throw new StatAlgoImporterServiceException(error);
 			}
 
-			if (hasCurrUserId) {
-				try {
-					token = pContext.getCurrentUserToken(scope,
-							Long.valueOf(currUserId));
-				} catch (Exception e) {
-					String error = "Error retrieving token for: [userId= "
-							+ currUserId + ", scope: " + scope + "]";
-					logger.error(error, e);
-					throw new StatAlgoImporterServiceException(error);
-				}
+			token = pContext.getCurrentUserToken(scope, userName);
 
-			} else {
-				token = pContext.getCurrentUserToken(scope, httpServletRequest);
-			}
-
-			logger.debug("Token: " + token);
 			if (token == null || token.isEmpty()) {
 				String error = "Error retrieving token for " + userName
 						+ " in " + scope + ": " + token;
@@ -160,6 +148,10 @@ public class SessionUtil {
 			String email = gCubeUser.getEmail();
 
 			if (hasScopeGroupId) {
+				logger.info("Set SecurityToken: " + token);
+				SecurityTokenProvider.instance.set(token);
+				logger.info("Set ScopeProvider: " + scope);
+				ScopeProvider.instance.set(scope);
 
 				groupId = scopeGroupId;
 

src/main/java/org/gcube/portlets/user/statisticalalgorithmsimporter/server/portlet/StatAlgoImporterPortlet.java

@@ -10,6 +10,7 @@ import javax.portlet.PortletException;
 import javax.portlet.PortletRequestDispatcher;
 import javax.portlet.RenderRequest;
 import javax.portlet.RenderResponse;
+import org.gcube.common.portal.PortalContext;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -44,9 +45,9 @@ public class StatAlgoImporterPortlet extends GenericPortlet {
 	public void doView(RenderRequest request, RenderResponse response) throws PortletException, IOException {
 		
 		logger.trace("Loading from JSP: "+VIEW_JSP);
+		logger.trace("Setting user in session using PortalContext");
+		PortalContext.setUserInSession(request);
 
-		//logger.trace("setting context using ScopeHelper");
-		//ScopeHelper.setContext(request);
 		
 		logger.trace("passing to the render");
 		PortletRequestDispatcher rd = getPortletContext().getRequestDispatcher(VIEW_JSP);

src/main/java/org/gcube/portlets/user/statisticalalgorithmsimporter/shared/Constants.java

@@ -29,4 +29,6 @@ public class Constants {
 	public static final String CURR_GROUP_ID = "CURR_GROUP_ID";
 	public static final String CURR_USER_ID = "CURR_USER_ID";
 	
+	public static final String LOCAL_UPLOAD_SERVLET = "LocalUploadServlet";
+
 }