|
@@ -2,7 +2,7 @@
|
|
package web
|
|
package web
|
|
|
|
|
|
import (
|
|
import (
|
|
- "github.com/garyburd/go-websocket/websocket"
|
|
|
|
|
|
+ "github.com/gorilla/websocket"
|
|
"net/http"
|
|
"net/http"
|
|
"ngrok/client/assets"
|
|
"ngrok/client/assets"
|
|
"ngrok/client/mvc"
|
|
"ngrok/client/mvc"
|
|
@@ -35,7 +35,7 @@ func NewWebView(ctl mvc.Controller, addr string) *WebView {
|
|
|
|
|
|
// handle web socket connections
|
|
// handle web socket connections
|
|
http.HandleFunc("/_ws", func(w http.ResponseWriter, r *http.Request) {
|
|
http.HandleFunc("/_ws", func(w http.ResponseWriter, r *http.Request) {
|
|
- conn, err := websocket.Upgrade(w, r.Header, nil, 1024, 1024)
|
|
|
|
|
|
+ conn, err := websocket.Upgrade(w, r, nil, 1024, 1024)
|
|
|
|
|
|
if err != nil {
|
|
if err != nil {
|
|
http.Error(w, "Failed websocket upgrade", 400)
|
|
http.Error(w, "Failed websocket upgrade", 400)
|
|
@@ -46,7 +46,7 @@ func NewWebView(ctl mvc.Controller, addr string) *WebView {
|
|
msgs := wv.wsMessages.Reg()
|
|
msgs := wv.wsMessages.Reg()
|
|
defer wv.wsMessages.UnReg(msgs)
|
|
defer wv.wsMessages.UnReg(msgs)
|
|
for m := range msgs {
|
|
for m := range msgs {
|
|
- err := conn.WriteMessage(websocket.OpText, m.([]byte))
|
|
|
|
|
|
+ err := conn.WriteMessage(websocket.TextMessage, m.([]byte))
|
|
if err != nil {
|
|
if err != nil {
|
|
// connection is closed
|
|
// connection is closed
|
|
break
|
|
break
|