diff options
| author | Paul Buetow <paul@buetow.org> | 2026-05-17 15:25:52 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-05-17 15:25:52 +0300 |
| commit | 914bd7cd6aa14e839332a98d91c30b19865b0cf2 (patch) | |
| tree | 02b11537237a204048589e14ed24938b805e42f7 /internal/repository/session.go | |
| parent | 3b24f0e1be832584d6550e8cc3e5d24329f66f90 (diff) | |
Restructure repo: move Go server into player-server/
Diffstat (limited to 'internal/repository/session.go')
| -rw-r--r-- | internal/repository/session.go | 60 |
1 files changed, 0 insertions, 60 deletions
diff --git a/internal/repository/session.go b/internal/repository/session.go deleted file mode 100644 index 3e43d09..0000000 --- a/internal/repository/session.go +++ /dev/null @@ -1,60 +0,0 @@ -package repository - -import ( - "context" - "database/sql" - "fmt" - "time" - - "codeberg.org/snonux/player/internal/model" -) - -// CreateSession inserts a new session. -func (s *SQLite) CreateSession(ctx context.Context, session *model.Session) error { - _, err := s.db.ExecContext(ctx, - `INSERT INTO sessions (id, user_id, expires_at, created_at) VALUES (?, ?, ?, ?)`, - session.ID, session.UserID, session.ExpiresAt, session.CreatedAt, - ) - if err != nil { - return fmt.Errorf("insert session: %w", err) - } - return nil -} - -// GetSessionByID retrieves a session by ID. -func (s *SQLite) GetSessionByID(ctx context.Context, id string) (*model.Session, error) { - row := s.db.QueryRowContext(ctx, - `SELECT id, user_id, expires_at, created_at FROM sessions WHERE id = ?`, id) - var sess model.Session - if err := row.Scan(&sess.ID, &sess.UserID, &sess.ExpiresAt, &sess.CreatedAt); err == sql.ErrNoRows { - return nil, nil - } else if err != nil { - return nil, err - } - return &sess, nil -} - -// DeleteSession removes a session by ID. -func (s *SQLite) DeleteSession(ctx context.Context, id string) error { - _, err := s.db.ExecContext(ctx, `DELETE FROM sessions WHERE id = ?`, id) - if err != nil { - return fmt.Errorf("delete session: %w", err) - } - return nil -} - -// DeleteExpiredSessions removes all sessions with expires_at older than now. -func (s *SQLite) DeleteExpiredSessions(ctx context.Context, now time.Time) error { - _, err := s.db.ExecContext(ctx, `DELETE FROM sessions WHERE expires_at < ?`, now) - if err != nil { - return fmt.Errorf("delete expired sessions: %w", err) - } - return nil -} - -func sqlNullTime(t *time.Time) sql.NullTime { - if t == nil { - return sql.NullTime{} - } - return sql.NullTime{Time: *t, Valid: true} -} |
