Class: Combi::WebSocket::Server

Inherits:
Object
  • Object
show all
Defined in:
lib/combi/buses/web_socket.rb

Instance Method Summary collapse

Constructor Details

#initialize(bus) ⇒ Server

Returns a new instance of Server.



9
10
11
12
 
# File 'lib/combi/buses/web_socket.rb', line 9

def initialize(bus)
  @bus = bus
  @bus.ready.succeed
end

Instance Method Details

#on_close(session) ⇒ Object 



31
32
33
 
# File 'lib/combi/buses/web_socket.rb', line 31

def on_close(session)
  session && session.close
end

#on_message(ws, session, raw_message) ⇒ Object 



25
26
27
28
29
 
# File 'lib/combi/buses/web_socket.rb', line 25

def on_message(ws, session, raw_message)
  Combi.logger.debug {"WS SERVER ON MESSAGE #{raw_message[0..500]}"}
  message = Yajl::Parser.parse raw_message, symbolize_keys: true
  @bus.on_message(ws, message, session)
end

#on_open(ws, handler) ⇒ Object 



20
21
22
23
 
# File 'lib/combi/buses/web_socket.rb', line 20

def on_open(ws, handler)
  Combi.logger.debug { "ON OPEN #{handler.inspect}" }
  handler.new_session(ws)
end

#start! ⇒ Object 



14
15
 
# File 'lib/combi/buses/web_socket.rb', line 14

def start!
end

#stop! ⇒ Object 



17
18
 
# File 'lib/combi/buses/web_socket.rb', line 17

def stop!
end