Add DCell support for Futures

Make the Router to duck-type on the recipient to support Futures

lib/dcell.rb

@@ -14,6 +14,7 @@
 require 'dcell/responses'
 require 'dcell/router'
 require 'dcell/rpc'
+require 'dcell/future'
 require 'dcell/server'
 require 'dcell/info_service'
 

lib/dcell/celluloid_ext.rb

@@ -66,4 +66,15 @@ def self._load(string)
       DCell::RPC._load(string)
     end
   end
+
+  class Future
+    def _dump(level)
+      address = DCell::Router.register self
+      DCell::Future.new(address,DCell.id,DCell.addr)._dump(level)
+    end
+
+    def self._load(string)
+      DCell::Future._load(string)
+    end
+  end
 end

lib/dcell/future.rb

@@ -0,0 +1,29 @@
+module DCell
+  class Future
+    def initialize(address,node_id,node_addr)
+      @address = address
+      @node_id = node_id
+      @node_addr = node_addr
+    end
+
+    def <<(message)
+      node = Node[@node_id]
+      node = Node.new(@node_id, @node_addr) unless node
+      node.send_message! Message::Relay.new(self, message)
+    end
+
+    def _dump(level)
+      Marshal.dump [@address, @node_id, @node_addr]
+    end
+
+    # Loader for custom marshal format
+    def self._load(string)
+      address, node_id, node_addr = Marshal.load(string)
+      if node_id == DCell.id
+        Router.find(address)
+      else
+        new(address, node_id, node_addr)
+      end
+    end
+  end
+end

lib/dcell/router.rb

@@ -44,24 +44,28 @@ def find(mailbox_address)
       end
 
       # Route a message to a given mailbox ID
-      def route(mailbox_address, message)
-        recipient = find mailbox_address
+      def route(recipient, message)
+        unless recipient.respond_to?(:signal)
+          recipient = find recipient
+        end
 
         if recipient
-          recipient << message
+          recipient.signal message
         else
-          Celluloid::Logger.debug("received message for invalid actor: #{mailbox_address.inspect}")
+          Celluloid::Logger.debug("received message for invalid actor: #{recipient.inspect}")
         end
       end
 
       # Route a system event to a given mailbox ID
-      def route_system_event(mailbox_address, event)
-        recipient = find mailbox_address
+      def route_system_event(recipient, event)
+        unless recipient.respond_to?(:system_event)
+          recipient = find recipient
+        end
 
         if recipient
           recipient.system_event event
         else
-          Celluloid::Logger.debug("received message for invalid actor: #{mailbox_address.inspect}")
+          Celluloid::Logger.debug("received message for invalid actor: #{recipient.inspect}")
         end
       end