Method: DigitalFabric::AgentProxy#run_websocket_connection

Defined in:

lib/tipi/digital_fabric/agent_proxy.rb

#run_websocket_connection(id, websocket) ⇒ Object

# File 'lib/tipi/digital_fabric/agent_proxy.rb', line 310

def run_websocket_connection(id, websocket)
  reader = spin("#{Fiber.current}.#{id}-ws") do
    websocket.recv_loop do |data|
      send_df_message(Protocol.ws_data(id, data))
    end
  end
  while (message = receive)
    case message[Protocol::Attribute::KIND]
    when Protocol::WS_DATA
      websocket << message[Protocol::Attribute::WS::DATA]
    when Protocol::WS_CLOSE
      return
    else
      raise "Unexpected websocket message #{message.inspect}"
    end
  end
ensure
  reader.stop
  websocket.close
end