tabular-data-gwt-service/src/main/java/org/gcube/portlets/user/td/gwtservice/server/social/TDMNotifications.java

package org.gcube.portlets.user.td.gwtservice.server.social;

import javax.servlet.http.HttpServletRequest;

import org.gcube.applicationsupportlayer.social.ApplicationNotificationsManager;
import org.gcube.applicationsupportlayer.social.NotificationsManager;
import org.gcube.applicationsupportlayer.social.shared.SocialNetworkingSite;
import org.gcube.applicationsupportlayer.social.shared.SocialNetworkingUser;
import org.gcube.portal.databook.shared.NotificationType;
import org.gcube.portlets.user.td.gwtservice.server.util.ServiceCredentials;
import org.gcube.portlets.user.td.gwtservice.shared.share.Contacts;
import org.gcube.portlets.user.td.gwtservice.shared.share.ShareRule;
import org.gcube.portlets.user.td.gwtservice.shared.share.ShareTabResource;
import org.gcube.portlets.user.td.gwtservice.shared.share.ShareTemplate;
import org.gcube.portlets.user.td.widgetcommonevent.shared.Constants;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * TDMNotification notification sharing TR, templates or rules
 * 
 * @author Giancarlo Panichi
 *
 *
 */
public class TDMNotifications extends Thread {
	private static Logger logger = LoggerFactory.getLogger(TDMNotifications.class);
	private ServiceCredentials serviceCredentials;
	private NotificationType notificationType;
	private ShareTabResource shareTabularResource;
	private ShareRule shareRule;
	private ShareTemplate shareTemplate;
	private SocialNetworkingSite site;
	private SocialNetworkingUser user;
	private String scope;

	/**
	 * Share Tabular Resource
	 * 
	 * @param request
	 *            Request
	 * @param serviceCredentials
	 *            Service credentials
	 * @param shareTabularResource
	 *            Share tabular resource
	 */
	public TDMNotifications(HttpServletRequest request, ServiceCredentials serviceCredentials,
			ShareTabResource shareTabularResource) {
		this.serviceCredentials = serviceCredentials;
		this.shareTabularResource = shareTabularResource;
		this.notificationType = NotificationType.TDM_TAB_RESOURCE_SHARE;
		site = new SocialNetworkingSite(request);
		user = new SocialNetworkingUser(serviceCredentials.getUserName(), serviceCredentials.getEmail(),
				serviceCredentials.getFullName(), serviceCredentials.getUserAvatarURL());
		scope = serviceCredentials.getScope();

	}

	/**
	 * 
	 * @param request
	 *            Request
	 * @param serviceCredentials
	 *            Service credentials
	 * @param shareRule
	 *            Share rule
	 */
	public TDMNotifications(HttpServletRequest request, ServiceCredentials serviceCredentials, ShareRule shareRule) {
		this.serviceCredentials = serviceCredentials;
		this.shareRule = shareRule;
		this.notificationType = NotificationType.TDM_RULE_SHARE;
		site = new SocialNetworkingSite(request);
		user = new SocialNetworkingUser(serviceCredentials.getUserName(), serviceCredentials.getEmail(),
				serviceCredentials.getFullName(), serviceCredentials.getUserAvatarURL());
		scope = serviceCredentials.getScope();

	}

	/**
	 * 
	 * @param request
	 *            Request
	 * @param serviceCredentials
	 *            Service credentials
	 * @param shareTemplate
	 *            Share template
	 */
	public TDMNotifications(HttpServletRequest request, ServiceCredentials serviceCredentials,
			ShareTemplate shareTemplate) {
		this.serviceCredentials = serviceCredentials;
		this.shareTemplate = shareTemplate;
		this.notificationType = NotificationType.TDM_TEMPLATE_SHARE;
		site = new SocialNetworkingSite(request);
		user = new SocialNetworkingUser(serviceCredentials.getUserName(), serviceCredentials.getEmail(),
				serviceCredentials.getFullName(), serviceCredentials.getUserAvatarURL());
		scope = serviceCredentials.getScope();

	}

	public void run() {
		switch (notificationType) {
		case TDM_TAB_RESOURCE_SHARE:
			tabularResourceNotify();
			break;
		case TDM_TEMPLATE_SHARE:
			templateNotify();
			break;
		case TDM_RULE_SHARE:
			ruleNotify();
			break;
		default:
			break;
		}

	}

