Class: Gack::Server

Inherits:
Object
  • Object
show all
Defined in:
lib/gack/server.rb

Overview

The main TCP server

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(tcp: TCPServer, port: 6565, logger: Gack::Logger) ⇒ Server

Returns a new instance of Server.



10
11
12
13
14
 
# File 'lib/gack/server.rb', line 10

def initialize(tcp: TCPServer, port: 6565, logger: Gack::Logger)
  @tcp = tcp
  @port = port
  @logger = logger
end

Instance Attribute Details

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



8
9
10
 
# File 'lib/gack/server.rb', line 8

def logger
  @logger
end

#port ⇒ Object (readonly)

Returns the value of attribute port.



8
9
10
 
# File 'lib/gack/server.rb', line 8

def port
  @port
end

#tcp ⇒ Object (readonly)

Returns the value of attribute tcp.



8
9
10
 
# File 'lib/gack/server.rb', line 8

def tcp
  @tcp
end

Instance Method Details

#event_loop(&blk) ⇒ Object 



16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/gack/server.rb', line 16

def event_loop(&blk)
  logger.info("starting. port=#{port}")

  server = tcp.new(port)

  loop do
    Thread.new(server.accept) do |client|
      main_handler(client, &blk)
    end
  end
rescue StandardError => e
  logger.error(e)
end

#failure_response ⇒ Object 



53
54
55
 
# File 'lib/gack/server.rb', line 53

def failure_response
  Response.new(Response::StatusCodes::TEMPORARY_FAILURE, 'Server Error')
end

#main_handler(client, &blk) ⇒ Object 



30
31
32
33
34
35
36
 
# File 'lib/gack/server.rb', line 30

def main_handler(client, &blk)
  unrescued_handler(client, &blk)
rescue StandardError => e
  logger.error(e)

  failure_response.finalize
end

#unrescued_handler(client, &blk) ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/gack/server.rb', line 38

def unrescued_handler(client, &blk)
  raw_request = receive_request(client)

  request = Request.new(raw_request)

  logger.info("request received: #{request.location}")

  response = blk.call(request)

  logger.info("response: #{response.status_code}")

  client.puts(response.finalize)
  client.close
end