Contents

class Midori::Request
  attr_accessor :ip, :port,
                :protocol, :method, :path, :query_string,
                :header, :body, :parsed

  def initialize
    @parsed = false
    @is_websocket = false
    @is_eventsource = false
  end

  # Init an request with StringIO data
  # === Attributes
  # * +data+ [+StringIO+] - Request data
  def parse(data)
    @header = {}

    # Parse request
    line = data.gets.split
    @protocol = line[2]
    @method = line[0]
    @query_string = line[1].match(/\?(.*?)$/)
    @query_string = @query_string[1] unless @query_string.nil?
    @path = line[1].gsub(/\?(.*?)$/, '')

    # Parse header
    while (line = data.gets) != "\r\n"
      line = line.split
      @header[line[0][0..-2]] = line[1..-1].join(' ')
    end

    # Deal with WebSocket
    if @header['Upgrade'] == 'websocket' && @header['Connection'] == 'Upgrade'
      @method = 'WEBSOCKET'
      @is_websocket = true
    end

    # Deal with EventSource
    if @header['Accept'] == 'text/event-stream'
      @method = 'EVENTSOURCE'
      @is_eventsource = true
    end

    # Parse body
    @body = data.read
    @parsed = true
  end

  def parsed?
    @parsed
  end

  def websocket?
    @is_websocket
  end

  def eventsource?
    @is_eventsource
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
em-midori-0.0.9.2	lib/em-midori/request.rb
em-midori-0.0.9.1	lib/em-midori/request.rb
em-midori-0.0.9	lib/em-midori/request.rb