diff options
author | Frédéric Guillot <fred@miniflux.net> | 2017-12-16 18:48:17 -0800 |
---|---|---|
committer | Frédéric Guillot <fred@miniflux.net> | 2017-12-16 18:48:17 -0800 |
commit | 18f55d156995371bfb06ca8cd91da5a922d2a937 (patch) | |
tree | 83229e4691ba2ea2e1ddd2de8810cd9ac40e7858 /storage | |
parent | 00257988ef1707a028cd7dd0b1f8f68e6e8fac53 (diff) |
Add scheduler to clean old sessions
Diffstat (limited to 'storage')
-rw-r--r-- | storage/session.go | 14 | ||||
-rw-r--r-- | storage/user_session.go | 14 |
2 files changed, 28 insertions, 0 deletions
diff --git a/storage/session.go b/storage/session.go index 17a63e2..106d618 100644 --- a/storage/session.go +++ b/storage/session.go @@ -75,3 +75,17 @@ func (s *Storage) FlushAllSessions() (err error) { return nil } + +// CleanOldSessions removes sessions older than 30 days. +func (s *Storage) CleanOldSessions() int64 { + query := `DELETE FROM sessions + WHERE id IN (SELECT id FROM sessions WHERE created_at < now() - interval '30 days')` + + result, err := s.db.Exec(query) + if err != nil { + return 0 + } + + n, _ := result.RowsAffected() + return n +} diff --git a/storage/user_session.go b/storage/user_session.go index ffb82fc..63e25e0 100644 --- a/storage/user_session.go +++ b/storage/user_session.go @@ -127,3 +127,17 @@ func (s *Storage) RemoveUserSessionByID(userID, sessionID int64) error { return nil } + +// CleanOldUserSessions removes user sessions older than 30 days. +func (s *Storage) CleanOldUserSessions() int64 { + query := `DELETE FROM user_sessions + WHERE id IN (SELECT id FROM user_sessions WHERE created_at < now() - interval '30 days')` + + result, err := s.db.Exec(query) + if err != nil { + return 0 + } + + n, _ := result.RowsAffected() + return n +} |