aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorre4k <re4k@re4k.info>2013-05-05 01:05:46 +0900
committerre4k <re4k@re4k.info>2013-05-05 01:05:46 +0900
commitff31433008efb63c43e83bdc3dcec7f999dd0cd4 (patch)
tree536c39c43d57602b76a3502ffb827d0721d2adfa /lib
parent991c9cfb729263e847889d30011b8cccf46678e1 (diff)
downloadaclog-ff31433008efb63c43e83bdc3dcec7f999dd0cd4.tar.gz
fix spam detection
Diffstat (limited to 'lib')
-rw-r--r--lib/receiver/worker.rb9
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