254 lines
10 KiB
Java
254 lines
10 KiB
Java
package org.gcube.portlets.user.gcubeloggedin.server;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Set;
|
|
|
|
import org.gcube.common.portal.PortalContext;
|
|
import org.gcube.common.portal.mailing.EmailNotification;
|
|
import org.gcube.portal.mailing.message.Recipient;
|
|
import org.gcube.portal.mailing.service.EmailTemplateService;
|
|
import org.gcube.portal.mailing.templates.TemplateUserHasLeftVRE;
|
|
import org.gcube.portlets.user.gcubeloggedin.client.LoggedinService;
|
|
import org.gcube.portlets.user.gcubeloggedin.shared.VObject;
|
|
import org.gcube.portlets.user.gcubeloggedin.shared.VObject.UserBelongingClient;
|
|
import org.gcube.portlets.user.gcubeloggedin.shared.VREClient;
|
|
import org.gcube.vomanagement.usermanagement.GroupManager;
|
|
import org.gcube.vomanagement.usermanagement.RoleManager;
|
|
import org.gcube.vomanagement.usermanagement.UserManager;
|
|
import org.gcube.vomanagement.usermanagement.exception.GroupRetrievalFault;
|
|
import org.gcube.vomanagement.usermanagement.exception.UserManagementSystemException;
|
|
import org.gcube.vomanagement.usermanagement.impl.LiferayGroupManager;
|
|
import org.gcube.vomanagement.usermanagement.impl.LiferayRoleManager;
|
|
import org.gcube.vomanagement.usermanagement.impl.LiferayUserManager;
|
|
import org.gcube.vomanagement.usermanagement.model.GCubeGroup;
|
|
import org.gcube.vomanagement.usermanagement.model.GCubeRole;
|
|
import org.gcube.vomanagement.usermanagement.model.GCubeUser;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import com.google.gwt.user.server.rpc.RemoteServiceServlet;
|
|
import com.liferay.portal.service.UserLocalServiceUtil;
|
|
|
|
/**
|
|
* The server side implementation of the RPC service.
|
|
*/
|
|
@SuppressWarnings("serial")
|
|
public class LoggedinServiceImpl extends RemoteServiceServlet implements LoggedinService {
|
|
|
|
private static final Logger _log = LoggerFactory.getLogger(LoggedinServiceImpl.class);
|
|
private PortalContext context = PortalContext.getConfiguration();
|
|
/**
|
|
* return the current selected VRE
|
|
*/
|
|
|
|
public VObject getSelectedRE(String portalURL) {
|
|
long currGroupId = context.getCurrentGroupId(getThreadLocalRequest());
|
|
GroupManager gm = new LiferayGroupManager();
|
|
GCubeGroup currGroup = null;
|
|
try {
|
|
currGroup = gm.getGroup(currGroupId);
|
|
} catch (UserManagementSystemException | GroupRetrievalFault e1) {
|
|
e1.printStackTrace();
|
|
}
|
|
String friendlyURL = currGroup.getFriendlyURL();
|
|
_log.debug("curr group: " + currGroup.getGroupName() + " friendlyURL = " + friendlyURL);
|
|
if (friendlyURL == null) {//the URL is not a portal URL, we are in devmode.
|
|
return new VREClient("Test VRE Name", "", "" +
|
|
"Fishery and Aquaculture Resources Management (FARM) Virtual Organisation</b> The FARM Virtual Organisation is the <b><i>dynamic group of individuals</i></b> and/or <b><i>institutions</i></b> defined around a set of <b><i>sharing rules</i></b> in which <b><i>resource providers</i></b> and <b><i>consumers</i></b> specify clearly and carefully just what is shared, who is allowed to share, and the conditions under which sharing occurs to serve the needs of the <b><i>Fisheries and Aquaculture Resources Management</i></b>. "
|
|
+ " This VO is conceived to support various application scenarios arising in the FARM Community including the production of Fisheries and Aquaculture Country Profiles, "
|
|
+ "the management of catch statistics including harmonisation, the dynamic generation of biodiversity maps and species distribution maps."
|
|
+ " This Virtual Organisation currently consists of:<ul> <li> approximately <b><i>13 gCube nodes</i></b>, "
|
|
+ "i.e. machines dedicated to run the gCube system;</li> "
|
|
+ " <li> approximately <b><i>89 running instances</i></b>, i.e. running gCube services supporting the operation of the infrastructure;</li> "
|
|
+ " <li> approximately <b><i>25 collections</i></b>, i.e. set of D4Science Information Objects including Earth images, AquaMaps, Graphs on catch statistics;</li> "
|
|
+ " <li> approximately <b><i>66 metadata collections</i></b>, i.e. set of Metadata Objects describing the Information Objects through various features and schemas;</li> "
|
|
+ " <li> approximately <b><i>58 other resources</i></b> including transformation programs, index types, etc.</li></ul></div>"
|
|
, "http://placehold.it/300x200", "", UserBelongingClient.BELONGING, false, true, true);
|
|
}
|
|
_log.trace("getting Selected Research Environment");
|
|
|
|
|
|
|
|
String name = currGroup.getGroupName();
|
|
String logoURL = gm.getGroupLogoURL(currGroup.getLogoId());
|
|
String desc = "";
|
|
//set the description for the vre
|
|
if (currGroup.getDescription() != null)
|
|
desc = currGroup.getDescription();
|
|
return new VREClient(name, "", desc, logoURL, "", UserBelongingClient.BELONGING, false, false, isCurrUserVREManager());
|
|
}
|
|
|
|
/**
|
|
*
|
|
* @return
|
|
*/
|
|
private boolean isCurrUserVREManager() {
|
|
|
|
long userId;
|
|
try {
|
|
userId = context.getCurrentUser(getThreadLocalRequest()).getUserId();
|
|
long groupId = context.getCurrentGroupId(getThreadLocalRequest());
|
|
RoleManager rm = new LiferayRoleManager();
|
|
long roleId = rm.getRoleIdByName(GCubeRole.VRE_MANAGER_LABEL);
|
|
boolean toReturn = rm.hasRole(userId, groupId, roleId);
|
|
return toReturn;
|
|
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
}
|
|
return false;
|
|
}
|
|
|
|
protected static ArrayList<String> getAdministratorsEmails(String scope) {
|
|
LiferayUserManager userManager = new LiferayUserManager();
|
|
LiferayGroupManager groupManager = new LiferayGroupManager();
|
|
long groupId = -1;
|
|
try {
|
|
List<GCubeGroup> allGroups = groupManager.listGroups();
|
|
_log.debug("Number of groups retrieved: " + allGroups.size());
|
|
for (int i = 0; i < allGroups.size(); i++) {
|
|
long grId = allGroups.get(i).getGroupId();
|
|
String groupScope = groupManager.getInfrastructureScope(grId);
|
|
_log.debug("Comparing: " + groupScope + " " + scope);
|
|
if (groupScope.equals(scope)) {
|
|
groupId = allGroups.get(i).getGroupId();
|
|
break;
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
}
|
|
Map<GCubeUser, List<GCubeRole>> usersAndRoles = null;
|
|
try {
|
|
usersAndRoles = userManager.listUsersAndRolesByGroup(groupId);
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
}
|
|
Set<GCubeUser> users = usersAndRoles.keySet();
|
|
ArrayList<String> adminEmailsList = new ArrayList<String>();
|
|
for (GCubeUser usr:users) {
|
|
List<GCubeRole> roles = usersAndRoles.get(usr);
|
|
for (int i = 0; i < roles.size(); i++) {
|
|
if (roles.get(i).getRoleName().equals("VO-Admin") || roles.get(i).getRoleName().equals("VRE-Manager")) {
|
|
adminEmailsList.add(usr.getEmail());
|
|
_log.debug("Admin: " + usr.getFullname());
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
return adminEmailsList;
|
|
}
|
|
|
|
@Override
|
|
public String saveVREDescription(String toSave) {
|
|
try {
|
|
long groupId = context.getCurrentGroupId(getThreadLocalRequest());
|
|
return new LiferayGroupManager().updateGroupDescription(groupId, toSave);
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
}
|
|
return null;
|
|
}
|
|
@Override
|
|
public boolean isLeaveButtonAvailable(String portalURL) {
|
|
|
|
if(isWithinPortal()){
|
|
long currGroupId = context.getCurrentGroupId(getThreadLocalRequest());
|
|
GroupManager gm = new LiferayGroupManager();
|
|
GCubeGroup currGroup = null;
|
|
try {
|
|
currGroup = gm.getGroup(currGroupId);
|
|
} catch (UserManagementSystemException | GroupRetrievalFault e1) {
|
|
e1.printStackTrace();
|
|
}
|
|
|
|
Boolean isMandatory = false;
|
|
try{
|
|
isMandatory = (Boolean) gm.readCustomAttr(currGroup.getGroupId(), org.gcube.vomanagement.usermanagement.model.CustomAttributeKeys.MANDATORY.getKeyName());
|
|
}catch(Exception e){
|
|
_log.error("Unable to evaluate if the leave button can be added for the current group " + currGroup.getGroupName(), e);
|
|
}
|
|
_log.debug("Is Leave button available in vre " + currGroup.getGroupName() + " ? " + isMandatory);
|
|
return !isMandatory;
|
|
}else return true;
|
|
}
|
|
/**
|
|
*@return the redirect url if everything goes ok, null otherwise
|
|
*/
|
|
@Override
|
|
public String removeUserFromVRE() {
|
|
String username = context.getCurrentUser(getThreadLocalRequest()).getUsername();
|
|
String scope = context.getCurrentScope(getThreadLocalRequest());
|
|
if (username.compareTo("test.user") == 0)
|
|
return null;
|
|
_log.debug("Going to remove user from the current Group: " + getCurrentGroupID() + ". Username is: " + username);
|
|
UserManager userM = new LiferayUserManager();
|
|
try {
|
|
userM.dismissUserFromGroup(getCurrentGroupID(), userM.getUserId(username));
|
|
sendUserUnregisteredNotification(username, scope,
|
|
PortalContext.getConfiguration().getGatewayURL(getThreadLocalRequest()),
|
|
PortalContext.getConfiguration().getGatewayName(getThreadLocalRequest()));
|
|
|
|
return PortalContext.getConfiguration().getSiteLandingPagePath(getThreadLocalRequest());
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
return null;
|
|
}
|
|
}
|
|
/**
|
|
* Get the current group ID
|
|
*
|
|
* @return the current group ID or null if an exception is thrown
|
|
* @throws Exception
|
|
* @throws CurrentGroupRetrievalException
|
|
*/
|
|
private long getCurrentGroupID() {
|
|
return context.getCurrentGroupId(getThreadLocalRequest());
|
|
}
|
|
/**
|
|
*
|
|
* @return true if you're running into the portal, false if in development
|
|
*/
|
|
private boolean isWithinPortal() {
|
|
try {
|
|
UserLocalServiceUtil.getService();
|
|
return true;
|
|
}
|
|
catch (com.liferay.portal.kernel.bean.BeanLocatorException ex) {
|
|
_log.trace("Development Mode ON");
|
|
return false;
|
|
}
|
|
}
|
|
/**
|
|
*
|
|
* @param username
|
|
* @param scope
|
|
* @param portalbasicurl
|
|
* @param gatewayName
|
|
*/
|
|
public void sendUserUnregisteredNotification(String username, String scope, String portalbasicurl, String gatewayName) {
|
|
ArrayList<String> adminEmails = getAdministratorsEmails(scope);
|
|
ArrayList<Recipient> recipients = new ArrayList<>();
|
|
for (String email : adminEmails) {
|
|
recipients.add(new Recipient(email));
|
|
}
|
|
UserManager um = new LiferayUserManager();
|
|
GCubeUser currUser = null;
|
|
try {
|
|
currUser = um.getUserByUsername(username);
|
|
} catch (Exception e) {
|
|
_log.trace("Error getUserByUsername", e);
|
|
}
|
|
|
|
String selectedVRE = scope.substring(scope.lastIndexOf("/")+1, scope.length());
|
|
|
|
EmailTemplateService.send("Unregistration from VRE",
|
|
new TemplateUserHasLeftVRE(currUser, selectedVRE, gatewayName, portalbasicurl),
|
|
getThreadLocalRequest(),
|
|
recipients.toArray(new Recipient[recipients.size()]));
|
|
|
|
}
|
|
}
|