package session

import (
	"context"
	"database/sql"
	"time"
)

type Row struct {
	ID        int64
	SessionID string
	CreatedAt time.Time
	ExpiresAt time.Time
}

// QCreate creates a new session.
func QCreate(ctx context.Context, db *sql.DB, sessionID string, expiresAt time.Time) (Row, error) {
	query := `
		INSERT INTO session (session_id, expires_at)
		VALUES ($1, $2)
		RETURNING id, session_id, created_at, expires_at
	`

	var row Row
	err := db.QueryRowContext(ctx, query, sessionID, expiresAt).Scan(
		&row.ID,
		&row.SessionID,
		&row.CreatedAt,
		&row.ExpiresAt,
	)
	return row, err
}

// QFindBySessionID finds a session by its session ID.
// Returns (nil, nil) if the session does not exist.
func QFindBySessionID(ctx context.Context, db *sql.DB, sessionID string) (*Row, error) {
	query := `
		SELECT id, session_id, created_at, expires_at
		FROM session
		WHERE session_id = $1
		LIMIT 1
	`

	var row Row
	err := db.QueryRowContext(ctx, query, sessionID).Scan(
		&row.ID,
		&row.SessionID,
		&row.CreatedAt,
		&row.ExpiresAt,
	)
	if err == sql.ErrNoRows {
		return nil, nil
	}
	if err != nil {
		return nil, err
	}

	return &row, nil
}

// QDelete deletes a session by its session ID.
func QDelete(ctx context.Context, db *sql.DB, sessionID string) error {
	query := `DELETE FROM session WHERE session_id = $1`
	_, err := db.ExecContext(ctx, query, sessionID)
	return err
}

// QDeleteExpired deletes all expired sessions.
func QDeleteExpired(ctx context.Context, db *sql.DB) error {
	query := `DELETE FROM session WHERE expires_at < NOW()`
	_, err := db.ExecContext(ctx, query)
	return err
}