Module: EventMachine::WebSocket::MessageProcessor06

Included in:
Handler06, Handler07, Handler08, Handler13
Defined in:
lib/em-websocket/message_processor_06.rb

Instance Method Summary collapse

Instance Method Details

#message(message_type, extension_data, application_data) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# 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? ⇒ Boolean

Ping & Pong supported

Returns:

  • (Boolean) 


59
60
61
 
# File 'lib/em-websocket/message_processor_06.rb', line 59

def pingable?
  true
end