Avoid panic from reading CSRF of nil session pointer (#10554)
* Avoid panic from reading CSRF of nil session pointer * Reorganize CSRF Handling * Remove autoimport added by IDE * Remove unnecessary nil check * gofmt
Этот коммит содержится в:
коммит произвёл
GitHub
родитель
24c8fdb1fa
Коммит
41fe33bbb1
@@ -102,10 +102,29 @@ func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
if len(token) != 0 {
|
if len(token) != 0 {
|
||||||
session, err := c.App.GetSession(token)
|
session, err := c.App.GetSession(token)
|
||||||
|
if err != nil {
|
||||||
|
c.Log.Info("Invalid session", mlog.Err(err))
|
||||||
|
if err.StatusCode == http.StatusInternalServerError {
|
||||||
|
c.Err = err
|
||||||
|
} else if h.RequireSession {
|
||||||
|
c.RemoveSessionCookie(w, r)
|
||||||
|
c.Err = model.NewAppError("ServeHTTP", "api.context.session_expired.app_error", nil, "token="+token, http.StatusUnauthorized)
|
||||||
|
}
|
||||||
|
} else if !session.IsOAuth && tokenLocation == app.TokenLocationQueryString {
|
||||||
|
c.Err = model.NewAppError("ServeHTTP", "api.context.token_provided.app_error", nil, "token="+token, http.StatusUnauthorized)
|
||||||
|
} else {
|
||||||
|
c.App.Session = *session
|
||||||
|
}
|
||||||
|
|
||||||
|
// Rate limit by UserID
|
||||||
|
if c.App.Srv.RateLimiter != nil && c.App.Srv.RateLimiter.UserIdRateLimit(c.App.Session.UserId, w) {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
csrfCheckPassed := false
|
csrfCheckPassed := false
|
||||||
|
|
||||||
// CSRF Check
|
// CSRF Check
|
||||||
if tokenLocation == app.TokenLocationCookie && h.RequireSession && !h.TrustRequester && r.Method != "GET" {
|
if c.Err == nil && tokenLocation == app.TokenLocationCookie && h.RequireSession && !h.TrustRequester && r.Method != "GET" {
|
||||||
csrfHeader := r.Header.Get(model.HEADER_CSRF_TOKEN)
|
csrfHeader := r.Header.Get(model.HEADER_CSRF_TOKEN)
|
||||||
if csrfHeader == session.GetCSRF() {
|
if csrfHeader == session.GetCSRF() {
|
||||||
csrfCheckPassed = true
|
csrfCheckPassed = true
|
||||||
@@ -122,32 +141,9 @@ func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
if !csrfCheckPassed {
|
if !csrfCheckPassed {
|
||||||
token = ""
|
token = ""
|
||||||
session = nil
|
c.App.Session = model.Session{}
|
||||||
c.Err = model.NewAppError("ServeHTTP", "api.context.session_expired.app_error", nil, "token="+token+" Appears to be a CSRF attempt", http.StatusUnauthorized)
|
c.Err = model.NewAppError("ServeHTTP", "api.context.session_expired.app_error", nil, "token="+token+" Appears to be a CSRF attempt", http.StatusUnauthorized)
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
csrfCheckPassed = true
|
|
||||||
}
|
|
||||||
|
|
||||||
if csrfCheckPassed {
|
|
||||||
if err != nil {
|
|
||||||
c.Log.Info("Invalid session", mlog.Err(err))
|
|
||||||
if err.StatusCode == http.StatusInternalServerError {
|
|
||||||
c.Err = err
|
|
||||||
} else if h.RequireSession {
|
|
||||||
c.RemoveSessionCookie(w, r)
|
|
||||||
c.Err = model.NewAppError("ServeHTTP", "api.context.session_expired.app_error", nil, "token="+token, http.StatusUnauthorized)
|
|
||||||
}
|
|
||||||
} else if !session.IsOAuth && tokenLocation == app.TokenLocationQueryString {
|
|
||||||
c.Err = model.NewAppError("ServeHTTP", "api.context.token_provided.app_error", nil, "token="+token, http.StatusUnauthorized)
|
|
||||||
} else {
|
|
||||||
c.App.Session = *session
|
|
||||||
}
|
|
||||||
|
|
||||||
// Rate limit by UserID
|
|
||||||
if c.App.Srv.RateLimiter != nil && c.App.Srv.RateLimiter.UserIdRateLimit(c.App.Session.UserId, w) {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Ссылка в новой задаче
Block a user