Class: Net::HTTP::Server::Daemon

Inherits:
GServer
  • Object
show all
Includes:
Requests, Responses
Defined in:
lib/net/http/server/daemon.rb

Constant Summary collapse

DEFAULT_HOST =

Default host to bind to.

'0.0.0.0'
DEFAULT_PORT =

Default port to listen on.

8080
MAX_CONNECTIONS =

Maximum number of simultaneous connections.

256

Constants included from Responses

Responses::BAD_REQUEST, Responses::HTTP_STATUSES, Responses::HTTP_VERSION

Constants included from Requests

Requests::DEFAULT_PORTS

Instance Method Summary collapse

Methods included from Responses

#write_body, #write_body_streamed, #write_headers, #write_response, #write_status

Methods included from Requests

#normalize_headers, #normalize_request, #normalize_uri, #read_request

Constructor Details

#initialize(options = {}) {|request, socket| ... } ⇒ Daemon

Creates a new HTTP Daemon.

Parameters:

  • options (Hash) (defaults to: {}) —

    Options for the daemon.

Options Hash (options):

  • :host (String) — default: DEFAULT_HOST —

    The host to run on.

  • :port (String) — default: DEFAULT_PORT —

    The port to listen on.

  • :max_connections (Integer) — default: MAX_CONNECTIONS —

    The maximum number of simultaneous connections.

  • :log (IO) — default: $stderr —

    The log to write errors to.

  • :handler (#call) —

    The HTTP Request Handler object.

Yields:

  • (request, socket) —

    If a block is given, it will be used to process HTTP Requests.

Yield Parameters:

  • request (Hash{Symbol => String,Array,Hash}) —

    The HTTP Request.

  • socket (TCPSocket) —

    The TCP socket of the client.



56
57
58
59
60
61
62
63
64
65
 
# File 'lib/net/http/server/daemon.rb', line 56

def initialize(options={},&block)
  host = options.fetch(:host,DEFAULT_HOST)
  port = options.fetch(:port,DEFAULT_PORT).to_i
  max_connections = options.fetch(:max_connections,MAX_CONNECTIONS)
  log = options.fetch(:log,$stderr)

  super(port,host,max_connections,log,false,true)

  handler(options[:handler],&block)
end

Instance Method Details

#handler(object = nil) {|request, stream| ... } ⇒ Object

Sets the HTTP Request Handler.

Parameters:

  • object (#call, nil) (defaults to: nil) —

    The HTTP Request Handler object.

Yields:

  • (request, stream) —

    If a block is given, it will be used to process HTTP Requests.

Yield Parameters:

  • request (Hash{Symbol => String,Array,Hash}) —

    The HTTP Request.

  • stream (Stream, ChunkedStream) —

    The stream of the HTTP Request body.

Raises:

  • (ArgumentError) —

    The HTTP Request Handler must respond to #call.



85
86
87
88
89
90
91
92
93
94
95
 
# File 'lib/net/http/server/daemon.rb', line 85

def handler(object=nil,&block)
  if object
    unless object.respond_to?(:call)
      raise(ArgumentError,"HTTP Request Handler must respond to #call")
    end
  elsif block.nil?
    raise(ArgumentError,"no HTTP Request Handler block given")
  end

  @handler = (object || block)
end

#serve(socket) ⇒ Object

Receives HTTP Requests and handles them.

Parameters:

  • socket (TCPSocket) —

    A new TCP connection.



103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
 
# File 'lib/net/http/server/daemon.rb', line 103

def serve(socket)
  if (raw_request = read_request(socket))
    parser = Parser.new

    begin
      request = parser.parse(raw_request)
    rescue Parslet::ParseFailed => error
      return Responses::BAD_REQUEST
    end

    normalize_request(request)

    stream = if request[:headers]['Transfer-Encoding'] == 'chunked'
               ChunkedStream.new(socket)
             else
               Stream.new(socket)
             end

    # rack compliant
    status, headers, body = @handler.call(request,stream)

    write_response(socket,status,headers,body)
  end
end