Added: async service calling with EM.defer refs #178

Conflicts:
	plugins/as_android_notifier/lib/as_android_notifier.rb

app/helpers/chat_helper.rb

@@ -37,12 +37,14 @@ def publish_message(event, message, room)
              { :content => to_json(message, room) }
            end
 
-    begin
-      AsakusaSatellite::MessagePusher.trigger("as-#{room.id}",
-                                              "message_#{event}",
-                                              data.to_json)
-    rescue => e
-      Rails.logger.warn "fail to send message: #{e.inspect}"
+    AsakusaSatellite::AsyncRunner.run do
+      begin
+        AsakusaSatellite::MessagePusher.trigger("as-#{room.id}",
+                                                "message_#{event}",
+                                                data.to_json)
+      rescue => e
+        Rails.logger.warn "fail to send message: #{e.inspect}"
+      end
     end
 
     if event == :create then

lib/asakusa_satellite.rb

@@ -3,6 +3,7 @@
 require 'asakusa_satellite/filter/filter_config'
 require 'asakusa_satellite/filter/loader'
 require 'asakusa_satellite/hook'
+require 'asakusa_satellite/async_runner'
 require 'asakusa_satellite/config'
 require 'asakusa_satellite/message_pusher'
 require 'asakusa_satellite/omniauth/adapter'

lib/asakusa_satellite/async_runner.rb

@@ -0,0 +1,14 @@
+require 'eventmachine'
+
+module AsakusaSatellite
+  class AsyncRunner
+    def self.run(&block)
+      if EM.reactor_running?
+        EM.defer(block)
+      else
+        block.call
+      end
+    end
+  end
+end
+

plugins/as_android_notifier/lib/as_android_notifier.rb

@@ -19,19 +19,21 @@ def after_create_message(context)
       device.device_type == 'android'
     }
 
-    android.to_a.map{|device|
-      { :registration_id => device.name,
-        :data => {
-          :message => text,
-          :id => room.id
+    AsakusaSatellite::AsyncRunner.run do
+      android.to_a.map{|device|
+        { :registration_id => device.name,
+          :data => {
+            :message => text,
+            :id => room.id
+          }
         }
+      }.tap{|xs|
+        C2DM.send_notifications(ENV["ANDROID_MAIL_ADDRESS"],
+          ENV["ANDROID_PASSWORD"],
+          xs,
+          ENV["ANDROID_APPLICATION_NAME"])
       }
-    }.tap{|xs|
-      C2DM.send_notifications(ENV["ANDROID_MAIL_ADDRESS"],
-        ENV["ANDROID_PASSWORD"],
-        xs,
-        ENV["ANDROID_APPLICATION_NAME"])
-    }
+    end
 
   end
 

plugins/as_chrome_notifier/lib/as_chrome_notifier.rb

@@ -6,10 +6,12 @@ def after_create_message(context)
     message = context[:message]
     room = context[:room]
 
-    room.owner_and_members.each do |member|
-      member.devices.each do |device|
-        if device.device_type == "chrome" and device.name
-          Chrome.send(device.name, message.id)
+    AsakusaSatellite::AsyncRunner.run do
+      room.owner_and_members.each do |member|
+        member.devices.each do |device|
+          if device.device_type == "chrome" and device.name
+            Chrome.send(device.name, message.id)
+          end
         end
       end
     end

plugins/as_iphone_notifier/lib/as_iphone_notifier.rb

@@ -31,16 +31,18 @@ def after_create_message(context)
       device.device_type.nil? or device.device_type == 'iphone'
     end
 
-    iphones.to_a.map{|iphone|
-      APNS::Notification.new(iphone.name,
-        :alert => text,
-        :sound => 'default',
-        :other => {
-          :id => room.id
-        })
-    }.tap{|xs|
-      APNS.send_notifications xs
-    }
+    AsakusaSatellite::AsyncRunner.run do
+      iphones.to_a.map{|iphone|
+        APNS::Notification.new(iphone.name,
+          :alert => text,
+          :sound => 'default',
+          :other => {
+            :id => room.id
+          })
+      }.tap{|xs|
+        APNS.send_notifications xs
+      }
+    end
   rescue => e
     Rails.logger.error e
   end