Merge f8571d5 into 4e80ee2

lib/reel/server.rb

@@ -12,6 +12,15 @@ class Server
     execute_block_on_receiver :initialize
     finalizer :shutdown
 
+    # Allow the existing `new` to be called, even though we will
+    # replace it with a default version that creates HTTP servers over
+    # TCP sockets.
+    #
+    class << self
+      alias_method :_new, :new
+      protected    :_new
+    end
+
     # Create a new Reel HTTP server
     #
     # @param [String] host address to bind to
@@ -35,7 +44,7 @@ def self.new(host, port, options = {} , &callback)
       server.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, 1)
       server.listen(backlog)
 
-      super(server, options, &callback)
+      self._new(server, options, &callback)
     end
 
     # Create a Reel HTTP server over a UNIX socket.
@@ -46,7 +55,7 @@ def self.new(host, port, options = {} , &callback)
     def self.unix(socket_path, options = {}, &callback)
       server = Celluloid::IO::UNIXServer.new(socket_path)
 
-      super(server, options, &callback)
+      self._new(server, options, &callback)
     end
 
     def initialize(server, options = {}, &callback)

spec/reel/server_spec.rb

@@ -52,4 +52,29 @@
 
     raise ex if ex
   end
+
+  it 'allows connections over UNIX sockets' do
+    ex = nil
+
+    handler = proc do |connection|
+      begin
+        request = connection.request
+        request.method.should eq 'GET'
+        connection.respond :ok, request.body.to_s
+      rescue => ex
+      end
+    end
+
+    Dir::Tmpname.create('reel-sock') do |path|
+      begin
+        server  = Reel::Server.unix(path, handler)
+        sock    = Net::BufferedIO.new UNIXSocket.new(path)
+        request = Net::HTTP::Get.new('/')
+
+        request.exec(sock, '1.1', path)
+      ensure
+        server.terminate if server && server.alive?
+      end
+    end
+  end
 end