diff options
author | re4k <re4k@re4k.info> | 2013-05-05 01:05:46 +0900 |
---|---|---|
committer | re4k <re4k@re4k.info> | 2013-05-05 01:05:46 +0900 |
commit | ff31433008efb63c43e83bdc3dcec7f999dd0cd4 (patch) | |
tree | 536c39c43d57602b76a3502ffb827d0721d2adfa /lib | |
parent | 991c9cfb729263e847889d30011b8cccf46678e1 (diff) | |
download | aclog-ff31433008efb63c43e83bdc3dcec7f999dd0cd4.tar.gz |
fix spam detection
Diffstat (limited to 'lib')
-rw-r--r-- | lib/receiver/worker.rb | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/lib/receiver/worker.rb b/lib/receiver/worker.rb index 19ee4af..b0f1d0f 100644 --- a/lib/receiver/worker.rb +++ b/lib/receiver/worker.rb @@ -96,6 +96,8 @@ class Receiver::Worker < DaemonSpawn::Base receive_retweet(msg) when "delete" receive_delete(msg) + when "spam" + receive_spam(msg) when "quit" # Heroku の cycling など Rails.logger.info("Quit(#{@worker_number}): #{msg["reason"]}") @@ -202,6 +204,13 @@ class Receiver::Worker < DaemonSpawn::Base end end end + + def receive_spam(msg) + Rails.logger.info("Receive Spam(#{@worker_number}): #{msg["id"]}") + # @@wq.push -> do + # # TODO + # end + end end class RegisterServer < EM::Connection |