Class: FSR::EventSocket

Inherits:

Object

• Object
• FSR::EventSocket

show all

Defined in:

lib/fsr/event_socket.rb

Instance Attribute Summary (collapse)

• - (Object) socket readonly

  Returns the value of attribute socket.

Instance Method Summary (collapse)

• - (Object) <<(cmd)

  Send a command, do not return response.

• - (Object) get_header_and_body

  Grab result from command and create a hash, simple but works.

• - (EventSocket) initialize(socket) constructor

  A new instance of EventSocket.

• - (Object) response

  Scrub result into a hash.

• - (Object) say(cmd)

  Send a command and return response.

5
6
7

# File 'lib/fsr/event_socket.rb', line 5

def initialize(socket)
  @socket = socket
end

3
4
5

# File 'lib/fsr/event_socket.rb', line 3

def socket
  @socket
end

16
17
18

# File 'lib/fsr/event_socket.rb', line 16

def <<(cmd)
  @socket.send("#{cmd}\n\n",0)
end

21
22
23
24
25
26
27
28
29
30
31
32
33

# File 'lib/fsr/event_socket.rb', line 21

def get_header_and_body
  headers, body = {}, ""
  until line = @socket.gets and line.chomp.empty?
    if (kv = line.chomp.split(/:\s+/,2)).size == 2
      headers.store *kv
    end
  end
  if (content_length = headers["Content-Length"].to_i) > 0
    Log.debug "content_length is #{content_length}, grabbing from socket"
    body << @socket.read(content_length)
  end
  headers.merge("body" => body.strip)
end

36
37
38

# File 'lib/fsr/event_socket.rb', line 36

def response
  get_header_and_body
end

10
11
12
13

# File 'lib/fsr/event_socket.rb', line 10

def say(cmd)
  @socket.send("#{cmd}\n\n",0)
  response
end