Vulcan/packages/telescope-subscribe-to-posts/lib/subscribe-to-posts.js

Telescope.registerModule("thread", {
  template: 'postSubscribe',
  order: 10
});

Posts.addToSchema(
  {
    propertyName: 'subscribers',
    propertySchema: {
      type: [String],
      optional: true,
      autoform: {
        omit: true
      }
    }
  }
);

Posts.addToSchema(
  {
    propertyName: 'subscriberCount',
    propertySchema: {
      type: Number,
      optional: true,
      autoform: {
        omit: true
      }
    }
  }
);

Telescope.registerModule("profileEdit", {
  template: 'userSubscribedPosts',
  order: 5
});

viewParameters.userSubscribedPosts = function (terms) {
  var user = Meteor.users.findOne(terms.userId),
      postsIds = [];

  if (user.subscribedItems && user.subscribedItems.Posts)
    postsIds = _.pluck(user.subscribedItems.Posts, "itemId");

  return {
    find: {_id: {$in: postsIds}},
    options: {limit: 5, sort: {postedAt: -1}}
  };
}

var hasSubscribedItem = function (item, user) {
  return item.subscribers && item.subscribers.indexOf(user._id) != -1;
};

var addSubscribedItem = function (userId, item, collection) {
  var field = 'subscribedItems.' + collection;
  var add = {};
  add[field] = item;
  Meteor.users.update({_id: userId}, {
    $addToSet: add
  });
};

var removeSubscribedItem = function (userId, itemId, collection) {
  var field = 'subscribedItems.' + collection;
  var remove = {};
  remove[field] = {itemId: itemId};
  Meteor.users.update({_id: userId}, {
    $pull: remove
  });
};

subscribeItem = function (collection, itemId, user) {
  var item = collection.findOne(itemId),
      collectionName = collection._name.slice(0,1).toUpperCase() + collection._name.slice(1);

  if (!user || !item || hasSubscribedItem(item, user))
    return false;

  // author can't subscribe item
  if (item.userId && item.userId === user._id)
    return false

  // Subscribe
  var result = collection.update({_id: itemId, subscribers: { $ne: user._id }}, {
    $addToSet: {subscribers: user._id},
    $inc: {subscriberCount: 1}
  });

  if (result > 0) {
    // Add item to list of subscribed items
    var obj = {
      itemId: item._id,
      subscribedAt: new Date()
    };
    addSubscribedItem(user._id, obj, collectionName);
  }

  return true;
};

unsubscribeItem = function (collection, itemId, user) {
  var user = Meteor.user(),
      item = collection.findOne(itemId),
      collectionName = collection._name.slice(0,1).toUpperCase()+collection._name.slice(1);

  if (!user || !item  || !hasSubscribedItem(item, user))
    return false;

  // Unsubscribe
  var result = collection.update({_id: itemId, subscribers: user._id }, {
    $pull: {subscribers: user._id},
    $inc: {subscriberCount: -1}
  });

  if (result > 0) {
    // Remove item from list of subscribed items
    removeSubscribedItem(user._id, itemId, collectionName);
  }
  return true;
};

Meteor.methods({
  subscribePost: function(postId) {
    return subscribeItem.call(this, Posts, postId, Meteor.user());
  },
  unsubscribePost: function(postId) {
    return unsubscribeItem.call(this, Posts, postId, Meteor.user());
  }
});