send follow message.

Author: zhuangbiaowei

config/config.rb

@@ -1,4 +1,4 @@
 require './lib/observer'
 Mongoid.configure.load!("./config/mongoid.yml")
-Mongoid.observers = BlockObserver,BlockLinkObserver
+Mongoid.observers = BlockObserver,BlockLinkObserver,WatchObserver
 Mongoid.instantiate_observers

controllers/controller_for_views.rb

@@ -144,7 +144,7 @@
 		r=Redis.new
 		id=@current_user.Id
 		while v=r.rpop(id)	do
-			@msgs << v
+			@msgs << Marshal.load(v)
 		end
 		r.del("#{id}_count")
 		@msg_count = 0

lib/observer.rb

@@ -1,5 +1,18 @@
+# encoding: utf-8
+
 class BlockObserver < Mongoid::Observer
+	def after_create(doc)
+	end
 end
 
 class BlockLinkObserver < Mongoid::Observer
 end
+
+class WatchObserver < Mongoid::Observer
+	def after_create(doc)
+		if doc.WatchType=="user"
+			user=User.where(:Id=>doc.UserId).first
+			send_message(doc.WatchedId,"<a href='/user/#{user.Id}'>#{user.Name}</a> now follow you.")
+		end
+	end
+end

lib/utils.rb

@@ -1,3 +1,5 @@
+# encoding: utf-8
+
 def user_avatar(id)
 	user=User.where(:Id=>id).first
 	if user
@@ -26,4 +28,10 @@ def get_msg_count(user)
 
 def is_followed(from_id,to_id)
 	return Watch.where(:UserId=>from_id,:WatchedId=>to_id,:WatchType=>'user').first
+end
+
+def send_message(user_id,msg)
+	r=Redis.new
+	r.rpush(user_id,Marshal.dump(msg))
+	r.incr("#{user_id}_count")
 end