|
|
@ -10,6 +10,7 @@ import (
|
|
|
|
"bytes"
|
|
|
|
"bytes"
|
|
|
|
"encoding/gob"
|
|
|
|
"encoding/gob"
|
|
|
|
go_redis "github.com/go-redis/redis/v8"
|
|
|
|
go_redis "github.com/go-redis/redis/v8"
|
|
|
|
|
|
|
|
"gopkg.in/errgo.v2/errors"
|
|
|
|
"net/http"
|
|
|
|
"net/http"
|
|
|
|
"reflect"
|
|
|
|
"reflect"
|
|
|
|
"sync"
|
|
|
|
"sync"
|
|
|
@ -308,7 +309,7 @@ func (ws *WServer) headerCheck(w http.ResponseWriter, r *http.Request, operation
|
|
|
|
case constant.ErrTokenDifferentUserID:
|
|
|
|
case constant.ErrTokenDifferentUserID:
|
|
|
|
status = int(constant.ErrTokenDifferentUserID.ErrCode)
|
|
|
|
status = int(constant.ErrTokenDifferentUserID.ErrCode)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
log.Error(operationID, "Token verify failed ", "query ", query, msg, err.Error(), "type: ", reflect.TypeOf(err))
|
|
|
|
log.Error(operationID, "Token verify failed ", "query ", query, msg, err.Error(), "type: ", reflect.TypeOf(errors.Cause(err)))
|
|
|
|
w.Header().Set("Sec-Websocket-Version", "13")
|
|
|
|
w.Header().Set("Sec-Websocket-Version", "13")
|
|
|
|
w.Header().Set("ws_err_msg", err.Error())
|
|
|
|
w.Header().Set("ws_err_msg", err.Error())
|
|
|
|
http.Error(w, err.Error(), status)
|
|
|
|
http.Error(w, err.Error(), status)
|
|
|
|