	private void tabularResourceNotify() {
		NotificationsManager nm = new ApplicationNotificationsManager(site, scope, user, Constants.APPLICATION_ID);

		for (Contacts contact : shareTabularResource.getContacts()) {
			if (contact.isGroup()) {
				/*try {
					List<String> members = WorkspaceUtil.getMembersByGroup(contact.getLogin());
					for (String member : members) {
						try {
							nm.notifyTDMTabularResourceSharing(member, shareTabularResource.getTabResource().getName(),
									new String(Constants.TABULAR_RESOURCE_ID + "="
											+ shareTabularResource.getTabResource().getTrId().getId()));

						} catch (Exception e) {
							logger.error("Error in the notification(Type: " + notificationType + " - "
									+ serviceCredentials.getUserName() + " share tabular resource id="
									+ shareTabularResource.getTabResource().getTrId().getId() + " with " + member
									+ "): " + e.getLocalizedMessage());
							e.printStackTrace();
						}
					}

				} catch (Exception e) {
					logger.error("Error in the notification(No members found for group " + contact.getLogin() + "): "
							+ e.getLocalizedMessage());
					e.printStackTrace();
				}*/

			} else {
				try {
					nm.notifyTDMTabularResourceSharing(contact.getLogin(),
							shareTabularResource.getTabResource().getName(), new String(Constants.TABULAR_RESOURCE_ID
									+ "=" + shareTabularResource.getTabResource().getTrId().getId()));

				} catch (Exception e) {
					logger.error("Error in the notification(Type: " + notificationType + " - "
							+ serviceCredentials.getUserName() + " share tabular resource id="
							+ shareTabularResource.getTabResource().getTrId().getId() + " with " + contact.getLogin()
							+ "): " + e.getLocalizedMessage());
					e.printStackTrace();
				}

			}
		}
	}

	private void ruleNotify() {
		NotificationsManager nm = new ApplicationNotificationsManager(site, scope, user, Constants.APPLICATION_ID);

		for (Contacts contact : shareRule.getContacts()) {
			if (contact.isGroup()) {

				/*try {
					List<String> members = WorkspaceUtil.getMembersByGroup(contact.getLogin());
					for (String member : members) {
						try {
							nm.notifyTDMObjectSharing(member, notificationType,
									shareRule.getRuleDescriptionData().getName(), null);

						} catch (Exception e) {
							logger.error("Error in the notification(Type: " + notificationType + " - "
									+ serviceCredentials.getUserName() + " share rule id="
									+ shareRule.getRuleDescriptionData().getId() + " with " + member + "): "
									+ e.getLocalizedMessage());
							e.printStackTrace();
						}
					}

				} catch (Exception e) {
					logger.error("Error in the notification(No members found for group " + contact.getLogin() + "): "
							+ e.getLocalizedMessage());
					e.printStackTrace();
				}*/

			} else {
				try {
					nm.notifyTDMObjectSharing(contact.getLogin(), notificationType,
							shareRule.getRuleDescriptionData().getName(), null);

				} catch (Exception e) {
					logger.error("Error in the notification(Type: " + notificationType + " - "
							+ serviceCredentials.getUserName() + " share rule id="
							+ shareRule.getRuleDescriptionData().getId() + " with " + contact.getLogin() + "): "
							+ e.getLocalizedMessage());
					e.printStackTrace();
				}

			}
		}

	}

	private void templateNotify() {
		NotificationsManager nm = new ApplicationNotificationsManager(site, scope, user, Constants.APPLICATION_ID);

		for (Contacts contact : shareTemplate.getContacts()) {
			if (contact.isGroup()) {
				/*
				try {
					List<String> members = WorkspaceUtil.getMembersByGroup(contact.getLogin());
					for (String member : members) {
						try {
							nm.notifyTDMObjectSharing(member, notificationType,
									shareTemplate.getTemplateData().getName(), null);

						} catch (Exception e) {
							logger.error("Error in the notification(Type: " + notificationType + " - "
									+ serviceCredentials.getUserName() + " share template id="
									+ shareTemplate.getTemplateData().getId() + " with " + member + "): "
									+ e.getLocalizedMessage());
							e.printStackTrace();
						}
					}

				} catch (Exception e) {
					logger.error("Error in the notification(No members found for group " + contact.getLogin() + "): "
							+ e.getLocalizedMessage());
					e.printStackTrace();
				}*/

			} else {
				try {
					nm.notifyTDMObjectSharing(contact.getLogin(), notificationType,
							shareTemplate.getTemplateData().getName(), null);

				} catch (Exception e) {
					logger.error("Error in the notification(Type: " + notificationType + " - "
							+ serviceCredentials.getUserName() + " share template id="
							+ shareTemplate.getTemplateData().getId() + " with " + contact.getLogin() + "): "
							+ e.getLocalizedMessage());
					e.printStackTrace();
				}

			}
		}

	}

}