EditCommentPlugin.java

package org.exoplatform.social.notification.plugin;

import org.apache.commons.lang.StringUtils;
import org.exoplatform.commons.api.notification.NotificationContext;
import org.exoplatform.commons.api.notification.model.NotificationInfo;
import org.exoplatform.commons.api.notification.plugin.BaseNotificationPlugin;
import org.exoplatform.container.xml.InitParams;
import org.exoplatform.social.core.activity.model.ExoSocialActivity;
import org.exoplatform.social.core.identity.model.Identity;
import org.exoplatform.social.core.identity.provider.SpaceIdentityProvider;
import org.exoplatform.social.notification.Utils;

import java.util.ArrayList;
import java.util.HashSet;
import java.util.Set;

public class EditCommentPlugin  extends BaseNotificationPlugin {
    public static final String ID = "EditCommentPlugin";

    protected boolean isSubComment = false;

    public EditCommentPlugin(InitParams initParams) {
        super(initParams);
    }

    @Override
    public NotificationInfo makeNotification(NotificationContext ctx) {
        ExoSocialActivity comment = ctx.value(SocialNotificationUtils.ACTIVITY);
        ExoSocialActivity activity = Utils.getActivityManager().getParentActivity(comment);

        Set<String> receivers = new HashSet<String>();
        if (StringUtils.isNotBlank(comment.getParentCommentId())) {
            ExoSocialActivity parentComment = Utils.getActivityManager().getActivity(comment.getParentCommentId());
            String parentCommentUserPosterId = Utils.getUserId(parentComment.getPosterId());
            if (isSubComment) {
                // Send notification to parent comment poster
                Utils.sendToActivityPoster(receivers, parentComment.getPosterId(), comment.getPosterId());
            } else {
                // Send notification to all others users who have commented on this activity
                // except parent comment poster
                Utils.sendToCommeters(receivers, activity.getCommentedIds(), comment.getPosterId());
                Utils.sendToStreamOwner(receivers, activity.getStreamOwner(), comment.getPosterId());
                Utils.sendToActivityPoster(receivers, activity.getPosterId(), comment.getPosterId());
                receivers.remove(parentCommentUserPosterId);
            }
        } else {
            // Send notification to all others users who have comment on this activity
            Utils.sendToCommeters(receivers, activity.getCommentedIds(), comment.getPosterId());
            Utils.sendToStreamOwner(receivers, activity.getStreamOwner(), comment.getPosterId());
            Utils.sendToActivityPoster(receivers, activity.getPosterId(), comment.getPosterId());
        }
        //
        return NotificationInfo.instance()
                .to(new ArrayList<String>(receivers))
                .with(SocialNotificationUtils.ACTIVITY_ID.getKey(), activity.getId())
                .with(SocialNotificationUtils.COMMENT_ID.getKey(), comment.getId())
                .with(SocialNotificationUtils.POSTER.getKey(), Utils.getUserId(comment.getUserId()))
                .key(getId());
    }


    @Override
    public String getId() {
        return ID;
    }

    @Override
    public boolean isValid(NotificationContext ctx) {
        ExoSocialActivity comment = ctx.value(SocialNotificationUtils.ACTIVITY);
        ExoSocialActivity activity = Utils.getActivityManager().getParentActivity(comment);

        if(isSubComment && comment.getParentCommentId() == null) {
            return false;
        }

        Identity spaceIdentity = Utils.getIdentityManager().getOrCreateIdentity(SpaceIdentityProvider.NAME, activity.getStreamOwner(), false);
        //if the space is not null and it's not the default activity of space, then it's valid to make notification
        if (spaceIdentity != null && activity.getPosterId().equals(spaceIdentity.getId())) {
            return false;
        }
        return true;
    }
}