async callback to generate feeds

models/comment.rb

@@ -20,12 +20,16 @@ class Comment
   #validates_presence_of :author # allow anonymity?
 
   before_destroy :delete_descendants
-  #after_create :create_feeds
+  after_create :generate_feeds
   
   def self.hash_tree(nodes)
     nodes.map{|node, sub_nodes| node.to_hash.merge("children" => hash_tree(sub_nodes).compact)}
   end
 
+  def comment_thread
+    comment_thread || root.comment_thread
+  end
+
   def to_hash(params={})
     if params[:recursive]
       self.class.hash_tree(subtree(order_by: [[:parent_ids, :asc], [:created_at, :asc]]))
@@ -36,4 +40,22 @@ class Comment
     end
   end
 
+  def generate_feeds
+    feed = Feed.new(
+      feed_type: "post_reply",
+      info: {
+        comment_thread_id: comment_thread.id,
+        comment_thread_title: comment_thread.title,
+        comment_id: id,
+      },
+    )
+    feed.actor = author
+    feed.target = self
+    feed.subscribers << comment_thread.watchers
+    feed.subscribers << author.followers
+    feed.save!
+  end
+
+  handle_asynchronously :generate_feeds
+
 end

models/comment_thread.rb

@@ -21,7 +21,7 @@ class CommentThread
   validates_presence_of :course_id # do we really need this?
   #validates_presence_of :author #allow anonymity?
   
-  #after_create :create_feeds
+  after_create :generate_feeds
   
   def to_hash(params={})
     doc = as_document.slice(*%w[title body course_id _id]).
@@ -33,4 +33,22 @@ class CommentThread
     doc
   end
 
+  def generate_feeds
+    feed = Feed.new(
+      feed_type: "post_topic",
+      info: {
+        commentable_id: commentable.id,
+        commentable_type: commentable.type,
+        comment_thread_id: comment_thread.id,
+        comment_thread_title: comment_thread.title,
+      },
+    )
+    feed.actor = author
+    feed.target = self
+    feed.subscribers << commentable.watchers
+    feed.subscribers << author.followers
+    feed.save!
+  end
+
+  handle_asynchronously :generate_feeds
 end

models/feed.rb

@@ -10,5 +10,9 @@ class Feed
 
   attr_accessible :feed_type, :info
 
+  validates_presence_of :feed_type
+  validates_presence_of :actor
+  validates_presence_of :target
+
   has_and_belongs_to_many :subscribers, class_name: "User", inverse_of: :subscribed_feeds
 end