Class: Async::WebSocket::Server

Inherits:
Protocol::HTTP::Middleware
  • Object
show all
Includes:
Protocol::WebSocket::Headers
Defined in:
lib/async/websocket/server.rb

Instance Method Summary collapse

Constructor Details

#initialize(delegate, protocols: [], handler: Connection) ⇒ Server

Returns a new instance of Server.



31
32
33
34
35
36
 
# File 'lib/async/websocket/server.rb', line 31

def initialize(delegate, protocols: [], handler: Connection)
  super(delegate)
  
  @protocols = protocols
  @handler = handler
end

Instance Method Details

#call(request) ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/async/websocket/server.rb', line 47

def call(request)
  if request.protocol == PROTOCOL
    # Select websocket sub-protocol:
    protocol = select_protocol(request)
    
    # request.headers = nil
    
    Response.for(request, headers, protocol: protocol, **options) do |stream|
      framer = Protocol::WebSocket::Framer.new(stream)
      
      yield handler.call(framer, protocol)
    end
  else
    super
  end
end

#response(request) ⇒ Object 



44
45
 
# File 'lib/async/websocket/server.rb', line 44

def response(request)
end

#select_protocol(request) ⇒ Object 



38
39
40
41
42
 
# File 'lib/async/websocket/server.rb', line 38

def select_protocol(request)
  if requested_protocol = request.headers[SEC_WEBSOCKET_PROTOCOL]
    return (requested_protocol & @protocols).first
  end
end