From 7ed011745a544873f40f806f1803cb8a4998ba01 Mon Sep 17 00:00:00 2001 From: Chris Date: Thu, 26 Oct 2017 14:21:22 -0500 Subject: Remove more global refs / state (#7723) * remove more global refs / state * fix job enterprise initialization * fix api4 test compilation * saml api endpoints fix --- app/session.go | 26 ++++++++++++-------------- 1 file changed, 12 insertions(+), 14 deletions(-) (limited to 'app/session.go') diff --git a/app/session.go b/app/session.go index 209604dc5..523f34747 100644 --- a/app/session.go +++ b/app/session.go @@ -12,8 +12,6 @@ import ( l4g "github.com/alecthomas/log4go" ) -var sessionCache *utils.Cache = utils.NewLru(model.SESSION_CACHE_SIZE) - func (a *App) CreateSession(session *model.Session) (*model.Session, *model.AppError) { session.Token = "" @@ -22,7 +20,7 @@ func (a *App) CreateSession(session *model.Session) (*model.Session, *model.AppE } else { session := result.Data.(*model.Session) - AddSessionToCache(session) + a.AddSessionToCache(session) return session, nil } @@ -32,7 +30,7 @@ func (a *App) GetSession(token string) (*model.Session, *model.AppError) { metrics := a.Metrics var session *model.Session - if ts, ok := sessionCache.Get(token); ok { + if ts, ok := a.sessionCache.Get(token); ok { session = ts.(*model.Session) if metrics != nil { metrics.IncrementMemCacheHitCounterSession() @@ -53,7 +51,7 @@ func (a *App) GetSession(token string) (*model.Session, *model.AppError) { } if !session.IsExpired() { - AddSessionToCache(session) + a.AddSessionToCache(session) } } } @@ -132,13 +130,13 @@ func (a *App) ClearSessionCacheForUser(userId string) { } func (a *App) ClearSessionCacheForUserSkipClusterSend(userId string) { - keys := sessionCache.Keys() + keys := a.sessionCache.Keys() for _, key := range keys { - if ts, ok := sessionCache.Get(key); ok { + if ts, ok := a.sessionCache.Get(key); ok { session := ts.(*model.Session) if session.UserId == userId { - sessionCache.Remove(key) + a.sessionCache.Remove(key) } } } @@ -146,12 +144,12 @@ func (a *App) ClearSessionCacheForUserSkipClusterSend(userId string) { a.InvalidateWebConnSessionCacheForUser(userId) } -func AddSessionToCache(session *model.Session) { - sessionCache.AddWithExpiresInSecs(session.Token, session, int64(*utils.Cfg.ServiceSettings.SessionCacheInMinutes*60)) +func (a *App) AddSessionToCache(session *model.Session) { + a.sessionCache.AddWithExpiresInSecs(session.Token, session, int64(*a.Config().ServiceSettings.SessionCacheInMinutes*60)) } -func SessionCacheLength() int { - return sessionCache.Len() +func (a *App) SessionCacheLength() int { + return a.sessionCache.Len() } func (a *App) RevokeSessionsForDeviceId(userId string, deviceId string, currentSessionId string) *model.AppError { @@ -227,7 +225,7 @@ func (a *App) UpdateLastActivityAtIfNeeded(session model.Session) { } session.LastActivityAt = now - AddSessionToCache(&session) + a.AddSessionToCache(&session) } func (a *App) CreateUserAccessToken(token *model.UserAccessToken) (*model.UserAccessToken, *model.AppError) { @@ -301,7 +299,7 @@ func (a *App) createSessionForUserAccessToken(tokenString string) (*model.Sessio } else { session := result.Data.(*model.Session) - AddSessionToCache(session) + a.AddSessionToCache(session) return session, nil } -- cgit v1.2.3-1-g7c22