Method serveWs

signaling/src/signaling/httpserver.go:71–85

serveWs handles websocket requests from the peer.

(w http.ResponseWriter, r *http.Request)

// serveWs handles websocket requests from the peer.
func (s *HttpServer) serveWs(w http.ResponseWriter, r *http.Request) {
	upgrader.CheckOrigin = func(r *http.Request) bool { return true }
	conn, err := upgrader.Upgrade(w, r, nil)
	if err != nil {
		logging.Errorf(logging.ProtoHTTP, "Error: %s", err)
		return
	}
	client := &WsClient{wsHub: s.WsHub, conn: conn, send: make(chan []byte, 256), SendMessage: make(chan WsMessageContainer, 256)}
	client.wsHub.register <- client

	// Allow collection of memory referenced by the caller by doing all work in
	// new goroutines.
	go client.writePump()
	go client.readPump()
}