Class: Knod::Server

Inherits:
Object
  • Object
show all
Includes:
FileUtilities
Defined in:
lib/knod/server.rb

Constant Summary collapse

DEFAULT_PORT = 
4444
DEFAULT_WEB_ROOT = 
'./'

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from FileUtilities

#file_extension

Constructor Details

#initialize(options = {}) ⇒ Server

Returns a new instance of Server.



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

def initialize(options={})
  port     = options.fetch(:port) { DEFAULT_PORT }
  @root    = options.fetch(:root) { DEFAULT_WEB_ROOT }
  @logging = options.fetch(:logging) { true }
  @server  = TCPServer.new('0.0.0.0', port)
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(method_sym, *args, &block) ⇒ Object (private) 



183
184
185
186
187
188
189
 
# File 'lib/knod/server.rb', line 183

def method_missing(method_sym, *args, &block)
  if method_sym.to_s.start_with?("do_")
    respond(501, "\"not implemented\"")
  else
    super
  end
end

Instance Attribute Details

#request ⇒ Object (readonly)

Returns the value of attribute request.



5
6
7
 
# File 'lib/knod/server.rb', line 5

def request
  @request
end

#server ⇒ Object (readonly)

Returns the value of attribute server.



5
6
7
 
# File 'lib/knod/server.rb', line 5

def server
  @server
end

#socket ⇒ Object (readonly)

Returns the value of attribute socket.



5
6
7
 
# File 'lib/knod/server.rb', line 5

def socket
  @socket
end

Instance Method Details

#accept_request_and_respond ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/knod/server.rb', line 24

def accept_request_and_respond
  @socket = server.accept
  @request = Request.new(socket)
  log request_line
  public_send "do_#{request.method}"
rescue => e
  log "#{e.class}: #{e.message}"
  log e.backtrace
  respond 500
ensure
  socket.close if socket
end

#do_DELETE ⇒ Object 



56
57
58
59
60
 
# File 'lib/knod/server.rb', line 56

def do_DELETE
  path = requested_path
  delete_file(path) if file?(path)
  respond 204
end

#do_GET(head = false) ⇒ Object 



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

def do_GET(head=false)
  path = requested_path
  path = join_path(path, 'index.html') if directory?(path)

  if file?(path)
    File.open(path, 'rb') do |file|
      socket.print file_response_header(file)
      IO.copy_stream(file, socket) unless head
    end
  else
    message = head ? '' : "\"File not found\""
    respond(404, message)
  end
end

#do_HEAD ⇒ Object 



52
53
54
 
# File 'lib/knod/server.rb', line 52

def do_HEAD
  do_GET(head=true)
end

#do_PATCH ⇒ Object 



70
71
72
73
74
75
76
77
78
79
 
# File 'lib/knod/server.rb', line 70

def do_PATCH
  path = requested_path
  data = if file?(path)
           merge_json(read_file(path), request.body)
         else
           request.body
         end
  write_to_path(path, data)
  respond(200, "\"Success\"")
end

#do_POST ⇒ Object 



82
83
84
85
86
87
88
 
# File 'lib/knod/server.rb', line 82

def do_POST
  path = requested_path
  create_directory(path)
  next_id = max_id_in_path(path) + 1
  write_file(join_path(path, "#{next_id}.json"), request.body)
  respond(201, "{\"id\":#{next_id}}")
end

#do_PUT ⇒ Object 



62
63
64
65
 
# File 'lib/knod/server.rb', line 62

def do_PUT
  write_to_path(requested_path, request.body)
  respond(200, "\"Success\"")
end

#port ⇒ Object 



90
91
92
 
# File 'lib/knod/server.rb', line 90

def port
  server.addr[1]
end

#start ⇒ Object 



17
18
19
20
21
22
 
# File 'lib/knod/server.rb', line 17

def start
  log "Starting server on port #{port}"
  loop do
    accept_request_and_respond
  end
end