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)
  @bus.log "ON MESSAGE #{raw_message[0..500]}"
  message = JSON.parse(raw_message)
  @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)
  @bus.log "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

#ws ⇒ Object 



35
36
37
 
# File 'lib/combi/buses/web_socket.rb', line 35

def ws
  @ws
end