Session Package

type Domain struct {
    Repository *Repository
    Service    *Service
}

func New(db db) *Domain

type Service struct {
    repo *Repository
}

func (s *Service) CreateSessionForUser(ctx context.Context, userId string) (string, error)

func (s *Service) GetUserIdFromSessionId(ctx context.Context, id string) (string, error)

func (s *Service) Get(ctx context.Context, id string) (*Session, error)

func (s *Service) GetByUserId(ctx context.Context, id string) (*Session, error)

func (s *Service) DeleteSession(ctx context.Context, id string) error

func (s *Service) DeleteSessionsByUserId(ctx context.Context, userId string) error

func (s *Service) Create(ctx context.Context, session *Session) error

type Repository struct {
    db db
}

func (r *Repository) Get(ctx context.Context, id string) (*Session, error)
func (r *Repository) GetByUserId(ctx context.Context, userID string) (*Session, error)
func (r *Repository) Create(ctx context.Context, session *Session) error
func (r *Repository) Delete(ctx context.Context, id string) error
func (r *Repository) DeleteByUserId(ctx context.Context, userId string) error
func (r *Repository) Migrations() fs.FS

INSERT INTO sessions (id, "user", created, expires)
VALUES (:id, :user, :created, :expires)

type Session struct {
    ID      string    `db:"id"      json:"id"`
    User    string    `db:"user"    json:"user"`
    Created time.Time `db:"created" json:"created"`
    Expires time.Time `db:"expires" json:"expires"`
}

func (s *Session) IsExpired() bool

CREATE TABLE sessions (
    id      TEXT PRIMARY KEY,
    "user"  TEXT NOT NULL,
    created TIMESTAMP NOT NULL,
    expires TIMESTAMP NOT NULL
);

package main

import (
    "context"
    "fmt"
    "time"

    "github.com/platforma-dev/platforma/database"
    "github.com/platforma-dev/platforma/session"
)

func main() {
    // Setup database
    dbDomain := database.New(database.Config{
        Host:     "localhost",
        Port:     5432,
        Database: "myapp",
        User:     "postgres",
        Password: "password",
    })

    // Initialize session domain
    sessionDomain := session.New(dbDomain.Service)

    ctx := context.Background()

    // Create a session for a user
    userId := "user-123"
    sessionId, err := sessionDomain.Service.CreateSessionForUser(ctx, userId)
    if err != nil {
        panic(err)
    }
    fmt.Printf("Created session: %s\n", sessionId)

    // Retrieve user ID from session
    retrievedUserId, err := sessionDomain.Service.GetUserIdFromSessionId(ctx, sessionId)
    if err != nil {
        panic(err)
    }
    fmt.Printf("Session belongs to user: %s\n", retrievedUserId)

    // Get full session details
    sessionObj, err := sessionDomain.Service.Get(ctx, sessionId)
    if err != nil {
        panic(err)
    }
    fmt.Printf("Session created: %v\n", sessionObj.Created)
    fmt.Printf("Session expires: %v\n", sessionObj.Expires)
    fmt.Printf("Is expired: %v\n", sessionObj.IsExpired())

    // Delete the session (logout)
    err = sessionDomain.Service.DeleteSession(ctx, sessionId)
    if err != nil {
        panic(err)
    }
    fmt.Println("Session deleted")
}

import (
    "github.com/platforma-dev/platforma/auth"
    "github.com/platforma-dev/platforma/session"
)

// Session service implements the authStorage interface
type authStorage interface {
    GetUserIdFromSessionId(context.Context, string) (string, error)
    CreateSessionForUser(context.Context, string) (string, error)
    DeleteSession(ctx context.Context, sessionId string) error
    DeleteSessionsByUserId(ctx context.Context, userId string) error
}

// Initialize both domains
sessionDomain := session.New(db)
authDomain := auth.New(
    db,
    sessionDomain.Service,  // Pass session service as authStorage
    "session_id",
    nil,  // default username validator
    nil,  // default password validator
    nil,  // no cleanup enqueuer
)

type db interface {
    NamedExecContext(ctx context.Context, query string, arg any) (sql.Result, error)
    GetContext(ctx context.Context, dest any, query string, args ...any) error
    SelectContext(ctx context.Context, dest any, query string, args ...any) error
    ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}