Merge branch 'unix_server' into 0.6.0-milestone

lib/reel.rb

@@ -14,6 +14,7 @@
 require 'reel/server'
 require 'reel/server/http'
 require 'reel/server/https'
+require 'reel/server/unix'
 
 require 'reel/websocket'
 require 'reel/stream'

lib/reel/request/body.rb

@@ -29,6 +29,10 @@ def each
         end
       end
 
+      def empty?
+        to_str.empty?
+      end
+
       # Eagerly consume the entire body as a string
       def to_str
         return @contents if @contents

lib/reel/server/unix.rb

@@ -0,0 +1,18 @@
+module Reel
+  class Server
+    class UNIX < Server
+
+      # Create a new Reel HTTPS server
+      #
+      # @option options [String] socket path to bind to
+      # @option options [Fixnum] backlog of requests to accept
+      #
+      # @return [Reel::Server::UNIX] Reel UNIX server actor
+      def initialize(socket_path, options={}, &callback)
+        server = Celluloid::IO::UNIXServer.new(socket_path)
+        options[:socket_path] = socket_path
+        super(server, options, &callback)
+      end
+    end
+  end
+end

spec/reel/unix_server_spec.rb

@@ -0,0 +1,39 @@
+require 'spec_helper'
+require 'net/http'
+
+describe Reel::Server::UNIX do
+  let(:endpoint) { URI(example_url) }
+  let(:response_body) { "ohai thar" }
+
+  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, self.response_body
+      rescue => ex
+      end
+    end
+
+    Dir::Tmpname.create('reel-sock') do |path|
+      begin
+        server  = Reel::Server::UNIX.new(path, &handler)
+        sock    = Net::BufferedIO.new Celluloid::IO::UNIXSocket.new(path)
+        request = Net::HTTP::Get.new('/')
+
+        request.exec(sock, '1.1', path)
+
+        response = Net::HTTPResponse.read_new(sock)
+        response.reading_body(sock, request.response_body_permitted?) { }
+
+        expect(response.body).to eq(self.response_body)
+      ensure
+        server.terminate if server && server.alive?
+      end
+    end
+
+    raise ex if ex
+  end
+end