You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
210 lines
8.0 KiB
Java
210 lines
8.0 KiB
Java
package org.gcube.portal;
|
|
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.clientFor;
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.queryFor;
|
|
|
|
import java.io.File;
|
|
import java.io.FileInputStream;
|
|
import java.io.IOException;
|
|
import java.util.List;
|
|
import java.util.Properties;
|
|
import java.util.concurrent.Executors;
|
|
import java.util.concurrent.ScheduledExecutorService;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
import javax.servlet.ServletException;
|
|
import javax.servlet.http.HttpServlet;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import javax.servlet.http.HttpServletResponse;
|
|
|
|
import org.gcube.application.framework.core.session.SessionManager;
|
|
import org.gcube.common.encryption.StringEncrypter;
|
|
import org.gcube.common.portal.PortalContext;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.AccessPoint;
|
|
import org.gcube.common.scope.api.ScopeProvider;
|
|
import org.gcube.portal.databook.server.DBCassandraAstyanaxImpl;
|
|
import org.gcube.portal.databook.server.DatabookStore;
|
|
import org.gcube.portal.socialmail.EmailPopAccount;
|
|
import org.gcube.portal.socialmail.PeriodicTask;
|
|
import org.gcube.resources.discovery.client.api.DiscoveryClient;
|
|
import org.gcube.resources.discovery.client.queries.api.SimpleQuery;
|
|
import org.gcube.vomanagement.usermanagement.exception.GroupRetrievalFault;
|
|
import org.gcube.vomanagement.usermanagement.impl.LiferayGroupManager;
|
|
import org.gcube.vomanagement.usermanagement.model.CustomAttributeKeys;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import com.liferay.portal.kernel.exception.PortalException;
|
|
import com.liferay.portal.kernel.exception.SystemException;
|
|
import com.liferay.portal.model.Group;
|
|
import com.liferay.portal.model.VirtualHost;
|
|
import com.liferay.portal.service.LayoutSetLocalServiceUtil;
|
|
import com.liferay.portal.service.VirtualHostLocalServiceUtil;
|
|
|
|
|
|
@SuppressWarnings("serial")
|
|
public class PortalSchedulerService extends HttpServlet {
|
|
|
|
private static final Logger _log = LoggerFactory.getLogger(PortalSchedulerService.class);
|
|
private static final String POP3_POLLING_MINUTES_INTERVAL = "pop3pollinginminutes";
|
|
|
|
private static final String POP3_SERVER_NAME = "Pop3MailServer";
|
|
|
|
|
|
private static DatabookStore store;
|
|
|
|
public void init() {
|
|
PortalContext context = PortalContext.getConfiguration();
|
|
String scope = "/" + context.getInfrastructureName();
|
|
ScopeProvider.instance.set(scope);
|
|
store = new DBCassandraAstyanaxImpl();
|
|
}
|
|
|
|
|
|
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
|
|
|
|
Group site;
|
|
EmailPopAccount popAccount = null;
|
|
try {
|
|
site = getSiteFromServletRequest(request);
|
|
popAccount = getPopAccountData(site);
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
}
|
|
|
|
String toReturn = "<DIV>Check Notification Email Starting ... </DIV>";
|
|
|
|
int pollingInterval = getPollingInterval();
|
|
|
|
ScheduledExecutorService pop3Scheduler = Executors.newScheduledThreadPool(1);
|
|
pop3Scheduler.scheduleAtFixedRate(new PeriodicTask(store, popAccount, request), 0, pollingInterval, TimeUnit.MINUTES);
|
|
String portalName = "unknown";
|
|
try {
|
|
portalName = popAccount.getPortalName() ;
|
|
}
|
|
catch (NullPointerException e){
|
|
_log.warn("Could not read popAccount data portal name", e);
|
|
}
|
|
_log.info("EmailParser stared for " + portalName + ", pollingInterval (in minutes)=" + pollingInterval);
|
|
toReturn = "<DIV>Check Notification Email Started ... </DIV>";
|
|
response.setContentType("text/html");
|
|
response.getWriter().write(toReturn);
|
|
}
|
|
|
|
/**
|
|
* read the time interval in minutes from a property file and returns it
|
|
*/
|
|
public int getPollingInterval() {
|
|
//get the portles to look for from the property file
|
|
Properties props = new Properties();
|
|
int toReturn = 7;
|
|
|
|
try {
|
|
String propertyfile = getCatalinaHome() + File.separator + "conf" + File.separator + "gcube-data.properties";
|
|
File propsFile = new File(propertyfile);
|
|
FileInputStream fis = new FileInputStream(propsFile);
|
|
props.load(fis);
|
|
toReturn = Integer.parseInt(props.getProperty(POP3_POLLING_MINUTES_INTERVAL));
|
|
}
|
|
//catch exception in case properties file does not exist
|
|
catch(IOException e) {
|
|
_log.error("gcube-data.properties file not found under $CATALINA_HOME/conf dir, returning default interval in minutes = " + toReturn);
|
|
return toReturn;
|
|
}
|
|
_log.debug("Returning poling interval in minutes: " + toReturn );
|
|
return toReturn;
|
|
}
|
|
/**
|
|
*
|
|
* @return $CATALINA_HOME
|
|
*/
|
|
private static String getCatalinaHome() {
|
|
return (System.getenv("CATALINA_HOME").endsWith("/") ? System.getenv("CATALINA_HOME") : System.getenv("CATALINA_HOME")+"/");
|
|
}
|
|
|
|
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {}
|
|
|
|
/**
|
|
*
|
|
* @param request
|
|
* @return the current Group instance based on the request
|
|
* @throws PortalException
|
|
* @throws SystemException
|
|
*/
|
|
private Group getSiteFromServletRequest(final HttpServletRequest request) throws PortalException, SystemException {
|
|
String serverName = request.getServerName();
|
|
_log.debug("currentHost is " + serverName);
|
|
Group site = null;
|
|
List<VirtualHost> vHosts = VirtualHostLocalServiceUtil.getVirtualHosts(0, VirtualHostLocalServiceUtil.getVirtualHostsCount());
|
|
for (VirtualHost virtualHost : vHosts) {
|
|
_log.debug("Found " + virtualHost.getHostname());
|
|
if (virtualHost.getHostname().compareTo("localhost") != 0 &&
|
|
virtualHost.getLayoutSetId() != 0 &&
|
|
virtualHost.getHostname().compareTo(serverName) == 0) {
|
|
long layoutSetId = virtualHost.getLayoutSetId();
|
|
site = LayoutSetLocalServiceUtil.getLayoutSet(layoutSetId).getGroup();
|
|
_log.debug("Found match! Your site is " + site.getName());
|
|
return site;
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
private EmailPopAccount getPopAccountData(Group site) throws GroupRetrievalFault {
|
|
|
|
_log.debug("Found site for vhost, name " + site.getName() + " reading custom field: " + CustomAttributeKeys.GATEWAY_SITE_NAME);
|
|
String gatewayName = (String) new LiferayGroupManager().readCustomAttr(site.getGroupId(), CustomAttributeKeys.GATEWAY_SITE_NAME.getKeyName());
|
|
|
|
//set the scope for the query
|
|
String curScope = ScopeProvider.instance.get();
|
|
PortalContext context = PortalContext.getConfiguration();
|
|
String scope2Set = "/" + context.getInfrastructureName();
|
|
ScopeProvider.instance.set(scope2Set);
|
|
|
|
EmailPopAccount toReturn = new EmailPopAccount();
|
|
toReturn.setPortalName(gatewayName);
|
|
SimpleQuery query = queryFor(ServiceEndpoint.class);
|
|
query.addCondition("$resource/Profile/Category/text() eq 'Portal'");
|
|
query.addCondition("$resource/Profile/Name/text() eq '" + gatewayName + "'");
|
|
|
|
DiscoveryClient<ServiceEndpoint> client = clientFor(ServiceEndpoint.class);
|
|
|
|
List<ServiceEndpoint> list = client.submit(query);
|
|
if (list == null || list.isEmpty()) {
|
|
_log.error("Could not find any Service endpoint registred in the infrastructure for this gateway: " + gatewayName);
|
|
return null;
|
|
}
|
|
else if (list.size() > 1) {
|
|
_log.warn("Found more than one Service endpoint registred in the infrastructure for this gateway: " + gatewayName);
|
|
return null;
|
|
}
|
|
else {
|
|
for (ServiceEndpoint res : list) {
|
|
org.gcube.common.resources.gcore.utils.Group<AccessPoint> apGroup = res.profile().accessPoints();
|
|
AccessPoint[] accessPoints = (AccessPoint[]) apGroup.toArray(new AccessPoint[apGroup.size()]);
|
|
for (int i = 0; i < accessPoints.length; i++) {
|
|
if (accessPoints[i].name().compareTo(POP3_SERVER_NAME) == 0) {
|
|
_log.info("Found credentials for " + POP3_SERVER_NAME);
|
|
AccessPoint found = accessPoints[i];
|
|
toReturn.setPop3Server(found.address());
|
|
toReturn.setPop3user(found.username());
|
|
String encrPassword = found.password();
|
|
try {
|
|
toReturn.setPop3password(StringEncrypter.getEncrypter().decrypt( encrPassword));
|
|
} catch (Exception e) {
|
|
_log.error("Something went wrong while decrypting password for " + POP3_SERVER_NAME);
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
//set the previous scope
|
|
ScopeProvider.instance.set(curScope);
|
|
return toReturn;
|
|
}
|
|
|
|
|
|
|
|
} |