Vulcan/collections/comments.js

Comments = new Meteor.Collection('comments');

// Comments = new Meteor.Collection("comments", {
//   schema: new SimpleSchema({
//     body: {
//       type: String,
//     },
//     baseScore: {
//       type: Number
//     },
//     score: {
//       type: Number
//     }
//     baseScore: {
//       type: Number
//     },
//     upvotes: {
//       type: Number
//     },
//     upvoters: {
//       type: []
//     },
//     downvotes: {
//       type: Number
//     },
//     downvoters: {
//       type: []
//     }
//     score: {
//       type: Number
//     },
//     author: {
//       type: String
//     },
//     inactive: {
//       type: Boolean
//     },
//     createdAt: {
//       type: Date
//     },
//     postId: {
//       type: "???"
//     },
//     userId: {
//       type: "???"
//     }
//   })
// });

Comments.deny({
  update: function(userId, post, fieldNames) {
    if(isAdminById(userId))
      return false;
    // deny the update if it contains something other than the following fields
    return (_.without(fieldNames, 'body').length > 0);
  }
});

Comments.allow({
  insert: canCommentById,
  update: canEditById,
  remove: canEditById
});




Meteor.methods({
  comment: function(postId, parentCommentId, text){
    var user = Meteor.user(),
        post=Posts.findOne(postId),
        postUser=Meteor.users.findOne(post.userId),
        timeSinceLastComment=timeSinceLast(user, Comments),
        cleanText= cleanUp(text),
        commentInterval = Math.abs(parseInt(getSetting('commentInterval',15))),
        properties={
          'commentAuthorId': user._id,
          'commentAuthorName': getDisplayName(user),
          'commentExcerpt': trimWords(stripMarkdown(cleanText),20),
          'postId': postId,
          'postHeadline' : post.headline
        };

    // check that user can comment
    if (!user || !canComment(user))
      throw new Meteor.Error(i18n.t('You need to login or be invited to post new comments.'));
    
    // check that user waits more than 15 seconds between comments
    if(!this.isSimulation && (timeSinceLastComment < commentInterval))
      throw new Meteor.Error(704, i18n.t('Please wait ')+(commentInterval-timeSinceLastComment)+i18n.t(' seconds before commenting again'));

    // Don't allow empty comments
    if (!cleanText)
      throw new Meteor.Error(704,i18n.t('Your comment is empty.'));
          
    var comment = {
        post: postId,
        body: cleanText,
        userId: user._id,
        submitted: new Date().getTime(),
        author: getDisplayName(user)
    };
    
    if(parentCommentId)
      comment.parent = parentCommentId;

    var newCommentId=Comments.insert(comment);

    // increment comment count
    Meteor.users.update({_id: user._id}, {$inc: {commentCount: 1}});

    // extend comment with newly created _id
    comment = _.extend(comment, {_id: newCommentId});

    Posts.update(postId, {$inc: {comments: 1}});

    Meteor.call('upvoteComment', comment);

    properties.commentId = newCommentId;

    if(!this.isSimulation){
      if(parentCommentId){
        // child comment
        var parentComment=Comments.findOne(parentCommentId);
        var parentUser=Meteor.users.findOne(parentComment.userId);

        properties.parentCommentId = parentCommentId;
        properties.parentAuthorId = parentComment.userId;
        properties.parentAuthorName = getDisplayName(parentUser);

        if(!this.isSimulation){
          // reply notification
          // do not notify users of their own actions (i.e. they're replying to themselves)
          if(parentUser._id != user._id){
            createNotification({
              event: 'newReply',
              properties: properties,
              userToNotify: parentUser,
              userDoingAction: user,
              sendEmail: getUserSetting('notifications.replies', false, parentUser)
            });
          }

          // comment notification
          // if the original poster is different from the author of the parent comment, notify them too
          if(postUser._id != user._id && parentComment.userId != post.userId){
            createNotification({
              event: 'newComment',
              properties: properties,
              userToNotify: postUser,
              userDoingAction: user,
              sendEmail: getUserSetting('notifications.comments', false, postUser)
            });
          }
        }
      }else{
        if(!this.isSimulation){
          // root comment
          // don't notify users of their own comments
          if(postUser._id != user._id){
            createNotification({
              event: 'newComment',
              properties: properties,
              userToNotify: postUser,
              userDoingAction: Meteor.user(),
              sendEmail: getUserSetting('notifications.comments', false, postUser)
            });
          }
        }
      }
    }
    return properties;
  },
  removeComment: function(commentId){
    var comment=Comments.findOne(commentId);
    if(canEdit(Meteor.user(), comment)){
      // decrement post comment count
      Posts.update(comment.post, {$inc: {comments: -1}});

      // decrement user comment count
      Meteor.users.update({_id: comment.userId}, {$inc: {commentCount: -1}});

      // note: should we also decrease user's comment karma ?
      Comments.remove(commentId);
    }else{
      throwError("You don't have permission to delete this comment.");
    }
  }
});