Add command for deleting expired sessions

Author: theandrew168

backend/command/session.go

@@ -4,10 +4,24 @@ import (
 	"time"
 
 	"github.com/theandrew168/bloggulus/backend/repository"
+	"github.com/theandrew168/bloggulus/backend/timeutil"
 )
 
 func (cmd *Command) DeleteExpiredSessions(now time.Time) error {
 	return cmd.repo.WithTransaction(func(tx *repository.Repository) error {
+		now := timeutil.Now()
+		expiredSessions, err := tx.Session().ListExpired(now)
+		if err != nil {
+			return err
+		}
+
+		for _, session := range expiredSessions {
+			err := tx.Session().Delete(session)
+			if err != nil {
+				return err
+			}
+		}
+
 		return nil
 	})
 }

backend/repository/session.go

@@ -148,6 +148,44 @@ func (r *SessionRepository) ReadBySessionID(sessionID string) (*model.Session, e
 	return row.unmarshal()
 }
 
+func (r *SessionRepository) ListExpired(now time.Time) ([]*model.Session, error) {
+	stmt := `
+		SELECT
+			session.id,
+			session.account_id,
+			session.hash,
+			session.expires_at,
+			session.created_at,
+			session.updated_at
+		FROM session
+		WHERE session.expires_at <= $1`
+
+	ctx, cancel := context.WithTimeout(context.Background(), postgres.Timeout)
+	defer cancel()
+
+	rows, err := r.conn.Query(ctx, stmt, now)
+	if err != nil {
+		return nil, err
+	}
+
+	sessionRows, err := pgx.CollectRows(rows, pgx.RowToStructByName[dbSession])
+	if err != nil {
+		return nil, postgres.CheckListError(err)
+	}
+
+	var sessions []*model.Session
+	for _, row := range sessionRows {
+		session, err := row.unmarshal()
+		if err != nil {
+			return nil, err
+		}
+
+		sessions = append(sessions, session)
+	}
+
+	return sessions, nil
+}
+
 func (r *SessionRepository) Delete(session *model.Session) error {
 	stmt := `
 		DELETE FROM session