mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-04-27 20:30:40 +08:00
gateway update
This commit is contained in:
parent
232a1be53e
commit
4ac827020d
@ -1,8 +1,6 @@
|
|||||||
package msggateway
|
package msggateway
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"OpenIM/pkg/errs"
|
|
||||||
"errors"
|
|
||||||
"net/http"
|
"net/http"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -10,35 +8,35 @@ func httpError(ctx *UserConnContext, err error) {
|
|||||||
code := http.StatusUnauthorized
|
code := http.StatusUnauthorized
|
||||||
ctx.SetHeader("Sec-Websocket-Version", "13")
|
ctx.SetHeader("Sec-Websocket-Version", "13")
|
||||||
ctx.SetHeader("ws_err_msg", err.Error())
|
ctx.SetHeader("ws_err_msg", err.Error())
|
||||||
if errors.Is(err, errs.ErrTokenExpired) {
|
//if errors.Is(err, errs.ErrTokenExpired) {
|
||||||
code = errs.ErrTokenExpired.Code()
|
// code = errs.ErrTokenExpired.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrTokenInvalid) {
|
//if errors.Is(err, errs.ErrTokenInvalid) {
|
||||||
code = errs.ErrTokenInvalid.Code()
|
// code = errs.ErrTokenInvalid.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrTokenMalformed) {
|
//if errors.Is(err, errs.ErrTokenMalformed) {
|
||||||
code = errs.ErrTokenMalformed.Code()
|
// code = errs.ErrTokenMalformed.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrTokenNotValidYet) {
|
//if errors.Is(err, errs.ErrTokenNotValidYet) {
|
||||||
code = errs.ErrTokenNotValidYet.Code()
|
// code = errs.ErrTokenNotValidYet.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrTokenUnknown) {
|
//if errors.Is(err, errs.ErrTokenUnknown) {
|
||||||
code = errs.ErrTokenUnknown.Code()
|
// code = errs.ErrTokenUnknown.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrTokenKicked) {
|
//if errors.Is(err, errs.ErrTokenKicked) {
|
||||||
code = errs.ErrTokenKicked.Code()
|
// code = errs.ErrTokenKicked.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrTokenDifferentPlatformID) {
|
//if errors.Is(err, errs.ErrTokenDifferentPlatformID) {
|
||||||
code = errs.ErrTokenDifferentPlatformID.Code()
|
// code = errs.ErrTokenDifferentPlatformID.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrTokenDifferentUserID) {
|
//if errors.Is(err, errs.ErrTokenDifferentUserID) {
|
||||||
code = errs.ErrTokenDifferentUserID.Code()
|
// code = errs.ErrTokenDifferentUserID.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrConnOverMaxNumLimit) {
|
//if errors.Is(err, errs.ErrConnOverMaxNumLimit) {
|
||||||
code = errs.ErrConnOverMaxNumLimit.Code()
|
// code = errs.ErrConnOverMaxNumLimit.Code()
|
||||||
}
|
//}
|
||||||
if errors.Is(err, errs.ErrConnArgsErr) {
|
//if errors.Is(err, errs.ErrConnArgsErr) {
|
||||||
code = errs.ErrConnArgsErr.Code()
|
// code = errs.ErrConnArgsErr.Code()
|
||||||
}
|
//}
|
||||||
ctx.ErrReturn(err.Error(), code)
|
ctx.ErrReturn(err.Error(), code)
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user