1
0
Fork 0
miniflux/storage/session.go

125 lines
2.9 KiB
Go
Raw Normal View History

2017-12-16 21:07:53 -05:00
// Copyright 2017 Frédéric Guillot. All rights reserved.
// Use of this source code is governed by the Apache 2.0
// license that can be found in the LICENSE file.
2018-08-25 00:51:50 -04:00
package storage // import "miniflux.app/storage"
2017-12-16 21:07:53 -05:00
import (
"database/sql"
"fmt"
2018-08-25 00:51:50 -04:00
"miniflux.app/crypto"
"miniflux.app/model"
2017-12-16 21:07:53 -05:00
)
// CreateAppSessionWithUserPrefs creates a new application session with the given user preferences.
func (s *Storage) CreateAppSessionWithUserPrefs(userID int64) (*model.Session, error) {
user, err := s.UserByID(userID)
if err != nil {
return nil, err
}
2017-12-16 21:07:53 -05:00
session := model.Session{
ID: crypto.GenerateRandomString(32),
Data: &model.SessionData{
CSRF: crypto.GenerateRandomString(64),
Theme: user.Theme,
Language: user.Language,
},
2017-12-16 21:07:53 -05:00
}
return s.createAppSession(&session)
}
// CreateAppSession creates a new application session.
func (s *Storage) CreateAppSession() (*model.Session, error) {
session := model.Session{
ID: crypto.GenerateRandomString(32),
Data: &model.SessionData{
CSRF: crypto.GenerateRandomString(64),
},
}
return s.createAppSession(&session)
}
func (s *Storage) createAppSession(session *model.Session) (*model.Session, error) {
2019-10-30 01:48:07 -04:00
query := `INSERT INTO sessions (id, data) VALUES ($1, $2)`
_, err := s.db.Exec(query, session.ID, session.Data)
2017-12-16 21:07:53 -05:00
if err != nil {
2019-10-30 01:48:07 -04:00
return nil, fmt.Errorf(`store: unable to create app session: %v`, err)
2017-12-16 21:07:53 -05:00
}
return session, nil
2017-12-16 21:07:53 -05:00
}
// UpdateAppSessionField updates only one session field.
func (s *Storage) UpdateAppSessionField(sessionID, field string, value interface{}) error {
2019-10-30 01:48:07 -04:00
query := `
UPDATE
sessions
SET
data = jsonb_set(data, '{%s}', to_jsonb($1::text), true)
WHERE
id=$2
`
2017-12-16 21:07:53 -05:00
_, err := s.db.Exec(fmt.Sprintf(query, field), value, sessionID)
if err != nil {
2019-10-30 01:48:07 -04:00
return fmt.Errorf(`store: unable to update session field: %v`, err)
2017-12-16 21:07:53 -05:00
}
return nil
}
// AppSession returns the given session.
func (s *Storage) AppSession(id string) (*model.Session, error) {
2017-12-16 21:07:53 -05:00
var session model.Session
query := "SELECT id, data FROM sessions WHERE id=$1"
err := s.db.QueryRow(query, id).Scan(
&session.ID,
&session.Data,
)
2019-10-30 01:48:07 -04:00
switch {
case err == sql.ErrNoRows:
return nil, fmt.Errorf(`store: session not found: %s`, id)
case err != nil:
return nil, fmt.Errorf(`store: unable to fetch session: %v`, err)
default:
return &session, nil
2017-12-16 21:07:53 -05:00
}
}
// FlushAllSessions removes all sessions from the database.
func (s *Storage) FlushAllSessions() (err error) {
_, err = s.db.Exec(`DELETE FROM user_sessions`)
if err != nil {
return err
}
_, err = s.db.Exec(`DELETE FROM sessions`)
if err != nil {
return err
}
return nil
}
2017-12-16 21:48:17 -05:00
// CleanOldSessions removes sessions older than specified days.
func (s *Storage) CleanOldSessions(days int) int64 {
2019-10-30 01:48:07 -04:00
query := `
DELETE FROM
sessions
WHERE
id IN (SELECT id FROM sessions WHERE created_at < now() - interval '%d days')
`
result, err := s.db.Exec(fmt.Sprintf(query, days))
2017-12-16 21:48:17 -05:00
if err != nil {
return 0
}
n, _ := result.RowsAffected()
return n
}