module EventMachine::WebSocket::MessageProcessor06

Public Instance Methods

message(message_type, extension_data, application_data) click to toggle source
# File lib/em-websocket/message_processor_06.rb, line 4
def message(message_type, extension_data, application_data)
  debug [:message_received, message_type, application_data]
  
  case message_type
  when :close
    status_code = case application_data.length
    when 0
      # close messages MAY contain a body
      nil
    when 1
      # Illegal close frame
      raise WSProtocolError, "Close frames with a body must contain a 2 byte status code"
    else
      application_data.slice!(0, 2).unpack('n').first
    end
    
    debug [:close_frame_received, status_code, application_data]
    
    @close_info = {
      :code => status_code || 1005,
      :reason => application_data,
      :was_clean => true,
    }

    if @state == :closing
      # We can close connection immediately since no more data may be
      # sent or received on this connection
      @connection.close_connection
    elsif @state == :connected
      # Acknowlege close & echo status back to client
      # The connection is considered closed
      close_data = [status_code || 1000].pack('n')
      send_frame(:close, close_data)
      @connection.close_connection_after_writing
    end
  when :ping
    # Pong back the same data
    send_frame(:pong, application_data)
    @connection.trigger_on_ping(application_data)
  when :pong
    @connection.trigger_on_pong(application_data)
  when :text
    if application_data.respond_to?(:force_encoding)
      application_data.force_encoding("UTF-8")
      unless application_data.valid_encoding?
        raise InvalidDataError, "Invalid UTF8 data"
      end
    end
    @connection.trigger_on_message(application_data)
  when :binary
    @connection.trigger_on_binary(application_data)
  end
end
pingable?() click to toggle source

Ping & Pong supported

# File lib/em-websocket/message_processor_06.rb, line 59
def pingable?
  true
end