summaryrefslogtreecommitdiff
path: root/internal/repository/session.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-05-17 15:25:52 +0300
committerPaul Buetow <paul@buetow.org>2026-05-17 15:25:52 +0300
commit914bd7cd6aa14e839332a98d91c30b19865b0cf2 (patch)
tree02b11537237a204048589e14ed24938b805e42f7 /internal/repository/session.go
parent3b24f0e1be832584d6550e8cc3e5d24329f66f90 (diff)
Restructure repo: move Go server into player-server/
Diffstat (limited to 'internal/repository/session.go')
-rw-r--r--internal/repository/session.go60
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}
-}